240 发简信
IP属地:北京
  • 120
    flink run任务提交流程<命令行方式>

    运行模式是 flink-on-yarn per-job模式,每个任务有独立的yarn session,启动任务的方式是CLI方式。所以我们任务启动命令像是这样: 那么任务具体...

  • 120
    flink如何管理kafka消费位点(原:how flink manages kafka consumer offsets)

    本文为翻译flink作者之一Fabian Hueske的文章 原文:https://www.ververica.com/blog/how-apache-flink-manag...