240 发简信
Jaming
IP属地：浙江
  • flinksql从kafka中消费mysql的binlog日志

    *使用canal采集mysql的binlog，输出到kafka，然后使用flinksql消费kafka，并输出到屏幕 mysql需要开始binl...

    9054 0 0
  • Resize,w 360,h 240
    FlinkSql cdc 从mysql表join之后写入elasticsearch

    github地址：https://github.com/ververica/flink-cdc-connectors Flink CDC Con...

    6143 3 0
  • Resize,w 360,h 240
    flinksql 1.11 消费kafka到hive中环境问题

    flink1.11发布以来，很多人就很关心hive仓库实时化。所以自己也试着尝试一下，然而遇到很多环境问题。 环境准备好之后，先在本地测试一下,...

    5632 0 0
  • flink 状态后端的简单理解

    MemoryStateBackend 状态数据保存在taskmanager的内存中，所以程序能够使用状态的大小受限于taskmanager的内存...

    5150 0 0
  • Resize,w 360,h 240
    flink watermark生成，向前推进时钟

    eventTime eventTime根据事件中的某个字段指定(assignTimestampsAndWatermarks) watermark...

    3126 0 0
  • flink 使用RichCoFlatMapFunction算子，用一个流控制另一个流输出

    感觉这种场景还是挺有用的，经过在本地和yarn上测，没问题

    6669 0 0
暂无个人介绍