Checkpointing Completed and then failed

[Abdullah bin Omar]

Hi,

I run the same code twice. First time the job is finished and I am able to see the checkpointing triggered and completed. However, the next time the job fails. (please, have a look at the attached pic). I can not figure out the problem. 

I am pretty sure is this because of this line of the code:

DataStream<String> data = env.socketTextStream("localhost", 9090);

Could you please inform me how can we get input from localhost? (I guess by chance my code works in one time, but later the job is shown failed)

[Arvid Heise-4]

Hi Abdullah,

without specific logs, it's hard to diagnose what went wrong. Could you check in your taskmanager logs if any error occurred and add it? In Flink UI, you can also browse the latest exceptions and look at the checkpoint history. That may give you (and us) additional insights.

On Thu, Mar 11, 2021 at 1:19 AM Abdullah bin Omar <[hidden email]> wrote:

Hi,

I run the same code twice. First time the job is finished and I am able to see the checkpointing triggered and completed. However, the next time the job fails. (please, have a look at the attached pic). I can not figure out the problem. 

I am pretty sure is this because of this line of the code:

DataStream<String> data = env.socketTextStream("localhost", 9090);

Could you please inform me how can we get input from localhost? (I guess by chance my code works in one time, but later the job is shown failed)