FileNotFoundException for ".inprogess" files in StreamingFileSink

Hi Team, Flink Version is *1.10* *java.io.FileNotFoundException: File does not exist: /data/staging/inbound/_user/cdcdcd/input/aaa_/30e73444-3405-471f-a05a-b32fb15fddfd/.SEP705052768755-12-3643.done.inprogress.4f2bba7c-68fa-4044-86f9-444057aa45ac* at

Re: Heartbeat of TaskManager with id container

fits the above situations. > > Best, > Xiangyu > > > Y SREEKARA BHARGAVA REDDY 于2023年7月31日周一 20:49写道： > >> Hi Team, >> >> Did any one face the below exception. >> If yes, please share the resolution. >> >> >&

log4j2 integration with flink 1.10

Hi Team, Does any one did integration flink 1.10 with log4j2 instead of log4j1. If yes, please share the reference for that. Any suggestion, greatly appreciated. Regards, Nagireddy Y.

Re: Heartbeat of TaskManager with id container

che.flink.streaming.runtime.tasks. >>>> StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call( >>>> StreamTaskActionExecutor.java:101) >>>> at org.apache.flink.streaming.runtime.tasks.StreamTask >>>> .notifyCheckpointComplet

Re: Heartbeat of TaskManager with id container

et a HDFS file > issue during the commit phase of checkpoint. Can u check why 'Staging file > does not exist' in the first place? > > Regards, > Xiangyu > > Y SREEKARA BHARGAVA REDDY 于2023年8月4日周五 12:21写道： > >> Hi Xiangyu/Dev Team, >> >> Thanks for reply. &

Re: Heartbeat of TaskManager with id container

ed; > 2), There might be a network issues between this TaskManager and JobMaster; > 3), In certain cases, JobMaster actor might also being too busy to process > the RPC requests from TaskManager; > > Pls check if your problem fits the above situations. > > Best, > Xiangyu > &g

Heartbeat of TaskManager with id container

Hi Team, Did any one face the below exception. If yes, please share the resolution. 2023-07-28 22:04:16 j*ava.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e19_1690528962823_0382_01_05 timed out.* at org.apache.flink.runtime.jobmaster.

Check points are discarded with reason NULL

Hi Team, While running flink streaming. i got following exception, Did you any one faced the issue? Check points are discarded with *reason is* NULL. org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold. at

Re: Flink Job restarting frequently.

as done. Regards, Nagireddy Y. On Wed, Jul 19, 2023 at 5:55 PM Y SREEKARA BHARGAVA REDDY < ynagiredd...@gmail.com> wrote: > Flink is restarting daily once. > Flink version: 1.10.0 > 2023-07-19 12:33:52 > org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint > tolera

Flink Job restarting frequently.

Flink is restarting daily once. Flink version: 1.10.0 2023-07-19 12:33:52 org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold. at org.apache.flink.runtime.checkpoint.CheckpointFailureManager