[Flink] Add org.apache.beam.sdk.transforms.ViewTest.testTriggeredLatestSingleton to sickbay

jto · jto · commit aaaa0230fca0 · 2025-01-27T11:14:39.000+01:00
restore gradle parallel mode
diff --git a/gradle.properties b/gradle.properties
@@ -16,7 +16,7 @@
 # limitations under the License.
 ################################################################################
 org.gradle.caching=true
-org.gradle.parallel=false
+org.gradle.parallel=true
 org.gradle.daemon=false
 org.gradle.configureondemand=true
 org.gradle.jvmargs=-Xss10240k
diff --git a/runners/flink/flink_runner.gradle b/runners/flink/flink_runner.gradle
@@ -242,6 +242,8 @@ def sickbayTests = [
         'org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests',
         'org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState',
         // TODO(https://github.com/apache/beam/issues/18198)
+        'org.apache.beam.sdk.transforms.ViewTest.testTriggeredLatestSingleton',
+        // testTriggeredLatestSingleton gets "stuck" both with or without --useDatastreamForBatch
 ]
 
 def createValidatesRunnerTask(Map m) {

Original file line number	Diff line number	Diff line change
`@@ -242,6 +242,8 @@ def sickbayTests = [`
`242`	`242`	`'org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests',`
`243`	`243`	`'org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState',`
`244`	`244`	`// TODO(https://github.com/apache/beam/issues/18198)`
	`245`	`+ 'org.apache.beam.sdk.transforms.ViewTest.testTriggeredLatestSingleton',`
	`246`	`+ // testTriggeredLatestSingleton gets "stuck" both with or without --useDatastreamForBatch`
`245`	`247`	`]`
`246`	`248`
`247`	`249`	`def createValidatesRunnerTask(Map m) {`