Hi, I have encountered a wired problem. After I start the job for several days, Flink gave me the following error:
*java.lang.RuntimeException: Unable to find a leader for partitions: [Partition: KafkaTopicPartition{topic='n/a', partition=-1}, KafkaPartitionHandle=[n/a,-1], offset=(not set)]* * at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.findLeaderForPartitions(Kafka08Fetcher.java:495)* * at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.runFetchLoop(Kafka08Fetcher.java:205)* * at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:449)* * at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87)* * at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:55)* * at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:95)* * at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:262)* * at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)* * at java.lang.Thread.run(Thread.java:748)* The Flink job died after this error and tried to restart but in vain at the end. Is there any reason why Flink was unable to find a leader for the partition? A more confusing question would be why is it trying to find topic 'n/a', instead of the topic we have specified? Thanks in advance! Best regards, Mu