diff --git a/bin/checkEnv.sh b/bin/checkEnv.sh
deleted file mode 100644
index d51bd5ca21..0000000000
--- a/bin/checkEnv.sh
+++ /dev/null
@@ -1,45 +0,0 @@
-#!/bin/sh
-#
-# Copyright 2019 WeBank
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-say() {
- printf 'check command fail \n %s\n' "$1"
-}
-
-err() {
- say "$1" >&2
- exit 1
-}
-
-check_cmd() {
- command -v "$1" > /dev/null 2>&1
-}
-
-need_cmd() {
- if ! check_cmd "$1"; then
- err "need '$1' (your linux command not found)"
- fi
-}
-echo "<-----start to check used cmd---->"
-need_cmd yum
-need_cmd java
-need_cmd mysql
-need_cmd unzip
-need_cmd expect
-need_cmd telnet
-need_cmd tar
-need_cmd sed
-need_cmd dos2unix
-echo "<-----end to check used cmd---->"
diff --git a/bin/checkServices.sh b/bin/checkServices.sh
deleted file mode 100644
index 72df04be43..0000000000
--- a/bin/checkServices.sh
+++ /dev/null
@@ -1,91 +0,0 @@
-#
-# Copyright 2019 WeBank
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-#!/bin/sh
-source ~/.bash_profile
-
-shellDir=`dirname $0`
-workDir=`cd ${shellDir}/..;pwd`
-
-##load config
-export LINKIS_DSS_CONF_FILE=${LINKIS_DSS_CONF_FILE:-"${workDir}/conf/config.sh"}
-export DISTRIBUTION=${DISTRIBUTION:-"${workDir}/conf/config.sh"}
-source ${LINKIS_DSS_CONF_FILE}
-source ${DISTRIBUTION}
-
-MICRO_SERVICE_NAME=$1
-MICRO_SERVICE_IP=$2
-MICRO_SERVICE_PORT=$3
-
-local_host="`hostname --fqdn`"
-
-ipaddr=$(ip addr | awk '/^[0-9]+: / {}; /inet.*global/ {print gensub(/(.*)\/(.*)/, "\\1", "g", $2)}'|awk 'NR==1')
-
-function isLocal(){
- if [ "$1" == "127.0.0.1" ];then
- return 0
- elif [ $1 == "localhost" ]; then
- return 0
- elif [ $1 == $local_host ]; then
- return 0
- elif [ $1 == $ipaddr ]; then
- return 0
- fi
- return 1
-}
-
-function executeCMD(){
- isLocal $1
- flag=$?
- echo "Is local "$flag
- if [ $flag == "0" ];then
- eval $2
- else
- ssh -p $SSH_PORT $1 $2
- fi
-
-}
-
-#echo "<--------------------------------------------------------------------------->"
-#echo "Start to Check if your microservice:$MICRO_SERVICE_NAME is normal via telnet"
-#echo ""
-#if ! executeCMD $SERVER_IP "test -e $DSS_INSTALL_HOME/$MICRO_SERVICE_NAME"; then
-# echo "$MICRO_SERVICE_NAME is not installed,the check steps will be skipped"
-# exit 0
-#fi
-echo "==========================================================="
-echo $MICRO_SERVICE_NAME
-echo $MICRO_SERVICE_IP
-echo $MICRO_SERVICE_PORT
-echo "==========================================================="
-
-if [ $MICRO_SERVICE_NAME == "visualis-server" ] && [ $MICRO_SERVICE_IP == "127.0.0.1" ]; then
- MICRO_SERVICE_IP=$ipaddr
-fi
-
-result=`echo -e "\n" | telnet $MICRO_SERVICE_IP $MICRO_SERVICE_PORT 2>/dev/null | grep Connected | wc -l`
-if [ $result -eq 1 ]; then
- echo "$MICRO_SERVICE_NAME is ok."
-else
- echo "<--------------------------------------------------------------------------->"
- echo "ERROR your $MICRO_SERVICE_NAME microservice is not start successful !!! ERROR logs as follows :"
- echo "PLEAESE CHECK DETAIL LOG,LOCATION:$DSS_INSTALL_HOME/$MICRO_SERVICE_NAME/logs/linkis.out"
- echo '<------------------------------------------------------------->'
- executeCMD $MICRO_SERVICE_IP "tail -n 50 $DSS_INSTALL_HOME/$MICRO_SERVICE_NAME/logs/*.out"
- echo '<-------------------------------------------------------------->'
- echo "PLEAESE CHECK DETAIL LOG,LOCATION:$DSS_INSTALL_HOME/$MICRO_SERVICE_NAME/logs/linkis.out"
- exit 1
-fi
-
diff --git a/bin/install.sh b/bin/install.sh
deleted file mode 100644
index 7a0b46db6d..0000000000
--- a/bin/install.sh
+++ /dev/null
@@ -1,583 +0,0 @@
-#
-# Copyright 2019 WeBank
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-#!/bin/sh
-#Actively load user env
-
-source ~/.bash_profile
-
-shellDir=`dirname $0`
-workDir=`cd ${shellDir}/..;pwd`
-
-#To be compatible with MacOS and Linux
-txt=""
-if [[ "$OSTYPE" == "darwin"* ]]; then
- txt="''"
-elif [[ "$OSTYPE" == "linux-gnu" ]]; then
- # linux
- txt=""
-elif [[ "$OSTYPE" == "cygwin" ]]; then
- echo "dss not support Windows operating system"
- exit 1
-elif [[ "$OSTYPE" == "msys" ]]; then
- echo "dss not support Windows operating system"
- exit 1
-elif [[ "$OSTYPE" == "win32" ]]; then
- echo "dss not support Windows operating system"
- exit 1
-elif [[ "$OSTYPE" == "freebsd"* ]]; then
- txt=""
-else
- echo "Operating system unknown, please tell us(submit issue) for better service"
- exit 1
-fi
-
-function isSuccess(){
-if [ $? -ne 0 ]; then
- echo "Failed to " + $1
- exit 1
-else
- echo "Succeed to" + $1
-fi
-}
-
-function checkJava(){
- java -version
- isSuccess "execute java --version"
-}
-
-function checkExternalServer(){
-echo "telnet check for your $SERVER_NAME, if you wait for a long time,may be your $SERVER_NAME does not prepared"
-result=`echo -e "\n" | telnet $EXTERNAL_SERVER_IP $EXTERNAL_SERVER_PORT 2>/dev/null | grep Connected | wc -l`
-if [ $result -eq 1 ]; then
- echo "$SERVER_NAME is OK."
-else
- echo "$SERVER_NAME is Bad. You need to prepare the' $SERVER_NAME ' environment in advance"
- exit 1
-fi
-}
-
-
-say() {
- printf 'check command fail \n %s\n' "$1"
-}
-
-err() {
- say "$1" >&2
- exit 1
-}
-
-check_cmd() {
- command -v "$1" > /dev/null 2>&1
-}
-
-need_cmd() {
- if ! check_cmd "$1"; then
- err "need '$1' (command not found)"
- fi
-}
-
-#check env
-sh ${workDir}/bin/checkEnv.sh
-isSuccess "check env"
-
-##load config
-echo "step1:load config"
-export DSS_CONFIG_PATH=${DSS_CONFIG_PATH:-"${workDir}/conf/config.sh"}
-export DSS_DB_CONFIG_PATH=${DSS_DB_CONFIG_PATH:-"${workDir}/conf/db.sh"}
-export DISTRIBUTION=${DISTRIBUTION:-"${workDir}/conf/config.sh"}
-source ${DSS_CONFIG_PATH}
-source ${DSS_DB_CONFIG_PATH}
-source ${DISTRIBUTION}
-isSuccess "load config"
-
-local_host="`hostname --fqdn`"
-ipaddr=$(ip addr | awk '/^[0-9]+: / {}; /inet.*global/ {print gensub(/(.*)\/(.*)/, "\\1", "g", $2)}'|awk 'NR==1')
-
-function isLocal(){
- if [ "$1" == "127.0.0.1" ];then
- return 0
- elif [ $1 == "localhost" ]; then
- return 0
- elif [ $1 == $local_host ]; then
- return 0
- elif [ $1 == $ipaddr ]; then
- return 0
- fi
- return 1
-}
-
-function executeCMD(){
- isLocal $1
- flag=$?
- if [ $flag == "0" ];then
- echo "Is local execution:$2"
- eval $2
- else
- echo "Is remote execution:$2"
- ssh -p $SSH_PORT $1 $2
- fi
-}
-
-function copyFile(){
- isLocal $1
- flag=$?
- src=$2
- dest=$3
- if [ $flag == "0" ];then
- echo "Is local cp "
- eval "cp -r $src $dest"
- else
- echo "Is remote cp "
- scp -r -P $SSH_PORT $src $1:$dest
- fi
-}
-
-##install mode choice
-if [ "$INSTALL_MODE" == "" ];then
- echo "Please enter the mode selection such as: 1"
- echo " 1: Lite"
- echo " 2: Simple"
- echo " 3: Standard"
- echo ""
- read -p "Please input the choice:" idx
- INSTALL_MODE=$idx
-fi
-
-if [[ '1' = "$INSTALL_MODE" ]];then
- echo "You chose lite installation mode"
- checkJava
- SERVER_NAME=MYSQL
- EXTERNAL_SERVER_IP=$MYSQL_HOST
- EXTERNAL_SERVER_PORT=$MYSQL_PORT
- checkExternalServer
-elif [[ '2' = "$INSTALL_MODE" ]];then
- echo "You chose sample installation mode"
- checkJava
- SERVER_NAME=MYSQL
- EXTERNAL_SERVER_IP=$MYSQL_HOST
- EXTERNAL_SERVER_PORT=$MYSQL_PORT
- checkExternalServer
-elif [[ '3' = "$INSTALL_MODE" ]];then
- echo "You chose Standard installation mode"
- #check for Java
- checkJava
- #check for mysql
- SERVER_NAME=MYSQL
- EXTERNAL_SERVER_IP=$MYSQL_HOST
- EXTERNAL_SERVER_PORT=$MYSQL_PORT
- checkExternalServer
- #check qualitis serivice
- SERVER_NAME=Qualitis
- EXTERNAL_SERVER_IP=$QUALITIS_ADRESS_IP
- EXTERNAL_SERVER_PORT=$QUALITIS_ADRESS_PORT
- if [[ $IGNORECHECK = "" ]];then
- checkExternalServer
- fi
- #check azkaban serivice
- SERVER_NAME=AZKABAN
- EXTERNAL_SERVER_IP=$AZKABAN_ADRESS_IP
- EXTERNAL_SERVER_PORT=$AZKABAN_ADRESS_PORT
- if [[ $IGNORECHECK = "" ]];then
- checkExternalServer
- fi
-else
- echo "no choice,exit!"
- exit 1
-fi
-
-##init db
-echo "Do you want to clear DSS table information in the database?"
-echo " 1: Do not execute table-building statements"
-echo " 2: Dangerous! Clear all data and rebuild the tables."
-echo ""
-
-MYSQL_INSTALL_MODE=1
-
-read -p "Please input the choice:" idx
-if [[ '2' = "$idx" ]];then
- MYSQL_INSTALL_MODE=2
- echo "You chose Rebuild the table"
-elif [[ '1' = "$idx" ]];then
- MYSQL_INSTALL_MODE=1
- echo "You chose not execute table-building statements"
-else
- echo "no choice,exit!"
- exit 1
-fi
-
-echo "create hdfs directory and local directory"
-if [ "$WORKSPACE_USER_ROOT_PATH" != "" ]
-then
- localRootDir=$WORKSPACE_USER_ROOT_PATH
- if [[ $WORKSPACE_USER_ROOT_PATH == file://* ]];then
- localRootDir=${WORKSPACE_USER_ROOT_PATH#file://}
- mkdir -p $localRootDir/$deployUser
- sudo chmod -R 775 $localRootDir/$deployUser
- elif [[ $WORKSPACE_USER_ROOT_PATH == hdfs://* ]];then
- localRootDir=${WORKSPACE_USER_ROOT_PATH#hdfs://}
- hdfs dfs -mkdir -p $localRootDir/$deployUser
- hdfs dfs -chmod -R 775 $localRootDir/$deployUser
- else
- echo "does not support $WORKSPACE_USER_ROOT_PATH filesystem types"
- fi
-isSuccess "create $WORKSPACE_USER_ROOT_PATH directory"
-fi
-
-
-if [ "$RESULT_SET_ROOT_PATH" != "" ]
-then
- localRootDir=$RESULT_SET_ROOT_PATH
- if [[ $RESULT_SET_ROOT_PATH == file://* ]];then
- localRootDir=${RESULT_SET_ROOT_PATH#file://}
- mkdir -p $localRootDir/$deployUser
- sudo chmod -R 775 $localRootDir/$deployUser
- elif [[ $RESULT_SET_ROOT_PATH == hdfs://* ]];then
- localRootDir=${RESULT_SET_ROOT_PATH#hdfs://}
- hdfs dfs -mkdir -p $localRootDir/$deployUser
- hdfs dfs -chmod -R 775 $localRootDir/$deployUser
- else
- echo "does not support $RESULT_SET_ROOT_PATH filesystem types"
- fi
-isSuccess "create $RESULT_SET_ROOT_PATH directory"
-fi
-
-
-if [ "$WDS_SCHEDULER_PATH" != "" ]
-then
- localRootDir=$WDS_SCHEDULER_PATH
- if [[ $WDS_SCHEDULER_PATH == file://* ]];then
- localRootDir=${WDS_SCHEDULER_PATH#file://}
- mkdir -p $localRootDir
- sudo chmod -R 775 $localRootDir
- elif [[ $WDS_SCHEDULER_PATH == hdfs://* ]];then
- localRootDir=${WDS_SCHEDULER_PATH#hdfs://}
- hdfs dfs -mkdir -p $localRootDir
- hdfs dfs -chmod -R 775 $localRootDir
- else
- echo "does not support $WDS_SCHEDULER_PATH filesystem types"
- fi
-isSuccess "create $WDS_SCHEDULER_PATH directory"
-fi
-
-
-##init db
-if [[ '2' = "$MYSQL_INSTALL_MODE" ]];then
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/dss_ddl.sql"
- isSuccess "source dss_ddl.sql"
- LOCAL_IP=$ipaddr
- if [ $GATEWAY_INSTALL_IP == "127.0.0.1" ];then
- echo "GATEWAY_INSTALL_IP is equals 127.0.0.1 ,we will change it to ip address"
- GATEWAY_INSTALL_IP_2=$LOCAL_IP
- else
- GATEWAY_INSTALL_IP_2=$GATEWAY_INSTALL_IP
- fi
- #echo $GATEWAY_INSTALL_IP_2
- sed -i "s/GATEWAY_INSTALL_IP_2/$GATEWAY_INSTALL_IP_2/g" ${workDir}/db/dss_dml.sql
- sed -i "s/GATEWAY_PORT/$GATEWAY_PORT/g" ${workDir}/db/dss_dml.sql
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/dss_dml.sql"
- isSuccess "source dss_dml.sql"
-
- if [[ '2' = "$INSTALL_MODE" ]] || [[ '3' = "$INSTALL_MODE" ]];then
- echo "visualis support,visualis database will be initialized !"
- if [ $VISUALIS_NGINX_IP == "127.0.0.1" ]||[ $VISUALIS_NGINX_IP == "0.0.0.0" ];then
- echo "VISUALIS_NGINX_IP is equals $VISUALIS_NGINX_IP ,we will change it to ip address"
- VISUALIS_NGINX_IP_2=$LOCAL_IP
- else
- VISUALIS_NGINX_IP_2=$VISUALIS_NGINX_IP
- fi
- #echo $VISUALIS_NGINX_IP_2
- sed -i "s/VISUALIS_NGINX_IP_2/$VISUALIS_NGINX_IP_2/g" ${workDir}/db/visualis.sql
- sed -i "s/VISUALIS_NGINX_PORT/$VISUALIS_NGINX_PORT/g" ${workDir}/db/visualis.sql
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/visualis.sql"
- isSuccess "source visualis.sql"
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/davinci.sql"
- isSuccess "source davinci.sql"
- fi
-
- if [[ '3' = "$INSTALL_MODE" ]];then
- echo "azkaban and qualitis support, azkaban and qualitis database will be initialized !"
- #azkaban
- if [ $AZKABAN_ADRESS_IP == "127.0.0.1" ];then
- echo "AZKABAN_ADRESS_IP is equals 127.0.0.1 ,we will change it to ip address"
- AZKABAN_ADRESS_IP_2=$LOCAL_IP
- else
- AZKABAN_ADRESS_IP_2=$AZKABAN_ADRESS_IP
- fi
- echo $AZKABAN_ADRESS_IP_2
- sed -i "s/AZKABAN_ADRESS_IP_2/$AZKABAN_ADRESS_IP_2/g" ${workDir}/db/azkaban.sql
- sed -i "s/AZKABAN_ADRESS_PORT/$AZKABAN_ADRESS_PORT/g" ${workDir}/db/azkaban.sql
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/azkaban.sql"
- isSuccess "source azkaban.sql"
- #qualitis
- if [ $QUALITIS_ADRESS_IP == "127.0.0.1" ];then
- echo "QUALITIS_ADRESS_IP is equals 127.0.0.1 ,we will change it to ip address"
- QUALITIS_ADRESS_IP_2=$LOCAL_IP
- else
- QUALITIS_ADRESS_IP_2=$QUALITIS_ADRESS_IP
- fi
- echo $QUALITIS_ADRESS_IP_2
- sed -i "s/QUALITIS_ADRESS_IP_2/$QUALITIS_ADRESS_IP_2/g" ${workDir}/db/qualitis.sql
- sed -i "s/QUALITIS_ADRESS_PORT/$QUALITIS_ADRESS_PORT/g" ${workDir}/db/qualitis.sql
- mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source ${workDir}/db/qualitis.sql"
- isSuccess "source qualitis.sql"
- fi
-fi
-
-##Deal special symbol '#'
-HIVE_META_PASSWORD=$(echo ${HIVE_META_PASSWORD//'#'/'\#'})
-MYSQL_PASSWORD=$(echo ${MYSQL_PASSWORD//'#'/'\#'})
-
-###linkis Eurkea info
-SERVER_IP=$EUREKA_INSTALL_IP
-SERVER_PORT=$EUREKA_PORT
-SERVER_HOME=$DSS_INSTALL_HOME
-
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-EUREKA_URL=http://$SERVER_IP:$EUREKA_PORT/eureka/
-
-##function start
-function installPackage(){
-echo "start to install $SERVERNAME"
-echo "$SERVERNAME-step1: create dir"
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-if ! executeCMD $SERVER_IP "test -e $SERVER_HOME"; then
- executeCMD $SERVER_IP "sudo mkdir -p $SERVER_HOME;sudo chown -R $deployUser:$deployUser $SERVER_HOME"
- isSuccess "create the dir of $SERVERNAME"
-fi
-
-echo "$SERVERNAME-step2:copy install package"
-copyFile $SERVER_IP ${workDir}/share/$PACKAGE_DIR/$SERVERNAME.zip $SERVER_HOME
-
-if ! executeCMD $SERVER_IP "test -e $SERVER_HOME/lib"; then
- copyFile $SERVER_IP ${workDir}/lib $SERVER_HOME
-fi
-
-#copyFile $SERVER_IP ${workDir}/lib $SERVER_HOME
-isSuccess "copy ${SERVERNAME}.zip"
-executeCMD $SERVER_IP "cd $SERVER_HOME/;rm -rf $SERVERNAME-bak; mv -f $SERVERNAME $SERVERNAME-bak"
-executeCMD $SERVER_IP "cd $SERVER_HOME/;unzip $SERVERNAME.zip > /dev/null"
-executeCMD $SERVER_IP "cd $SERVER_HOME/;scp -r lib/* $SERVER_HOME/$SERVERNAME/lib"
-isSuccess "unzip ${SERVERNAME}.zip"
-
-echo "$SERVERNAME-step3:subsitution conf"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/application.yml
-executeCMD $SERVER_IP "sed -i \"s#port:.*#port: $SERVER_PORT#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#defaultZone:.*#defaultZone: $EUREKA_URL#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#hostname:.*#hostname: $SERVER_IP#g\" $SERVER_CONF_PATH"
-isSuccess "subsitution conf of $SERVERNAME"
-}
-##function end
-
-##function start
-function installVisualis(){
-echo "start to install $SERVERNAME"
-echo "$SERVERNAME-step1: create dir"
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-if ! executeCMD $SERVER_IP "test -e $SERVER_HOME"; then
- executeCMD $SERVER_IP "sudo mkdir -p $SERVER_HOME;sudo chown -R $deployUser:$deployUser $SERVER_HOME"
- isSuccess "create the dir of $SERVERNAME"
-fi
-
-echo "$SERVERNAME-step2:copy install package"
-copyFile $SERVER_IP ${workDir}/share/$PACKAGE_DIR/$SERVERNAME.zip $SERVER_HOME
-isSuccess "copy ${SERVERNAME}.zip"
-executeCMD $SERVER_IP "cd $SERVER_HOME/;rm -rf $SERVERNAME-bak; mv -f $SERVERNAME $SERVERNAME-bak"
-executeCMD $SERVER_IP "cd $SERVER_HOME/;unzip $SERVERNAME.zip > /dev/null"
-isSuccess "unzip ${SERVERNAME}.zip"
-}
-##function end
-
-
-##function start
-function installAppjoints(){
-echo "start to install $APPJOINTNAME"
-echo "$APPJOINTNAME Install-step1: create dir"
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-if ! executeCMD $SERVER_IP "test -e $SERVER_HOME/$APPJOINTPARENT"; then
- executeCMD $SERVER_IP "sudo mkdir -p $SERVER_HOME/$APPJOINTPARENT;sudo chown -R $deployUser:$deployUser $SERVER_HOME/$APPJOINTPARENT"
- isSuccess "create the dir of $SERVER_HOME/$APPJOINTPARENT;"
-fi
-
-echo "$APPJOINTNAME-step2:copy install package"
-copyFile $SERVER_IP $workDir/share/appjoints/$APPJOINTNAME/*.zip $SERVER_HOME/$APPJOINTPARENT
-isSuccess "copy ${APPJOINTNAME}.zip"
-executeCMD $SERVER_IP "cd $SERVER_HOME/$APPJOINTPARENT/;unzip -o dss-*-appjoint.zip > /dev/null;rm -rf dss-*-appjoint.zip"
-isSuccess "install ${APPJOINTNAME}.zip"
-}
-##function end
-
-##dss-Server install
-PACKAGE_DIR=dss/dss-server
-SERVERNAME=dss-server
-SERVER_IP=$DSS_SERVER_INSTALL_IP
-SERVER_PORT=$DSS_SERVER_PORT
-SERVER_HOME=$DSS_INSTALL_HOME
-###install Dss-Server
-installPackage
-###update Dss-Server linkis.properties
-echo "$SERVERNAME-step4:update linkis.properties"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/linkis.properties
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.server.mybatis.datasource.url.*#wds.linkis.server.mybatis.datasource.url=jdbc:mysql://${MYSQL_HOST}:${MYSQL_PORT}/${MYSQL_DB}?characterEncoding=UTF-8#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.server.mybatis.datasource.username.*#wds.linkis.server.mybatis.datasource.username=$MYSQL_USER#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.server.mybatis.datasource.password.*#wds.linkis.server.mybatis.datasource.password=$MYSQL_PASSWORD#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.dss.appjoint.scheduler.azkaban.address.*#wds.dss.appjoint.scheduler.azkaban.address=http://${AZKABAN_ADRESS_IP}:${AZKABAN_ADRESS_PORT}#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.gateway.ip.*#wds.linkis.gateway.ip=$GATEWAY_INSTALL_IP#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.gateway.port.*#wds.linkis.gateway.port=$GATEWAY_PORT#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.dss.appjoint.scheduler.project.store.dir.*#wds.dss.appjoint.scheduler.project.store.dir=$WDS_SCHEDULER_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "echo "$deployUser=$deployUser" >> $SERVER_HOME/$SERVERNAME/conf/token.properties"
-isSuccess "subsitution linkis.properties of $SERVERNAME"
-echo "<----------------$SERVERNAME:end------------------->"
-echo ""
-
-if [[ '2' = "$INSTALL_MODE" ]]||[[ '3' = "$INSTALL_MODE" ]];then
-##Flow execution Install
-PACKAGE_DIR=dss/dss-flow-execution-entrance
-SERVERNAME=dss-flow-execution-entrance
-SERVER_IP=$FLOW_EXECUTION_INSTALL_IP
-SERVER_PORT=$FLOW_EXECUTION_PORT
-SERVER_HOME=$DSS_INSTALL_HOME
-###Install flow execution
-installPackage
-###Update flow execution linkis.properties
-echo "$SERVERNAME-step4:update linkis.properties"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/linkis.properties
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.entrance.config.logPath.*#wds.linkis.entrance.config.logPath=$WORKSPACE_USER_ROOT_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.resultSet.store.path.*#wds.linkis.resultSet.store.path=$RESULT_SET_ROOT_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.gateway.url.*#wds.linkis.gateway.url=http://${GATEWAY_INSTALL_IP}:${GATEWAY_PORT}#g\" $SERVER_CONF_PATH"
-isSuccess "subsitution linkis.properties of $SERVERNAME"
-echo "<----------------$SERVERNAME:end------------------->"
-echo ""
-##Appjoint entrance Install
-PACKAGE_DIR=plugins/linkis/linkis-appjoint-entrance
-SERVERNAME=linkis-appjoint-entrance
-SERVER_IP=$APPJOINT_ENTRANCE_INSTALL_IP
-SERVER_PORT=$APPJOINT_ENTRANCE_PORT
-SERVER_HOME=$DSS_INSTALL_HOME
-###Install appjoint entrance
-installPackage
-###Update appjoint entrance linkis.properties
-echo "$SERVERNAME-step4:update linkis.properties"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/linkis.properties
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.entrance.config.logPath.*#wds.linkis.entrance.config.logPath=$WORKSPACE_USER_ROOT_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.resultSet.store.path.*#wds.linkis.resultSet.store.path=$RESULT_SET_ROOT_PATH#g\" $SERVER_CONF_PATH"
-isSuccess "subsitution linkis.properties of $SERVERNAME"
-echo "<----------------$SERVERNAME:end------------------->"
-echo ""
-##visualis-server Install
-PACKAGE_DIR=visualis-server
-SERVERNAME=visualis-server
-SERVER_IP=$VISUALIS_SERVER_INSTALL_IP
-SERVER_PORT=$VISUALIS_SERVER_PORT
-SERVER_HOME=$DSS_INSTALL_HOME
-###install visualis-server
-installVisualis
-###update visualis-server linkis.properties
-echo "$SERVERNAME-step4:update linkis.properties"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/linkis.properties
-if [ $VISUALIS_NGINX_IP == "127.0.0.1" ]||[ $VISUALIS_NGINX_IP == "0.0.0.0" ]; then
- VISUALIS_NGINX_IP=$ipaddr
-fi
-if [ $VISUALIS_SERVER_INSTALL_IP == "127.0.0.1" ]||[ $VISUALIS_SERVER_INSTALL_IP == "0.0.0.0" ]; then
- VISUALIS_SERVER_INSTALL_IP=$ipaddr
-fi
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.entrance.config.logPath.*#wds.linkis.entrance.config.logPath=$WORKSPACE_USER_ROOT_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.linkis.resultSet.store.path.*#wds.linkis.resultSet.store.path=$RESULT_SET_ROOT_PATH#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.dss.visualis.gateway.ip.*#wds.dss.visualis.gateway.ip=$GATEWAY_INSTALL_IP#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#wds.dss.visualis.gateway.port.*#wds.dss.visualis.gateway.port=$GATEWAY_PORT#g\" $SERVER_CONF_PATH"
-SERVER_CONF_PATH=$SERVER_HOME/$SERVERNAME/conf/application.yml
-executeCMD $SERVER_IP "sed -i \"s#address: 127.0.0.1#address: $VISUALIS_SERVER_INSTALL_IP#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#port: 9007#port: $VISUALIS_SERVER_PORT#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#url: http://0.0.0.0:0000/dss/visualis#url: http://$VISUALIS_NGINX_IP:$VISUALIS_NGINX_PORT/dss/visualis#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#address: 0.0.0.0#address: $VISUALIS_NGINX_IP#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#port: 0000#port: $VISUALIS_NGINX_PORT#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#defaultZone: http://127.0.0.1:20303/eureka/#defaultZone: http://$EUREKA_INSTALL_IP:$EUREKA_PORT/eureka/#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#url: jdbc:mysql://127.0.0.1:3306/xxx?characterEncoding=UTF-8#url: jdbc:mysql://$MYSQL_HOST:$MYSQL_PORT/$MYSQL_DB?characterEncoding=UTF-8#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#username: xxx#username: $MYSQL_USER#g\" $SERVER_CONF_PATH"
-executeCMD $SERVER_IP "sed -i \"s#password: xxx#password: $MYSQL_PASSWORD#g\" $SERVER_CONF_PATH"
-isSuccess "subsitution linkis.properties of $SERVERNAME"
-echo "<----------------$SERVERNAME:end------------------->"
-echo ""
-#APPJOINTS INSTALL
-echo "<----------------datachecker appjoint install start------------------->"
-APPJOINTPARENT=dss-appjoints
-APPJOINTNAME=datachecker
-#datachecker appjoint install
-installAppjoints
-echo "$APPJOINTNAME:subsitution conf"
-APPJOINTNAME_CONF_PATH_PATENT=$SERVER_HOME/$APPJOINTPARENT/$APPJOINTNAME/appjoint.properties
-executeCMD $SERVER_IP "sed -i \"s#job.datachecker.jdo.option.url.*#job.datachecker.jdo.option.url=$HIVE_META_URL#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-executeCMD $SERVER_IP "sed -i \"s#job.datachecker.jdo.option.username.*#job.datachecker.jdo.option.username=$HIVE_META_USER#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-executeCMD $SERVER_IP "sed -i \"s#job.datachecker.jdo.option.password.*#job.datachecker.jdo.option.password=$HIVE_META_PASSWORD#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-isSuccess "subsitution conf of datachecker"
-echo "<----------------datachecker appjoint install end------------------->"
-echo ""
-echo "<----------------eventchecker appjoint install start------------------->"
-APPJOINTPARENT=dss-appjoints
-APPJOINTNAME=eventchecker
-#eventchecker appjoint install
-installAppjoints
-echo "$APPJOINTNAME:subsitution conf"
-APPJOINTNAME_CONF_PATH_PATENT=$SERVER_HOME/$APPJOINTPARENT/$APPJOINTNAME/appjoint.properties
-executeCMD $SERVER_IP "sed -i \"s#msg.eventchecker.jdo.option.url.*#msg.eventchecker.jdo.option.url=jdbc:mysql://${MYSQL_HOST}:${MYSQL_PORT}/${MYSQL_DB}?characterEncoding=UTF-8#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-executeCMD $SERVER_IP "sed -i \"s#msg.eventchecker.jdo.option.username.*#msg.eventchecker.jdo.option.username=$MYSQL_USER#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-executeCMD $SERVER_IP "sed -i \"s#msg.eventchecker.jdo.option.password.*#msg.eventchecker.jdo.option.password=$MYSQL_PASSWORD#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-isSuccess "subsitution conf of eventchecker"
-echo "<----------------$APPJOINTNAME:end------------------->"
-echo ""
-echo "<----------------visualis appjoint install start------------------->"
-APPJOINTPARENT=dss-appjoints
-APPJOINTNAME=visualis
-#visualis appjoint install
-installAppjoints
-echo "<----------------$APPJOINTNAME:end------------------->"
-fi
-
-##lite and sample version does not install qualitis APPJoint and scheduis APPJoint
-if [[ '3' = "$INSTALL_MODE" ]];then
-echo ""
-echo "<----------------qualitis appjoint install start------------------->"
-APPJOINTPARENT=dss-appjoints
-APPJOINTNAME=qualitis
-#qualitis appjoint install
-installAppjoints
-APPJOINTNAME_CONF_PATH_PATENT=$SERVER_HOME/$APPJOINTPARENT/$APPJOINTNAME/appjoint.properties
-executeCMD $SERVER_IP "sed -i \"s#baseUrl=http://127.0.0.1:8090#baseUrl=http://$QUALITIS_ADRESS_IP:$QUALITIS_ADRESS_PORT#g\" $APPJOINTNAME_CONF_PATH_PATENT"
-isSuccess "subsitution conf of qualitis"
-echo "<----------------$APPJOINTNAME:end------------------->"
-echo ""
-echo "<----------------schedulis appjoint install start------------------->"
-APPJOINTPARENT=dss-appjoints
-APPJOINTNAME=schedulis
-#schedulis appjoint install
-installAppjoints
-isSuccess "subsitution conf of schedulis"
-echo "<----------------$APPJOINTNAME:end------------------->"
-fi
diff --git a/bin/start-all.sh b/bin/start-all.sh
deleted file mode 100644
index 98a07f6bdc..0000000000
--- a/bin/start-all.sh
+++ /dev/null
@@ -1,189 +0,0 @@
-#!/usr/bin/env bash
-#
-# Copyright 2019 WeBank
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-# Start all dss applications
-info="We will start all dss applications, it will take some time, please wait"
-echo ${info}
-
-#Actively load user env
-source /etc/profile
-source ~/.bash_profile
-
-shellDir=`dirname $0`
-
-workDir=`cd ${shellDir}/..;pwd`
-
-CONF_DIR="${workDir}"/conf
-
-export LINKIS_DSS_CONF_FILE=${LINKIS_DSS_CONF_FILE:-"${CONF_DIR}/config.sh"}
-export DISTRIBUTION=${DISTRIBUTION:-"${CONF_DIR}/config.sh"}
-source $LINKIS_DSS_CONF_FILE
-source ${DISTRIBUTION}
-function isSuccess(){
-if [ $? -ne 0 ]; then
- echo "ERROR: " + $1
- exit 1
-else
- echo "INFO:" + $1
-fi
-}
-local_host="`hostname --fqdn`"
-
-ipaddr=$(ip addr | awk '/^[0-9]+: / {}; /inet.*global/ {print gensub(/(.*)\/(.*)/, "\\1", "g", $2)}'|awk 'NR==1')
-
-function isLocal(){
- if [ "$1" == "127.0.0.1" ];then
- return 0
- elif [ $1 == "localhost" ]; then
- return 0
- elif [ $1 == $local_host ]; then
- return 0
- elif [ $1 == $ipaddr ]; then
- return 0
- fi
- return 1
-}
-
-function executeCMD(){
- isLocal $1
- flag=$?
- echo "Is local "$flag
- if [ $flag == "0" ];then
- eval $2
- else
- ssh -p $SSH_PORT $1 $2
- fi
-
-}
-
-#if there is no LINKIS_INSTALL_HOME,we need to source config again
-if [ -z ${DSS_INSTALL_HOME} ];then
- echo "Warning: DSS_INSTALL_HOME does not exist, we will source config"
- if [ ! -f "${LINKIS_DSS_CONF_FILE}" ];then
- echo "Error: can not find config file, start applications failed"
- exit 1
- else
- source ${LINKIS_DSS_CONF_FILE}
- fi
-fi
-
-function startApp(){
-echo "<-------------------------------->"
-echo "Begin to start $SERVER_NAME"
-SERVER_BIN=${DSS_INSTALL_HOME}/${SERVER_NAME}/bin
-#echo $SERVER_BIN
-SERVER_LOCAL_START_CMD="dos2unix ${SERVER_BIN}/* > /dev/null 2>&1; dos2unix ${SERVER_BIN}/../conf/* > /dev/null 2>&1;sh ${SERVER_BIN}/start-${SERVER_NAME}.sh > /dev/null 2>&1 &"
-SERVER_REMOTE_START_CMD="source /etc/profile;source ~/.bash_profile;cd ${SERVER_BIN}; dos2unix ./* > /dev/null 2>&1; dos2unix ../conf/* > /dev/null 2>&1; sh start-${SERVER_NAME}.sh > /dev/null 2>&1"
-
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-if ! executeCMD $SERVER_IP "test -e $SERVER_BIN"; then
- echo "<-------------------------------->"
- echo "$SERVER_NAME is not installed,the start steps will be skipped"
- echo "<-------------------------------->"
- return
-fi
-
-isLocal $SERVER_IP
-flag=$?
-echo "Is local "$flag
-if [ $flag == "0" ];then
- eval $SERVER_LOCAL_START_CMD
-else
- ssh -p $SSH_PORT $SERVER_IP $SERVER_REMOTE_START_CMD
-fi
-isSuccess "End to start $SERVER_NAME"
-echo "<-------------------------------->"
-sleep 15 #for Eureka register
-}
-
-#dss-server
-SERVER_NAME=dss-server
-SERVER_IP=$DSS_SERVER_INSTALL_IP
-startApp
-
-#dss-flow-execution-entrance
-SERVER_NAME=dss-flow-execution-entrance
-SERVER_IP=$FLOW_EXECUTION_INSTALL_IP
-startApp
-
-#dss-flow-execution-entrance
-SERVER_NAME=linkis-appjoint-entrance
-SERVER_IP=$APPJOINT_ENTRANCE_INSTALL_IP
-startApp
-
-#visualis-server
-SERVER_NAME=visualis-server
-SERVER_IP=$VISUALIS_SERVER_INSTALL_IP
-startApp
-
-echo ""
-echo "Start to check all dss microservice"
-echo ""
-
-function checkServer(){
-echo "<-------------------------------->"
-echo "Begin to check $SERVER_NAME"
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-SERVER_BIN=${SERVER_HOME}/${SERVER_NAME}/bin
-
-if ! executeCMD $SERVER_IP "test -e ${DSS_INSTALL_HOME}/${SERVER_NAME}"; then
- echo "$SERVER_NAME is not installed,the checkServer steps will be skipped"
- return
-fi
-
-sh $workDir/bin/checkServices.sh $SERVER_NAME $SERVER_IP $SERVER_PORT
-isSuccess "start $SERVER_NAME "
-sleep 3
-echo "<-------------------------------->"
-}
-
-#check dss-server
-SERVER_NAME=dss-server
-SERVER_IP=$DSS_SERVER_INSTALL_IP
-SERVER_PORT=$DSS_SERVER_PORT
-checkServer
-
-
-#check dss-flow-execution-entrance
-SERVER_NAME=dss-flow-execution-entrance
-SERVER_IP=$FLOW_EXECUTION_INSTALL_IP
-SERVER_PORT=$FLOW_EXECUTION_PORT
-checkServer
-
-#check linkis-appjoint-entrance
-SERVER_NAME=linkis-appjoint-entrance
-SERVER_IP=$APPJOINT_ENTRANCE_INSTALL_IP
-SERVER_PORT=$APPJOINT_ENTRANCE_PORT
-checkServer
-
-
-#check visualis-server
-sleep 10 #visualis service need more time to register
-SERVER_NAME=visualis-server
-SERVER_IP=$VISUALIS_SERVER_INSTALL_IP
-SERVER_PORT=$VISUALIS_SERVER_PORT
-checkServer
-
-echo "DSS started successfully"
diff --git a/bin/stop-all.sh b/bin/stop-all.sh
deleted file mode 100644
index 838b9babc9..0000000000
--- a/bin/stop-all.sh
+++ /dev/null
@@ -1,133 +0,0 @@
-#!/usr/bin/env bash
-#
-# Copyright 2019 WeBank
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-
-
-# Start all dss applications
-info="We will stop all dss applications, it will take some time, please wait"
-echo ${info}
-
-#Actively load user env
-source ~/.bash_profile
-
-workDir=`dirname "${BASH_SOURCE-$0}"`
-workDir=`cd "$workDir"; pwd`
-
-
-CONF_DIR="${workDir}"/../conf
-export LINKIS_DSS_CONF_FILE=${LINKIS_DSS_CONF_FILE:-"${CONF_DIR}/config.sh"}
-export DISTRIBUTION=${DISTRIBUTION:-"${CONF_DIR}/config.sh"}
-source ${DISTRIBUTION}
-
-local_host="`hostname --fqdn`"
-ipaddr=$(ip addr | awk '/^[0-9]+: / {}; /inet.*global/ {print gensub(/(.*)\/(.*)/, "\\1", "g", $2)}'|awk 'NR==1')
-
-function isSuccess(){
-if [ $? -ne 0 ]; then
- echo "ERROR: " + $1
- exit 1
-else
- echo "INFO:" + $1
-fi
-}
-
-function isLocal(){
- if [ "$1" == "127.0.0.1" ];then
- return 0
- elif [ $1 == "localhost" ]; then
- return 0
- elif [ $1 == $local_host ]; then
- return 0
- elif [ $1 == $ipaddr ]; then
- return 0
- fi
- return 1
-}
-
-function executeCMD(){
- isLocal $1
- flag=$?
- echo "Is local "$flag
- if [ $flag == "0" ];then
- eval $2
- else
- ssh -p $SSH_PORT $1 $2
- fi
-
-}
-
-
-#if there is no LINKIS_INSTALL_HOME,we need to source config again
-if [ -z ${DSS_INSTALL_HOME} ];then
- echo "Warning: DSS_INSTALL_HOME does not exist, we will source config"
- if [ ! -f "${LINKIS_DSS_CONF_FILE}" ];then
- echo "Error: can not find config file, stop applications failed"
- exit 1
- else
- source ${LINKIS_DSS_CONF_FILE}
- fi
-fi
-
-function stopAPP(){
-echo "<-------------------------------->"
-echo "Begin to stop $SERVER_NAME"
-SERVER_BIN=${DSS_INSTALL_HOME}/${SERVER_NAME}/bin
-SERVER_LOCAL_STOP_CMD="sh ${SERVER_BIN}/stop-${SERVER_NAME}.sh"
-SERVER_REMOTE_STOP_CMD="source /etc/profile;source ~/.bash_profile;cd ${SERVER_BIN}; sh stop-${SERVER_NAME}.sh "
-if test -z "$SERVER_IP"
-then
- SERVER_IP=$local_host
-fi
-
-if ! executeCMD $SERVER_IP "test -e ${DSS_INSTALL_HOME}/${SERVER_NAME}"; then
- echo "$SERVER_NAME is not installed,the stop steps will be skipped"
- return
-fi
-
-isLocal $SERVER_IP
-flag=$?
-echo "Is local "$flag
-if [ $flag == "0" ];then
- eval $SERVER_LOCAL_STOP_CMD
-else
- ssh -p $SSH_PORT $SERVER_IP $SERVER_REMOTE_STOP_CMD
-fi
-echo "<-------------------------------->"
-sleep 3
-}
-
-#dss-server
-SERVER_NAME=dss-server
-SERVER_IP=$DSS_SERVER_INSTALL_IP
-stopAPP
-
-#dss-flow-execution-entrance
-SERVER_NAME=dss-flow-execution-entrance
-SERVER_IP=$FLOW_EXECUTION_INSTALL_IP
-stopAPP
-
-#dss-flow-execution-entrance
-SERVER_NAME=linkis-appjoint-entrance
-SERVER_IP=$APPJOINT_ENTRANCE_INSTALL_IP
-stopAPP
-
-#visualis-server
-SERVER_NAME=visualis-server
-SERVER_IP=$VISUALIS_SERVER_INSTALL_IP
-stopAPP
-
-echo "stop-all shell script executed completely"
diff --git a/datachecker-appjoint/pom.xml b/datachecker-appjoint/pom.xml
deleted file mode 100644
index d609c3ab32..0000000000
--- a/datachecker-appjoint/pom.xml
+++ /dev/null
@@ -1,139 +0,0 @@
-
-
-
-
-
- dss
- com.webank.wedatasphere.dss
- 0.9.1
-
- 4.0.0
-
- dss-datachecker-appjoint
-
-
-
- org.apache.commons
- commons-lang3
- 3.4
-
-
-
- com.alibaba
- druid
- 1.0.28
-
-
-
- com.webank.wedatasphere.dss
- dss-appjoint-core
- ${dss.version}
- provided
- true
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- log4j
- log4j
- 1.2.17
-
-
-
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-deploy-plugin
-
-
-
- net.alchim31.maven
- scala-maven-plugin
-
-
- org.apache.maven.plugins
- maven-jar-plugin
-
-
- org.apache.maven.plugins
- maven-assembly-plugin
- 2.3
- false
-
-
- make-assembly
- package
-
- single
-
-
-
- src/main/assembly/distribution.xml
-
-
-
-
-
- false
- dss-datachecker-appjoint
- false
- false
-
- src/main/assembly/distribution.xml
-
-
-
-
-
-
- src/main/java
-
- **/*.xml
-
-
-
- src/main/resources
-
- **/*.properties
- **/application.yml
- **/bootstrap.yml
- **/log4j2.xml
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/datachecker-appjoint/src/main/assembly/distribution.xml b/datachecker-appjoint/src/main/assembly/distribution.xml
deleted file mode 100644
index 503ab0f381..0000000000
--- a/datachecker-appjoint/src/main/assembly/distribution.xml
+++ /dev/null
@@ -1,136 +0,0 @@
-
-
-
- dss-datachecker-appjoint
-
- zip
-
- true
- datachecker
-
-
-
-
-
- lib
- true
- true
- false
- true
- true
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- ${basedir}/src/main/resources
-
- appjoint.properties
-
- 0777
- /
- unix
-
-
-
- ${basedir}/src/main/resources
-
- log4j.properties
- log4j2.xml
-
- 0777
- conf
- unix
-
-
-
-
-
-
diff --git a/datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/DataCheckerDao.java b/datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/DataCheckerDao.java
deleted file mode 100644
index d84a0d4bc6..0000000000
--- a/datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/DataCheckerDao.java
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package com.webank.wedatasphere.dss.appjoint.schedulis.jobtype.connector;
-
-import com.alibaba.druid.pool.DruidDataSource;
-import com.webank.wedatasphere.dss.appjoint.schedulis.jobtype.entity.DataChecker;
-import org.apache.log4j.Logger;
-
-import javax.sql.DataSource;
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-import java.util.stream.Collectors;
-
-public class DataCheckerDao {
-
- private static final String SQL_SOURCE_TYPE_JOB_TABLE =
- "SELECT * FROM DBS d JOIN TBLS t ON t.DB_ID = d.DB_ID WHERE d.NAME=? AND t.TBL_NAME=?";
-
- private static final String SQL_SOURCE_TYPE_JOB_PARTITION =
- "SELECT * FROM DBS d JOIN TBLS t ON t.DB_ID = d.DB_ID JOIN PARTITIONS p ON p.TBL_ID = t.TBL_ID WHERE d.NAME=? AND t.TBL_NAME=? AND p.PART_NAME=?";
-
- private static DataSource jobDS;
- private static DataCheckerDao instance;
-
- public static DataCheckerDao getInstance() {
- if (instance == null) {
- synchronized (DataCheckerDao.class) {
- if (instance == null) {
- instance = new DataCheckerDao();
- }
- }
- }
- return instance;
- }
-
- public boolean validateTableStatusFunction(Properties props, Logger log) {
- if (jobDS == null) {
- jobDS = DataDruidFactory.getJobInstance(props, log);
- if (jobDS == null) {
- log.error("Error getting Druid DataSource instance");
- return false;
- }
- }
- removeBlankSpace(props);
- log.info("=============================Data Check Start==========================================");
- String dataCheckerInfo = props.getProperty(DataChecker.DATA_OBJECT);
- log.info("(DataChecker info) database table partition info : " + dataCheckerInfo);
- long waitTime = Long.valueOf(props.getProperty(DataChecker.WAIT_TIME, "1")) * 3600 * 1000;
- int queryFrequency = Integer.valueOf(props.getProperty(DataChecker.QUERY_FREQUENCY, "30000"));
-// String timeScape = props.getProperty(DataChecker.TIME_SCAPE, "NULL");
- log.info("(DataChecker info) wait time : " + waitTime);
- log.info("(DataChecker info) query frequency : " + queryFrequency);
-// log.info("(DataChecker info) time scape : " + timeScape);
- List