[
https://issues.apache.org/jira/browse/BEAM-12041?focusedWorklogId=570858&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-570858
]
ASF GitHub Bot logged work on BEAM-12041:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 24/Mar/21 00:00
Start Date: 24/Mar/21 00:00
Worklog Time Spent: 10m
Work Description: kennknowles commented on a change in pull request
#14318:
URL: https://github.com/apache/beam/pull/14318#discussion_r600042151
##########
File path:
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java
##########
@@ -849,7 +849,8 @@ public void translate(CombineGroupedValues transform,
TranslationContext context
stepContext.addEncodingInput(fn.getAccumulatorCoder());
- boolean isFnApi =
DataflowRunner.useUnifiedWorker(context.getPipelineOptions());
+ List<String> experiments =
context.getPipelineOptions().getExperiments();
Review comment:
Assuming the ULR goes green, I think this piece can be omitted. This got
pulled in but is not really related.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 570858)
Time Spent: 0.5h (was: 20m)
> Project beam_PostCommit_Java_ValidatesRunner_ULR is failing
> -----------------------------------------------------------
>
> Key: BEAM-12041
> URL: https://issues.apache.org/jira/browse/BEAM-12041
> Project: Beam
> Issue Type: Bug
> Components: sdk-java-core, test-failures
> Reporter: Valentyn Tymofieiev
> Assignee: Kenneth Knowles
> Priority: P1
> Labels: currently-failing
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> First faliure:
> https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_ULR/
> From scanning through commits on the build,
> https://github.com/apache/beam/pull/14226 is the most suspicious to me,
> others seems to me not relevant.
> {noformat}
> org.apache.beam.sdk.transforms.ViewTest.testMapAsEntrySetSideInput
> Failing for the past 1 build (Since Failed#676 )
> Took 12 sec.
> Error Message
> java.lang.RuntimeException: The Runner experienced the following error during
> execution:
> Traceback (most recent call last):
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/local_job_service.py",
> line 275, in _run_job
> result = fn_runner.FnApiRunner(
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py",
> line 204, in run_via_runner_api
> return self.run_stages(stage_context, stages)
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py",
> line 368, in run_stages
> stage_results = self._run_stage(
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py",
> line 559, in _run_stage
> last_result, deferred_inputs, fired_timers = self._run_bundle(
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py",
> line 605, in _run_bundle
> result, splits = bundle_manager.process_bundle(
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py",
> line 947, in process_bundle
> raise RuntimeError(result.error)
> RuntimeError: org.apache.beam.sdk.util.UserCodeException:
> java.lang.AssertionError: expected:<2> but was:<0>
> at
> org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:39)
> at
> org.apache.beam.sdk.transforms.ViewTest$24$DoFnInvoker.invokeProcessElement(Unknown
> Source)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingParDo(FnApiDoFnRunner.java:764)
> at
> org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:246)
> at
> org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:200)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1681)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner.access$2500(FnApiDoFnRunner.java:139)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner$WindowObservingProcessBundleContext.outputWithTimestamp(FnApiDoFnRunner.java:2082)
> at
> org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.outputWithTimestamp(DoFnOutputReceivers.java:87)
> at
> org.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn.processElement(Read.java:308)
> at
> org.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn$DoFnInvoker.invokeProcessElement(Unknown
> Source)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1049)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:139)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:638)
> at
> org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:633)
> at
> org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:246)
> at
> org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:200)
> at
> org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:220)
> at
> org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43)
> at
> org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25)
> at
> org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:111)
> at
> org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:308)
> at
> org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:173)
> at
> org.apache.beam.fn.harness.control.BeamFnControlClient.lambda$processInstructionRequests$0(BeamFnControlClient.java:157)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.AssertionError: expected:<2> but was:<0>
> at org.junit.Assert.fail(Assert.java:89)
> at org.junit.Assert.failNotEquals(Assert.java:835)
> at org.junit.Assert.assertEquals(Assert.java:647)
> at org.junit.Assert.assertEquals(Assert.java:633)
> at
> org.apache.beam.sdk.transforms.ViewTest$24.processElement(ViewTest.java:1008)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
