Aljoscha Krettek created FLINK-2009:
---------------------------------------
Summary: Time-Based Windows fail with Chaining Disabled
Key: FLINK-2009
URL:
https://issues.apache.org/jira/browse/FLINK-2009 Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Aljoscha Krettek
When disabling chaining a streaming job with a time-based window fails right away with this:
{code}
14:17:50,917 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.runtime.streamrecord.StreamRecordSerializer.serialize(StreamRecordSerializer.java:89)
at org.apache.flink.streaming.runtime.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:83)
at org.apache.flink.streaming.api.collector.StreamOutput.collect(StreamOutput.java:63)
at org.apache.flink.streaming.api.collector.CollectorWrapper.collect(CollectorWrapper.java:39)
at org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer.emitWindow(StreamDiscretizer.java:143)
at org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer.triggerOnFakeElement(StreamDiscretizer.java:131)
at org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer$WindowingCallback.sendFakeElement(StreamDiscretizer.java:194)
at org.apache.flink.streaming.api.windowing.policy.TimeTriggerPolicy.activeFakeElementEmission(TimeTriggerPolicy.java:121)
at org.apache.flink.streaming.api.windowing.policy.TimeTriggerPolicy$TimeCheck.run(TimeTriggerPolicy.java:148)
at java.lang.Thread.run(Thread.java:745)
{code}
I assume it is because the window events that get emitted for fake elements are not properly filled. This does not surface if chaining is enabled because then the window events don't pass through the serialisation stack.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
Locked
