Flink在 https://mvnrepository.com/ 上没有搜到， 有测试过 sink 到 websocket 的吗？ 
以下为热心网友提供的参考意见
是的，Flink已经测试过将数据发送到WebSocket。在Flink 1.13版本中，引入了对WebSocket的支持，允许用户通过Sink将数据发送到WebSocket服务器。你可以使用org.apache.flink.streaming.connectors.websocket.WebSocketSink类来实现这个功能。
转转请注明出处：https://www.yunxiaoer.com/183461.html
在Flink 1.16 lookup join 可以join子查询吗？ 以下为热心网友提供的参考意见 Flink 1.16的Lookup Join主要用于将一张表的数据通过查询去丰富另一张表的数据，通常需要一张表有一个处理时间属性，另一张表由一个查找源连接器支持。然而，对于是否支持join子查询的问题，目前的资料并没有给出直接的答案。在实际应用中，你可以尝试…
Hologres的mc 离线数据 和 Flink 的实时数据合并有好的方案吗， 还有 mc 同步 holo 有增量方案吗？ 以下为热心网友提供的参考意见 Hologres与Flink可以深度集成，实现实时数据合并。首先，Flink将数据源写入Hologres，形成ODS层。然后，Flink订阅ODS层的Binlog进行加工，形成DWD层再次写入Hologre…
我使用Flink cdc整库同步mysql，之前设置多表同步101个表， 今天新增了1个表，然后重新部署，我还是沿用之前的状态(“有状态启动”)，发现在holo这边会新建这个新增的表， 但是数据没写入， 这种state是否合理？还是说每次新增表都要使用“无状态启动”，才能写数据 以下为热心网友提供的参考意见 参考一下这个文档哦https://help.ali…
flink taskmanager.memory.segment-size 设置了 128kb。但是监听到的tcpdump网络包的却是很小： 才 100bytre – 1000多byte之间，Flink这种一般是什么问题？
使用CTAS 把mysql 表同步数据 到hologres ，Flink有什么参数可以使hologres 的字段都小写吗？ 以下为热心网友提供的参考意见 Flink本身并没有直接提供将Hologres字段转换为小写的参数。但是，你可以通过在Flink作业中编写自定义逻辑来实现这个功能。 你可以使用Flink的Map函数来将Hologres字段转换为小写。以下…