[ https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Mark Liu closed BEAM-624. ------------------------- > NoClassDefFoundError Failed Dataflow Streaming Job > -------------------------------------------------- > > Key: BEAM-624 > URL: https://issues.apache.org/jira/browse/BEAM-624 > Project: Beam > Issue Type: Bug > Reporter: Mark Liu > Assignee: Mark Liu > Fix For: Not applicable > > > NoClassDefFoundError when running streaming job on Dataflow service. > Full stacktrace here when : > {code} > (bb04a33113307d77): Exception: java.lang.NoClassDefFoundError: > org/apache/beam/sdk/util/AttemptBoundedExponentialBackOff > com.google.cloud.dataflow.worker.runners.worker.WorkerCustomSources$UnboundedReaderIterator.advance(WorkerCustomSources.java:694) > > com.google.cloud.dataflow.worker.util.common.worker.ReadOperation$SynchronizedReaderIterator.advance(ReadOperation.java:371) > > com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:198) > > com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:139) > > com.google.cloud.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:71) > > com.google.cloud.dataflow.worker.runners.worker.StreamingDataflowWorker.process(StreamingDataflowWorker.java:660) > > com.google.cloud.dataflow.worker.runners.worker.StreamingDataflowWorker.access$500(StreamingDataflowWorker.java:89) > > com.google.cloud.dataflow.worker.runners.worker.StreamingDataflowWorker$6.run(StreamingDataflowWorker.java:487) > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > {code} > Retore AttemptBounded/AttemptAndTimeBounded backoff classes which are removed > in this commit[1] in order to pass Dataflow streaming job against at HEAD. > [1] > https://github.com/apache/incubator-beam/commit/dbbcbe604e167b306feac2443bec85f2da3c1dd6 -- This message was sent by Atlassian JIRA (v6.3.4#6332)