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] >>>>>>>>>>>>>>>>> Caused by: kafka.common.FailedToSendMessageException: >>>>>>>>>>>>>>>>> Failed to send messages after 3 tries. >>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)

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] >>>>>>>>>>>>>>>>> Caused by: kafka.common.FailedToSendMessageException: >>>>>>>>>>>>>>>>> Failed to send messages after 3 tries. >>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
  2. 0

    frequently times out at first start

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

    crashes when item is added

    GitHub | 2 years ago | ingenthr
    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

    Kafka broker failed to consume messages through kafka.javaapi.producer.Producer.send() batch API

    Stack Overflow | 2 years ago | abhishek08aug
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  6. 0

    Kafka producer not working in windows

    Stack Overflow | 3 years ago | Srivatsan Nallazhagappan
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

    2 unregistered visitors
    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] >>>>>>>>>>>>>>>>> Caused by: kafka.common.FailedToSendMessageException: >>>>>>>>>>>>>>>>> Failed to send messages after 3 tries. >>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)

      at kafka.producer.Producer.send()
    2. Apache Kafka
      Producer.send
      1. kafka.producer.Producer.send(Producer.scala:77)
      2. kafka.javaapi.producer.Producer.send(Producer.scala:42)
      2 frames