From dc750e270932a57ce728e5d2ae043b7476685909 Mon Sep 17 00:00:00 2001 From: Ufuk Celebi Date: Tue, 27 Oct 2015 17:40:03 +0100 Subject: [PATCH] [FLINK-2927] [runtime] Provide default required configuration keys in flink-conf of binary distribution --- flink-dist/src/main/resources/flink-conf.yaml | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/flink-dist/src/main/resources/flink-conf.yaml b/flink-dist/src/main/resources/flink-conf.yaml index 5928d93a8bfbe..6f56e89555751 100644 --- a/flink-dist/src/main/resources/flink-conf.yaml +++ b/flink-dist/src/main/resources/flink-conf.yaml @@ -128,13 +128,18 @@ webclient.port: 8080 #============================================================================== -# High Availability +# Master High Availability (required configuration) #============================================================================== # The list of ZooKepper quorum peers that coordinate the high-availability -# setup. This must be a list of the form -# "host_1[:peerPort[:leaderPort]],host_2[:peerPort[:leaderPort]],..." +# setup. This must be a list of the form: +# "host1:clientPort,host2[:clientPort],..." (default clientPort: 2181) # # recovery.mode: zookeeper # -# recovery.zookeeper.quorum: localhost +# recovery.zookeeper.quorum: localhost:2181,... +# +# Note: You need to set the state backend to 'filesystem' and the checkpoint +# directory (see above) before configuring the storageDir. +# +# recovery.zookeeper.storageDir: hdfs:///recovery