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

yhu pushed a commit to branch post-2-62-0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/post-2-62-0 by this push:
     new 4a13930acc8 Skip highly flaky test
4a13930acc8 is described below

commit 4a13930acc843ef2ee2509b65e530fab746458ee
Author: Yi Hu <[email protected]>
AuthorDate: Wed Jan 29 14:00:16 2025 -0500

    Skip highly flaky test
---
 .../dataflow/worker/windmill/client/grpc/GrpcGetDataStreamTest.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStreamTest.java
 
b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStreamTest.java
index 3125def64b3..cc9ee611e6f 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStreamTest.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStreamTest.java
@@ -49,6 +49,7 @@ import 
org.apache.beam.vendor.grpc.v1p60p1.io.grpc.util.MutableHandlerRegistry;
 import 
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.Uninterruptibles;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.Timeout;
@@ -148,6 +149,7 @@ public class GrpcGetDataStreamTest {
   }
 
   @Test
+  @Ignore("https://github.com/apache/beam/issues/28957";)
   public void 
testRequestKeyedData_sendOnShutdownStreamThrowsWindmillStreamShutdownException()
 {
     GetDataStreamTestStub testStub =
         new GetDataStreamTestStub(new TestGetDataStreamRequestObserver());

Reply via email to