[ 
https://issues.apache.org/jira/browse/APEXMALHAR-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684373#comment-15684373
 ] 

bright chen commented on APEXMALHAR-2339:
-----------------------------------------

The KeyedWindowed operator started with rate around 35k/second.
then the rate decreased to around 2k/second in 20 minutes.
And then ended with "heartbeat timeout"
Following is the log. And attached memory and cpu usage

016-11-21 10:26:19,746 [2/windowedOperator:MyKeyedWindowedOperator] INFO  
window.KeyedWindowedOperatorBenchmarkApp$MyKeyedWindowedOperator endWindow - 
total: count: 16851212; time: 1204346; average: 13992; period: count: 20768; 
dropped: 1232; time: 11810; average: 1758
2016-11-21 10:26:40,884 [2/windowedOperator:MyKeyedWindowedOperator] INFO  
window.KeyedWindowedOperatorBenchmarkApp$MyKeyedWindowedOperator endWindow - 
total: count: 16871901; time: 1225484; average: 13767; period: count: 20689; 
dropped: 311; time: 21138; average: 978
2016-11-21 10:26:56,919 [2/windowedOperator:MyKeyedWindowedOperator] INFO  
window.KeyedWindowedOperatorBenchmarkApp$MyKeyedWindowedOperator endWindow - 
total: count: 16892901; time: 1241519; average: 13606; period: count: 21000; 
dropped: 0; time: 16034; average: 1309
2016-11-21 10:27:04,741 [2/windowedOperator:MyKeyedWindowedOperator] INFO  
window.KeyedWindowedOperatorBenchmarkApp$MyKeyedWindowedOperator endWindow - 
total: count: 16912901; time: 1249341; average: 13537; period: count: 20000; 
dropped: 0; time: 7822; average: 2556
2016-11-21 10:33:58,354 [main] INFO  stram.StreamingContainerManager 
monitorHeartbeat - Container container-0@localhost heartbeat timeout (403334 
ms).

> Windowed Operator benchmarking
> ------------------------------
>
>                 Key: APEXMALHAR-2339
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2339
>             Project: Apache Apex Malhar
>          Issue Type: Task
>            Reporter: bright chen
>            Assignee: bright chen
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to