We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 777dcf7 commit 6161f4eCopy full SHA for 6161f4e
runners/flink/flink_runner.gradle
@@ -236,6 +236,10 @@ class ValidatesRunnerConfig {
236
def sickbayTests = [
237
// TODO(https://github.com/apache/beam/issues/21306)
238
'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testOnWindowTimestampSkew',
239
+ // Flink errors are not deterministic. Exception may just be
240
+ // org.apache.flink.runtime.operators.coordination.TaskNotRunningException: Task is not running, but in state FAILED
241
+ // instead of the actual cause. Real cause is visible in the logs.
242
+ 'org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests'
243
]
244
245
def createValidatesRunnerTask(Map m) {
0 commit comments