This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.20 by this push:
new 429962c2ce5 [FLINK-40707][python] Fix Beam imports in
DefaultJobBundleFactoryTest
429962c2ce5 is described below
commit 429962c2ce5dd3cb9db34d68c0940d775f5c2c9b
Author: Martijn Visser <[email protected]>
AuthorDate: Fri Sep 18 10:56:20 2026 +0200
[FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest
The backport of FLINK-39572 kept master's imports. This branch builds Beam
2.43.0, where Environments, ModelCoders and ExecutableStage are in
org.apache.beam.runners.core.construction and the vendored gRPC package is
v1p48p1. 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-1.20 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..40c44b8e36b 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.v1p48p1.com.google.protobuf.Struct;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.event.Level;
