[
https://issues.apache.org/jira/browse/FLINK-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2009:
---------------------------------------
Assignee: Aljoscha Krettek
> 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
> Assignee: 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)
