[FLINK-3523] Storm SpoutSplitExample fails with a ClassCastException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: Legacy Components / Storm Compatibility
• Assignee: Matthias J. Sax
• Reporter: Stephan Ewen
• Created: 26/Feb/16 14:17
• Updated: 06/Apr/16 14:44
• Resolved: 06/Apr/16 14:44

Description

Caused by: java.lang.ClassCastException: org.apache.flink.storm.util.SplitStreamType cannot be cast to java.lang.Integer
	at org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
	at org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
	at org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
	at java.lang.Thread.run(Thread.java:745)