You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/06/28 08:50:38 UTC
[inlong] branch master updated: [INLONG-4799][Manager] Add Flink plugin initialization for standalone deployment (#4801)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 4e0a18606 [INLONG-4799][Manager] Add Flink plugin initialization for standalone deployment (#4801)
4e0a18606 is described below
commit 4e0a1860636dd7aa1996a61933ea2811dd2bd877
Author: Charles Zhang <do...@apache.org>
AuthorDate: Tue Jun 28 16:50:32 2022 +0800
[INLONG-4799][Manager] Add Flink plugin initialization for standalone deployment (#4801)
---
bin/init-config.sh | 4 ++++
conf/inlong.conf | 6 ++++++
.../manager-plugins/src/main/resources/flink-sort-plugin.properties | 5 ++---
3 files changed, 12 insertions(+), 3 deletions(-)
diff --git a/bin/init-config.sh b/bin/init-config.sh
index 075ba003a..5b399ebf5 100644
--- a/bin/init-config.sh
+++ b/bin/init-config.sh
@@ -72,6 +72,10 @@ init_inlong_manager() {
sed -i 's/spring.datasource.druid.username=.*/'''spring.datasource.druid.username=${spring_datasource_username}'''/g' application-prod.properties
sed -i 's/spring.datasource.druid.password=.*/'''spring.datasource.druid.password=${spring_datasource_password}'''/g' application-prod.properties
fi
+ echo "Init inlong manager flink plugin configuration"
+ cd $INLONG_HOME/inlong-manager/plugins
+ sed -i 's/flink.rest.address=.*/'''flink.rest.address=${flink_rest_address}'''/g' flink-sort-plugin.properties
+ sed -i 's/flink.rest.port=.*/'''flink.rest.port=${flink_rest_port}'''/g' flink-sort-plugin.properties
}
if [ $# -eq 0 ]; then
diff --git a/conf/inlong.conf b/conf/inlong.conf
index 7698ba823..9b49a1fa0 100644
--- a/conf/inlong.conf
+++ b/conf/inlong.conf
@@ -47,6 +47,12 @@ manager_server_hostname=127.0.0.1
# manager port
manager_server_port=8083
+############## Flink Configuration ##############
+# the REST server address for Flink
+flink_rest_address=127.0.0.1
+# the REST server Port for Flink
+flink_rest_port=8081
+
############## DataProxy Configuration ##############
dataproxy_port=46801
diff --git a/inlong-manager/manager-plugins/src/main/resources/flink-sort-plugin.properties b/inlong-manager/manager-plugins/src/main/resources/flink-sort-plugin.properties
index bef035205..7b70c404a 100644
--- a/inlong-manager/manager-plugins/src/main/resources/flink-sort-plugin.properties
+++ b/inlong-manager/manager-plugins/src/main/resources/flink-sort-plugin.properties
@@ -21,10 +21,9 @@
########################
# flink config
########################
-# Flink config
-# Flink host split by coma if more than one host, such as 'host1,host2'
+# the REST server address for Flink
flink.rest.address=127.0.0.1
-# Flink port
+# the REST server Port for Flink
flink.rest.port=8081
# Flink jobmanager port
flink.jobmanager.port=6123