发简信
IP属地：浙江
*使用canal采集mysql的binlog，输出到kafka，然后使用flinksql消费kafka，并输出到屏幕 mysql需要开始binl...
github地址：https://github.com/ververica/flink-cdc-connectors Flink CDC Con...
flink1.11发布以来，很多人就很关心hive仓库实时化。所以自己也试着尝试一下，然而遇到很多环境问题。 环境准备好之后，先在本地测试一下,...
MemoryStateBackend 状态数据保存在taskmanager的内存中，所以程序能够使用状态的大小受限于taskmanager的内存...
eventTime eventTime根据事件中的某个字段指定(assignTimestampsAndWatermarks) watermark...
感觉这种场景还是挺有用的，经过在本地和yarn上测，没问题