reuvenlax commented on PR #25940: URL: https://github.com/apache/beam/pull/25940#issuecomment-1549002438
https://github.com/apache/beam/pull/26707 should fix this. On Mon, May 15, 2023 at 9:50 PM Yi Hu ***@***.***> wrote: > Newly added test > org.apache.beam.sdk.transforms.ViewTest.testTriggeredLatestSingleton is > failing on several validate runner postcommits: > > > https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_VR_Dataflow_V2_Streaming/3502/testReport/ > > > https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_PVR_Flink_Streaming/ > > > https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_ValidatesRunner_Flink/ > > highly flaky (~80%) > > > https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_PVR_Samza/ > permared: > > java.lang.RuntimeException: The Runner experienced the following error during execution: > java.lang.UnsupportedOperationException: class org.apache.beam.runners.samza.SamzaRunner currently only supports event time or processing time but get SYNCHRONIZED_PROCESSING_TIME > at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176) > at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117) > at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81) > at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321) > > > https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_ValidatesRunner_ULR/ > permared: > > 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 296, in _run_job > self.result = self._invoke_runner() > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/local_job_service.py", line 318, in _invoke_runner > return 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 224, 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 455, in run_stages > bundle_results = self._execute_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 783, in _execute_bundle > 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 1012, 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 1380, in process_bundle > self.bundle_context_manager.get_buffer( > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py", line 1172, in get_buffer > self.execution_context.pipeline_context.windowing_strategies[ > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/pipeline_context.py", line 163, in __getitem__ > return self.get_by_id(id) > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/runners/pipeline_context.py", line 114, in get_by_id > self._id_to_obj[id] = self._obj_type.from_runner_api( > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/transforms/core.py", line 3403, in from_runner_api > triggerfn=TriggerFn.from_runner_api(proto.trigger, context), > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/transforms/trigger.py", line 304, in from_runner_api > return { > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/transforms/trigger.py", line 737, in from_runner_api > TriggerFn.from_runner_api(proto.repeat.subtrigger, context)) > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/transforms/trigger.py", line 304, in from_runner_api > return { > File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_ULR/src/sdks/python/apache_beam/transforms/trigger.py", line 413, in from_runner_api > proto.after_processing_time.timestamp_transforms[0].delay. > IndexError: list index out of range > > — > Reply to this email directly, view it on GitHub > <https://github.com/apache/beam/pull/25940#issuecomment-1548985493>, or > unsubscribe > <https://github.com/notifications/unsubscribe-auth/AFAYJVK7ATSWRPZK3KQKN7LXGMBPZANCNFSM6AAAAAAWEOQE3Y> > . > You are receiving this because you modified the open/close state.Message > ID: ***@***.***> > -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
