Created
February 23, 2018 16:06
-
-
Save Ethanlm/bcab1289a3813af6d7135aa95b1aaa14 to your computer and use it in GitHub Desktop.
storm jar /tmp/storm-loadgen-2.0.0-SNAPSHOT.jar org.apache.storm.loadgen.ThroughputVsLatency --spouts 1 --splitters 2 --counters 1 --rate 1000 -c topology.debug=true
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2018-02-23 15:13:29.923 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.923 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.923 o.a.s.e.Executor Thread-15-spout-executor[7, 7] [INFO] Processing received message FOR -2 TUPLE: source: __system:-1, stream: __tick, id: {}, [30] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null | |
2018-02-23 15:13:29.923 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.923 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@414b2d91,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.923 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.923 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-898368918032736033=2153843694847534884}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-898368918032736033, 2153843694847534884, 7] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-898368918032736033, 2153843694847534884, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@3f6b1dec,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.924 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-670190708051257909=6473846926634836572}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-670190708051257909, 6473846926634836572, 7] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-670190708051257909, 6473846926634836572, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.924 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@51d1f8,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.924 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.924 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {1113272857987749391=-5280791368309534841}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[1113272857987749391, -5280791368309534841, 7] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [1113272857987749391, -5280791368309534841, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@253ac67,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.925 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {7785562807018466370=-3974642227059907678}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[7785562807018466370, -3974642227059907678, 7] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [7785562807018466370, -3974642227059907678, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@2c87e0b8,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.925 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-2945268503773121608=7955113330244476978}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-2945268503773121608, 7955113330244476978, 7] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-2945268503773121608, 7955113330244476978, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.925 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@1ea1a446,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {2433637399941217831=-4775307915805447287}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[2433637399941217831, -4775307915805447287, 7] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [2433637399941217831, -4775307915805447287, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@45015604,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-5382427092617171060=1361586220318927175}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-5382427092617171060, 1361586220318927175, 7] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-5382427092617171060, 1361586220318927175, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@327fcf77,stream=default,values=[the cow jumped over the moon],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[the cow jumped over the moon] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-2326796910011501489=-9058953493644093661}, [the cow jumped over the moon] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-2326796910011501489, -9058953493644093661, 7] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.926 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-2326796910011501489, -9058953493644093661, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@1973ff2,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-3659632986644515419=1850505929719853547}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-3659632986644515419, 1850505929719853547, 7] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-3659632986644515419, 1850505929719853547, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@45505930,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-5650992414040395723=9143295509378770633}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-5650992414040395723, 9143295509378770633, 7] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-5650992414040395723, 9143295509378770633, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@374a50b2,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.927 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {4321487601688154365=7737862761783088327}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.927 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[4321487601688154365, 7737862761783088327, 7] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [4321487601688154365, 7737862761783088327, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@57e18868,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.928 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {1985755909347277943=6746440532548870804}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[1985755909347277943, 6746440532548870804, 7] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [1985755909347277943, 6746440532548870804, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@16b3ab02,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.928 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-7440859121119337481=5402941495512231048}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-7440859121119337481, 5402941495512231048, 7] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-7440859121119337481, 5402941495512231048, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.928 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@4a0a18d6,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.928 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.928 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {5374271472050720086=-5861287587227021595}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[5374271472050720086, -5861287587227021595, 7] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [5374271472050720086, -5861287587227021595, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@1281f95f,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-2280032688302247723=-7248876163940298657}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-2280032688302247723, -7248876163940298657, 7] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-2280032688302247723, -7248876163940298657, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@40efe057,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.929 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {3441504215316009274=7238994640023679197}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[3441504215316009274, 7238994640023679197, 7] | |
2018-02-23 15:13:29.929 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [3441504215316009274, 7238994640023679197, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.929 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@598222e4,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.930 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {621093991600517695=-8670884887992901503}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[621093991600517695, -8670884887992901503, 7] | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [621093991600517695, -8670884887992901503, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@5546b769,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {4151279941105373484=1410688607698969318}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[4151279941105373484, 1410688607698969318, 7] | |
2018-02-23 15:13:29.930 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [4151279941105373484, 1410688607698969318, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.930 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@3f976ac1,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.931 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {3338087320896930754=4243659539130819240}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[3338087320896930754, 4243659539130819240, 7] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [3338087320896930754, 4243659539130819240, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@496e3245,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.931 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {5261442182694773083=-2385599367550093016}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[5261442182694773083, -2385599367550093016, 7] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [5261442182694773083, -2385599367550093016, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.931 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@2a9d153c,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.931 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.931 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-5708276707717195186=-1818361626144379248}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-5708276707717195186, -1818361626144379248, 7] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-5708276707717195186, -1818361626144379248, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@5f1bdb7,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-7849853144321662568=6820922738195428884}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-7849853144321662568, 6820922738195428884, 7] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-7849853144321662568, 6820922738195428884, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@7f22c0e6,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-7749000285253251912=-3433571623149983109}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-7749000285253251912, -3433571623149983109, 7] | |
2018-02-23 15:13:29.932 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-7749000285253251912, -3433571623149983109, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.932 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@13af1ad1,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.932 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {6640226359650455001=-7081180802004513059}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[6640226359650455001, -7081180802004513059, 7] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [6640226359650455001, -7081180802004513059, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@1372efc4,stream=default,values=[the cow jumped over the moon],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.933 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[the cow jumped over the moon] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {3883026916628753462=8958117836284237742}, [the cow jumped over the moon] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[3883026916628753462, 8958117836284237742, 7] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [3883026916628753462, 8958117836284237742, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@37ef445a,stream=default,values=[the cow jumped over the moon],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.933 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[the cow jumped over the moon] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-2585881388121841991=9060789302123036666}, [the cow jumped over the moon] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.933 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-2585881388121841991, 9060789302123036666, 7] | |
2018-02-23 15:13:29.933 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-2585881388121841991, 9060789302123036666, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@4735b38b,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.934 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-5978124566284735259=6698741816667057906}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-5978124566284735259, 6698741816667057906, 7] | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-5978124566284735259, 6698741816667057906, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@62f937ec,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {2749359835920529910=8087990647557583270}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[2749359835920529910, 8087990647557583270, 7] | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [2749359835920529910, 8087990647557583270, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.934 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@46b15149,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.934 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {4667904203049705031=-7668161714088833773}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[4667904203049705031, -7668161714088833773, 7] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [4667904203049705031, -7668161714088833773, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@2b531c33,stream=default,values=[snow white and the seven dwarfs],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[snow white and the seven dwarfs] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-6710889391526219022=8641430702758915168}, [snow white and the seven dwarfs] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-6710889391526219022, 8641430702758915168, 7] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-6710889391526219022, 8641430702758915168, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@3bef7c15,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-1068340956087094339=-9215847907946893468}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.935 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-1068340956087094339, -9215847907946893468, 7] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-1068340956087094339, -9215847907946893468, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@351932d4,stream=default,values=[four score and seven years ago],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.936 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[four score and seven years ago] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {-8813846595224151244=-3277003009501094549}, [four score and seven years ago] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-8813846595224151244, -3277003009501094549, 7] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-8813846595224151244, -3277003009501094549, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@6a10776b,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.936 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {7971175606488145169=-6698429366735814598}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[7971175606488145169, -6698429366735814598, 7] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [7971175606488145169, -6698429366735814598, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@c20cdb3,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.936 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.936 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-6164913431863909660=-9147353590609368241}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-6164913431863909660, -9147353590609368241, 7] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-6164913431863909660, -9147353590609368241, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@6cf8da2d,stream=default,values=[the cow jumped over the moon],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.937 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[the cow jumped over the moon] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-3803859782690787601=-5827470942801513620}, [the cow jumped over the moon] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-3803859782690787601, -5827470942801513620, 7] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-3803859782690787601, -5827470942801513620, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.937 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@722dec9c,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.937 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.937 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {8287181739746724178=2405527158475594326}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[8287181739746724178, 2405527158475594326, 7] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [8287181739746724178, 2405527158475594326, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@5095305b,stream=default,values=[i am at two with nature],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.938 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[i am at two with nature] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-3261077390821205145=-1350986428575649062}, [i am at two with nature] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-3261077390821205145, -1350986428575649062, 7] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-3261077390821205145, -1350986428575649062, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@5b55e862,stream=default,values=[the cow jumped over the moon],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.938 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[the cow jumped over the moon] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 5 tuple: source: spout:7, stream: default, id: {-8067667579802919569=3555205385660416272}, [the cow jumped over the moon] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[-8067667579802919569, 3555205385660416272, 7] | |
2018-02-23 15:13:29.938 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [-8067667579802919569, 3555205385660416272, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.938 o.a.s.e.s.SpoutExecutor Thread-15-spout-executor[7, 7] [INFO] SPOUT Failing null : TupleInfo[taskId=7,messageId=org.apache.storm.loadgen.LoadSpout$SentWithTime@31798639,stream=default,values=[an apple a day keeps the doctor away],timestamp=0,id=<null>] REASON: TIMEOUT | |
2018-02-23 15:13:29.939 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=default values=[an apple a day keeps the doctor away] | |
2018-02-23 15:13:29.939 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 6 tuple: source: spout:7, stream: default, id: {4415441672268561005=4504424821011733219}, [an apple a day keeps the doctor away] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.939 o.a.s.d.Task Thread-15-spout-executor[7, 7] [INFO] Emitting Tuple: taskId=7 componentId=spout stream=__ack_init values=[4415441672268561005, 4504424821011733219, 7] | |
2018-02-23 15:13:29.939 o.a.s.e.ExecutorTransfer Thread-15-spout-executor[7, 7] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: spout:7, stream: __ack_init, id: {}, [4415441672268561005, 4504424821011733219, 7] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.939 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.939 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.939 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.940 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.940 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.940 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.941 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.941 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.942 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.943 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.943 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.943 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.944 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.944 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.944 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.945 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.945 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.945 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.946 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.946 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.946 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.939 o.a.s.u.Utils Thread-15-spout-executor[7, 7] [ERROR] Async loop died! | |
java.lang.RuntimeException: java.lang.IllegalStateException: Queue full | |
at org.apache.storm.executor.Executor.accept(Executor.java:288) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:309) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:290) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:281) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:173) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:163) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.Utils$2.run(Utils.java:352) [storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131] | |
Caused by: java.lang.IllegalStateException: Queue full | |
at java.util.AbstractQueue.add(AbstractQueue.java:98) ~[?:1.8.0_131] | |
at org.apache.storm.daemon.worker.WorkerTransfer.tryTransferRemote(WorkerTransfer.java:112) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.daemon.worker.WorkerState.tryTransferRemote(WorkerState.java:526) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.ExecutorTransfer.tryTransfer(ExecutorTransfer.java:71) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.daemon.Task.sendUnanchored(Task.java:196) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutOutputCollectorImpl.sendSpoutMsg(SpoutOutputCollectorImpl.java:164) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutOutputCollectorImpl.emit(SpoutOutputCollectorImpl.java:75) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:51) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.loadgen.LoadSpout.fail(LoadSpout.java:135) ~[stormjar.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor.failSpoutMsg(SpoutExecutor.java:362) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$1.expire(SpoutExecutor.java:126) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$1.expire(SpoutExecutor.java:119) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.RotatingMap.rotate(RotatingMap.java:77) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor.tupleActionFn(SpoutExecutor.java:298) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.Executor.accept(Executor.java:284) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
... 7 more | |
2018-02-23 15:13:29.947 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.947 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.948 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.949 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.949 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.949 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.948 o.a.s.e.e.ReportError Thread-15-spout-executor[7, 7] [ERROR] Error | |
java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalStateException: Queue full | |
at org.apache.storm.utils.Utils$2.run(Utils.java:365) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131] | |
Caused by: java.lang.RuntimeException: java.lang.IllegalStateException: Queue full | |
at org.apache.storm.executor.Executor.accept(Executor.java:288) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:309) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:290) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:281) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:173) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:163) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.Utils$2.run(Utils.java:352) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
... 1 more | |
Caused by: java.lang.IllegalStateException: Queue full | |
at java.util.AbstractQueue.add(AbstractQueue.java:98) ~[?:1.8.0_131] | |
at org.apache.storm.daemon.worker.WorkerTransfer.tryTransferRemote(WorkerTransfer.java:112) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.daemon.worker.WorkerState.tryTransferRemote(WorkerState.java:526) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.ExecutorTransfer.tryTransfer(ExecutorTransfer.java:71) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.daemon.Task.sendUnanchored(Task.java:196) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutOutputCollectorImpl.sendSpoutMsg(SpoutOutputCollectorImpl.java:164) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutOutputCollectorImpl.emit(SpoutOutputCollectorImpl.java:75) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:51) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.loadgen.LoadSpout.fail(LoadSpout.java:135) ~[stormjar.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor.failSpoutMsg(SpoutExecutor.java:362) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$1.expire(SpoutExecutor.java:126) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$1.expire(SpoutExecutor.java:119) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.RotatingMap.rotate(RotatingMap.java:77) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor.tupleActionFn(SpoutExecutor.java:298) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.Executor.accept(Executor.java:284) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:309) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:290) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:281) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:173) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:163) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.Utils$2.run(Utils.java:352) ~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
... 1 more | |
2018-02-23 15:13:29.950 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.950 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.950 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.951 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.951 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.951 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.952 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.952 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.952 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.953 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.954 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.954 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.955 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.955 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.955 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.956 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.956 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.956 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.957 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.957 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.957 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.958 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.958 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.958 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.959 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.959 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.960 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.960 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.961 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.961 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.962 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.962 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.962 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.963 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.963 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.963 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.964 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.964 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.964 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.965 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.966 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.966 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.966 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.967 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.967 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.967 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.968 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.968 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.969 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.969 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.969 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.970 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.971 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.971 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.971 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.972 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.972 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.972 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.973 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.973 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.973 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.974 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.974 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.974 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.975 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.976 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.976 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.976 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.977 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.977 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.978 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.978 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.979 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.979 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.979 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.980 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.980 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.980 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.981 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.981 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.981 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.982 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.982 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.982 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.983 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.983 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.984 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.985 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.985 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.985 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.986 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.986 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.986 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.986 o.a.s.u.Utils Thread-15-spout-executor[7, 7] [ERROR] Halting process: Worker died | |
java.lang.RuntimeException: Halting process: Worker died | |
at org.apache.storm.utils.Utils.exitProcess(Utils.java:467) [storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.utils.Utils$4.run(Utils.java:735) [storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:46) [storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT] | |
at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) [?:1.8.0_131] | |
2018-02-23 15:13:29.987 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.987 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.987 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.988 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.988 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.988 o.a.s.u.Utils Thread-22 [INFO] Halting after 1 seconds | |
2018-02-23 15:13:29.988 o.a.s.d.w.Worker Thread-21 [INFO] Shutting down worker wc-test-6-1519398552 62110d74-7b86-486d-9a1e-1fa16bc98286-10.88.213.187 6701 | |
2018-02-23 15:13:29.988 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.989 o.a.s.m.n.Client Thread-21 [INFO] closing Netty Client Netty-Client-tartsmart.corp.ne1.yahoo.com/10.88.213.187:6700 | |
2018-02-23 15:13:29.989 o.a.s.m.n.Client Thread-21 [INFO] waiting up to 600000 ms to send 0 pending messages to Netty-Client-tartsmart.corp.ne1.yahoo.com/10.88.213.187:6700 | |
2018-02-23 15:13:29.989 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.990 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.990 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.991 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.991 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.992 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.992 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.992 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.993 o.a.s.d.w.Worker Thread-21 [INFO] Terminating messaging context | |
2018-02-23 15:13:29.993 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.993 o.a.s.d.w.Worker Thread-21 [INFO] Shutting down executors | |
2018-02-23 15:13:29.993 o.a.s.e.ExecutorShutdown Thread-21 [INFO] Shutting down executor __system:[-1, -1] | |
2018-02-23 15:13:29.993 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.993 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.993 o.a.s.u.Utils Thread-14-__system-executor[-1, -1] [INFO] Async loop interrupted! | |
2018-02-23 15:13:29.994 o.a.s.e.ExecutorShutdown Thread-21 [INFO] Shut down executor __system:[-1, -1] | |
2018-02-23 15:13:29.994 o.a.s.e.ExecutorShutdown Thread-21 [INFO] Shutting down executor spout:[7, 7] | |
2018-02-23 15:13:29.994 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.994 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.994 o.a.s.e.ExecutorTransfer Thread-16-split-executor[6, 6] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:6, stream: __ack_ack, id: {}, [6754912660392047236, -1052985309986082973] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.995 o.a.s.e.ExecutorTransfer Thread-18-count-executor[4, 4] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: count:4, stream: __ack_ack, id: {}, [2310107945134690800, 693092163481200782] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] | |
2018-02-23 15:13:29.995 o.a.s.e.ExecutorTransfer Thread-17-split-executor[5, 5] [INFO] TRANSFERRING tuple [dest: 1 tuple: source: split:5, stream: __ack_ack, id: {}, [-3725514935921330412, -8537976200607907661] PROC_START_TIME(sampled): null EXEC_START_TIME(sampled): null] |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment