oh, I am wrong again, the last it is in flink_1.12.2 not flink_1.11.2
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I had tested flink job in flink_1.11.2 and flink_1.12.2. The error log I post
before is in flink_1.11.2 cluster.
Now I run job in flink_1.11.2.
1. The wrong Options of Kafka Connector
Ip is right, port is wrong,
```
CREATE TABLE KafkaTable (
message STRING
) WITH (
'connecto
Thanks a lot for your message. This could be a bug in Flink. It seems that
the archival of the execution graph is failing because some classes are
unloaded.
What I observe from your stack traces is that some classes are loaded from
flink-dist_2.11-1.11.2.jar, while other classes are loaded from
te
environment:
flinksql 1.12.2
k8s session mode
description:
I got follow error log when my kafka connector port was wrong
>
2021-04-25 16:49:50
org.apache.kafka.common.errors.TimeoutException: Timeout of 6ms expired
before the position for partition filebeat_json_install_log-3 could
