You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had searched in the issues and found no similar issues.
Java Version
1.78
Scala Version
2.11.x
StreamPark Version
2.1.4
Flink Version
1.13.5
deploy mode
yarn-session
What happened
Caused by: java.lang.LinkageError: loader constraint violation: when resolving interface method "org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer.committedOffsets(Lorg/apache/kafka/clients/consumer/OffsetResetStrategy;)Lorg/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer;" the class loader (instance of org/apache/flink/util/ChildFirstClassLoader) of the current class, com/yzc/bigdata/flink/monitor/task/CompanyBehaviorCountTask, and the class loader (instance of org/apache/streampark/flink/proxy/ChildFirstClassLoader) for the method's defining class, org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer, have different Class objects for the type org/apache/kafka/clients/consumer/OffsetResetStrategy used in the signature
Error Exception
Caused by: java.lang.LinkageError: loader constraint violation: when resolving interface method "org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer.committedOffsets(Lorg/apache/kafka/clients/consumer/OffsetResetStrategy;)Lorg/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer;" the class loader (instance of org/apache/flink/util/ChildFirstClassLoader) of the current class, com/yzc/bigdata/flink/monitor/task/CompanyBehaviorCountTask, and the class loader (instance of org/apache/streampark/flink/proxy/ChildFirstClassLoader) for the method's defining class, org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer, have different Class objects for the type org/apache/kafka/clients/consumer/OffsetResetStrategy used in the signature
Search before asking
Java Version
1.78
Scala Version
2.11.x
StreamPark Version
2.1.4
Flink Version
1.13.5
deploy mode
yarn-session
What happened
Caused by: java.lang.LinkageError: loader constraint violation: when resolving interface method "org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer.committedOffsets(Lorg/apache/kafka/clients/consumer/OffsetResetStrategy;)Lorg/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer;" the class loader (instance of org/apache/flink/util/ChildFirstClassLoader) of the current class, com/yzc/bigdata/flink/monitor/task/CompanyBehaviorCountTask, and the class loader (instance of org/apache/streampark/flink/proxy/ChildFirstClassLoader) for the method's defining class, org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer, have different Class objects for the type org/apache/kafka/clients/consumer/OffsetResetStrategy used in the signature
Error Exception
Screenshots
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: