Support Questions
Find answers, ask questions, and share your expertise
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for
- Cloudera Community
- :
- Support
- :
- Support Questions
- :
- Re: Apache Storm WordCount Program Output
Options
- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Options
- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Apache Storm WordCount Program Output
Highlighted
Re: Apache Storm WordCount Program Output
Mentor
Created 01-15-2016 10:17 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Email to a Friend
- Report Inappropriate Content
can you also post the spout code? Take a look at the storm-starter example, specifically ExclamationTopology. You'll be able to view the results of anything you're printing out in supervisor logs at /var/log/storm. @Akshay Shingote
Highlighted
Re: Apache Storm WordCount Program Output
Explorer
Created 01-18-2016 06:59 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Email to a Friend
- Report Inappropriate Content
Following is my spout code which reads words
@Artem Ervitspublic class WordReader extends BaseRichSpout
{
private SpoutOutputCollector collector;
private FileReader fileReader;
private boolean completed = false;
public void ack(Object msgId) {
System.out.println("OK:"+msgId);
}
public void close() {}
public void fail(Object msgId) {
System.out.println("FAIL:"+msgId);
}
/**
* The only thing that the methods will do It is emit each
* file line
*/
public void nextTuple() {
/**
* The nextuple it is called forever, so if we have been readed the file
* we will wait and then return
*/
if(completed){
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
//Do nothing
}
return;
}
String str;
//Open the reader
BufferedReader reader = new BufferedReader(fileReader);
try{
//Read all lines
while((str = reader.readLine()) != null){
/**
* By each line emmit a new value with the line as a their
*/
this.collector.emit(new Values(str),str);
}
}catch(Exception e){
throw new RuntimeException("Error reading tuple",e);
}finally{
completed = true;
}
}
/**
* We will create the file and get the collector object
*/
public void open(Map conf, TopologyContext context,
SpoutOutputCollector collector) {
try {
this.fileReader = new FileReader(conf.get("wordsFile").toString());
} catch (FileNotFoundException e) {
throw new RuntimeException("Error reading file ["+conf.get("wordFile")+"]");
}
this.collector = collector;
}
/**
* Declare the output field "word"
*/
public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields("line"));
}
}
Re: Apache Storm WordCount Program Output
Explorer
Created 01-18-2016 07:16 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Email to a Friend
- Report Inappropriate Content
@Artem Ervits:As you said I went through the logs in /var/log/storm...In application-name -worker log file I found these following logs : Is these what I really get when I run WordCount Program ??
2016-01-15 14:58:33.691 b.s.d.task [INFO] Emitting: word-counter default [storm, {storm=1}]
2016-01-15 14:58:33.692 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-8348710384844471183=3588653195059424065}, [storm]
2016-01-15 14:58:33.692 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-8348710384844471183 6135008062829212202]
2016-01-15 14:58:33.692 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-8348710384844471183=3588653195059424065}, [storm] TASK: 3 DELTA:
2016-01-15 14:58:33.692 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {3873495111721387323=-1361110683980171437}, [test]
2016-01-15 14:58:33.693 b.s.d.task [INFO] Emitting: word-normalizer default [test]
2016-01-15 14:58:33.693 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {3873495111721387323=-8327152215513187828}, [test]
2016-01-15 14:58:33.693 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [3873495111721387323 7020089438728736095]
2016-01-15 14:58:33.693 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3873495111721387323 7020089438728736095]
2016-01-15 14:58:33.694 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: 2 TUPLE: source: word-reader:4, stream: default, id: {3873495111721387323=-1361110683980171437}, [test]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {3019472566015270743=-3346388363094288106}, [an]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-8348710384844471183 6135008062829212202]
2016-01-15 14:58:33.695 b.s.d.task [INFO] Emitting: word-reader __ack_init [3019472566015270743 -3346388363094288106 4]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-8348710384844471183=6135008062829212202}, [storm]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {3873495111721387323=-1361110683980171437}, [test] TASK: 3 DELTA:
2016-01-15 14:58:33.695 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3019472566015270743 -3346388363094288106 4]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {5606815396768900929=8856560436727666341}, [are]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-8348710384844471183=6135008062829212202}, [storm] TASK: 2 DELTA:
2016-01-15 14:58:33.695 b.s.d.task [INFO] Emitting: word-reader default [storm]
2016-01-15 14:58:33.695 b.s.d.task [INFO] Emitting: word-normalizer default [are]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {3873495111721387323=-8327152215513187828}, [test]
2016-01-15 14:58:33.695 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {3476732415982803994=-4357403442784978407}, [storm]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {5606815396768900929=-3403324947437350728}, [are]
2016-01-15 14:58:33.696 b.s.d.task [INFO] Emitting: word-reader __ack_init [3476732415982803994 -4357403442784978407 4]
2016-01-15 14:58:33.696 b.s.d.task [INFO] Emitting: word-counter default [test, {storm=1, test=1}]
2016-01-15 14:58:33.696 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [5606815396768900929 -6184525071543187939]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3476732415982803994 -4357403442784978407 4]
2016-01-15 14:58:33.696 b.s.d.task [INFO] Emitting: word-reader default [simple]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [5606815396768900929 -6184525071543187939]
2016-01-15 14:58:33.696 b.s.d.task [INFO] Emitting: word-counter __ack_ack [3873495111721387323 -8327152215513187828]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {5606815396768900929=8856560436727666341}, [are]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {3166738897773801792=-3002351572582086873}, [simple]
2016-01-15 14:58:33.696 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {5606815396768900929=8856560436727666341}, [are] TASK: 3 DELTA:
2016-01-15 14:58:33.697 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3873495111721387323 -8327152215513187828]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-6904995293562913739=-6165647448705023493}, [great]
2016-01-15 14:58:33.697 b.s.d.task [INFO] Emitting: word-reader __ack_init [3166738897773801792 -3002351572582086873 4]
2016-01-15 14:58:33.697 b.s.d.task [INFO] Emitting: word-normalizer default [great]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {3873495111721387323=-8327152215513187828}, [test]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3166738897773801792 -3002351572582086873 4]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-6904995293562913739=7594063588566046947}, [great]
2016-01-15 14:58:33.697 b.s.d.task [INFO] Emitting: word-reader default [application]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {3873495111721387323=-8327152215513187828}, [test] TASK: 2 DELTA:
2016-01-15 14:58:33.697 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-6904995293562913739 -4391941100209579752]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {-2644721620688610173=4258087949161768273}, [application]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-6904995293562913739 -4391941100209579752]
2016-01-15 14:58:33.697 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {5606815396768900929=-3403324947437350728}, [are]
2016-01-15 14:58:33.698 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-6904995293562913739=-6165647448705023493}, [great]
2016-01-15 14:58:33.698 b.s.d.task [INFO] Emitting: word-reader __ack_init [-2644721620688610173 4258087949161768273 4]
2016-01-15 14:58:33.698 b.s.d.task [INFO] Emitting: word-counter default [are, {storm=1, test=1, are=1}]
2016-01-15 14:58:33.698 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-6904995293562913739=-6165647448705023493}, [great] TASK: 3 DELTA:
2016-01-15 14:58:33.698 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-2644721620688610173 4258087949161768273 4]
2016-01-15 14:58:33.698 b.s.d.task [INFO] Emitting: word-counter __ack_ack [5606815396768900929 -3403324947437350728]
2016-01-15 14:58:33.698 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {836664335768127530=-122270000364872169}, [is]
2016-01-15 14:58:33.698 b.s.d.task [INFO] Emitting: word-reader default [but]
2016-01-15 14:58:33.698 b.s.d.task [INFO] Emitting: word-normalizer default [is]
2016-01-15 14:58:33.698 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [5606815396768900929 -3403324947437350728]
2016-01-15 14:58:33.699 b.s.d.executor [INFO] Preparing bolt __acker:(1)
2016-01-15 14:58:33.699 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {836664335768127530=-4084171163148490794}, [is]
2016-01-15 14:58:33.699 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {5606815396768900929=-3403324947437350728}, [are]
2016-01-15 14:58:33.699 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [836664335768127530 4116157990635272641]
2016-01-15 14:58:33.700 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {5606815396768900929=-3403324947437350728}, [are] TASK: 2 DELTA:
2016-01-15 14:58:33.700 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [836664335768127530 4116157990635272641]
2016-01-15 14:58:33.700 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-6904995293562913739=7594063588566046947}, [great]
2016-01-15 14:58:33.700 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {836664335768127530=-122270000364872169}, [is]
2016-01-15 14:58:33.700 b.s.d.task [INFO] Emitting: word-counter default [great, {storm=1, test=1, are=1, great=1}]
2016-01-15 14:58:33.700 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {836664335768127530=-122270000364872169}, [is] TASK: 3 DELTA:
2016-01-15 14:58:33.700 b.s.d.executor [INFO] Prepared bolt __acker:(1)
2016-01-15 14:58:33.700 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-6904995293562913739 7594063588566046947]
2016-01-15 14:58:33.700 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {3019472566015270743=-3346388363094288106}, [an]
2016-01-15 14:58:33.701 b.s.d.task [INFO] Emitting: word-normalizer default [an]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-6904995293562913739 7594063588566046947]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-8348710384844471183 3588653195059424065 4]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {3019472566015270743=3194708398529701619}, [an]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-6904995293562913739=7594063588566046947}, [great]
2016-01-15 14:58:33.701 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [3019472566015270743 -154565087412977691]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-8348710384844471183 3588653195059424065 4]
2016-01-15 14:58:33.701 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-6904995293562913739=7594063588566046947}, [great] TASK: 2 DELTA:
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [-8348710384844471183 3588653195059424065 4] TASK: 1 DELTA:
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {836664335768127530=-4084171163148490794}, [is]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3019472566015270743 -154565087412977691]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {3019472566015270743=-3346388363094288106}, [an]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3873495111721387323 -1361110683980171437 4]
2016-01-15 14:58:33.702 b.s.d.task [INFO] Emitting: word-counter default [is, {storm=1, test=1, are=1, is=1, great=1}]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {3019472566015270743=-3346388363094288106}, [an] TASK: 3 DELTA:
2016-01-15 14:58:33.702 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3873495111721387323 -1361110683980171437 4]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {3476732415982803994=-4357403442784978407}, [storm]
2016-01-15 14:58:33.702 b.s.d.task [INFO] Emitting: word-counter __ack_ack [836664335768127530 -4084171163148490794]
2016-01-15 14:58:33.702 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [3873495111721387323 -1361110683980171437 4] TASK: 1 DELTA: 0
2016-01-15 14:58:33.702 b.s.d.task [INFO] Emitting: word-normalizer default [storm]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [836664335768127530 -4084171163148490794]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {3476732415982803994=3140219300272482684}, [storm]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {836664335768127530=-4084171163148490794}, [is]
2016-01-15 14:58:33.703 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [3476732415982803994 -1723989740179582107]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {836664335768127530=-4084171163148490794}, [is] TASK: 2 DELTA:
2016-01-15 14:58:33.703 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3476732415982803994 -1723989740179582107]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {3019472566015270743=3194708398529701619}, [an]
2016-01-15 14:58:33.703 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {3476732415982803994=-4357403442784978407}, [storm]
2016-01-15 14:58:33.704 b.s.d.task [INFO] Emitting: word-counter default [an, {storm=1, test=1, are=1, is=1, great=1, an=1}]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {3476732415982803994=-4357403442784978407}, [storm] TASK: 3 DELTA:
2016-01-15 14:58:33.704 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [5606815396768900929 8856560436727666341 4]
2016-01-15 14:58:33.704 b.s.d.task [INFO] Emitting: word-counter __ack_ack [3019472566015270743 3194708398529701619]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {3166738897773801792=-3002351572582086873}, [simple]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [5606815396768900929 8856560436727666341 4]
2016-01-15 14:58:33.704 b.s.d.task [INFO] Emitting: word-normalizer default [simple]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3019472566015270743 3194708398529701619]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [5606815396768900929 8856560436727666341 4] TASK: 1 DELTA:
2016-01-15 14:58:33.704 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {3166738897773801792=-6459367511201737622}, [simple]
2016-01-15 14:58:33.704 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {3019472566015270743=3194708398529701619}, [an]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-6904995293562913739 -6165647448705023493 4]
2016-01-15 14:58:33.705 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [3166738897773801792 8074450959888536397]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {3019472566015270743=3194708398529701619}, [an] TASK: 2 DELTA:
2016-01-15 14:58:33.705 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-6904995293562913739 -6165647448705023493 4]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {-3755836399149826733=6156608899632535318}, [but]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3166738897773801792 8074450959888536397]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {3476732415982803994=3140219300272482684}, [storm]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [-6904995293562913739 -6165647448705023493 4] TASK: 1 DELTA:
2016-01-15 14:58:33.705 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {3166738897773801792=-3002351572582086873}, [simple]
2016-01-15 14:58:33.705 b.s.d.task [INFO] Emitting: word-reader __ack_init [-3755836399149826733 6156608899632535318 4]
2016-01-15 14:58:33.705 b.s.d.task [INFO] Emitting: word-counter default [storm, {storm=2, test=1, are=1, is=1, great=1, an=1}]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [836664335768127530 -122270000364872169 4]
2016-01-15 14:58:33.705 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {3166738897773801792=-3002351572582086873}, [simple] TASK: 3 DELTA:
2016-01-15 14:58:33.706 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-3755836399149826733 6156608899632535318 4]
2016-01-15 14:58:33.706 b.s.d.task [INFO] Emitting: word-counter __ack_ack [3476732415982803994 3140219300272482684]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-2644721620688610173=4258087949161768273}, [application]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [836664335768127530 -122270000364872169 4]
2016-01-15 14:58:33.706 b.s.d.task [INFO] Emitting: word-reader default [very]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3476732415982803994 3140219300272482684]
2016-01-15 14:58:33.706 b.s.d.task [INFO] Emitting: word-normalizer default [application]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [836664335768127530 -122270000364872169 4] TASK: 1 DELTA:
2016-01-15 14:58:33.706 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {2247170131491427289=1249513627528559881}, [very]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {3476732415982803994=3140219300272482684}, [storm]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-2644721620688610173=3772187515776150658}, [application]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-8348710384844471183 7272917871821445483]
2016-01-15 14:58:33.706 b.s.d.task [INFO] Emitting: word-reader __ack_init [2247170131491427289 1249513627528559881 4]
2016-01-15 14:58:33.706 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {3476732415982803994=3140219300272482684}, [storm] TASK: 2 DELTA:
2016-01-15 14:58:33.707 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-2644721620688610173 1102894699295312339]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {3166738897773801792=-6459367511201737622}, [simple]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [2247170131491427289 1249513627528559881 4]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-8348710384844471183 7272917871821445483]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-2644721620688610173 1102894699295312339]
2016-01-15 14:58:33.707 b.s.d.task [INFO] Emitting: word-counter default [simple, {storm=2, test=1, are=1, is=1, simple=1, great=1, an=1}]
2016-01-15 14:58:33.707 b.s.d.task [INFO] Emitting: word-reader default [powerfull]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [-8348710384844471183 7272917871821445483] TASK: 1 DELTA:
2016-01-15 14:58:33.707 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-2644721620688610173=4258087949161768273}, [application]
2016-01-15 14:58:33.707 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {3622331100494670904=3562472101861227696}, [powerfull]
2016-01-15 14:58:33.707 b.s.d.task [INFO] Emitting: word-counter __ack_ack [3166738897773801792 -6459367511201737622]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-2644721620688610173=4258087949161768273}, [application] TASK: 3 DELTA:
2016-01-15 14:58:33.708 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3873495111721387323 7020089438728736095]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] Preparing bolt __system:(-1)
2016-01-15 14:58:33.708 b.s.d.task [INFO] Emitting: word-reader __ack_init [3622331100494670904 3562472101861227696 4]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3166738897773801792 -6459367511201737622]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-3755836399149826733=6156608899632535318}, [but]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3622331100494670904 3562472101861227696 4]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {3166738897773801792=-6459367511201737622}, [simple]
2016-01-15 14:58:33.708 b.s.d.task [INFO] Emitting: word-normalizer default [but]
2016-01-15 14:58:33.708 b.s.d.task [INFO] Emitting: word-reader default [really]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {3166738897773801792=-6459367511201737622}, [simple] TASK: 2 DELTA: 1
2016-01-15 14:58:33.708 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-3755836399149826733=-2036947486990360801}, [but]
2016-01-15 14:58:33.708 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {5598820146121914901=-1392318991271218769}, [really]
2016-01-15 14:58:33.708 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-3755836399149826733 -5274871706802223095]
2016-01-15 14:58:33.709 b.s.d.task [INFO] Emitting: word-reader __ack_init [5598820146121914901 -1392318991271218769 4]
2016-01-15 14:58:33.709 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-3755836399149826733 -5274871706802223095]
2016-01-15 14:58:33.709 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [5598820146121914901 -1392318991271218769 4]
2016-01-15 14:58:33.711 b.s.d.executor [INFO] Prepared bolt __system:(-1)
2016-01-15 14:58:33.711 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: 0 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3873495111721387323 7020089438728736095]
2016-01-15 14:58:33.711 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-3755836399149826733=6156608899632535318}, [but]
2016-01-15 14:58:33.711 b.s.d.task [INFO] Emitting: word-reader default [StOrm]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-3755836399149826733=6156608899632535318}, [but] TASK: 3 DELTA:
2016-01-15 14:58:33.712 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-2644721620688610173=3772187515776150658}, [application]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {-5311889501273724839=-6424980270203679450}, [StOrm]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [3873495111721387323 7020089438728736095] TASK: 1 DELTA:
2016-01-15 14:58:33.712 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {2247170131491427289=1249513627528559881}, [very]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting: word-counter default [application, {storm=2, test=1, application=1, are=1, is=1, simple=1, great=1, an=1}]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting: word-normalizer default [very]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-8348710384844471183 6135008062829212202]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting: word-reader __ack_init [-5311889501273724839 -6424980270203679450 4]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-2644721620688610173 3772187515776150658]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {2247170131491427289=-4790799406211271617}, [very]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [2247170131491427289 -5993020805103580874]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-5311889501273724839 -6424980270203679450 4]
2016-01-15 14:58:33.712 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [-8348710384844471183]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-2644721620688610173 3772187515776150658]
2016-01-15 14:58:33.712 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [2247170131491427289 -5993020805103580874]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-2644721620688610173=3772187515776150658}, [application]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {2247170131491427289=1249513627528559881}, [very]
2016-01-15 14:58:33.713 b.s.d.task [INFO] Emitting: word-reader default [is]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] TRANSFERING tuple TASK: 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [-8348710384844471183]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {2247170131491427289=1249513627528559881}, [very] TASK: 3 DELTA:
2016-01-15 14:58:33.713 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-2644721620688610173=3772187515776150658}, [application] TASK: 2 DELTA:
2016-01-15 14:58:33.713 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-8348710384844471183 6135008062829212202]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {3622331100494670904=3562472101861227696}, [powerfull]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {-4210604260192247499=2039164882510202710}, [is]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-3755836399149826733=-2036947486990360801}, [but]
2016-01-15 14:58:33.713 b.s.d.task [INFO] Emitting: word-normalizer default [powerfull]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] Execute done TUPLE source: word-counter:2, stream: __ack_ack, id: {}, [-8348710384844471183 6135008062829212202] TASK: 1 DELTA:
2016-01-15 14:58:33.713 b.s.d.task [INFO] Emitting: word-counter default [but, {but=1, storm=2, test=1, application=1, are=1, is=1, simple=1, great=1, an=1}]
2016-01-15 14:58:33.713 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {3622331100494670904=282012851938122965}, [powerfull]
2016-01-15 14:58:33.714 b.s.d.task [INFO] Emitting: word-reader __ack_init [-4210604260192247499 2039164882510202710 4]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3019472566015270743 -3346388363094288106 4]
2016-01-15 14:58:33.714 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [3622331100494670904 3646113262202822757]
2016-01-15 14:58:33.714 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-3755836399149826733 -2036947486990360801]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3019472566015270743 -3346388363094288106 4]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3622331100494670904 3646113262202822757]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-3755836399149826733 -2036947486990360801]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {3622331100494670904=3562472101861227696}, [powerfull]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [3019472566015270743 -3346388363094288106 4] TASK: 1 DELTA:
2016-01-15 14:58:33.714 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-4210604260192247499 2039164882510202710 4]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {3622331100494670904=3562472101861227696}, [powerfull] TASK: 3 DELTA:
2016-01-15 14:58:33.714 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3476732415982803994 -4357403442784978407 4]
2016-01-15 14:58:33.714 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-3755836399149826733=-2036947486990360801}, [but]
2016-01-15 14:58:33.714 b.s.d.task [INFO] Emitting: word-reader default [great]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {5598820146121914901=-1392318991271218769}, [really]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3476732415982803994 -4357403442784978407 4]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] TRANSFERING tuple TASK: 3 TUPLE: source: word-reader:4, stream: default, id: {-4568501325903703450=4968173464740562826}, [great]
2016-01-15 14:58:33.715 b.s.d.task [INFO] Emitting: word-normalizer default [really]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [3476732415982803994 -4357403442784978407 4] TASK: 1 DELTA:
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [5606815396768900929 -6184525071543187939]
2016-01-15 14:58:33.715 b.s.d.task [INFO] Emitting: word-reader __ack_init [-4568501325903703450 4968173464740562826 4]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [5606815396768900929 -6184525071543187939]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-4568501325903703450 4968173464740562826 4]
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [5606815396768900929 -6184525071543187939] TASK: 1 DELTA:
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3873495111721387323 -8327152215513187828]
2016-01-15 14:58:33.716 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [3873495111721387323]
2016-01-15 14:58:33.716 b.s.d.executor [INFO] Processing received message FOR 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [-8348710384844471183]
2016-01-15 14:58:33.716 b.s.d.executor [INFO] TRANSFERING tuple TASK: 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [3873495111721387323]
2016-01-15 14:58:33.716 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3873495111721387323 -8327152215513187828]
2016-01-15 14:58:33.716 b.s.d.executor [INFO] SPOUT Acking message -8348710384844471183 storm
2016-01-15 14:58:33.716 b.s.d.executor [INFO] Execute done TUPLE source: word-counter:2, stream: __ack_ack, id: {}, [3873495111721387323 -8327152215513187828] TASK: 1 DELTA:
2016-01-15 14:58:33.716 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3166738897773801792 -3002351572582086873 4]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [3166738897773801792 -3002351572582086873 4]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [3166738897773801792 -3002351572582086873 4] TASK: 1 DELTA:
2016-01-15 14:58:33.715 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-3755836399149826733=-2036947486990360801}, [but] TASK: 2 DELTA:
2016-01-15 14:58:33.715 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {5598820146121914901=2587997876945014387}, [really]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-6904995293562913739 -4391941100209579752]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {2247170131491427289=-4790799406211271617}, [very]
2016-01-15 14:58:33.717 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [5598820146121914901 -3510811982431617060]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-6904995293562913739 -4391941100209579752]
2016-01-15 14:58:33.717 STDIO [INFO] OK:storm
2016-01-15 14:58:33.717 b.s.d.task [INFO] Emitting: word-counter default [very, {but=1, very=1, storm=2, test=1, application=1, are=1, is=1, simple=1, great=1, an=1}]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [-6904995293562913739 -4391941100209579752] TASK: 1 DELTA:
2016-01-15 14:58:33.717 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [5598820146121914901 -3510811982431617060]
2016-01-15 14:58:33.717 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-2644721620688610173 4258087949161768273 4]
2016-01-15 14:58:33.717 b.s.d.task [INFO] Emitting: word-counter __ack_ack [2247170131491427289 -4790799406211271617]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {5598820146121914901=-1392318991271218769}, [really]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-reader:4, stream: __ack_init, id: {}, [-2644721620688610173 4258087949161768273 4]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [2247170131491427289 -4790799406211271617]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {5598820146121914901=-1392318991271218769}, [really] TASK: 3 DELTA:
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: __ack_init, id: {}, [-2644721620688610173 4258087949161768273 4] TASK: 1 DELTA:
2016-01-15 14:58:33.718 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {2247170131491427289=-4790799406211271617}, [very]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-5311889501273724839=-6424980270203679450}, [StOrm]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [5606815396768900929 -3403324947437350728]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {2247170131491427289=-4790799406211271617}, [very] TASK: 2 DELTA:
2016-01-15 14:58:33.718 b.s.d.task [INFO] Emitting: word-normalizer default [storm]
2016-01-15 14:58:33.718 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [5606815396768900929]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {3622331100494670904=282012851938122965}, [powerfull]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] TRANSFERING tuple TASK: 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [5606815396768900929]
2016-01-15 14:58:33.718 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-5311889501273724839=7333356645800650177}, [storm]
2016-01-15 14:58:33.718 b.s.d.task [INFO] Emitting: word-counter default [powerfull, {but=1, very=1, storm=2, test=1, application=1, are=1, is=1, simple=1, powerfull=1, great=1, an=1}]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [5606815396768900929 -3403324947437350728]
2016-01-15 14:58:33.719 b.s.d.task [INFO] Emitting: word-counter __ack_ack [3622331100494670904 282012851938122965]
2016-01-15 14:58:33.719 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-5311889501273724839 -4390812275327407897]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] Execute done TUPLE source: word-counter:2, stream: __ack_ack, id: {}, [5606815396768900929 -3403324947437350728] TASK: 1 DELTA:
2016-01-15 14:58:33.719 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3622331100494670904 282012851938122965]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-5311889501273724839 -4390812275327407897]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [836664335768127530 4116157990635272641]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-5311889501273724839=-6424980270203679450}, [StOrm]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {3622331100494670904=282012851938122965}, [powerfull]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [836664335768127530 4116157990635272641]
2016-01-15 14:58:33.719 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-5311889501273724839=-6424980270203679450}, [StOrm] TASK: 3 DELTA:
2016-01-15 14:58:33.719 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {3622331100494670904=282012851938122965}, [powerfull] TASK: 2 DELTA:
2016-01-15 14:58:33.719 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [836664335768127530 4116157990635272641] TASK: 1 DELTA:
2016-01-15 14:58:33.720 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-4210604260192247499=2039164882510202710}, [is]
2016-01-15 14:58:33.720 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {5598820146121914901=2587997876945014387}, [really]
2016-01-15 14:58:33.720 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-6904995293562913739 7594063588566046947]
2016-01-15 14:58:33.720 b.s.d.task [INFO] Emitting: word-normalizer default [is]
2016-01-15 14:58:33.720 b.s.d.task [INFO] Emitting: word-counter default [really, {but=1, very=1, storm=2, test=1, application=1, are=1, is=1, simple=1, powerfull=1, great=1, an=1, really=1}]
2016-01-15 14:58:33.720 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [-6904995293562913739]
2016-01-15 14:58:33.720 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-4210604260192247499=-9210764837221504154}, [is]
2016-01-15 14:58:33.720 b.s.d.executor [INFO] TRANSFERING tuple TASK: 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [-6904995293562913739]
2016-01-15 14:58:33.720 b.s.d.task [INFO] Emitting: word-counter __ack_ack [5598820146121914901 2587997876945014387]
2016-01-15 14:58:33.720 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-4210604260192247499 -7178637172869157840]
2016-01-15 14:58:33.720 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-6904995293562913739 7594063588566046947]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [5598820146121914901 2587997876945014387]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-4210604260192247499 -7178637172869157840]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Execute done TUPLE source: word-counter:2, stream: __ack_ack, id: {}, [-6904995293562913739 7594063588566046947] TASK: 1 DELTA:
2016-01-15 14:58:33.721 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {5598820146121914901=2587997876945014387}, [really]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3019472566015270743 -154565087412977691]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-4210604260192247499=2039164882510202710}, [is]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {5598820146121914901=2587997876945014387}, [really] TASK: 2 DELTA:
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-4210604260192247499=2039164882510202710}, [is] TASK: 3 DELTA:
2016-01-15 14:58:33.721 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3019472566015270743 -154565087412977691]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-5311889501273724839=7333356645800650177}, [storm]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Processing received message FOR 3 TUPLE: source: word-reader:4, stream: default, id: {-4568501325903703450=4968173464740562826}, [great]
2016-01-15 14:58:33.721 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [3019472566015270743 -154565087412977691] TASK: 1 DELTA:
2016-01-15 14:58:33.721 b.s.d.task [INFO] Emitting: word-counter default [storm, {but=1, very=1, storm=3, test=1, application=1, are=1, is=1, simple=1, powerfull=1, great=1, an=1, really=1}]
2016-01-15 14:58:33.722 b.s.d.task [INFO] Emitting: word-normalizer default [great]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [836664335768127530 -4084171163148490794]
2016-01-15 14:58:33.722 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-5311889501273724839 7333356645800650177]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] TRANSFERING tuple TASK: 2 TUPLE: source: word-normalizer:3, stream: default, id: {-4568501325903703450=6632671953480721225}, [great]
2016-01-15 14:58:33.722 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [836664335768127530]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-5311889501273724839 7333356645800650177]
2016-01-15 14:58:33.722 b.s.d.task [INFO] Emitting: word-normalizer __ack_ack [-4568501325903703450 1799614049722836163]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] TRANSFERING tuple TASK: 4 TUPLE: source: __acker:1, stream: __ack_ack, id: {}, [836664335768127530]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-5311889501273724839=7333356645800650177}, [storm]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-5311889501273724839=7333356645800650177}, [storm] TASK: 2 DELTA:
2016-01-15 14:58:33.722 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [-4568501325903703450 1799614049722836163]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [836664335768127530 -4084171163148490794]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-4210604260192247499=-9210764837221504154}, [is]
2016-01-15 14:58:33.722 b.s.d.executor [INFO] BOLT ack TASK: 3 TIME: TUPLE: source: word-reader:4, stream: default, id: {-4568501325903703450=4968173464740562826}, [great]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] Execute done TUPLE source: word-counter:2, stream: __ack_ack, id: {}, [836664335768127530 -4084171163148490794] TASK: 1 DELTA:
2016-01-15 14:58:33.723 b.s.d.task [INFO] Emitting: word-counter default [is, {but=1, very=1, storm=3, test=1, application=1, are=1, is=2, simple=1, powerfull=1, great=1, an=1, really=1}]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] Execute done TUPLE source: word-reader:4, stream: default, id: {-4568501325903703450=4968173464740562826}, [great] TASK: 3 DELTA:
2016-01-15 14:58:33.723 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3476732415982803994 -1723989740179582107]
2016-01-15 14:58:33.723 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-4210604260192247499 -9210764837221504154]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] TRANSFERING tuple TASK: 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [-4210604260192247499 -9210764837221504154]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] BOLT ack TASK: 1 TIME: TUPLE: source: word-normalizer:3, stream: __ack_ack, id: {}, [3476732415982803994 -1723989740179582107]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] BOLT ack TASK: 2 TIME: TUPLE: source: word-normalizer:3, stream: default, id: {-4210604260192247499=-9210764837221504154}, [is]
2016-01-15 14:58:33.723 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: __ack_ack, id: {}, [3476732415982803994 -1723989740179582107] TASK: 1 DELTA:
2016-01-15 14:58:33.723 b.s.d.executor [INFO] Execute done TUPLE source: word-normalizer:3, stream: default, id: {-4210604260192247499=-9210764837221504154}, [is] TASK: 2 DELTA:
2016-01-15 14:58:33.724 b.s.d.executor [INFO] Processing received message FOR 2 TUPLE: source: word-normalizer:3, stream: default, id: {-4568501325903703450=6632671953480721225}, [great]
2016-01-15 14:58:33.724 b.s.d.executor [INFO] Processing received message FOR 1 TUPLE: source: word-counter:2, stream: __ack_ack, id: {}, [3019472566015270743 3194708398529701619]
2016-01-15 14:58:33.724 b.s.d.task [INFO] Emitting: word-counter default [great, {but=1, very=1, storm=3, test=1, application=1, are=1, is=2, simple=1, powerfull=1, great=2, an=1, really=1}]
2016-01-15 14:58:33.724 b.s.d.task [INFO] Emitting: word-counter __ack_ack [-4568501325903703450 6632671953480721225]
2016-01-15 14:58:33.724 b.s.d.task [INFO] Emitting direct: 4; __acker __ack_ack [3019472566015270743]
Highlighted
Re: Apache Storm WordCount Program Output
Mentor
Created 01-18-2016 03:22 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Email to a Friend
- Report Inappropriate Content
yes, what were you expecting @Akshay Shingote? the words are being emitted as in this example
[great,{but=1, very=1, storm=3, test=1, application=1, are=1,is=2, simple=1, powerfull=1, great=2, an=1, really=1}]
Highlighted
Re: Apache Storm WordCount Program Output
Mentor
Created 02-02-2016 03:03 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Email to a Friend
- Report Inappropriate Content
@Akshay Shingote has this been resolved? Can you post your solution or accept best answer?
- « Previous
-
- 1
- 2
- Next »
Announcements
Product Announcements
Product Announcements
Product Announcements
Product Announcements
Product Announcements
