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.