In the process of upgrading a few jobs to Flink 1.19.1 (from 1.18.1) and noticed that the

env.fromCollection()

function had been deprecated in favor of using

env.fromData()

in quite a few tests, however after making this change, I’m noticing some exceptions being thrown when it’s called such as the following:

java.lang.VerifyError: JVMVRFY007 final method overridden; class=org/apache/flink/streaming/api/transformations/UnionTransformation, method=getTransitivePredecessors()Ljava/util/List;

The class itself is just a simple POJO (or list of POJO objects) and had previously worked without issue similar to the example below within a job graph test:

val tenants = buildSampleTenants() 
val sampleTenants = env.fromData(tenants).uid("tenants")

whereas:

val sampleTenants = env.fromCollection(tenants).uid("tenants")

would work without issue.