Skip to content

Instantly share code, notes, and snippets.

@goaquin
Created February 1, 2017 20:09
Show Gist options
  • Save goaquin/358ad76249647ead5a952f31b9cd8a64 to your computer and use it in GitHub Desktop.
Save goaquin/358ad76249647ead5a952f31b9cd8a64 to your computer and use it in GitHub Desktop.
2017-02-01 17:04:52,116 [user:*admin] [pipeline:kudu sep optimizado streaming] [thread:ProductionPipelineRunnable-kudu sep optimizado streaming] WARN ProductionPipeline - Error while running: com.streamsets.pipeline.api.StageException: KUDU_03 - Errors while writing to Kudu: At least one of the Deferreds failed, first exception:
com.streamsets.pipeline.api.StageException: KUDU_03 - Errors while writing to Kudu: At least one of the Deferreds failed, first exception:
at com.streamsets.pipeline.stage.destination.kudu.KuduTarget.writeBatch(KuduTarget.java:410)
at com.streamsets.pipeline.stage.destination.kudu.KuduTarget.write(KuduTarget.java:285)
at com.streamsets.pipeline.configurablestage.DTarget.write(DTarget.java:38)
at com.streamsets.datacollector.runner.StageRuntime$2.call(StageRuntime.java:177)
at com.streamsets.datacollector.runner.StageRuntime$2.call(StageRuntime.java:161)
at com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:150)
at com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:189)
at com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:233)
at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runBatch(ProductionPipelineRunner.java:484)
at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.run(ProductionPipelineRunner.java:301)
at com.streamsets.datacollector.runner.Pipeline.run(Pipeline.java:204)
at com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:109)
at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:72)
at com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:758)
at com.streamsets.datacollector.execution.runner.common.AsyncRunner$4.call(AsyncRunner.java:147)
at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:233)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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)
Caused by: org.apache.kudu.client.NonRecoverableException: At least one of the Deferreds failed, first exception:
at org.apache.kudu.client.KuduException.transformException(KuduException.java:100)
at org.apache.kudu.client.KuduSession.flush(KuduSession.java:104)
at com.streamsets.pipeline.stage.destination.kudu.KuduTarget.writeBatch(KuduTarget.java:384)
... 21 more
Caused by: com.stumbleupon.async.DeferredGroupException: At least one of the Deferreds failed, first exception:
at com.stumbleupon.async.DeferredGroup.done(DeferredGroup.java:169)
at com.stumbleupon.async.DeferredGroup.recordCompletion(DeferredGroup.java:142)
at com.stumbleupon.async.DeferredGroup.access$000(DeferredGroup.java:36)
at com.stumbleupon.async.DeferredGroup$1Notify.call(DeferredGroup.java:82)
at com.stumbleupon.async.Deferred.doCall(Deferred.java:1280)
at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
at com.stumbleupon.async.Deferred.callback(Deferred.java:1002)
at org.apache.kudu.client.KuduRpc.handleCallback(KuduRpc.java:205)
at org.apache.kudu.client.KuduRpc.errback(KuduRpc.java:225)
at org.apache.kudu.client.AsyncKuduClient.tooManyAttemptsOrTimeout(AsyncKuduClient.java:1067)
at org.apache.kudu.client.AsyncKuduClient.delayedSendRpcToTablet(AsyncKuduClient.java:1278)
at org.apache.kudu.client.AsyncKuduClient.handleRetryableError(AsyncKuduClient.java:1263)
at org.apache.kudu.client.AsyncKuduClient.handleNotLeader(AsyncKuduClient.java:1258)
at org.apache.kudu.client.TabletClient.dispatchTSErrorOrReturnException(TabletClient.java:542)
at org.apache.kudu.client.TabletClient.decode(TabletClient.java:478)
at org.apache.kudu.client.TabletClient.decode(TabletClient.java:83)
at org.apache.kudu.client.shaded.org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:500)
at org.apache.kudu.client.shaded.org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.apache.kudu.client.TabletClient.handleUpstream(TabletClient.java:670)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
at org.apache.kudu.client.shaded.org.jboss.netty.handler.timeout.ReadTimeoutHandler.messageReceived(ReadTimeoutHandler.java:184)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
at org.apache.kudu.client.AsyncKuduClient$TabletClientPipeline.sendUpstream(AsyncKuduClient.java:1856)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.apache.kudu.client.shaded.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.apache.kudu.client.shaded.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
... 3 more
Caused by: org.apache.kudu.client.NonRecoverableException: RPC can not complete before timeout: Batch{operations=10, tablet="1cf300ca41774794873c22a4873c7709" [<start>, 0x00000001), ignoreAllDuplicateRows=false}
at org.apache.kudu.client.AsyncKuduClient.tooManyAttemptsOrTimeout(AsyncKuduClient.java:1066)
... 29 more
Caused by: org.apache.kudu.client.RecoverableException: Replica ca199fafca544df2a1b2a01be9d5266d is not leader of this config. Role: FOLLOWER. Consensus state: current_term: 6 leader_uuid: "" config { opid_index: 2494750 OBSOLETE_local: false peers { permanent_uuid: "ca199fafca544df2a1b2a01be9d5266d" member_type: VOTER last_known_addr { host: "totoro.akainix.local" port: 7250 } } peers { permanent_uuid: "5c09a555c205482b8131f15b2c249ec6" member_type: VOTER last_known_addr { host: "lebeche.akainix.local" port: 7250 } } }
... 26 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment