Skip to content

Commit 794b6fd

Browse files
committed
solve conflicts
2 parents ca24c41 + 3b0a508 commit 794b6fd

File tree

2,694 files changed

+148459
-66798
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

2,694 files changed

+148459
-66798
lines changed

.github/workflows/build.yml

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,5 +51,6 @@ jobs:
5151
- name: Build frontend by node.js
5252
run: |
5353
cd web
54-
npm install
54+
npm install lerna -g
55+
lerna bootstrap
5556
npm run build

.gitignore

Lines changed: 60 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -1,88 +1,110 @@
1-
*.iml
21
.idea
3-
.vscode
2+
.idea/*
3+
44
.DS_Store
5-
*.class
65

76
assembly/target
87
assembly/dss-package/target
8+
9+
10+
# dss-commons
11+
dss-commons/dss-sender-service/target
12+
13+
# dss-appconn
914
dss-appconn/appconns/dss-datachecker-appconn/target
1015
dss-appconn/appconns/dss-eventchecker-appconn/target
1116
dss-appconn/appconns/dss-orchestrator-framework-appconn/target
1217
dss-appconn/appconns/dss-schedulis-appconn/target
18+
dss-appconn/appconns/dss-sendemail-appconn/esb-email-support/target
1319
dss-appconn/appconns/dss-sendemail-appconn/sendemail-appconn-core/target
14-
dss-appconn/appconns/dss-visualis-appconn/target
1520
dss-appconn/appconns/dss-workflow-appconn/target
21+
dss-appconn/appconns/dss-sso-appconn/target
22+
dss-appconn/appconns/dss-scriptis-appconn-appconn/target
1623
dss-appconn/dss-appconn-core/target
1724
dss-appconn/dss-appconn-loader/target
25+
dss-appconn/dss-schedule-appconn-core/target
26+
dss-appconn/linkis-appconn-engineplugin/target
27+
dss-appconn/appconns/dss-dolphinscheduler-appconn/target
1828
dss-appconn/dss-appconn-manager/dss-appconn-manager-client/target
1929
dss-appconn/dss-appconn-manager/dss-appconn-manager-core/target
2030
dss-appconn/dss-scheduler-appconn/target
21-
dss-appconn/linkis-appconn-engineplugin/target
2231

32+
# dss-apps
2333
dss-apps/dss-apiservice-server/target
24-
dss-apps/dss-datapipe-server/target
34+
dss-apps/dss-scriptis-server/target
35+
36+
#dss-guide
37+
dss-apps/dss-user-guide/dss-user-guide-server/src/main/resources/
38+
dss-apps/dss-user-guide/dss-user-guide-server/target
2539

40+
# dss-commons
2641
dss-commons/dss-common/target
2742
dss-commons/dss-contextservice/target
28-
dss-commons/dss-sender-service/target
2943

44+
# dss-framework
3045
dss-framework/dss-appconn-framework/target
3146
dss-framework/dss-framework-common/target
3247
dss-framework/dss-framework-orchestrator-server/target
3348
dss-framework/dss-framework-project-server/target
3449
dss-framework/dss-framework-workspace-server/target
3550
dss-framework/framework-plugins/dss-framework-orchestrator-publish/target
51+
dss-framework/framework-plugins/dss-framework-release-server/target
52+
dss-framework/framework-plugins/dss-framework-migrate-server/target
53+
dss-framework/dss-framework-admin/target
54+
dss-framework/dss-framework-sql-template/target
55+
dss-framework/dss-framework-dbapi-server/target
56+
dss-framework/dss-framework-admin-service/target
3657

37-
dss-orchestrator/dss-orchestrator-core/target
58+
59+
# dss-orchestrator
3860
dss-orchestrator/dss-orchestrator-common/target
39-
dss-orchestrator/dss-orchestrator-conversion-standard/target
61+
dss-orchestrator/dss-orchestrator-core/target
4062
dss-orchestrator/dss-orchestrator-db/target
4163
dss-orchestrator/dss-orchestrator-loader/target
4264
dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/target
4365
dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/target
4466
dss-orchestrator/orchestrators/dss-workflow/dss-workflow-common/target
67+
dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/target
68+
dss-orchestrator/dss-orchestrator-conversion-standard/target
4569
dss-orchestrator/orchestrators/dss-workflow/dss-workflow-conversion-standard/target
4670
dss-orchestrator/orchestrators/dss-workflow/dss-workflow-sdk/target
47-
dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/target
4871

72+
# dss-standars
4973
dss-standard/dss-standard-common/target
50-
dss-standard/development-standard/development-process-standard/target
51-
dss-standard/development-standard/development-process-standard-execution/target
5274
dss-standard/sso-standard/origin-sso-integration-standard/target
5375
dss-standard/sso-standard/spring-origin-sso-integration-plugin/target
5476
dss-standard/sso-standard/sso-integration-standard/target
77+
dss-standard/development-standard/development-process-standard/target
78+
dss-standard/development-standard/development-process-standard-execution/target
5579
dss-standard/structure-standard/dss-project-plugin/target
5680
dss-standard/structure-standard/dss-role-plugin/target
57-
dss-standard/structure-standard/spring-origin-dss-project-plugin/target
5881
dss-standard/structure-standard/dss-structure-integration-standard/target
82+
dss-standard/structure-standard/spring-origin-dss-project-plugin/target
83+
84+
#dss-data-api
85+
dss-apps/dss-data-api/dss-data-api-server/src/main/resources
86+
dss-apps/dss-data-api/dss-api-sql-template/target
87+
dss-apps/dss-data-api/dss-data-api-server/target
88+
89+
#dss-data-governance
90+
dss-apps/dss-data-governance/dss-data-governance-server/src/main/resources
91+
dss-apps/dss-data-governance/dss-data-governance-server/target
92+
dss-apps/dss-data-governance/dss-data-governance-common/target
93+
dss-apps/dss-data-governance/dss-data-asset-server/target
94+
dss-apps/dss-data-governance/dss-data-classification-server/target
95+
dss-apps/dss-data-governance/dss-data-warehouse-dao/target
96+
dss-apps/dss-data-governance/dss-data-warehouse-service/target
97+
dss-apps/dss-data-governance/dss-data-warehouse-server/target
5998

99+
100+
# plugins
101+
plugins/azkaban/linkis-jobtype/target
60102
plugins/linkis/dss-gateway-support/target
61103

62-
datachecker-appjoint/target/
63-
dss-appjoint-auth/target/
64-
dss-appjoint-core/target/
65-
dss-appjoint-loader/target/
66-
dss-application/target/
67-
dss-azkaban-scheduler-appjoint/target/
68-
dss-common/target/
69-
dss-flow-execution-entrance/target/
70-
dss-linkis-node-execution/target/
71-
dss-scheduler-appjoint-core/target/
72-
dss-server/target/
73-
eventchecker-appjoint/target/
74-
plugins/azkaban/linkis-jobtype/target/
75-
plugins/linkis/linkis-appjoint-entrance/target/
76-
77-
sendemail-appjoint/sendemail-core/target/
78-
visualis-appjoint/appjoint/target/
79-
80-
dss-user-manager/target/
81104
logs
82-
### Example user template template
83-
### Example user template
84-
85-
# IntelliJ project files
105+
logs/*
86106

87-
out
88-
gen
107+
*.iml
108+
/plugins/dolphinscheduler/dss-dolphinscheduler-client/target
109+
/plugins/dolphinscheduler/dolphinscheduler-prod-metrics/target
110+
/plugins/dolphinscheduler/dss-dolphinscheduler-token/target

assembly/bin/appconn-install.sh

Lines changed: 63 additions & 51 deletions
Original file line numberDiff line numberDiff line change
@@ -22,62 +22,80 @@ function isSuccess(){
2222
echo "Failed to " + $1
2323
exit 1
2424
else
25-
echo "Succeed to" + $1
25+
echo "Succeed to " + $1
2626
fi
2727
}
2828

2929
PROC_NAME=DSSProjectServerApplication
30-
ProcNumber=`ps -ef |grep -w $PROC_NAME|grep -v grep|wc -l`
30+
ProcNumber=`ps -ef | grep -w $PROC_NAME | grep -v grep | wc -l`
3131
if [ $ProcNumber -le 0 ];then
32-
echo "${PROC_NAME} is not running,Please check whether DSS is installed"
33-
exit 1000
32+
echo "${PROC_NAME} is not running, please ensure whether DSS is installed and started."
33+
exit 10
3434
else
35-
echo "Begine to install appconn"
35+
echo "Begine to install new AppConn plugin..."
3636
fi
3737

3838
##choose install mysql mode
3939
function initInstallAppConn() {
40-
echo "Please select the type of installation component?"
41-
echo " 1: schedulis"
42-
echo " 2: visualis"
43-
echo " 3:Your AppConn Name"
44-
echo " 4:exit"
45-
read -p "Please input the choice:" idx
46-
if [[ '1' = "$idx" ]];then
47-
APPCONN_NAME="schedulis"
48-
elif [[ '2' = "$idx" ]];then
49-
APPCONN_NAME="visualis"
50-
elif [[ '4' = "$idx" ]];then
51-
echo "no choice,exit!"
52-
exit 1
40+
if [ ! -z $1 ];then
41+
APPCONN_NAME=$1
42+
echo "Begin to install default appconn:$APPCONN_NAME"
5343
else
54-
APPCONN_NAME=$idx
55-
fi
56-
echo "Current installation component is ${APPCONN_NAME}"
57-
58-
echo ""
59-
echo "If this machine(127.0.0.1) is installed, enter 1"
60-
echo "For others, you need to enter a complete IP address."
61-
read -p "Please enter the ip of appconn: " ip
62-
APPCONN_INSTALL_IP=$ip
63-
if [[ '1' = "$ip" ]];then
64-
APPCONN_INSTALL_IP="127.0.0.1"
44+
echo "Please input the name of installation AppConn, e.g: schedulis."
45+
read -p "Please input the AppConn name:" idx
46+
if [[ 'exit' = "$idx" ]];then
47+
echo "exit!"
48+
exit 1
49+
else
50+
APPCONN_NAME=$idx
51+
fi
52+
echo "Current installation AppConn is ${APPCONN_NAME}"
53+
echo ""
54+
echo "Please input the installed IP address of $APPCONN_NAME."
55+
echo "e.g: if you have installed $APPCONN_NAME with 192.168.1.1:8080, please input ip in 192.168.1.1"
56+
read -p "Please input the IP: " ip
57+
APPCONN_INSTALL_IP=$ip
58+
echo ""
59+
echo "e.g: if you have installed $APPCONN_NAME with 192.168.1.1:8080, please input port in 8080"
60+
read -p "Please input the port:" port
61+
APPCONN_INSTALL_PORT=$port
6562
fi
66-
echo "You input ip is ${APPCONN_INSTALL_IP}"
6763

6864
echo ""
69-
read -p "Please enter the port of appconn:" port
70-
APPCONN_INSTALL_PORT=$port
71-
echo "You input ip is ${APPCONN_INSTALL_PORT}"
65+
replaceCommonIp
66+
echo "The base url of $APPCONN_NAME is http://${APPCONN_INSTALL_IP}:${APPCONN_INSTALL_PORT}/."
7267
}
7368

7469
function replaceCommonIp() {
7570
if [[ $APPCONN_INSTALL_IP == "127.0.0.1" ]] || [[ $APPCONN_INSTALL_IP == "0.0.0.0" ]];then
76-
echo "APPCONN_INSTALL_IP is equals $APPCONN_INSTALL_IP, we will change it to ip address"
71+
echo "since you input the ip to $APPCONN_INSTALL_IP, we will change it to real ip $LOCAL_IP."
7772
APPCONN_INSTALL_IP=$LOCAL_IP
7873
fi
7974
}
8075

76+
function replaceDefaultAppconnSql() {
77+
sed -i "s#EVENTCHECKER_JDBC_URL#$EVENTCHECKER_JDBC_URL#g" $DB_DML_PATH
78+
sed -i "s#EVENTCHECKER_JDBC_USERNAME#$EVENTCHECKER_JDBC_USERNAME#g" $DB_DML_PATH
79+
sed -i "s#EVENTCHECKER_JDBC_PASSWORD#$EVENTCHECKER_JDBC_PASSWORD#g" $DB_DML_PATH
80+
81+
sed -i "s#DATACHECKER_JOB_JDBC_URL#$DATACHECKER_JOB_JDBC_URL#g" $DB_DML_PATH
82+
sed -i "s#DATACHECKER_JOB_JDBC_USERNAME#$DATACHECKER_JOB_JDBC_USERNAME#g" $DB_DML_PATH
83+
sed -i "s#DATACHECKER_JOB_JDBC_PASSWORD#$DATACHECKER_JOB_JDBC_PASSWORD#g" $DB_DML_PATH
84+
85+
sed -i "s#DATACHECKER_BDP_JDBC_URL#$DATACHECKER_BDP_JDBC_URL#g" $DB_DML_PATH
86+
sed -i "s#DATACHECKER_BDP_JDBC_USERNAME#$DATACHECKER_BDP_JDBC_USERNAME#g" $DB_DML_PATH
87+
sed -i "s#DATACHECKER_BDP_JDBC_PASSWORD#$DATACHECKER_BDP_JDBC_PASSWORD#g" $DB_DML_PATH
88+
89+
sed -i "s#BDP_MASK_IP#127.0.0.1#g" $DB_DML_PATH
90+
sed -i "s#BDP_MASK_PORT#8087#g" $DB_DML_PATH
91+
92+
sed -i "s#EMAIL_HOST#${EMAIL_HOST}#g" $DB_DML_PATH
93+
sed -i "s#EMAIL_PORT#${EMAIL_PORT}#g" $DB_DML_PATH
94+
sed -i "s#EMAIL_USERNAME#${EMAIL_USERNAME}#g" $DB_DML_PATH
95+
sed -i "s#EMAIL_PASSWORD#${EMAIL_PASSWORD}#g" $DB_DML_PATH
96+
sed -i "s#EMAIL_PROTOCOL#${EMAIL_PROTOCOL}#g" $DB_DML_PATH
97+
}
98+
8199
##choose execute mysql mode
82100
function executeSQL() {
83101
TEMP_DB_DML_PATH=${SOURCE_ROOT}/dss-appconns/${APPCONN_NAME}/db
@@ -86,28 +104,22 @@ function executeSQL() {
86104
sed -i "s/APPCONN_INSTALL_IP/$APPCONN_INSTALL_IP/g" $DB_DML_PATH
87105
sed -i "s/APPCONN_INSTALL_PORT/$APPCONN_INSTALL_PORT/g" $DB_DML_PATH
88106
sed -i "s#DSS_INSTALL_HOME_VAL#$DSS_INSTALL_HOME#g" $DB_DML_PATH
107+
if [ ! -z $1 ];then
108+
replaceDefaultAppconnSql
109+
fi
89110
mysql -h$MYSQL_HOST -P$MYSQL_PORT -u$MYSQL_USER -p$MYSQL_PASSWORD -D$MYSQL_DB --default-character-set=utf8 -e "source $DB_DML_PATH"
90-
isSuccess "source $DB_DML_PATH"
91-
echo "the table update finished"
111+
isSuccess "initialize the database settings $DB_DML_PATH"
112+
echo "initialize the $TEMP_DB_DML_PATH/init.sql for $APPCONN_NAME succeed."
92113
}
93114

94115
echo ""
95-
echo "step1:Initialize installation settings"
96-
initInstallAppConn
97-
echo ""
98-
99-
echo "step2:replaceIp"
100-
replaceCommonIp
101-
echo ""
102-
103-
echo "step3:update database"
104-
executeSQL
116+
echo "Step1: get the AppConn basic settings."
117+
initInstallAppConn $1
105118
echo ""
106119

107-
echo "step4:refresh appconn load"
108-
curl -H "Token-Code:BML-AUTH" -H "Token-User:hadoop" -X GET http://${GATEWAY_INSTALL_IP}:${GATEWAY_PORT}/api/rest_j/v1/dss/framework/project/appconn/${APPCONN_NAME}/load
120+
echo "Step2: initialize the database settings."
121+
executeSQL $1
109122
echo ""
110123

111-
echo ""
112-
echo "step5:Restart the DSS service,please use sbin/dss-start-all.sh to restart it!"
113-
echo ""
124+
echo "Step3: load the plugin of $APPCONN_NAME AppConn in DSS."
125+
sh $SOURCE_ROOT/bin/appconn-refresh.sh $APPCONN_NAME

assembly/bin/appconn-refresh.sh

Lines changed: 57 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,57 @@
1+
#!/bin/sh
2+
3+
if [ -z $SOURCE_ROOT ]; then
4+
#Actively load user env
5+
source ~/.bashrc
6+
shellDir=`dirname $0`
7+
workDir=`cd ${shellDir}/..;pwd`
8+
SOURCE_ROOT=${workDir}
9+
#load config
10+
source ${SOURCE_ROOT}/conf/config.sh
11+
source ${SOURCE_ROOT}/conf/db.sh
12+
fi
13+
14+
function isSuccess(){
15+
if [ $? -ne 0 ]; then
16+
echo "Failed to " + $1
17+
exit 1
18+
else
19+
echo "Succeed to " + $1
20+
fi
21+
}
22+
23+
if [ -z $1 ];then
24+
if [ -z $APPCONN_NAME ]; then
25+
APPCONN_NAME=''
26+
echo "Please input the name of refreshing AppConn, e.g: schedulis."
27+
read -p "Please input the AppConn name: " APPCONN_NAME
28+
fi
29+
30+
echo ""
31+
echo "Try to refresh the plugin of $APPCONN_NAME AppConn in all DSS micro-services."
32+
echo "The following 2 ways can take effect:"
33+
echo "1. restart DSS, we will use ${SOURCE_ROOT}/sbin/dss-start-all.sh to restart it!"
34+
echo "2. do nothing, just wait for 5 minutes. Since the DSS micro-services will refresh all the AppConn plugins every 10 minutes."
35+
echo ""
36+
read -p "Please input the choise: " choise
37+
if [[ '1' = "$choise" ]]; then
38+
echo "You chose to restart DSS, now try to restart DSS..."
39+
sh $SOURCE_ROOT/sbin/dss-start-all.sh
40+
else
41+
echo "You chose to wait for 5 minutes."
42+
echo "Now try to call dss-framework-project to reload the plugin of $APPCONN_NAME AppConn."
43+
curl -H "Token-Code:BML-AUTH" -H "Token-User:hadoop" -X GET http://${GATEWAY_INSTALL_IP}:${GATEWAY_PORT}/api/rest_j/v1/dss/framework/project/appconn/${APPCONN_NAME}/load
44+
isSuccess "reload the plugin of $APPCONN_NAME AppConn in dss-framework-project."
45+
echo "Now please wait for 5 minutes, then all of the DSS micro-services will refresh the ${APPCONN_NAME} AppConn plugin."
46+
echo ""
47+
exit 0
48+
fi
49+
else
50+
APPCONN_NAME=$1
51+
echo "Now try to call dss-framework-project to reload the plugin of $APPCONN_NAME AppConn."
52+
curl -H "Token-Code:BML-AUTH" -H "Token-User:hadoop" -X GET http://${GATEWAY_INSTALL_IP}:${GATEWAY_PORT}/api/rest_j/v1/dss/framework/project/appconn/${APPCONN_NAME}/load
53+
isSuccess "reload the plugin of $APPCONN_NAME AppConn in dss-framework-project."
54+
echo "Now please wait for 5 minutes, then all of the DSS micro-services will refresh the ${APPCONN_NAME} AppConn plugin."
55+
echo ""
56+
exit 0
57+
fi

0 commit comments

Comments
 (0)