NullFieldException is thrown when testing IterativeDataStream with tuples and maxBy

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

NullFieldException is thrown when testing IterativeDataStream with tuples and maxBy

Szabó Péter
I'm running the following code and getting the RuntimeException "Emit
failed due to: org.apache.flink.types.NullFieldException: Field 0 is null,
but expected to hold a value."
https://dl.dropboxusercontent.com/u/64242132/TestExample.java

Does somebody know what causes it?
Another issue is that if the source does not sleep between emits, the
program freezes.

Peter
Reply | Threaded
Open this post in threaded view
|

Re: NullFieldException is thrown when testing IterativeDataStream with tuples and maxBy

Márton Balassi
Hey,

Seems like a weird interaction between output splitting and windowing.
Could you please open a JIRA ticket for it?

Thanks,

Marton


On Mon, Mar 9, 2015 at 10:22 AM, Szabó Péter <[hidden email]>
wrote:

> I'm running the following code and getting the RuntimeException "Emit
> failed due to: org.apache.flink.types.NullFieldException: Field 0 is null,
> but expected to hold a value."
> https://dl.dropboxusercontent.com/u/64242132/TestExample.java
>
> Does somebody know what causes it?
> Another issue is that if the source does not sleep between emits, the
> program freezes.
>
> Peter
>