[FLINK-1662] NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: API / DataStream
• Assignee: Péter Szabó
• Reporter: Péter Szabó
• Created: 09/Mar/15 16:05
• Updated: 28/Feb/19 11:15
• Resolved: 01/Apr/15 08:35

Description

NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy.

Stack Trace:
17:02:56,332 ERROR org.apache.flink.streaming.api.collector.StreamOutput - Emit failed due to: org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value.
at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:118)
at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:30)
at org.apache.flink.streaming.api.streamrecord.StreamRecordSerializer.serialize(StreamRecordSerializer.java:92)
at org.apache.flink.streaming.api.streamrecord.StreamRecordSerializer.serialize(StreamRecordSerializer.java:29)
at org.apache.flink.runtime.plugable.SerializationDelegate.write(SerializationDelegate.java:51)
at org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer.addRecord(SpanningRecordSerializer.java:76)
at org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:86)
at org.apache.flink.streaming.api.collector.StreamOutput.collect(StreamOutput.java:65)
at org.apache.flink.streaming.api.collector.DirectedCollectorWrapper.collect(DirectedCollectorWrapper.java:95)
at org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer.emitWindow(StreamDiscretizer.java:142)
at org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer.triggerOnFakeElement(StreamDiscretizer.java:129)
at org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer.processRealElement(StreamDiscretizer.java:101)
at org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer.invoke(StreamDiscretizer.java:75)
at org.apache.flink.streaming.api.streamvertex.StreamVertex.invokeUserFunction(StreamVertex.java:85)
at org.apache.flink.streaming.api.streamvertex.OutputHandler.invokeUserFunction(OutputHandler.java:229)
at org.apache.flink.streaming.api.streamvertex.StreamVertex.invoke(StreamVertex.java:121)
at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
at java.lang.Thread.run(Thread.java:745)

Examples can be found in commit https://github.com/mbalassi/flink/commit/42c7889777a0a6d558d58feeb5acb3c06b6fb7df.