te and read method
> > accordingly and written serialization tests accordingly, inspired by
> > EventAggregatorsTest.java. The tests pass and everything runs well
> on
> > a local setup.
> >
> > Now, when ru
io.IOException: io.netty.handler.codec.DecoderException:
> java.lang.RuntimeException: Error while deserializing event.
> at
>
>
org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.checkError(RemoteInputChannel.java:264)
> at
>
>
org.apache.flink.runtime.io.network.par
AggregatorsTest.java. The tests pass and everything runs well on
> a local setup.
>
> Now, when run on a cluster, I encounter the following error:
>
> java.io.IOException: io.netty.handler.codec.DecoderException:
> java.la
on a cluster, I encounter the following error:
java.io.IOException: io.netty.handler.codec.DecoderException:
java.lang.RuntimeException: Error while deserializing event.
at
org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.checkError(RemoteInputChannel.java:264)
at
