Pipeline failed after running 30sec with error in yarn logs:
20/12/15 16:51:09 ERROR async.DefaultEventHandler: Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: log
20/12/15 16:51:17 INFO producer.Producer: Producer shutdown completed in 27 ms Exception in thread "kafka-publisher" java.lang.NullPointerException at org.apache.twill.internal.kafka.client.SimpleKafkaPublisher$ProducerCancellable.run(SimpleKafkaPublisher.java:228) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)
i want to check topic in embded kafka but i didn’t find documentation about kafka in cdap product
please help me to fix this issue
regards
Release Notes
None
Activity
Show:
Edwin EliaDecember 15, 2020 at 10:12 PM
For questions about use case and debugging, please use the mailing list
Won't Fix
Pinned fields
Click on the next to a field label to start pinning.
Hi
i’m trying to launch a new pipeline in cdap UI
Pipeline failed after running 30sec with error in yarn logs:
20/12/15 16:51:09 ERROR async.DefaultEventHandler: Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: log
20/12/15 16:51:17 INFO producer.Producer: Producer shutdown completed in 27 ms
Exception in thread "kafka-publisher" java.lang.NullPointerException
at org.apache.twill.internal.kafka.client.SimpleKafkaPublisher$ProducerCancellable.run(SimpleKafkaPublisher.java:228)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
i want to check topic in embded kafka but i didn’t find documentation about kafka in cdap product
please help me to fix this issue
regards