Hi, Could you also provide the job master log?
Best, Stefan > On 9. Jan 2019, at 12:02, sohimankotia <sohimanko...@gmail.com> wrote: > > Hi, > > I am running Flink Streaming Job with 1.5.5 version. > > - Job is basically reading from Kafka , windowing on 2 minutes , and writing > to hdfs using AvroBucketing Sink . > - Job is running with parallelism 132 > - Checkpointing is enabled with interval of 1 minute. > - Savepoint is enabled and getting triggered every 30 min . > > > Few Modified Properties : > > akka.ask.timeout: 15min > akka.client.timeout: 900s > akka.lookup.timeout: 60s > akka.tcp.timeout : 900s > > akka.watch.heartbeat.interval: 120s > akka.watch.heartbeat.pause: 900s > > Issues : > > Job is getting restarted 3 to 4 time every day ( At random times). It simply > says attempting to cancel task. No exception or logging . I tried to set > > log4j.logger.org.apache.flink.runtime.taskmanager.Task=DEBUG,file > > But nothing important is getting logged. > > Enabling DEBUGGING at Flink level is making Streaming Application to slow ( > so can not do that ). > > Attaching Task logs . > > task.gz > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t894/task.gz> > > > > Thanks > Sohi > > > > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
