fyi
The problem seems to be that samoa-api uses Kryo 2.17 and Flink 2.24.0. All
flink-related tests pass if I upgrade samoa to 2.24.0. You can also ask at the
samoa-incubating dev-list if that will be ok to change. Maybe it would be good
to test the same version on storm, samza and s4 respectiv
Hello,
I am currently working on the integration of Flink Streaming API to
SAMOA and I have some problems with an exception that I take from the kryo
serialiser:
Caused by: java.lang.ArrayIndexOutOfBoundsException
at java.lang.System.arraycopy(Native Method)
at org.apache.flink.core.memory.Memory
