Hi Ram, Thanks for the reply . yes I am getting those messages. These lines appearing throughout the log file.
2017-03-02 03:25:36,635 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=4,name=Kafka_Input.outputPort#unifier] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,636 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=3,name=Avro_Convert] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,636 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=5,name=Field_Extract] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,636 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=7,name=Order_Correct] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,636 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=8,name=Session_Check] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,638 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=16,name=Session_Check.hdfsOutput#unifier] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,638 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=15,name=Hdfs_Write] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,639 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=14,name=Session_Check.dupRecsOutput#unifier] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,639 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=13,name=Retriggered_Recs_Hdfs_Write] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,639 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=9,name=Session_Check] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,639 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=11,name=Session_Check] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,639 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=10,name=Session_Check] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,640 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=12,name=Session_Check] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,640 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=6,name=Empty_Vis_Recs_Hdfs_Write] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 2017-03-02 03:25:36,640 WARN stram.StreamingContainerManager (StreamingContainerManager.java:updateRecoveryCheckpoints(1966)) - Marking operator PTOperator[id=17,name=Invalid_Json_Recs_Hdfs_Write] blocked committed window 58b7b29900000eeb, recovery window 58b7b29900000eeb, current time 1488446736626, last window id change time 0, window processing timeout millis 60000 Thanks Rishi Mishra -- View this message in context: http://apache-apex-users-list.78494.x6.nabble.com/Apex-application-getting-killed-at-regular-interval-tp1421p1425.html Sent from the Apache Apex Users list mailing list archive at Nabble.com.
