hi guys,If I understand it correctly, will only some checkpoints be
recovered when there is an error in the Flink batch?
Piotr Nowojski 于2022年2月8日周二 19:05写道:
> Hi,
>
> I second Chesnay's comment and would like to better understand the
> motivation behind this. At the surface it sounds to me like
嗨,我这边在使用flink1.12.2提交yarn-application的任务时发现一个问题,
提交任务的flink官网的例子为
./bin/flink run-application -t yarn-application
./examples/streaming/TopSpeedWindowing.jar
如果其中有部分写错的话 yarn-application 写成了 yarn-appliation的话
就会报错
[image: image.png]
这里我看了代码是CliFrontend 封装的 213行的配置集合 effectiveConfiguration
有问题,导致Def
Hi, I'm using flink1.12.2 a problem is found when submitting the task of
yarn application,
An example of the Flink official website submitting a task is
./bin/flink run-application -t yarn-application ./
examples/streaming/TopSpeedWindowing. jar
If some of them are misspelled, then yen application
fine,I'll create a jira issue
胡伟华 于2022年3月24日周四 19:59写道:
> HI, congpeng
>
> Thanks for your report, I agree with you, we should be more explicit about
> not finding the corresponding Factory for the specified target. Could you
> create a jira issue for this?
>
>
&g
I created a jira FLINK-26858
丛鹏 于2022年3月25日周五 10:24写道:
> fine,I'll create a jira issue
>
> 胡伟华 于2022年3月24日周四 19:59写道:
>
>> HI, congpeng
>>
>> Thanks for your report, I agree with you, we should be more explicit
>> about not finding the correspondin