退订
Hi Jiayi Liao.
Thanks your replying. Add attachment . And can’t get any useful messages;
> 2020年4月27日 12:40，Jiayi Liao 写道：
>
> <粘贴的图形-1.tiff>
Hi all,
Why my flink checkpoint always expired, I used RocksDB checkpoint,
and I can’t get any useful messages for this. Could you help me ? Thanks very
much.
Hi all,
Could you list details how Flink job on Yarn resources managed ?
I used command “-p 20 -yn 5 -ys 3 -yjm 2048m -ytm 2048m” to run flink job. I
got
containers vcores
8 22
Task Managers 7 Total Task Slots 21
I used command “-p 20 -yn 7 -ys 4 -yjm 2048m -ytm 2048m” to
>>> Savepoint.load(env, path) is in state processor API library, you should
>>> add the following dependency in your project.
>>>
>>>
>>> org.apache.flink
>>> flink-state-processor-api_2.11
>>> 1.9.1
>>>
>>>
>&g
Hi all,
I want to load checkpoint or savepoint metadata on dev . in this case , I
want to debug saved checkpoint metadata. And I knew flink provided a api which
is Savepoint.load(env, path), but I can’t find it and can’t use it. Anyone who
know about this ? Could you help me ? Thanks very
Hi All,
Desc
We deploy flink streaming jobs on hadoop cluster on per-job model and use
zookeeper as HighAvailabilityService, but we found that flink job will restart
because of the network disconnected temporarily between jobmanager and
zookeeper.So we analyze this problem deeply. Flink
