diff --git a/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Samza.json b/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Samza.json index cdaa11075bdf..cccf60ad1fc6 100644 --- a/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Samza.json +++ b/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Samza.json @@ -1,3 +1,4 @@ { - "https://github.com/apache/beam/pull/34830": "testing" + "https://github.com/apache/beam/pull/34830": "testing", + "https://github.com/apache/beam/issues/35429": "testing" } diff --git a/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Spark.json b/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Spark.json index cdaa11075bdf..cccf60ad1fc6 100644 --- a/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Spark.json +++ b/.github/trigger_files/beam_PostCommit_Python_ValidatesRunner_Spark.json @@ -1,3 +1,4 @@ { - "https://github.com/apache/beam/pull/34830": "testing" + "https://github.com/apache/beam/pull/34830": "testing", + "https://github.com/apache/beam/issues/35429": "testing" } diff --git a/sdks/python/apache_beam/runners/portability/samza_runner_test.py b/sdks/python/apache_beam/runners/portability/samza_runner_test.py index 6112a50e8511..cc8d947f054e 100644 --- a/sdks/python/apache_beam/runners/portability/samza_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/samza_runner_test.py @@ -190,6 +190,9 @@ def test_custom_window_type(self): def test_reshuffle_after_custom_window(self): raise unittest.SkipTest("https://github.com/apache/beam/issues/34831") + def test_sliding_windows(self): + raise unittest.SkipTest("https://github.com/apache/beam/issues/35429") + if __name__ == '__main__': # Run the tests. diff --git a/sdks/python/apache_beam/runners/portability/spark_runner_test.py b/sdks/python/apache_beam/runners/portability/spark_runner_test.py index cf6536be4c2d..fe7160d4e18b 100644 --- a/sdks/python/apache_beam/runners/portability/spark_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/spark_runner_test.py @@ -191,6 +191,9 @@ def test_custom_merging_window(self): def test_custom_window_type(self): raise unittest.SkipTest("https://github.com/apache/beam/issues/20641") + def test_sliding_windows(self): + raise unittest.SkipTest("https://github.com/apache/beam/issues/35429") + # Inherits all other tests from PortableRunnerTest.