Re: Flink SQL 1.10.0窗口计算结果无法sink

可以替换成其他 sink 试一下，比如 kafka，验证下是不是 sink 的问题。 Btw，1.11 里面可以非常方便地创建一个测试 sink，比如 CREATE TABLE print_table WITH ('connector' = 'print') LIKE tb_sink (EXCLUDING ALL) Best, Jark On Sat, 20 Jun 2020 at 15:51, Benchao Li wrote: > Hi, > > 根据你的描述，应该是sink这里有问题的可能性比较大。因为正常的query可以输出结果，但是insert到sink就看不到输出。

Re: Flink SQL 1.10.0窗口计算结果无法sink

Hi, 根据你的描述，应该是sink这里有问题的可能性比较大。因为正常的query可以输出结果，但是insert到sink就看不到输出。 你可以看下你的job的metrics，每个operator的输入输出，看下window operator是否有输出。 此外，也可以看下这个sink的实现，是否有攒batch的一些逻辑，比如要打到多少条数据才会输出等。 王超 <1984chaow...@gmail.com> 于2020年6月20日周六 下午1:18写道： > 除了pravega connector之外的有没有什么地方有问题呢？ > > On Fri, Jun 19, 2020 at 1

Re: Flink SQL 1.10.0窗口计算结果无法sink

除了pravega connector之外的有没有什么地方有问题呢？ On Fri, Jun 19, 2020 at 18:43 Leonard Xu wrote: > Hi, > pravega connector[1] 应该不是社区提供的，之前没看过这个connector的代码, > 看你的描述，可以检查下写入时是否有一些参数需要设置。 > > > 祝好， > Leonard Xu > [1] https://github.com/pravega/flink-connectors < > https://github.com/pravega/flink-connectors> >

Re: Flink SQL 1.10.0窗口计算结果无法sink

Hi, pravega connector[1] 应该不是社区提供的，之前没看过这个connector的代码, 看你的描述，可以检查下写入时是否有一些参数需要设置。 祝好， Leonard Xu [1] https://github.com/pravega/flink-connectors > 在 2020年6月19日，13:31，王超 <1984chaow...@gmail.com> 写道： > > 各位大神求帮忙看一下。 > > Flink 版本：1.10.0 > Planner：b

Flink SQL 1.10.0窗口计算结果无法sink

各位大神求帮忙看一下。 Flink 版本：1.10.0 Planner：blink 我在使用Flink SQL的时候遇到了一个问题，能否帮忙看一下，我尝试在寻找了解决方法，但是没有起作用。 比如我发现类似的问题 https://www.mail-archive.com/user-zh@flink.apache.org/msg03916.html 中描述的问题，根据这个mail中的解决方法我设置了timezone，但是问题没有被解决。 Flink Table Env配置 *StreamExecutionEnvironment env = StreamExecutionEnvironme