You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Durgesh Mishra (Jira)" <ji...@apache.org> on 2022/10/21 02:27:00 UTC

[jira] [Created] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

Durgesh Mishra created FLINK-29711:
--------------------------------------

             Summary: Topic notification not present in metadata after 60000 ms.
                 Key: FLINK-29711
                 URL: https://issues.apache.org/jira/browse/FLINK-29711
             Project: Flink
          Issue Type: Bug
          Components: API / Core
    Affects Versions: 1.14.6, 1.14.4
            Reporter: Durgesh Mishra


Failed to send data to Kafka null with FlinkKafkaInternalProducer\{transactionalId='null', inTransaction=false, closed=false}
at org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.throwException(KafkaWriter.java:405)
at org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.lambda$onCompletion$0(KafkaWriter.java:391)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
at java.base/java.lang.Thread.run(Unknown Source)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)