Abacn commented on PR #37313:
URL: https://github.com/apache/beam/pull/37313#issuecomment-3874005733
Current test failures:
```
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_batch_pardo_fusion_break
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_batch_to_element_pardo
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_flattened_side_input
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_gbk_side_input
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_multimap_multiside_input
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_multimap_side_input
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_multimap_side_input_type_coercion
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pack_combiners
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pardo_side_input_dependencies
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pardo_side_inputs
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pardo_unfusable_side_inputs
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pardo_unfusable_side_inputs_with_separation
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_pardo_windowed_side_inputs
FAILED
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestOptimized::test_sdf_synthetic_source
```
```
java.lang.IllegalArgumentException
at
org.apache.beam.model.pipeline.v1.RunnerApi$Components.getTransformsOrThrow(RunnerApi.java:1038)
at
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.getSideInputIdToPCollectionViewMap(FlinkStreamingPortablePipelineTranslator.java:991)
at
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.transformSideInputs(FlinkStreamingPortablePipelineTranslator.java:1033)
at
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.translateExecutableStage(FlinkStreamingPortablePipelineTranslator.java:755)
at
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.translate(FlinkStreamingPortablePipelineTranslator.java:280)
at
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.translate(FlinkStreamingPortablePipelineTranslator.java:127)
at
org.apache.beam.runners.flink.FlinkPipelineRunner.runPipelineWithTranslator(FlinkPipelineRunner.java:96)
at
org.apache.beam.runners.flink.FlinkPipelineRunner.run(FlinkPipelineRunner.java:86)
at
org.apache.beam.runners.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:86)
at
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
at
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)
at
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
```
problems related to side input
https://github.com/apache/beam/actions/runs/21840420138/job/63022922889
--
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]
