答复: 【Flink sql 1.10.0问题】

看不见图，最好别发图，以文字发 发件人: 忝忝向�� <153488...@qq.com> 日期: 星期日, 2020年7月26日 22:05 收件人: user-zh 主题: 【Flink sql 1.10.0问题】 Hi,all: Flink 1.10.0 sql提交报错如下，请问是什么原因呢? 谢谢. [cid:37FA1919@1626B468.F28B1D5F]

??Flink sql 1.10.0??????

Hi,all: Flink 1.10.0 sql??? .

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

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 >

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 =

Re: flink sql 1.10.0 对hive GenericUDF支持，之前的图片在邮件组不显示，重新编辑

现在在做把原来离线 hive 上的任务迁移到flink sql > 1.10.0的工作，之前看文档说flink 支持hive的GenericUDF，但是我发现个别在flink中报错，请问是我哪里设置有问题么？ > 比如current_timestamp() > 在hive中语句： > select > from_unixtime(unix_timestamp(current_timestamp()),'MMddHHmmss');正常执行 >而提交flink sql 任务报错 > org.apache.flink.ta

flink sql 1.10.0 ??hive GenericUDF????????????????????????????????????????

hi all?? ?? hive ??flink sql 1.10.0flink hive??GenericUDF??flink?? current_timestamp() ??hive select from_unixtime(unix_timestamp(current_timestamp()),'MMddHHmmss

flink sql 1.10.0 ??hive GenericUDF????

hi all?? ?? hive ??flink sql 1.10.0flink hive??GenericUDF??flink?? current_timestamp() ??hive?? ??flink sql org.apache.flink.table.api.ValidationException: SQL