You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by "SendDreams (via GitHub)" <gi...@apache.org> on 2026/01/20 08:17:19 UTC

[I] Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题 [flink-cdc]

SendDreams opened a new issue, #4229:
URL: https://github.com/apache/flink-cdc/issues/4229

   ### Please don't check the box below
   
   - [x] I'm aware that bugs and new features should be reported on [Apache Jira](https://issues.apache.org/jira)  or Flink mailing list (dev@flink.apache.org) instead of here
   
   ### Again, please don't check the box below
   
   - [x] I'm aware that new issues on GitHub will be ignored and automatically closed.
   
   ### 请不要勾选以下选项
   
   - [x] 我已知悉缺陷和新功能需要在 [Apache Jira](https://issues.apache.org/jira) 或 Flink 邮件列表(dev@flink.apache.org)中反馈,而不是在这里创建新 issue。
   
   ### 也请不要勾选以下选项
   
   - [x] 我已知悉 GitHub 上的新 issue 会被忽略且自动关闭。


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@flink.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题 [flink-cdc]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #4229:
URL: https://github.com/apache/flink-cdc/issues/4229#issuecomment-3775517689

   As required by Apache Flink, please report bugs or new features on Apache Jira under the project Flink using component tag Flink CDC. You must have a JIRA account in order to log cases and issues. If you don’t have an ASF JIRA account, you can request one at the ASF Self-serve portal, account creation requires review by the PMC member of the application project, which normally takes one to two working days to be approved.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题 [flink-cdc]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #4229: Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题
URL: https://github.com/apache/flink-cdc/issues/4229


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题 [flink-cdc]

Posted by "SendDreams (via GitHub)" <gi...@apache.org>.
SendDreams commented on issue #4229:
URL: https://github.com/apache/flink-cdc/issues/4229#issuecomment-3771602444

   我使用Flink CDC 3.5.0 + Flink 1.20.0 + java 8,将cdc任务提交到k8s集群中,然后taskmaanger报错:
   2026-01-20 15:58:04
   org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
   	at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:416)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:869)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:836)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:825)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732)
   	at org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:202)
   	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.<init>(RegularOperatorChain.java:60)
   	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:789)
   	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:771)
   	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970)
   	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:939)
   	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763)
   	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
   	at java.lang.Thread.run(Thread.java:750)
   Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.flink.cdc.connectors.starrocks.sink.EventRecordSerializationSchema to field com.starrocks.connector.flink.table.sink.v2.StarRocksSink.serializationSchema of type com.starrocks.connector.flink.table.sink.v2.RecordSerializationSchema in instance of com.starrocks.connector.flink.table.sink.v2.StarRocksSink
   	at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2301)
   	at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1431)
   	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2437)
   	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
   	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
   	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
   	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
   	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
   	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
   	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
   	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
   	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
   	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:533)
   	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:521)
   	at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:475)
   	at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:400)
   
   是版本兼容性问题吗


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Flink CDC 3.5.0 + Flink 1.20.0 + java 8兼容性问题 [flink-cdc]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #4229:
URL: https://github.com/apache/flink-cdc/issues/4229#issuecomment-3775517740

   This issue has been closed because Flink CDC doesn't use GitHub issue trackers.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org