flinkStreamSQL

flinkStreamSQL copied to clipboard

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

1

IDEA执行快速运行里面的构建语句 `mvn clean package -Dmaven.test.skip -e` 报错为 `[INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 51.086 s [INFO] Finished at: 2021-07-07T14:48:00+08:00 [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal on project...

RainbowWS

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

6

flinkStreamSQL 1.10的Kafka数据源不支持group-offsets模式，Flink原生版支持的。 在实际应用中，最常用的就是这个模式，Flink原生版本只要设置了groupId， 即使是latest和earlist两种offset模式, 也只是在groupId有新值时，从最新或者最初始开始读，其后就是按照group-offsets来读取的，这样就可以保证任务重启后，准确地衔接上。 希望大佬们可以让flinkStreamSQL 也支持group-offset模式。

bcwoauthtest

阅读源码的疑惑

1

大佬，我看到源码中 在 registerTable 中 env.addSource 后 stream 转为 Table 并保存，然后在 sideSqlExec.exec 中获取 Table 又转为 stream 在与 sideTable join 。 这样做的考虑只是为了有 adaptSql 时过滤流，还是有其他因素呀？ 如果没有 adaptSql 可以在env.addSource 后的 stream 直接与 sideTable join...

RockeyCui

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

2

Field types of query result and redistered TabledSink do not match Query schema: [a: ARRAY] Sink schema: [a: LEGACY('ARRAY','ANY

naichunW

请教group windows的order by问题

1

需要根据1秒的window中的ROWTIME进行排序，但是报如下错误： Exception in thread "main" org.apache.flink.table.api.TableException: Sort on a non-time-attribute field is not supported. at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlanInternal(StreamExecSort.scala:118) at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlanInternal(StreamExecSort.scala:59) at org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58) at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlan(StreamExecSort.scala:59) at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSink.translateToTransformation(StreamExecSink.scala:184) at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.scala:91) at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.scala:48) at org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)...

caigenxing

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

3

xyls82

AccordwangAccord

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

1

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

ithjz

zihjiang

重构hbase维度表的rowkey计算列，可以更简单的新增rowkey算法， 方法： 1.在EReplaceOpType当中，增加你写的方法的枚举名字和对应引用 2.实现AbstractReplaceOperator抽象类 AddReplaceOperator就是简单的模板方法 目前支持 md5(add(name + id)) + ‘test’多方法递归和多参数等场景

chaozwn