问题一:有没有知道flink sql 怎么调式啊,我找了半天也没看到什么资料?
有没有大佬知道flink sql 怎么调式啊,我找了半天也没看到什么资料?我想debug一个消息进来了,在sql中计算到出去的全过程,在每个算子中的数据的流转变化,不是那个explain计划。以前用DataStream API都可以自己debug,现在换成sql api不知道怎么做了?
参考答案:
找个开发平台调试,streampark或者dinky
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582431
问题二:flink MySQL cdc可以支持一个源同步到多个sink吗?
flink MySQL cdc可以支持一个源同步到多个sink吗? 比如说另一个MySQL数据库和Redis缓存?
参考答案:
这个用FlinkSQL的statement可以实现。弄多个insert放statement就可以了。另外在具体实践过程中好像没有办法保证事务的。因为执行过程两者是隔离的。只能做到两者各自有事务。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582348
问题三:Flink CDC这个问题有知道怎么解决的嘛?
Flink CDC这个问题有知道怎么解决的嘛?mysqlcdc使用了自定义的反序列化器之后就这样了
参考答案:
自定义序列化器引用的包不对,
用这个包org.apache.kafka.connect.json.JsonConverterConfig
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582347
问题四:csdn上说 flink cdc 要创建这些目录,我创建了把包挪进去还是没用?
csdn上说 flink cdc 要创建这些目录,我创建了把包挪进去还是没用?
参考答案:
lib里的包就是对应本地跑的flink-1.x.x/lib就好了呀
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582339
问题五:Flink CDC中oracle有现成的sink吗?
Flink CDC中oracle有现成的sink吗?
参考答案:
oracle flink1.15开始有,以下版本需要自己写,网上有现成的找一找
关于本问题的更多回答可点击进行查看: