This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 4d22ad0cc3f [FLINK-32301][test] Set options instead of replacing
entire config
4d22ad0cc3f is described below
commit 4d22ad0cc3ff24619cd111e139cf3f9606521a6b
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri May 26 14:13:45 2023 +0200
[FLINK-32301][test] Set options instead of replacing entire config
---
flink-end-to-end-tests/test-scripts/common.sh | 28 +++++++++++++--------------
1 file changed, 13 insertions(+), 15 deletions(-)
diff --git a/flink-end-to-end-tests/test-scripts/common.sh
b/flink-end-to-end-tests/test-scripts/common.sh
index 1bef68bbefb..a54f834a6a6 100644
--- a/flink-end-to-end-tests/test-scripts/common.sh
+++ b/flink-end-to-end-tests/test-scripts/common.sh
@@ -167,36 +167,34 @@ function create_ha_config() {
echo "localhost:8081" > ${FLINK_DIR}/conf/masters
# then move on to create the flink-conf.yaml
- sed 's/^ //g' > ${FLINK_DIR}/conf/flink-conf.yaml << EOL
#==============================================================================
# Common
#==============================================================================
- jobmanager.rpc.address: localhost
- jobmanager.rpc.port: 6123
- jobmanager.memory.process.size: 1024m
- taskmanager.memory.process.size: 1024m
- taskmanager.numberOfTaskSlots: ${TASK_SLOTS_PER_TM_HA}
+ set_config_key "jobmanager.rpc.address" "localhost"
+ set_config_key "jobmanager.rpc.port" "6123"
+ set_config_key "jobmanager.memory.process.size" "1024m"
+ set_config_key "taskmanager.memory.process.size" "1024m"
+ set_config_key "taskmanager.numberOfTaskSlots" "${TASK_SLOTS_PER_TM_HA}"
#==============================================================================
# High Availability
#==============================================================================
- high-availability.type: zookeeper
- high-availability.zookeeper.storageDir: file://${TEST_DATA_DIR}/recovery/
- high-availability.zookeeper.quorum: localhost:2181
- high-availability.zookeeper.path.root: /flink
- high-availability.cluster-id: /test_cluster_one
+ set_config_key "high-availability.type" "zookeeper"
+ set_config_key "high-availability.zookeeper.storageDir"
"file://${TEST_DATA_DIR}/recovery/"
+ set_config_key "high-availability.zookeeper.quorum" "localhost:2181"
+ set_config_key "high-availability.zookeeper.path.root" "/flink"
+ set_config_key "high-availability.cluster-id" "/test_cluster_one"
#==============================================================================
# Web Frontend
#==============================================================================
- rest.port: 8081
+ set_config_key "rest.port" "8081"
- queryable-state.server.ports: 9000-9009
- queryable-state.proxy.ports: 9010-9019
-EOL
+ set_config_key "queryable-state.server.ports" "9000-9009"
+ set_config_key "queryable-state.proxy.ports" "9010-9019"
}
function get_node_ip {
