Flink version : 1.13.1 Flink CDC version: 2.1.1 Database and version: mysql 8.0.1 flink on yarn per-job : /opt/cloudera/parcels/FLINK/lib/flink/bin/flink run -m yarn ...
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java ...
Some results have been hidden because they may be inaccessible to you
Show inaccessible results
Feedback