Checkpointing Completed and then failed

[Abdullah bin Omar <ab...@gmail.com>]

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)

Re: Checkpointing Completed and then failed

[Arvid Heise <ar...@apache.org>]

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 <
abdullahbinomar29@gmail.com> 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)
>