This is an automated email from the ASF dual-hosted git repository.
emilyye pushed a commit to branch release-2.36.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.36.0 by this push:
new d5e75c5 [release-2.36.0][BEAM-13575] Sickbay test that is flaky to
restore precommit test signal (#16410) (#16435)
d5e75c5 is described below
commit d5e75c5a0b132e3feb3710c4b90625d6f5a0d475
Author: emily <[email protected]>
AuthorDate: Wed Jan 5 14:53:41 2022 -0800
[release-2.36.0][BEAM-13575] Sickbay test that is flaky to restore
precommit test signal (#16410) (#16435)
Co-authored-by: Lukasz Cwik <[email protected]>
---
.../org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java
b/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java
index b9c0f34..406c6fd 100644
---
a/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java
+++
b/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java
@@ -51,6 +51,7 @@ import org.apache.flink.streaming.util.TestStreamEnvironment;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.ClassRule;
+import org.junit.Ignore;
import org.junit.Test;
import org.junit.rules.TemporaryFolder;
@@ -120,6 +121,7 @@ public class FlinkRequiresStableInputTest {
* restore the savepoint to check if we produce impotent results.
*/
@Test(timeout = 30_000)
+ @Ignore("BEAM-13575")
public void testParDoRequiresStableInput() throws Exception {
FlinkPipelineOptions options = FlinkPipelineOptions.defaults();
options.setParallelism(1);