From 41cda9ff7d863da98074a278db8abca21604d0e7 Mon Sep 17 00:00:00 2001
From: Yi Hu <yathu@google.com>
Date: Wed, 29 Jan 2025 14:41:42 -0500
Subject: [PATCH] Skip highly flaky test (#33804)

---
 .../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 1c270e4285b2..a9d381aaa179 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.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 void testRequestKeyedData() {
   }
 
   @Test
+  @Ignore("https://github.com/apache/beam/issues/28957")
   public void testRequestKeyedData_sendOnShutdownStreamThrowsWindmillStreamShutdownException() {
     GetDataStreamTestStub testStub =
         new GetDataStreamTestStub(new TestGetDataStreamRequestObserver());