Page MenuHomePhabricator

Upgrade eventutiltilies-flink Java lib to Flink 1.17
Closed, ResolvedPublic

Description

In T335408 we upgraded our Flink image as well as our eventutilities-python code and tests to use Flink 1.17.

We should do the same for our underlying Java library.

Ideally this would be as simple as bumping flink.version in pom.xml, but it seem there is at least one incompatibility:

Compilation failure:
[ERROR] /srv/home/otto/event-utilities/eventutilities-flink/src/test/java/org/wikimedia/eventutilities/flink/TestEventRowSerializer.java:[154,48] method writeSerializerSnapshot in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil cannot be applied to given types;
[ERROR]   required: org.apache.flink.core.memory.DataOutputView,org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>
[ERROR]   found: org.apache.flink.core.memory.DataOutputView,org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<E>,org.apache.flink.api.common.typeutils.TypeSerializer<E>
[ERROR]   reason: cannot infer type-variable(s) T
[ERROR]     (actual and formal argument lists differ in length)
[ERROR] /srv/home/otto/event-utilities/eventutilities-flink/src/test/java/org/wikimedia/eventutilities/flink/TestEventRowSerializer.java:[156,55] method readSerializerSnapshot in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil cannot be applied to given types;
[ERROR]   required: org.apache.flink.core.memory.DataInputView,java.lang.ClassLoader
[ERROR]   found: org.apache.flink.core.memory.DataInputView,java.lang.ClassLoader,<nulltype>
[ERROR]   reason: cannot infer type-variable(s) T
[ERROR]     (actual and formal argument lists differ in length)