[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626950#comment-17626950
]
Durgesh Mishra edited comment on FLINK-29711 at 11/2/22 4:52 AM:
-----------------------------------------------------------------
[~mason6345] Not sure that will be issue, Because as a whole json object which
we collecting is never null.
Object contains some entity which might be null.
Code which we are using inside the TripSerializer. Null records will only send
in case of exception.
[~mason6345] Now can you help me out here ? I understand we need to add null
check before sending out the data. But apart from that, Is anything else we can
try ?
!image-2022-11-02-10-19-01-824.png|width=354,height=133!
was (Author: JIRAUSER297316):
[~mason6345] Not sure that will be issue, Because as a whole json object which
we collecting is never null.
Object contains some entity which might be null.
Code which we are using inside the TripSerializer. Null records will only send
in case of exception.
!image-2022-11-02-10-19-01-824.png|width=354,height=133!
> 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: Connectors / Kafka
> Affects Versions: 1.14.4, 1.14.6
> Reporter: Durgesh Mishra
> Priority: Major
> Attachments: image-2022-11-01-08-41-21-836.png,
> image-2022-11-02-10-19-01-824.png
>
>
> 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)
