I'd start debugging your spout code.
On Sat, Jun 28, 2014 at 11:26 AM, Tomas Mazukna <[email protected]> wrote: > Storm topology, not trident > > http://screencast.com/t/YRyEDUqdPhg > > kafa spouts (home grown) are showing failed messages, but the bolts have > not failed any. > > I even turned off timeouts: > config.put("topology.enable.message.timeouts", false); > > but just can not figure out why spout "ora_mile" is not sending messages > to "assign_rowKey" bolt > > > OraMilestoneSpout oraMileSpout = new > OraMilestoneSpout(oraMilestoneTopic,"exchange-milestones-"+environment); > builder.setSpout(SPOUT_ORA_MILESTONE, oraMileSpout, > oraMilestoneSpoutThreads ); > > .. > AssignRowKeyBolt assignRowKeyBolt = new AssignRowKeyBolt(); > builder.setBolt( BOLT_ASSIGN_ROW_KEY, assignRowKeyBolt, > assignRowKeyThreads ) > .fieldsGrouping( BOLT_LOAD_ORA_CLAIM, > TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP)) > .fieldsGrouping( SPOUT_RAP_MILESTONE, > TopologyConstants.MILESTONES_STREAM, new > Fields(TopologyConstants.FIELD_GROUP)) > .fieldsGrouping( SPOUT_RAP_CLAIM, > TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP)) > .fieldsGrouping( SPOUT_ORA_MILESTONE, > TopologyConstants.MILESTONES_STREAM, new > Fields(TopologyConstants.FIELD_GROUP)) > .fieldsGrouping( BOLT_RAP_PROFILE, > TopologyConstants.PROFILES_STREAM, new > Fields(TopologyConstants.FIELD_GROUP)) > .fieldsGrouping( BOLT_CLE_CLAIM_PARSER, > TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP)); > > > Any pointers? > For some reason I only see this on production traffic. > > -- > Tomas Mazukna > 678-557-3834 > -- Ce n'est pas une signature
