bcwoauthtest

希望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模式。

1.10版本Redis维表中RedisAllReqRow类存在数据越界异常

2

RedisAllReqRow的 flatMap(Tuple2 input, Collector out)方法124行存在数组越界异常。

1.10版本中发现连续Join时抛出数组越界异常

3

我将flinkStreamSql从1.8.1升级到1.10，原来可以运行的Join语句出错了。 tableA是源表， tableB 是维表，执行下面的语句 CREATE VIEW v_a_join_b AS SELECT A.col_a1,A.col_a2,A.col_a3,B1.col_b as col_b1,B2.col_b as col_b2 FROM tableA AS A LEFT JOIN tableB AS B1 ON A.col_a1 = B1.col_b LEFT JOIN tableB...