Apache Storm: Remembering old number of output fields for spout on cluster

[Stuart Perks <st...@hotmail.com>]

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>