Flink CDC 社区有提供1.14支持的,2.2.1版本即可。你这个好像是没有开启checkpoint, 开启下就好了。
// enable checkpoint
env.enableCheckpointing(1000);
祝好,
Leonard
> 2022年11月3日 上午11:34,左岩 <13520871...@163.com> 写道:
>
> 我用的是flink1.14
> ,因为官方没有匹配的版本,所以自己编译的flinkCDC,binlog也开启了,然后也没报错,读不到mysql的数据,idea控制台不报错也不输出数据,可能是什么原因呢(运行日志见附件)
> p
要在mysql表上t_stu上建个主键,只在FlinkSQL上指定主键不行。
> 在 2022年11月3日,11:54,yinghua...@163.com 写道:
>
> 要在mysql表上t_stu上建个主键,只在FlinkSQL上指定主键不行。
>
>
>
> yinghua...@163.com
>
> 发件人: 左岩
> 发送时间: 2022-11-03 11:34
> 收件人: user-zh
> 主题: flinkcdc 读不到mysql中数据
> 我用的是flink1.14
> ,因为官方没有匹配的版本,所以自己编译的flinkCDC,binlog也开启了,然
我用的是flink1.14
,因为官方没有匹配的版本,所以自己编译的flinkCDC,binlog也开启了,然后也没报错,读不到mysql的数据,idea控制台不报错也不输出数据,可能是什么原因呢(运行日志见附件)
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
conf.setInteger("rest.port", 10041);
StreamExecutionEnvironment env =
StreamExecutionEnvi
提供一下你的作业的SQL?详细一点的上下文
> -原始邮件-
> 发件人: "junjie.m...@goupwith.com"
> 发送时间: 2022-11-02 15:21:39 (星期三)
> 收件人: user-zh
> 抄送:
> 主题: flink1.14.5报错提示 “无法编译表程序。这是一个bug。请提交一个问题。”
>
> flink1.14.5遇到一个很奇怪的报错,报错提示 “无法编译表程序。这是一个bug。请提交一个问题。”
> 报错信息如下:
> /* 1 */
> /* 2 */ public final class Wate
Hi,
这种情况一般是这两个 TaskManager 出现故障断开连接了。可以再查看下之前的日志验证下。
Best,
Weihua
On Wed, Nov 2, 2022 at 9:41 AM casel.chen wrote:
> 今天线上 Flink 1.13.2 作业遇到如下报错,请问是何原因,要如何解决?
> 作业内容是从kafka topic消费canal json数据写到另一个mysql库表
>
>
> 2022-09-17 19:40:03,088 ERROR akka.remote.Remoting
> [] - Associati
Hi,
Sorry for slow reply. I have debugged and found why the error occurs. Please
try using Hive2’s Beeline to connect to the SQL Gateway. I think it is a quick
solution.
The ‘CLI_ODBC_KEYWORDS' is new in Hive3, and in Initialization phase of
connection, Beeline will send a request using t
你好. 但是下一次cp发起之时, kafka transaction 已经超时失败了, sink端precommit之前,写入到kafka的数据,
是不是就丢失了?
发件人: Xuyang
发送时间: 2022年11月1日 23:08
收件人: user-zh@flink.apache.org
主题: Re:flink exactly once
写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?
Hi, 应该会等到下一次做cp