You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Lukasz Gajowy (JIRA)" <ji...@apache.org> on 2019/01/08 13:52:00 UTC
[jira] [Assigned] (BEAM-6368) NoSuchMethodError in streaming load
tests
[ https://issues.apache.org/jira/browse/BEAM-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lukasz Gajowy reassigned BEAM-6368:
-----------------------------------
Assignee: Lukasz Gajowy (was: Scott Wegner)
> NoSuchMethodError in streaming load tests
> -----------------------------------------
>
> Key: BEAM-6368
> URL: https://issues.apache.org/jira/browse/BEAM-6368
> Project: Beam
> Issue Type: Improvement
> Components: test-failures
> Reporter: Lukasz Gajowy
> Assignee: Lukasz Gajowy
> Priority: Major
>
> While running an unbounded source on Dataflow runner we get the folllowing stacktrace:
> {code:java}
> java.lang.NoSuchMethodError: org.apache.beam.model.pipeline.v1.RunnerApi$BeamConstants$Constants.getValueDescriptor()Lorg/apache/beam/vendor/grpc/v1p13p1/com/google/protobuf/Descriptors$EnumValueDescriptor;
> at org.apache.beam.sdk.transforms.windowing.BoundedWindow.extractTimestampFromProto (BoundedWindow.java:84)
> at org.apache.beam.sdk.transforms.windowing.BoundedWindow.<clinit> (BoundedWindow.java:49)
> at org.apache.beam.runners.dataflow.worker.WindmillTimeUtils.windmillToHarnessTimestamp (WindmillTimeUtils.java:49)
> at org.apache.beam.runners.dataflow.worker.WindmillTimeUtils.windmillToHarnessWatermark (WindmillTimeUtils.java:34)
> at org.apache.beam.runners.dataflow.worker.StreamingDataflowWorker.dispatchLoop (StreamingDataflowWorker.java:902)
> at org.apache.beam.runners.dataflow.worker.StreamingDataflowWorker.access$200 (StreamingDataflowWorker.java:143)
> at org.apache.beam.runners.dataflow.worker.StreamingDataflowWorker$1.run (StreamingDataflowWorker.java:588)
> at java.lang.Thread.run (Thread.java:745)
> {code}
>
> After reverting [https://github.com/apache/beam/pull/7324] the issue does not occur
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)