Open huangzeehui opened 2 days ago
Hello @huangzeehui, this issue is about CDC/CDCSOURCE, so I assign it to @aiwenmo. If you have any questions, you can comment and reply.
你好 @huangzeehui, 这个 issue 是关于 CDC/CDCSOURCE 的,所以我把它分配给了 @aiwenmo。如有任何问题,可以评论回复。
Hello @huangzeehui, this issue is about web, so I assign it to @Zzm0809. If you have any questions, you can comment and reply.
你好 @huangzeehui, 这个 issue 是关于 web 的,所以我把它分配给了 @Zzm0809。如有任何问题,可以评论回复。
Search before asking
What happened
该jar是将mysqlcdc读取到的json数据简单执行map算子,然而即使jar包中包含TestFlink$1,仍然报错java.lang.ClassNotFoundException: com.tes.flin.TestFlink$1,去除map算子后正常
核心代码:
我将map修改为重写序列化器,此次提交就出现报错
What you expected to happen
How to reproduce
Anything else
No response
Version
1.0.3
Are you willing to submit PR?
Code of Conduct