Please help.
After changing a spouts declaration from a single field output to two the
cluster seems to remember its old declaration of output. For example
declarer.declare(new Fields("userTask"));
To
declarer.declare(new Fields("tupleTrackingId","userTask"));
This spout has be serialized. Which is remembered also.
The error in the log states
Tuple created with wrong number of fields. Expected 1 fields but got 2
fields
But now it has the new declaration.
Questions
Is there a way to clear history of a storm cluster? Or clear the historically
generated serialized object?
Or if this another issue?
For sanity here is the spout output.
outputCollector.emit(new Values(msgID, task), msgID);
Thanks
http://stackoverflow.com/questions/31564143/apache-storm-remembering-old-number-of-output-fields-for-spout
<http://stackoverflow.com/questions/31564143/apache-storm-remembering-old-number-of-output-fields-for-spout>
