Skip to content

Commit a94425f

Browse files
committed
Ignore result of flaky ResumeFromCheckpointStreamingTest.testWithResume
1 parent f258f0c commit a94425f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

runners/spark/src/test/java/org/apache/beam/runners/spark/translation/streaming/ResumeFromCheckpointStreamingTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,7 @@
8282
import org.junit.AfterClass;
8383
import org.junit.Before;
8484
import org.junit.BeforeClass;
85+
import org.junit.Ignore;
8586
import org.junit.Test;
8687
import org.junit.experimental.categories.Category;
8788
import org.junit.rules.TemporaryFolder;
@@ -144,6 +145,7 @@ private static void produce(Map<String, Instant> messages) {
144145

145146
@Test
146147
@Category(UsesCheckpointRecovery.class)
148+
@Ignore("Very flaky: https://github.com/apache/beam/issues/34946")
147149
public void testWithResume() throws Exception {
148150
// write to Kafka
149151
produce(

0 commit comments

Comments
 (0)