|
问题1：使用CDC执行flink任务时报错
flink Can''t call rollback when autocommit=true
解决：可能是kafka的topic没有数据，判空就可以了。
问题2：集群上执行flink任务
per-job模式运行报异常，global limit =2; local limit is =1
解决：代码引用的依赖和集群上的hadoop环境冲突。
问题3：数据量大的时候执行per-job模式报错
Caused by: java.lang.Exception: [2021-08-17 18:42:50.353]Exception from container-launch.
Container id: container_e11_1627612938926_0154_01_000004
Exit code: 239
[2021-08-17 18:42:50.354]Container exited with a non-zero exit code 239. Error file: prelaunch.err.
Last 4096 bytes of prelaunch.err :
[2021-08-17 18:42:50.355]Container exited with a non-zero exit code 239. Error file: prelaunch.err.
Last 4096 bytes of prelaunch.err :
解决：
暂未解决
|