??????????flink sql ???? Multiple factories for identifier 'jdbc' that implement

?? Caused by: org.apache.flink.table.api.ValidationException: Multiple factories for identifier 'jdbc' that implement 'org.apache.flink.table.factories.DynamicTableSinkFactory' found in the classpath DynamicTableSinkFactory ?? package

Re: flink-cdc 无法读出binlog，程序也不报错

破案了，字段类型没按官网的要求对应起来，对应起来后正常了 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flinksql1.11长时间没有数据写入mysql，会报ava.sql.SQLException: No operations allowed after statement closed.

Hi，yanzi 可以贴下完整的报错信息吗？ 祝好， Leonard Xu > 在 2020年12月3日，10:36，yanzi 写道： > > 使用flinksql 1.11版本，运行计算好的指标落入mysql，长时间没有数据会报错，导致任务会失败。 > 针对：https://issues.apache.org/jira/browse/FLINK-16681，已经修复此问题，但是我们使用1.11最新版本，运行一段时间后，发现还是会有此问题，如何解决 > > > > -- > Sent from:

Re:Flink SQL使用Tumble窗口函数报NoSuchMethodError functions/AggregateFunction 异常

Hi, 你的 Flink 版本是哪个呢。从报错来看你在用 legacy planner，可以使用 blink planner 试试。 Best, Hailong 在 2020-12-03 10:02:08，"18293503878" <18293503...@163.com> 写道： >大家使用Flink SQL的tumble函数时，将结果表转换为流，报如下错误的异常吗 >Exception in thread "main" java.lang.NoSuchMethodError:

Re:flinksql1.11长时间没有数据写入mysql，会报ava.sql.SQLException: No operations allowed after statement closed.

JdbcBatchingOutputFormat: for (int i = 0; i <= executionOptions.getMaxRetries(); i++) { try { attemptFlush(); batchCount = 0; break; } catch (SQLException e) { LOG.error("JDBC executeBatch error, retry times = {}", i, e); if (i >= executionOptions.getMaxRetries()) { throw new

flink sql??????????????????????

?? flink sql??percentile

flinksql1.11长时间没有数据写入mysql，会报ava.sql.SQLException: No operations allowed after statement closed.

使用flinksql 1.11版本，运行计算好的指标落入mysql，长时间没有数据会报错，导致任务会失败。 针对：https://issues.apache.org/jira/browse/FLINK-16681，已经修复此问题，但是我们使用1.11最新版本，运行一段时间后，发现还是会有此问题，如何解决 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: zookeeper更换leader对flink的影响

那Curator的state为什么会变成suspended或lost呢？我重启zk一般都是一台一台重启，而且我最近才刚刚又试过一次，我是先重启了follower zk节点，结果刚刚kill一瞬间flink任务全部出问题了。 Yang Wang 于2020年12月1日周二 下午8:18写道： > Flink是利用Curator Framework来进行Leader Election和Retrieval，当时Curator的State > 变成Suspended或者Lost的时候都会触发leader的revoke，进而导致需要Cancel掉之前的job >

flink-cdc 无法读出binlog，程序也不报错

hi，大佬们好，我用写了段java代码，通过cdc读取mysql的数据并通过print-table打印出来，但实际没打印，代码也不报错，一直处于运行状态 *idea中运行信息如下：* SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further

Re: Flink CEP 动态加载 pattern

Hi 你好, 现在Flink CEP还不支持动态加载规则。社区现在有一个JIRA来跟踪这个需求： https://issues.apache.org/jira/browse/FLINK-7129 您可以关注这个JIRA来获取最新进展。 > 在 2020年12月2日，17:48，huang botao 写道： > > Hi，在项目中常遇到规则变更的情况，我们一般怎么动态加载这些规则？Flink CEP有原生支持动态加载规则的API吗？

Re: the remote task manager was lost

可以看一下 remote task 对应的 tm 日志，看看有没有啥异常 Best, Congxian 赵一旦 于2020年12月2日周三 下午6:17写道： > 我都是80G、100G这么分配资源的。。。 > > guanxianchun 于2020年10月28日周三 下午5:02写道： > > > flink版本： flink-1.11 > > taskmanager memory: 8G > > jobmanager memory: 2G > > akka.ask.timeout：20s > > akka.retry-gate-closed-for： 5000 > >

Flink SQL????source ????

hi?? ??source table??topic??6??sinkinsert mysqlinsert source tablekafkakafka

为什么要关闭calcite的隐式转换功能

目前flink sql，flink hive sql都不支持隐式转换功能。我们在调试的时候发现其实calcite本身是支持的。但是flink这边强制关闭了。而hive本身是支持隐式转换的。这导致我们的hive任务无法迁移到flink上执行。请问关闭的原因是什么？如果我们这边开启会带来什么问题吗？

请问为什么关闭calcite的隐式转换

目前flink sql这边不支持隐式转换，导致sql中发现类型不一致的场景会报错，而且flink hive sql也有同样的问题，但是hive本身其实是支持的，这个差别导致原来hive sql任务基本无法使用flink来执行。我在调试的时候发现其实calcite本身是有隐式转换的功能的，但是flink这边强制的关闭了隐式转换。请问关闭的原因是什么？如果我们希望开启的话，会导致什么问题吗？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

为什么要关闭calcite的隐式转换功能

目前flink sql，flink hive sql都不支持隐式转换功能。我们在调试的时候发现其实calcite本身是支持的。但是flink这边强制关闭了。而hive本身是支持隐式转换的。这导致我们的hive任务无法迁移到flink上执行。请问关闭的原因是什么？如果我们这边开启会带来什么问题吗？

Re: the remote task manager was lost

我都是80G、100G这么分配资源的。。。 guanxianchun 于2020年10月28日周三 下午5:02写道： > flink版本： flink-1.11 > taskmanager memory: 8G > jobmanager memory: 2G > akka.ask.timeout：20s > akka.retry-gate-closed-for： 5000 > client.timeout：600s > > 运行一段时间后报the remote task manager was lost ，错误信息如下： > 2020-10-28 00:25:30,608 INFO

I defined a Kafka dynamic table in SQL-Client, but the kafka theme had some elements in the wrong format, so an exception was thrown in SQL-Client. Can we define the Kafka dynamic table with some addi

Caused by: java.io.IOException: Failed to deserialize JSON ''. at

Flink CEP 动态加载 pattern

Hi，在项目中常遇到规则变更的情况，我们一般怎么动态加载这些规则？Flink CEP有原生支持动态加载规则的API吗？

Re: 修改topic名称后从Savepoint重启会怎么消费Kafka

这个是正解，参考之前提的一个 Issue https://issues.apache.org/jira/browse/FLINK-16865 Best zhisheng Shuai Xia 于2020年12月2日周三 下午2:03写道： > > hi，实时上并不是你说的这样，从sp重启时因为存在RestoreState，而且Topic名称被修改，会导致restoredState内找不到新的KafkaTopicPartition > 新的消费位置会置为EARLIEST_OFFSET > > > if (restoredState != null) { >for