Test filtes.

apache · Dec 4, 2024 · f0fe5ea · f0fe5ea
1 parent 54c26c9
commit f0fe5ea
Showing 1 changed file with 5 additions and 10 deletions.
diff --git a/runners/prism/java/build.gradle b/runners/prism/java/build.gradle
@@ -106,6 +106,7 @@ def sickbayTests = [
     'org.apache.beam.sdk.testing.TestStreamTest.testLateDataAccumulating',
     'org.apache.beam.sdk.testing.TestStreamTest.testMultipleStreams',
     'org.apache.beam.sdk.testing.TestStreamTest.testProcessingTimeTrigger',
+    'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testRequiresTimeSortedInputWithLateDataAndAllowedLateness',
 
     // Coding error somehow: short write: reached end of stream after reading 5 bytes; 98 bytes expected
     'org.apache.beam.sdk.testing.TestStreamTest.testMultiStage',
@@ -172,13 +173,6 @@ def sickbayTests = [
     // java.lang.IllegalStateException: java.io.EOFException
     'org.apache.beam.sdk.transforms.ViewTest.testSideInputWithNestedIterables',
 
-    // Requires Time Sorted Input 
-    // 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testRequiresTimeSortedInput',
-    // 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testRequiresTimeSortedInputWithTestStream',
-    // 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testRequiresTimeSortedInputWithLateDataAndAllowedLateness',
-    // 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testTwoRequiresTimeSortedInputWithLateData',
-    // 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testRequiresTimeSortedInputWithLateData',
-
     // Missing output due to processing time timer skew.
     'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testProcessElementSkew',
 
@@ -193,6 +187,10 @@ def sickbayTests = [
     // sharded_key coder isn't implemented in Prism.
     'org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testWithShardedKeyInGlobalWindow',
 
+    // SDK dies, terminating the job, but due to a bug in how onWindowExpiry is implemented in prism.
+    // excludeTestsMatching 'org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testBufferingTimerInFixedWindow'
+    // excludeTestsMatching 'org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testInStreamingMode'
+
     // Filtered by PortableRunner tests.
     // Teardown not called in exceptions
     // https://github.com/apache/beam/issues/20372
@@ -242,9 +240,6 @@ def createPrismValidatesRunnerTask = { name, environmentType ->
        excludeCategories 'org.apache.beam.sdk.testing.UsesMultimapState'
     }
     filter {
-      // Hangs, but due to a bug in how onWindowExpiry is implemented in prism.
-      excludeTestsMatching 'org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testBufferingTimerInFixedWindow'
-      excludeTestsMatching 'org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testInStreamingMode'
       for (String test : sickbayTests) {
           excludeTestsMatching test
       }