Skip to content

Instantly share code, notes, and snippets.

@arrawatia

arrawatia/Trident trace

Created June 23, 2013 19:01
Show Gist options
  • Save arrawatia/5846116 to your computer and use it in GitHub Desktop.
Save arrawatia/5846116 to your computer and use it in GitHub Desktop.
Download ZIP
Trace of trident execution.
Raw
Trident trace
{transfer-Q|wordCounter-1-1372013468|259be866-478a-46c4-9479-9ab71b748e59|2198f4ae-89cf-48e9-9e1b-7b7db420de16|4}-created. Buffer size : 1024
transfer-Q
{executor-receive-Q|wordCounter-1-1372013468|[2 2]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[3 3]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[4 4]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[5 5]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[6 6]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[-1 -1]}-created. Buffer size : 1024
executor-receive-Q
{executor-receive-Q|wordCounter-1-1372013468|[1 1]}-created. Buffer size : 1024
executor-receive-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|$spoutcoord-spout0|[2 2]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|__acker|[3 3]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|b-0|[4 4]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|b-1|[5 5]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|spout0|[6 6]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:bolt|__system|[-1 -1]}-created. Buffer size : 1024
executor-send-Q
{executor-send-Q|wordCounter-1-1372013468|:spout|$mastercoord-bg0|[1 1]}-created. Buffer size : 1024
executor-send-Q
MasterBatchCoordinator| open | Managing spout : spout1
MasterBatchCoordinator| nextTuple -> sync | Emits to stream :$batch values :1:0
AckerBolt|got |stream: __ack_init Curr: {:spout-task 1, :val -3532742300011895965} id: -6114911911436832988 tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-6114911911436832988 -3532742300011895965 1] pending : [{-6114911911436832988={:spout-task 1, :val -3532742300011895965}}, {}]
AckerBolt|ack |tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-6114911911436832988 -3532742300011895965 1] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : spout0:0 gets tuple : source: $spoutcoord-spout0:2, stream: $batch, id: {-6114911911436832988=1140751370603784058}, [1:0, null] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@4678f83a[attemptId=0,info=storm.trident.topology.BatchInfo@cfefc0,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@538526aa[commitStream=<null>,expectedTaskReports=0,targetTasks=[5]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
InstrumentedFixedBatchSpout| emitBatch | msgId : 1
TridentBoltExecutor| finishBatch | Component : spout0:0 gets tuple : source: $spoutcoord-spout0:2, stream: $batch, id: {-6114911911436832988=1140751370603784058}, [1:0, null]
TridentBoltExecutor| finishBatch | Component : spout0:0 emits to stream : $coord-bg0 with values :[1:0, 3]
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val 1140751370603784058} id: -6114911911436832988 tuple: source: $spoutcoord-spout0:2, stream: __ack_ack, id: {}, [-6114911911436832988 -4526699491819289575] pending : [{-6114911911436832988={:spout-task 1, :val 1140751370603784058}}, {}]
AckerBolt|ack |tuple: source: $spoutcoord-spout0:2, stream: __ack_ack, id: {}, [-6114911911436832988 -4526699491819289575] collector: backtype.storm.task.OutputCollector@512d297a
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val -3219833911403585986} id: -6114911911436832988 tuple: source: spout0:6, stream: __ack_ack, id: {}, [-6114911911436832988 -2556890864854451900] pending : [{-6114911911436832988={:spout-task 1, :val -3219833911403585986}}, {}]
AckerBolt|ack |tuple: source: spout0:6, stream: __ack_ack, id: {}, [-6114911911436832988 -2556890864854451900] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: s1, id: {}, [1:0, the cow jumped over the moon] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@c265121[attemptId=0,info=storm.trident.topology.BatchInfo@279853c2,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: s1, id: {}, [1:0, the man went to the store and bought some candy] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@c265121[attemptId=0,info=storm.trident.topology.BatchInfo@279853c2,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=1,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: s1, id: {}, [1:0, four score and seven years ago] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@c265121[attemptId=0,info=storm.trident.topology.BatchInfo@279853c2,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=2,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: $coord-bg0, id: {-6114911911436832988=-3219833911403585986}, [1:0, 3] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@c265121[attemptId=0,info=storm.trident.topology.BatchInfo@279853c2,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=3,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| finishBatch | Component : b-1:0 gets tuple : source: spout0:6, stream: $coord-bg0, id: {-6114911911436832988=-3219833911403585986}, [1:0, 3]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, moon, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| finishBatch | Component : b-1:0 emits to stream : $coord-bg0 with values :[1:0, 18]
TridentBoltExecutor| finishBatch | Component : b-1:0 acks with tuple : source: spout0:6, stream: $coord-bg0, id: {-6114911911436832988=-3219833911403585986}, [1:0, 3]
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val -2930778817701111571} id: -6114911911436832988 tuple: source: b-1:5, stream: __ack_ack, id: {}, [-6114911911436832988 289094783495292627] pending : [{-6114911911436832988={:spout-task 1, :val -2930778817701111571}}, {}]
AckerBolt|ack |tuple: source: b-1:5, stream: __ack_ack, id: {}, [-6114911911436832988 289094783495292627] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, bought, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=1,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, the, 4] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=2,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, some, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=3,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, score, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=4,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, cow, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=5,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, went, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=6,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, and, 2] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=7,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, to, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=8,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, seven, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=9,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, over, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=10,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, store, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=11,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, years, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=12,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, jumped, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=13,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, candy, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=14,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, ago, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=15,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, four, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=16,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [1:0, man, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=17,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: $coord-bg0, id: {-6114911911436832988=-2930778817701111571}, [1:0, 18] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=18,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| checkFinish | Component : b-0:0 acks with tuple: source: b-1:5, stream: $coord-bg0, id: {-6114911911436832988=-2930778817701111571}, [1:0, 18]
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val 0} id: -6114911911436832988 tuple: source: b-0:4, stream: __ack_ack, id: {}, [-6114911911436832988 -2930778817701111571] pending : [{-6114911911436832988={:spout-task 1, :val 0}}, {}]
AckerBolt|emit |stream: __ack_ack Curr: {:spout-task 1, :val 0} id: -6114911911436832988 tuple: source: b-0:4, stream: __ack_ack, id: {}, [-6114911911436832988 -2930778817701111571] dest: 1
AckerBolt|ack |tuple: source: b-0:4, stream: __ack_ack, id: {}, [-6114911911436832988 -2930778817701111571] collector: backtype.storm.task.OutputCollector@512d297a
MasterBatchCoordinator| ack | gets msgId :1:0 -> sync | Emits to stream :$commit values :1:0
AckerBolt|got |stream: __ack_init Curr: {:spout-task 1, :val -5818152488494909400} id: -3459610308093322015 tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-3459610308093322015 -5818152488494909400 1] pending : [{-3459610308093322015={:spout-task 1, :val -5818152488494909400}}, {}]
AckerBolt|ack |tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-3459610308093322015 -5818152488494909400 1] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: $mastercoord-bg0:1, stream: $commit, id: {-3459610308093322015=-5818152488494909400}, [1:0] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@25fe6783[attemptId=0,info=storm.trident.topology.BatchInfo@613ddcf1,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=1,expectedTupleCount=18,receivedTuples=18,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| finishBatch | Component : b-0:0 gets tuple : source: $mastercoord-bg0:1, stream: $commit, id: {-3459610308093322015=-5818152488494909400}, [1:0]
InstrumentedMemoryMapState| multiUpdate | ... updating 18 [storm.trident.state.CombinerValueUpdater@1a6d3ca2, storm.trident.state.CombinerValueUpdater@79a7bd3b, storm.trident.state.CombinerValueUpdater@7378aae2, storm.trident.state.CombinerValueUpdater@771b16a7, storm.trident.state.CombinerValueUpdater@136c6b08, storm.trident.state.CombinerValueUpdater@32e6e42e, storm.trident.state.CombinerValueUpdater@548ea21d, storm.trident.state.CombinerValueUpdater@60354949, storm.trident.state.CombinerValueUpdater@4a5e88f7, storm.trident.state.CombinerValueUpdater@4723646, storm.trident.state.CombinerValueUpdater@66492ff1, storm.trident.state.CombinerValueUpdater@4eeaabad, storm.trident.state.CombinerValueUpdater@10ad1355, storm.trident.state.CombinerValueUpdater@52d03a00, storm.trident.state.CombinerValueUpdater@64900079, storm.trident.state.CombinerValueUpdater@2a0f3b83, storm.trident.state.CombinerValueUpdater@4e0c2b07, storm.trident.state.CombinerValueUpdater@dd0099]
TridentBoltExecutor| finishBatch | Component : b-0:0 acks with tuple : source: $mastercoord-bg0:1, stream: $commit, id: {-3459610308093322015=-5818152488494909400}, [1:0]
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val 0} id: -3459610308093322015 tuple: source: b-0:4, stream: __ack_ack, id: {}, [-3459610308093322015 -5818152488494909400] pending : [{-3459610308093322015={:spout-task 1, :val 0}}, {}]
AckerBolt|emit |stream: __ack_ack Curr: {:spout-task 1, :val 0} id: -3459610308093322015 tuple: source: b-0:4, stream: __ack_ack, id: {}, [-3459610308093322015 -5818152488494909400] dest: 1
AckerBolt|ack |tuple: source: b-0:4, stream: __ack_ack, id: {}, [-3459610308093322015 -5818152488494909400] collector: backtype.storm.task.OutputCollector@512d297a
MasterBatchCoordinator| ack | gets msgId :1:0 -> outputs to stream :$success1:0-> sync | Emits to stream :$batch values :2:0
InstrumentedFixedBatchSpout| ack | msgId :1
TridentBoltExecutor| execute | Component : spout0:0 acks with tuple: source: $mastercoord-bg0:1, stream: $success, id: {}, [1:0]
TridentBoltExecutor| execute | Component : spout0:0 gets tuple : source: $spoutcoord-spout0:2, stream: $batch, id: {-4305030286671151427=-3117400813516761170}, [2:0, null] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@4162b8ce[attemptId=0,info=storm.trident.topology.BatchInfo@3852fdeb,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@538526aa[commitStream=<null>,expectedTaskReports=0,targetTasks=[5]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
InstrumentedFixedBatchSpout| emitBatch | msgId : 2
TridentBoltExecutor| finishBatch | Component : spout0:0 gets tuple : source: $spoutcoord-spout0:2, stream: $batch, id: {-4305030286671151427=-3117400813516761170}, [2:0, null]
TridentBoltExecutor| finishBatch | Component : spout0:0 emits to stream : $coord-bg0 with values :[2:0, 2]
AckerBolt|got |stream: __ack_init Curr: {:spout-task 1, :val 8427739561181884963} id: -4305030286671151427 tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-4305030286671151427 8427739561181884963 1] pending : [{-4305030286671151427={:spout-task 1, :val 8427739561181884963}}, {}]
AckerBolt|ack |tuple: source: $mastercoord-bg0:1, stream: __ack_init, id: {}, [-4305030286671151427 8427739561181884963 1] collector: backtype.storm.task.OutputCollector@512d297a
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val -3117400813516761170} id: -4305030286671151427 tuple: source: $spoutcoord-spout0:2, stream: __ack_ack, id: {}, [-4305030286671151427 -6896809827908885107] pending : [{-4305030286671151427={:spout-task 1, :val -3117400813516761170}}, {}]
AckerBolt|ack |tuple: source: $spoutcoord-spout0:2, stream: __ack_ack, id: {}, [-4305030286671151427 -6896809827908885107] collector: backtype.storm.task.OutputCollector@512d297a
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val 5879748857938365638} id: -4305030286671151427 tuple: source: spout0:6, stream: __ack_ack, id: {}, [-4305030286671151427 -8852436305561445528] pending : [{-4305030286671151427={:spout-task 1, :val 5879748857938365638}}, {}]
AckerBolt|ack |tuple: source: spout0:6, stream: __ack_ack, id: {}, [-4305030286671151427 -8852436305561445528] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: s1, id: {}, [2:0, how many apples can you eat] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@382a7640[attemptId=0,info=storm.trident.topology.BatchInfo@6bb9808e,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: s1, id: {}, [2:0, to be or not to be the person] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@382a7640[attemptId=0,info=storm.trident.topology.BatchInfo@6bb9808e,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=1,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-1:0 gets tuple : source: spout0:6, stream: $coord-bg0, id: {-4305030286671151427=5879748857938365638}, [2:0, 2] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@382a7640[attemptId=0,info=storm.trident.topology.BatchInfo@6bb9808e,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@1a2f9dd[commitStream=<null>,expectedTaskReports=1,targetTasks=[4]],reportedTasks=0,expectedTupleCount=0,receivedTuples=2,taskEmittedTuples={},failed=false,receivedCommit=true,delayedAck=<null>]
TridentBoltExecutor| finishBatch | Component : b-1:0 gets tuple : source: spout0:6, stream: $coord-bg0, id: {-4305030286671151427=5879748857938365638}, [2:0, 2]
TridentBoltExecutor| finishBatch | Component : b-1:0 emits to stream : $coord-bg0 with values :[2:0, 12]
TridentBoltExecutor| finishBatch | Component : b-1:0 acks with tuple : source: spout0:6, stream: $coord-bg0, id: {-4305030286671151427=5879748857938365638}, [2:0, 2]
AckerBolt|got |stream: __ack_ack Curr: {:spout-task 1, :val -1476603651079422794} id: -4305030286671151427 tuple: source: b-1:5, stream: __ack_ack, id: {}, [-4305030286671151427 -5036400274517692304] pending : [{-4305030286671151427={:spout-task 1, :val -1476603651079422794}}, {}]
AckerBolt|ack |tuple: source: b-1:5, stream: __ack_ack, id: {}, [-4305030286671151427 -5036400274517692304] collector: backtype.storm.task.OutputCollector@512d297a
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, person, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=0,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, not, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=1,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, many, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=2,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, the, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=3,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, eat, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=4,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, can, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=5,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, you, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=6,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, apples, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=7,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, how, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=8,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, be, 2] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=9,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, or, 1] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=10,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: s4, id: {}, [2:0, to, 2] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=11,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| execute | Component : b-0:0 gets tuple : source: b-1:5, stream: $coord-bg0, id: {-4305030286671151427=-1476603651079422794}, [2:0, 12] TRACKED : storm.trident.topology.TridentBoltExecutor$TrackedBatch@434fb3e1[attemptId=0,info=storm.trident.topology.BatchInfo@25aa9b4d,condition=storm.trident.topology.TridentBoltExecutor$CoordCondition@24748417[commitStream=GlobalStreamId(componentId:$mastercoord-bg0, streamId:$commit),expectedTaskReports=1,targetTasks=[]],reportedTasks=0,expectedTupleCount=0,receivedTuples=12,taskEmittedTuples={},failed=false,receivedCommit=false,delayedAck=<null>]
TridentBoltExecutor| checkFinish | Component : b-0:0 acks with tuple: source: b-1:5, stream: $coord-bg0, id: {-4305030286671151427=-1476603651079422794}, [2:0, 12]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment