Re: Flink shutdown with exception when run in idea IDE

2022-01-24 Thread Chesnay Schepler
Certain (expected and completely fine) lifecycle events, like the one you mentioned, do log a stacktrace on debug level I believe. This one is not a cause for concern. On 24/01/2022 11:02, Caizhi Weng wrote: Hi! The exception stack you provided is not complete. Could you please provide the w

Re: Flink shutdown with exception when run in idea IDE

2022-01-24 Thread Caizhi Weng
Hi! The exception stack you provided is not complete. Could you please provide the whole exception stack (including all "Caused by")? Also could you please provide your user code so that others can look into this problem? Shawn Du 于2022年1月24日周一 17:22写道: > Hi experts, > I am new to flink, just r

Flink shutdown with exception when run in idea IDE

2022-01-24 Thread Shawn Du
Hi experts, I am new to flink, just run a simple job in IDE, but there are many exceptions thrown when job finished(see blow). job source is bounded, read from a local file and run in streaming mode. there is a customer sink also, simply write to local file. It seems that each time I run, I got d