Facing SequenceNumber被视为flink-connector-kinesis-4.1.0 jar的泛型类型异常

m1m5dgzv 于 2023-09-28 发布在 Apache

关注(0)|答案(1)|浏览(128)

我尝试使用flink-connector-kinesis-4.1.0 jar[https：//mvnrepository.com/artifact/org.apache.flink/flink-connector-kinesis/4.1.0-1.17]与flink 1.17集成kinesis流连接器，但我在flink作业启动时遇到以下异常。看起来下面的JIRA修复没有添加到最新的flink-connector-kinesis-4.1.0-1.17 jar中。我通过反编译jar来确认这一点
https://issues.apache.org/jira/browse/FLINK-24943
提交修复：https://github.com/apache/flink/pull/20257/commits/610c2420b09f7fd05039ccdb9d8a810bb5d7daf7
你能建议一下这里的替代方案吗？
异常日志

java.lang.UnsupportedOperationException: Generic types have been disabled in the ExecutionConfig and type org.apache.flink.streaming.connectors.kinesis.model.SequenceNumber is treated as a generic type.
    at org.apache.flink.api.java.typeutils.GenericTypeInfo.createSerializer(GenericTypeInfo.java:87)
    at org.apache.flink.api.java.typeutils.TupleTypeInfo.createSerializer(TupleTypeInfo.java:104)
    at org.apache.flink.api.java.typeutils.TupleTypeInfo.createSerializer(TupleTypeInfo.java:49)
    at org.apache.flink.api.java.typeutils.ListTypeInfo.createSerializer(ListTypeInfo.java:99)
    at org.apache.flink.api.common.state.StateDescriptor.initializeSerializerUnlessSet(StateDescriptor.java:311)

apache-flink

来源：https://stackoverflow.com/questions/77034893/facing-sequencenumber-is-treated-as-a-generic-type-exception-with-flink-connecto