问题一:想请教下 部署flink集群的话 Standalone模式 Yarn模式 模式用哪个模式好一点?
想请教下 部署flink集群的话 Standalone模式 Yarn模式 Kubernetes模式用哪个模式好一点?另外需要安装zookeeper来实现高可用么?
参考答案:
Standalone模式也很稳定呀,已经跑了大半年了;建议下载解压,直接启动 。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587194
问题二:请问一下 Flink CDC提交没有反应是怎么回事?
请问一下 Flink CDC提交没有反应是怎么回事?
参考答案:
机器卡了的概率很大
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587193
问题三:flink sink websocket 需要哪个依赖?
flink sink websocket 需要哪个依赖?
参考答案:
自己重新写 sink
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587253
问题四:Flink有测试过 sink 到 websocket 的吗?
Flink在 https://mvnrepository.com/ 上没有搜到, 有测试过 sink 到 websocket 的吗?
参考答案:
是的,Flink已经测试过将数据发送到WebSocket。在Flink 1.13版本中,引入了对WebSocket的支持,允许用户通过Sink将数据发送到WebSocket服务器。你可以使用org.apache.flink.streaming.connectors.websocket.WebSocketSink
类来实现这个功能。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/587252
问题五:Flink重新发任务,怎么从上一个checkpoint点位恢复?
Flink重新发任务,怎么从上一个checkpoint点位恢复?
参考答案:
启动任务的时候可以指定 ck 地址 也可以指定 sp 地址 两个都可以恢复
关于本问题的更多回答可点击进行查看: