java - Strom must declare exactly one stream form last bolt in LinearDRPCTopology? -


i want data output kafka queue, write topology follow:

lineardrpctopologybuilder builder = new lineardrpctopologybuilder("xx"); builder.addbolt(new jdentryparsebolt(config), 2); builder.addbolt(new jdcrawlerbolt(config), 2).shufflegrouping(); builder.addbolt(new jdparsebolt(config), 2).shufflegrouping(); builder.addbolt(new kafkabolt<string, integer>(), 2).shufflegrouping();  config conf = new config(); map<string, string> map = new hashmap<>(); map.put("metadata.broker.list", "127.0.0.1:9092"); map.put("serializer.class", "kafka.serializer.stringencoder"); conf.put("topic", "jdquerycrawler"); conf.setmaxtaskparallelism(10);  localdrpc drpc = new localdrpc(); localcluster cluster = new localcluster(); cluster.submittopology("xx-drpc", conf, builder.createlocaltopology(drpc));

when submit topology, returns:

java.lang.runtimeexception: must declare 1 stream last bolt in lineardrpctopology             @ backtype.storm.drpc.lineardrpctopologybuilder.createtopology(lineardrpctopologybuilder.java:152) ~[storm-core-0.9.3.jar:0.9.3]             @ backtype.storm.drpc.lineardrpctopologybuilder.createlocaltopology(lineardrpctopologybuilder.java:87) ~[storm-core-0.9.3.jar:0.9.3]             @ com.ipin.jd.process.topology.testcrawlerdrpc.main(testcrawlerdrpc.java:58) ~[test-classes/:na]

what "exactly 1 stream last bolt in lineardrpc" mean? not add more 1 stream.


Comments

Post a Comment

Popular posts from this blog

javascript - AngularJS custom datepicker directive -

i make custom datepicker directive custom template. but have no idea how start building it... how include date data directive? i appreciate guide or give me advice work on more precisely. it might you! follow below steps html code sample: <label>birth date</label> <input type="text" ng-model="birthdate" date-options="dateoptions" custom-datepicker/> <hr/> <pre>birthdate = {{birthdate}}</pre> <script type="text/ng-template" id="custom-datepicker.html"> <div class="enhanced-datepicker"> <div class="proxied-field-wrap"> <input type="text" ui-date-format="yy-mm-dd" ng-model="ngmodel" ui-date="dateoptions"/> </div> <label> <button class="btn" type="button"><i class="icon-calendar"></i>
Read more

javascript - jQuery date picker - Disable dates after the selection from the first date picker -

<!doctype html> <html lang="en"> <head> <meta charset="utf-8"> <title>jquery ui datepicker - default functionality</title> <link rel="stylesheet" href="//code.jquery.com/ui/1.11.4/themes/smoothness/jquery-ui.css"> <script src="//code.jquery.com/jquery-1.10.2.js"></script> <script src="//code.jquery.com/ui/1.11.4/jquery-ui.js"></script> <link rel="stylesheet" href="/resources/demos/style.css"> <script> $(function () { $("#datepicker1").datepicker(); }); </script> <script> $(function () { $("#datepicker2").datepicker(); }); </script> </head> <body> <p>date 1: <input type="text" id="datepicker1"></p> <p>date 2: <input type="t
Read more