We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1045e82 commit daab652Copy full SHA for daab652
runners/flink/flink_runner.gradle
@@ -242,6 +242,8 @@ def sickbayTests = [
242
'org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests',
243
'org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState',
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
247
]
248
249
def createValidatesRunnerTask(Map m) {
0 commit comments