(beam) branch master updated: Fix internal test failure after #39487 (#39591)

[shunping]

This is an automated email from the ASF dual-hosted git repository.

shunping pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new a6b3399e41d Fix internal test failure after #39487 (#39591)
a6b3399e41d is described below

commit a6b3399e41d85ad398712c9c5df2758839534f41
Author: Shunping Huang <shunp...@google.com>
AuthorDate: Mon Aug 3 13:23:43 2026 -0400

    Fix internal test failure after #39487 (#39591)
---
 .../beam/runners/dataflow/worker/WindmillKeyedWorkItem.java  | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java
index ff5be071ede..290c25836f6 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java
@@ -201,12 +201,14 @@ public class WindmillKeyedWorkItem<K, ElemT> implements 
KeyedWorkItem<K, ElemT>
   }
 
   @Override
-  @SuppressWarnings("nullness")
+  @SuppressWarnings({"nullness", "unchecked"})
   public Iterable<WindowedValue<?>> elementWindowsIterable() {
-    return FluentIterable.from(workItem.getMessageBundlesList())
-        .transformAndConcat(Windmill.InputMessageBundle::getMessagesList)
-        .transform(this::parseElemWindowOnly)
-        .filter(Objects::nonNull);
+    return (Iterable<WindowedValue<?>>)
+        (Iterable<?>)
+            FluentIterable.from(workItem.getMessageBundlesList())
+                
.transformAndConcat(Windmill.InputMessageBundle::getMessagesList)
+                .transform(this::parseElemWindowOnly)
+                .filter(Objects::nonNull);
   }
 
   @Override