This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a commit to branch release-2.3
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.3 by this push:
new ae68dd4950c [FLINK-40707][python] Fix Beam imports in
DefaultJobBundleFactoryTest
ae68dd4950c is described below
commit ae68dd4950c1485fc470cb02c08cc02b59ce20aa
Author: Martijn Visser <[email protected]>
AuthorDate: Fri Sep 18 10:56:13 2026 +0200
[FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest
The backport of FLINK-39572 kept master's imports. This branch builds Beam
2.54.0, where Environments, ModelCoders and ExecutableStage are in
org.apache.beam.runners.core.construction and the vendored gRPC package is
v1p60p1. Beam moved those classes after 2.54.0 and renames the vendored
package
with every release, so master's imports do not resolve here. flink-python
has
not compiled on release-2.3 since.
Generated-by: Claude Code (Claude Opus 5)
---
.../runners/fnexecution/control/DefaultJobBundleFactoryTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/flink-python/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java
b/flink-python/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java
index 105ca0272ec..9b63c5afde3 100644
---
a/flink-python/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java
+++
b/flink-python/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactoryTest.java
@@ -30,13 +30,13 @@ import
org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload;
import org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec;
import org.apache.beam.model.pipeline.v1.RunnerApi.PCollection;
import org.apache.beam.model.pipeline.v1.RunnerApi.WindowingStrategy;
+import org.apache.beam.runners.core.construction.Environments;
+import org.apache.beam.runners.core.construction.ModelCoders;
+import org.apache.beam.runners.core.construction.graph.ExecutableStage;
import org.apache.beam.runners.fnexecution.environment.EnvironmentFactory;
import org.apache.beam.runners.fnexecution.environment.RemoteEnvironment;
import org.apache.beam.runners.fnexecution.provisioning.JobInfo;
-import org.apache.beam.sdk.util.construction.Environments;
-import org.apache.beam.sdk.util.construction.ModelCoders;
-import org.apache.beam.sdk.util.construction.graph.ExecutableStage;
-import org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.Struct;
+import org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.Struct;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.event.Level;
