问题一:flink大会的ppt和文章有没有哪里有整理的?
flink大会的ppt和文章有没有哪里有整理的?
参考答案:
「Flink Forward Asia 2023 」PPT 阅读合集 ,上面链接。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586095
问题二:Flink两个流 需要关联,但是条件是A流的一个字段(字符串)包含B流的 一个字段?
Flink两个流 需要关联,但是条件是A流的一个字段(字符串)包含B流的 一个字段,前辈们有过类似经验吗 用join或者 connect写不出来呀?
参考答案:
两个流判断符合条件就可以合流
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586090
问题三:你们Flink CDC docker 的时区一般设置的什么?
你们Flink CDC docker 的时区一般设置的什么?
参考答案:
ENV TZ=Asia/Shanghai
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587143
问题四:Flink CDC3.0有没有办法从保存点继续启动啊?
Flink CDC3.0有没有办法从保存点继续启动啊?另外是不是这个保存点:bash bin/flink-cdc.sh mysql-to-doris.yaml --flink-home /data/flink-1.18.0 -s
参考答案:
所有的flink任务都可以检查点启动。你能不以提交jar包的方式
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587139
问题五:Flink CDC这个有没有办法从保存点里面继续启动啊?
Flink CDC这个有没有办法从保存点里面继续启动啊?bash bin/flink-cdc.sh mysql-to-doris.yaml --flink-home /data/flink-1.18.0
参考答案:
是的,Flink CDC支持从保存点(savepoint)中恢复作业。要使用保存点启动作业,请按照以下步骤操作:
- 首先,确保您已经创建了一个MySQL到Doris的CDC作业,并且已经运行了一段时间,以便生成一些数据和保存点。
- 然后,停止正在运行的CDC作业。您可以使用以下命令停止作业:
bin/flink-cdc.sh stop mysql-to-doris.yaml --flink-home /data/flink-
- 接下来,使用以下命令从保存点中恢复作业:
bin/flink-cdc.sh start mysql-to-doris.yaml --from savepoint --flink-home /data/flink-
- 其中,
--from savepoint
选项告诉Flink从指定的保存点中恢复作业。 - 最后,等待作业从保存点中恢复并开始运行。您可以使用以下命令检查作业的状态:
bin/flink-cdc.sh status mysql-to-doris.yaml --flink-home /data/flink-
通过以上步骤,您可以从保存点中恢复Flink CDC作业并继续处理数据。请注意,如果您在恢复作业之前修改了配置文件或代码,则可能需要重新应用这些更改。
关于本问题的更多回答可点击进行查看: