This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 7779d8690b073acd93172f2bf5d98572f9b2b17c Author: Igal Shilman <[email protected]> AuthorDate: Wed Apr 1 23:57:38 2020 +0200 [FLINK-16927][core] Add legacy scheduler This commit adds a jobmanager.scheduler = legacy property As a workaround to FLINK-16139. --- .../statefun-e2e-tests-common/src/main/resources/flink-conf.yaml | 1 + tools/docker/flink-distribution-template/conf/flink-conf.yaml | 1 + tools/k8s/templates/config-map.yaml | 1 + 3 files changed, 3 insertions(+) diff --git a/statefun-e2e-tests/statefun-e2e-tests-common/src/main/resources/flink-conf.yaml b/statefun-e2e-tests/statefun-e2e-tests-common/src/main/resources/flink-conf.yaml index 4af978f..7d7c307 100644 --- a/statefun-e2e-tests/statefun-e2e-tests-common/src/main/resources/flink-conf.yaml +++ b/statefun-e2e-tests/statefun-e2e-tests-common/src/main/resources/flink-conf.yaml @@ -20,3 +20,4 @@ state.backend.rocksdb.timer-service.factory: ROCKSDB state.checkpoints.dir: file:///checkpoint-dir state.backend.incremental: true taskmanager.memory.process.size: 4g +jobmanager.scheduler: legacy diff --git a/tools/docker/flink-distribution-template/conf/flink-conf.yaml b/tools/docker/flink-distribution-template/conf/flink-conf.yaml index d0d4522..574ccb0 100644 --- a/tools/docker/flink-distribution-template/conf/flink-conf.yaml +++ b/tools/docker/flink-distribution-template/conf/flink-conf.yaml @@ -20,6 +20,7 @@ classloader.parent-first-patterns.additional: org.apache.flink.statefun;org.apache.kafka;com.google.protobuf execution.checkpointing.max-concurrent-checkpoints: 1 +jobmanager.scheduler: legacy #============================================================================== # Recommended configurations. Users may change according to their needs. diff --git a/tools/k8s/templates/config-map.yaml b/tools/k8s/templates/config-map.yaml index a57e7ff..d6bda3e 100644 --- a/tools/k8s/templates/config-map.yaml +++ b/tools/k8s/templates/config-map.yaml @@ -34,6 +34,7 @@ data: execution.checkpointing.interval: {{ .Values.checkpoint.interval }} taskmanager.memory.process.size: {{ .Values.worker.jvm_mem }} parallelism.default: {{ .Values.worker.replicas }} + jobmanager.scheduler: legacy log4j-console.properties: |+ log4j.rootLogger=INFO, console
