Fork me on GitHub

Flink 原理与实现: Flink流程小总结

字数统计: 79字   |   阅读时长≈ 1分

整个Flink Job运行过程图

Flink Job提交流程到背压到TaskManager里面的slot,任务链等详情

Flink 窗口总结

Flink 时间语义及watermark机制小总结

Flink 状态一致性及保证状态的机制(checkpoint检查点算法)

Flink和kafka是如何实现端到端的exactly-once的呢?

赏

谢谢你请我吃糖果

支付宝
微信

扫一扫，分享到微信

标签列表:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

主要涉及技术：
大数据开发、Java后端开发
联系QQ:3101001329
微信:shangbaishuyao

很惭愧

只做了一点微小的工作
谢谢大家