[STORM-2295] KafkaSpoutStreamsNamedTopics changing the sequence of fields name while emitting data

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.x
• Fix Version/s: 2.0.0, 1.1.0
• Component/s: storm-kafka-client
• Assignee: Sachin Pasalkar
• Reporter: Sachin Pasalkar
• Created: 16/Jan/17 13:56
• Updated: 19/Jan/17 07:19
• Resolved: 19/Jan/17 07:19

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<>();

Issue Links

• links to: GitHub Pull Request #1878