kafka.common.FailedToSendMessageException: Failed to send messages after 3 >>>>>>>> tries. >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:294) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:281) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.KafkaAuditPublisher.publish(KafkaAuditPublisher.java:72) >>>>>>>> ~[co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.AuditPublishers.publishAccess(AuditPublishers.java:77) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.doWriteLineage(LineageWriterDatasetFramework.java:159) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.writeLineage(LineageWriterDatasetFramework.java:141) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.ForwardingDatasetFramework.writeLineage(ForwardingDatasetFramework.java:176) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.workflow.NameMappedDatasetFramework.writeLineage(NameMappedDatasetFramework.java:172) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data.dataset.SystemDatasetInstantiator.writeLineage(SystemDatasetInstantiator.java:108) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:143) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:127) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache.getDataset(SingleThreadDatasetCache.java:170) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:150) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:126) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.AbstractContext.getDataset(AbstractContext.java:179) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addOutput(BasicMapReduceContext.java:311) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:88) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runUnchecked(LogContext.java:145) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runWithoutLoggingUnchecked(LogContext.java:139) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext.addOutput(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:89) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:57) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:44) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at co.cask.cdap.etl.log.LogContext.run(LogContext.java:59) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable.prepareRun(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.ETLMapReduce.beforeSubmit(ETLMapReduce.java:189) >>>>>>>> [cdap-etl-batch-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:471) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.transaction.Transactions.execute(Transactions.java:174) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.beforeSubmit(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.startUp(MapReduceRuntimeService.java:204) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:47) >>>>>>>> [com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$1$1.run(MapReduceRuntimeService.java:386) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]

Google Groups | Poorna Chandra | 6 months ago
  1. 0

    Re: ETL Data pipeline Keep on running for 1 hr without any result

    Google Groups | 6 months ago | Poorna Chandra
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 >>>>>>>> tries. >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:294) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:281) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.KafkaAuditPublisher.publish(KafkaAuditPublisher.java:72) >>>>>>>> ~[co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.AuditPublishers.publishAccess(AuditPublishers.java:77) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.doWriteLineage(LineageWriterDatasetFramework.java:159) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.writeLineage(LineageWriterDatasetFramework.java:141) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.ForwardingDatasetFramework.writeLineage(ForwardingDatasetFramework.java:176) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.workflow.NameMappedDatasetFramework.writeLineage(NameMappedDatasetFramework.java:172) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data.dataset.SystemDatasetInstantiator.writeLineage(SystemDatasetInstantiator.java:108) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:143) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:127) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache.getDataset(SingleThreadDatasetCache.java:170) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:150) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:126) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.AbstractContext.getDataset(AbstractContext.java:179) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addOutput(BasicMapReduceContext.java:311) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:88) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runUnchecked(LogContext.java:145) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runWithoutLoggingUnchecked(LogContext.java:139) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext.addOutput(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:89) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:57) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:44) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at co.cask.cdap.etl.log.LogContext.run(LogContext.java:59) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable.prepareRun(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.ETLMapReduce.beforeSubmit(ETLMapReduce.java:189) >>>>>>>> [cdap-etl-batch-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:471) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.transaction.Transactions.execute(Transactions.java:174) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.beforeSubmit(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.startUp(MapReduceRuntimeService.java:204) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:47) >>>>>>>> [com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$1$1.run(MapReduceRuntimeService.java:386) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]
  2. 0

    TopicOrPartitionUnknown exception thrown by KafkaStorage

    GitHub | 2 years ago | manuzhang
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  3. 0

    Need Help : Issues using Kafka 2.8.0 with log4 j1.2.8

    Stack Overflow | 2 years ago | user3774752
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Producer doesn't fail gracefully if broker doesn't exisit

    GitHub | 3 years ago | joekiller
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. kafka.common.FailedToSendMessageException

      Failed to send messages after 3 >>>>>>>> tries. >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:294) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:281) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) >>>>>>>> ~[com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.KafkaAuditPublisher.publish(KafkaAuditPublisher.java:72) >>>>>>>> ~[co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.audit.AuditPublishers.publishAccess(AuditPublishers.java:77) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.doWriteLineage(LineageWriterDatasetFramework.java:159) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework.writeLineage(LineageWriterDatasetFramework.java:141) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.ForwardingDatasetFramework.writeLineage(ForwardingDatasetFramework.java:176) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.workflow.NameMappedDatasetFramework.writeLineage(NameMappedDatasetFramework.java:172) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data.dataset.SystemDatasetInstantiator.writeLineage(SystemDatasetInstantiator.java:108) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:143) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache$LineageRecordingDatasetCache.get(SingleThreadDatasetCache.java:127) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.SingleThreadDatasetCache.getDataset(SingleThreadDatasetCache.java:170) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:150) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.dataset2.DynamicDatasetCache.getDataset(DynamicDatasetCache.java:126) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.AbstractContext.getDataset(AbstractContext.java:179) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addOutput(BasicMapReduceContext.java:311) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:88) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext$4.call(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runUnchecked(LogContext.java:145) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.log.LogContext.runWithoutLoggingUnchecked(LogContext.java:139) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSinkContext.addOutput(MapReduceSinkContext.java:84) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:89) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.hydrator.plugin.sink.HBaseSink.prepareRun(HBaseSink.java:57) >>>>>>>> [1465456927467-0/:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:44) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable$1.call(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at co.cask.cdap.etl.log.LogContext.run(LogContext.java:59) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.LoggedBatchConfigurable.prepareRun(LoggedBatchConfigurable.java:41) >>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.etl.batch.mapreduce.ETLMapReduce.beforeSubmit(ETLMapReduce.java:189) >>>>>>>> [cdap-etl-batch-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:471) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$2.call(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.data2.transaction.Transactions.execute(Transactions.java:174) >>>>>>>> [co.cask.cdap.cdap-data-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.beforeSubmit(MapReduceRuntimeService.java:466) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService.startUp(MapReduceRuntimeService.java:204) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at >>>>>>>> com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:47) >>>>>>>> [com.google.guava.guava-13.0.1.jar:na] >>>>>>>> at >>>>>>>> co.cask.cdap.internal.app.runtime.batch.MapReduceRuntimeService$1$1.run(MapReduceRuntimeService.java:386) >>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]

      at kafka.producer.Producer.send()
    2. Apache Kafka
      Producer.send
      1. kafka.producer.Producer.send(Producer.scala:77)
      1 frame