todd5167
todd5167
https://www.bilibili.com/video/av54074405?from=search&seid=8684141189851289657 Flink Checkpoint-轻量级分布式快照
@tiloulou177 是的,你看看flink client相关代码就知道了
@lingya 可以自己升级下的
@TyvmR 你先用1.12那个分支,新的分支我需要测试下
@lovecodec 暂时没要加入pyspark的规划。你可以看下pyspark提交的参数,比较方便集成的。
@suyuNJ 指定你集群的hadoop配置文件夹,会提交到远程的Yarn上的。
@maidou75293 @qiuqingyu 新推了一版本1.8_dev可以在试试,需要拷贝flink-table-common-1.8.1.jar和flink-table-planner_2.11-1.8.1.jar到flinklib下。
@taiziwang 你的Jdk版本不是1.8吧
@maidou75293 最新版本已经做了相关处理
@lijianfeng6666526 你用yarnPer 和 -pluginLoadMode shipfile 模式试试,yarnsession模式我们的测试的比较少。