commit 8787c13675bfa8484c1f6074165c6cbd613c734b
author Ismaël Mejía <iemejia@gmail.com> Thu May 06 09:13:52 2021 +0200
committer GitHub <noreply@github.com> Thu May 06 09:13:52 2021 +0200
tree 3cbd4dcbf9d41499194e8f5a5a254eb663d38441
parent 7af241e1e6cf83190bd1b97d26ae82edc2a97f1d
parent 9fef5b4ca7fbebd81028d4cc7acd83ef6a6a29d9

Merge pull request #14740: [BEAM-7320] Only run one pipeline in TextIOWriteTest.testWriteViaSink

sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOWriteTest.java

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOWriteTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOWriteTest.java
index 588f91f..4cb8448 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOWriteTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOWriteTest.java
@@ -689,20 +689,6 @@
                 .apply("Read Files", TextIO.readFiles()))
         .containsInAnyOrder(data);
 
-    PAssert.that(
-            p.apply("Create Data ReadAll", Create.of(data))
-                .apply(
-                    "Write ReadAll",
-                    FileIO.<String>write()
-                        .to(tempFolder.getRoot().toString())
-                        .withSuffix(".txt")
-                        .via(TextIO.sink())
-                        .withIgnoreWindowing())
-                .getPerDestinationOutputFilenames()
-                .apply("Extract Values ReadAll", Values.create())
-                .apply("Read All", TextIO.readAll()))
-        .containsInAnyOrder(data);
-
     p.run();
   }