storm-user mailing list archives

Hi Bijoy,

  Please find the declareOutputFields() & nextTuple() method of my spout.

public void declareOutputFields(OutputFieldsDeclarer declarer) {
            declarer.declare(new Fields("EventData","EventType"));
      }

public void nextTuple() {

            try {

                  //Some code here...
                  _collector.emit(new Values(eventData,eventType));


            } catch (IOException e) {
                  e.printStackTrace();
            }
      }

Regards
Bishnu

From: bijoy deb [mailto:bijoy.computers@gmail.com]
Sent: 05 February 2014 21:01
To: user@storm.incubator.apache.org
Subject: Re: STORM: Getting error "non-existent fields while submitting the topology"

Hi,

Can you show your declareOutputFields() method from the Spout; I think are you might not have
declared the output fields (in your case EventData and EventType) correctly over there.

Thanks
Bijoy

On Wed, Feb 5, 2014 at 5:26 PM, Bishnu Patro <Bishnu_Patro@symantec.com<mailto:Bishnu_Patro@symantec.com>>
wrote:
Hi,

   I am getting the following error when I submit the topology to storm:

556  [main] WARN  backtype.storm.StormSubmitter - Topology submission exception
backtype.storm.generated.InvalidTopologyException: null
                at backtype.storm.generated.Nimbus$submitTopology_result.read(Nimbus.java:2449)
~[storm-core-0.9.0-rc2.jar:na]

557  [main] ERROR com.symantec.dcsc.so.platform.ep.storm.services.topologyconfiguration.TopologyConfiguration
- InvalidTopologyException(msg:Component: [VMBolt1] subscribes from stream: [default] of component
[VMSpout1] with non-existent fields: #{"EventData,EventType"})
InvalidTopologyException(msg:Component: [VMBolt1] subscribes from stream: [default] of component
[VMSpout1] with non-existent fields: #{"EventData,EventType"})
                at backtype.storm.generated.Nimbus$submitTopology_result.read(Nimbus.java:2449)

Here, EventData is a custom type derived from java.io.Serializable class
And EventType is a string field.

When I just pass the EventType from my spout(VMSpout1) to bolt (VMBolt1), it works fine.

But, when I the pass the "EventData" custom type & "EventType" String type, from my spout(VMSpout1)
to bolt(VMBolt1) then I get the above error while submitting the topology.

Can someone please help what this error all about and how to resolve it?

Thanks & Regards
Bishnu