退订

退订

Re: flink jdbc connector不支持source

Hi, JDBC connector 是支持 source 的，应该是没有将最新的文档同步翻译成中文，可以参考一下英文文档 [1]。 [1] https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/ 祝好 > On Apr 10, 2022, at 11:07, casel.chen wrote: > > 现有一个场景是需要用flink一次性批量将某个mysql库下指定表（不同schema)同步到hudi表里面，查了一下官网flink jdbc > connec

日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决？

各位老大， 现在是 Flink 1.14.4 集群，通过 pyflink执行 sql 做流处理， taskmanager日志大量 The state is cleared because of state ttl. This will result in incorrect result. You can increase the state ttl to avoid this. 为什么出现？如何解决？ 2022-04-09 17:08:54,672 INFO org.apache.flink.streaming.runtime.operators.sink.AbstractS