Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
1.x
-
None
Description
If you look at below code allFields variable is HashSet. To which we have added the o/p of kafkaSpoutStream.getOutputFields().toList(). That sort data on hash basis rather than keeping same sequence.
@Override public Fields getOutputFields() { final Set<String> allFields = new HashSet<>(); for (KafkaSpoutStream kafkaSpoutStream : topicToStream.values()) { allFields.addAll(kafkaSpoutStream.getOutputFields().toList()); } return new Fields(new ArrayList<>(allFields)); }
Changes needed is below
final Set<String> allFields = new LinkedHashSet<>();
Attachments
Issue Links
- links to