Skip to content

Commit 9064743

Browse files
authored
Revert "[Flink] disable operator chaining in validatesRunner" (#33838)
This reverts commit 2c01ac0.
1 parent 7356785 commit 9064743

File tree

2 files changed

+0
-24
lines changed

2 files changed

+0
-24
lines changed

runners/flink/flink_runner.gradle

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -274,8 +274,6 @@ def createValidatesRunnerTask(Map m) {
274274
)
275275
// maxParallelForks decreased from 4 in order to avoid OOM errors
276276
maxParallelForks 2
277-
def flinkConfDir = System.getProperty("user.dir") + "/runners/flink/src/test/validatesRunnerConfig"
278-
environment("FLINK_CONF_DIR", flinkConfDir)
279277
useJUnit {
280278
if (config.checkpointing) {
281279
includeCategories 'org.apache.beam.sdk.testing.UsesBundleFinalizer'

runners/flink/src/test/validatesRunnerConfig/flink-conf.yaml

Lines changed: 0 additions & 22 deletions
This file was deleted.

0 commit comments

Comments
 (0)