Wang Luning

icon location Mars icon location Contributor of @apache Flink/Kyuubi/Iceberg Ex-maintainer of FlinkX. An acute phantom assassin

Results 37 comments of Wang Luning

请教group windows的order by问题

Flink要开启EventTime。你试下

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

FlinkX 1.12试一下？

有无对sql 语法校验的方法

getPlan

binlog异步处理机制会导致flink异常中断时数据丢失

@WTZ468071157

阅读源码的疑惑

主要是适配SQL

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

文档里有个选项的，你启动的时候指定savePointPath。看下文档里的参数配置。

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

1.12 已经发布在FlinkX 项目里，没有这个问题

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

你可以把你全的SQL发下

create view中语法问题

这个我们以后在1.10分支里考虑升级下

flinkx-connector-elasticsearch7 not support map datatype.

coming soon