问题一:Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗?
Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗?exec "$JAVA_RUN" -classpath "$CLASSPATH" "${LOG_SETTINGS[@]}" com.ververica.cdc.cli.CliFrontend "$@"
参考答案:
参考
https://ververica.github.io/flink-cdc-connectors/master/content/%E5%BF%AB%E9%80%9F%E4%B8%8A%E6%89%8B/mysql-starrocks-pipeline-tutorial-zh.html 。要么是flink的环境配置错了,你的flink里面缺少这个文件。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590859
问题二:Flink CDC里cdc mongo 碰到这样的数据咋处理?
Flink CDC里cdc mongo 碰到这样的数据"freightrates":{"$numberLong":"100000"},你们是咋处理的?
参考答案:
这样BsonDocment.parse and then toStrinig。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590858
问题三:Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真为啥?
Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真是怎么个情况?
参考答案:
应该是ui显示的问题。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590857
问题四:Flink CDC里这个超时时间有没有地方去配置呢?
Flink CDC里这个超时时间有没有地方去配置呢?
参考答案:
看下wait_timeout这个配置
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590852
问题五:Flink CDC里mysql CDC是否可以基于binlog的位置信息启动?
Flink CDC里mysql CDC是否可以基于binlog的位置信息启动? 同步数据时是否可以把binlog的位置信息传输到sink端?
参考答案:
这个需要自己改造实现点位数据下移,可以基于binlog点位启动,master现在支持binlog二分查找了。
关于本问题的更多回答可点击进行查看: