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:72) >>>>>>>>>>>>>>>>>>>>>> [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.createInput(BasicMapReduceContext.java:420) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:252) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:227) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:117) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [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.MapReduceSourceContext.setInput(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:213) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-0/:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:64) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-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:170) >>>>>>>>>>>>>>>>>>>>>> [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:72) >>>>>>>>>>>>>>>>>>>>>> [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.createInput(BasicMapReduceContext.java:420) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:252) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:227) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:117) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [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.MapReduceSourceContext.setInput(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:213) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-0/:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:64) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-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:170) >>>>>>>>>>>>>>>>>>>>>> [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:72) >>>>>>>>>>>>>>>>>>>>>> [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.createInput(BasicMapReduceContext.java:420) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:252) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.internal.app.runtime.batch.BasicMapReduceContext.addInput(BasicMapReduceContext.java:227) >>>>>>>>>>>>>>>>>>>>>> [co.cask.cdap.cdap-app-fabric-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:117) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.cdap.etl.batch.mapreduce.MapReduceSourceContext$7.call(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [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.MapReduceSourceContext.setInput(MapReduceSourceContext.java:113) >>>>>>>>>>>>>>>>>>>>>> [cdap-etl-core-3.4.1.jar:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:213) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-0/:na] >>>>>>>>>>>>>>>>>>>>>> at >>>>>>>>>>>>>>>>>>>>>> co.cask.hydrator.plugin.db.batch.source.DBSource.prepareRun(DBSource.java:64) >>>>>>>>>>>>>>>>>>>>>> [1465456928749-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:170) >>>>>>>>>>>>>>>>>>>>>> [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