flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy
Date Wed, 01 Apr 2015 08:35:53 GMT

     [ https://issues.apache.org/jira/browse/FLINK-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Gyula Fora resolved FLINK-1662.
-------------------------------
    Resolution: Fixed

1a3ae03baff7cc3a406e2e63e7d57b3f7c71ea26

> NullFieldException is thrown when testing IterativeDataStream with tuples, windowing
and maxBy
> ----------------------------------------------------------------------------------------------
>
>                 Key: FLINK-1662
>                 URL: https://issues.apache.org/jira/browse/FLINK-1662
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Péter Szabó
>            Assignee: Péter Szabó
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message