Re: Re:Re: The wrong Options of Kafka Connector, will make the cluster can not run any job

2021-04-27 Thread cxydevelop
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/

Re:Re: The wrong Options of Kafka Connector, will make the cluster can not run any job

2021-04-27 Thread chenxuying
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