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

Reply via email to