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