t; Hello,
>
> while running a job on Flink 1.1.2 on a cluster of 3 nodes using the
> KafkaProducer010, I encounter this error:
>
> WARN org.apache.flink.runtime.client.JobClientActor -
> Discard message LeaderSessionMessage(null,ConnectionTimeout) because the
>
Hello,
while running a job on Flink 1.1.2 on a cluster of 3 nodes using the
KafkaProducer010, I encounter this error:
WARN org.apache.flink.runtime.client.JobClientActor-
Discard message LeaderSessionMessage(null,ConnectionTimeout) because the
expected leader session ID 4a1c16fe