Hi,
In short, [1] means whether the job will trigger checkpoints, and [2] means
which operators will take action when checkpoints are triggered.
If use ExampleCountSource, flink-streaming-java should be a dependency in
pom.xml and classes such as ListState, ListStateDescriptor,
FunctionInitial
Hi,
CheckpointedFunction is needed to trigger and complete the checkpoint, is
it right?
What is the work for the code in here [1]? it [1] said to enable
checkpointing or some other function. What is the difference between [1]
and [2]?
If we use ExampleCountSource[2] example, what will be the im
Hi,
After implementing SourceFunction, you can use it to create a DataStream
using env.addSource() in your main method.
For example, if you have your custom source class with the name CustomSource
that implements SourceFunction, then it can be used for getting
input data and the if-statement afte
Hi Smile,
Thank you for your reply.
I read [1] according to the last email. I will have to add implements
SourceFunction CheckpointedFunction with the main class. Then
calling run() and cancel() inside the main class. Is it correct?
I just run the sample code from apache flink. I can not under
Hi,
Could you please change the source to an endless one? For example a Kafka
source or a custom source that implements SourceFunction([1])?
env.readTextFile() won't wait for all data to be finished, but exit
immediately after telling readers what to read. So it may exit before the
first checkpoi
The picture in first e-mail shows that job was completed in 93ms
From: Abdullah bin Omar
Sent: Monday, March 8, 2021 3:53 PM
To: user@flink.apache.org
Subject: Re: Trigger and completed Checkpointing do not appeared
Hi,
Please read the previous email (and also
