DTStack/flinkStreamSQL

Issues

• Flink SQL 使用滚动窗口，能不能获取到延迟数据，跟datastream一样，可以放到侧输出里面

  #467 opened 6 months ago by xiongmozhou
  1

• 这个如何引入使用flink-connector-hive啊

  #437 opened 3 years ago by xyls82
  3

• Exception in thread "main" org.apache.flink.client.program.ProgramInvocationException

  #399 opened 4 years ago by marshals1995
  1

• 问，这个和原生的flink sql有什么区别？做了哪些原生没有的特性？

  #397 opened 3 years ago by xunchangguo
  3

• Yarn模式下的sql是在什么地方解析的

  #433 opened 3 years ago by AstraHoo
  0

• kudu sink writemode参数没填写报NULLPointerException

  #432 opened 3 years ago by jepsonzhang
  1

• 新版FlinkStreamSQL已经融合进FlinkX项目

  #431 opened 3 years ago by a49a
  0

• 有无对sql 语法校验的方法

  #430 opened 3 years ago by etdick
  1

• 1.10release版本编译不通过Could not find artifact com.dtstack.flink:sql.core:jar:tests:1.0-SNAPSHOT

  #425 opened 4 years ago by RainbowWS
  1

• kafka source，原生的flink可以读取解析到kafka的元数据比如timestamp。FlinkStreamSql支持读取元数据吗？应该如何操作？

  #419 opened 4 years ago by redcheeks666
  1

• 希望flinkStreamSQL 1.10的Kafka数据源可以像flink原生版一样支持group-offsets模式

  #354 opened 5 years ago by bcwoauthtest
  6

• flink

  #427 opened 4 years ago by xyls82
  0

• DDL中Flink支持mysql

  #390 opened 4 years ago by huanzui
  2

• 有没支持RabbitMQ数据源计划

  #389 opened 4 years ago by huanzui
  1

• HBase维表关联报异常：java.lang.ClassCastException: org.apache.flink.table.dataformat.GenericRow cannot be cast to org.apache.flink.types.Row

  #393 opened 4 years ago by junzizai
  5

• 不支持blink 下的 开窗函数的 RANGE 写法

  #395 opened 4 years ago by yujiayue0815
  1

• flinkStreamSQL with rocketMQ 展望

  #353 opened 4 years ago by RoadOfShang
  0

• mongosink 支持upsert么？根据自定义主键字段进行更新操作

  #405 opened 4 years ago by hd1990
  1

• 能否支持es7？

  #352 opened 4 years ago by 274869388
  1

• 有没有支持web ui啊？

  #429 opened 4 years ago by Mdz-Bigdata
  1

• Create table 中Array<String> 类型提交报错

  #421 opened 4 years ago by naichunW
  2

• 请教group windows的order by问题

  #357 opened 4 years ago by caigenxing
  1

• 官网数组类型字段解析示例不能运行

  #380 opened 4 years ago by zhanghaoxuan-git
  1

• 消费kafka后，未提交偏移量

  #381 opened 4 years ago by easonliu30624700
  3

• flinkStreamsql 保留字和字段冲突 ，反引号无效

  #384 opened 4 years ago by hqisog
  2

• flinkstreamsql kafka任务，开启checkpoint，如果我手动杀死任务，如何从指定的最后一次保存的checkpoint启动任务

  #428 opened 4 years ago by xyls82
  3

• 今天发现维表只能支持12个，我勒个去

  #426 opened 4 years ago by AccordwangAccord
  0

• flinkStreamSQL 这个项目,有没有好心人做了web系统,供大家方便使用呀?

  #418 opened 4 years ago by ithjz
  1

• flinkStreamSQL 这个项目是否支持 华为云版本的fi 的flink sql ? 有人试过吗?

  #411 opened 4 years ago by ithjz
  1

• 【2021-04-11】FlinkStreamSQL 更新记录

  #420 opened 4 years ago by FlechazoW
  0

• 我想放到 centos7上运行 , 发现没有plugin这个组件,是要自己编译吗?

  #414 opened 4 years ago by ithjz
  1

• 我win10本地运行 ,读kafka写kafka ,咋就没有这个呢? com.dtstack.flink.sql.sink.kafka.table.KafkaSinkParser

  #417 opened 4 years ago by ithjz
  2

• Standalone模式提交怎么会调用异常？

  #402 opened 4 years ago by jiaenqiu
  2

• flinkStreamSql更新

  #415 opened 4 years ago by HiLany
  0

• Unknown database 'flinktest' ,明明是有这个 库, 为何最好老是说不存在?

  #413 opened 4 years ago by ithjz
  1

• .RuntimeException: create table statement requires property of type 报错了?

  #412 opened 4 years ago by ithjz
  0

• 【2021-03-02】FlinkStreamSQL变更记录

  #407 opened 4 years ago by FlechazoW
  0

• 【2021-03-02】FlinkSteamSQL增加资源校验，增加errorLimit参数控制表失败条数

  #409 opened 4 years ago by FlechazoW
  0

• FlinkStreamSQL的insert时不支持union all函数

  #401 opened 4 years ago by jianlan519588
  0

• Could not run job in detached mode. (JobID: 8010199d48a29fd36cf4389a96f22c13)

  #400 opened 4 years ago by marshals1995
  0

• Standalone模式报错

  #398 opened 4 years ago by Feral-Jas
  1

• 不支持在窗口函数下的开窗函数

  #394 opened 4 years ago by yujiayue0815
  0

• 支持yarn PerJob模式提交SQL吗？

  #392 opened 4 years ago by wongxingjun
  1

• yarnPer模式下作业任务失败

  #391 opened 4 years ago by blackMoutin
  3

• 设置并行度后，数据延迟严重

  #388 opened 4 years ago by hqisog
  1

• join后的where中流表和维表同名字段值取反

  #387 opened 4 years ago by zjfplayer
  3

• sink oracle端的时候偶尔有几个任务出现 kafka接收到数据有 Initializing C3P0 pool

  #383 opened 4 years ago by tonyC2016
  3

• es5和es的sink插件id参数不填时, 报空指针异常

  #385 opened 4 years ago by zihjiang
  1

• streamsql avro 格式问题

  #356 opened 4 years ago by hqisog
  0

• flink1.11.1 on yarn 分离模式没有生效，我用的hadoop3.1.1

  #355 opened 5 years ago by owencwl
  0