From 02dbd0369be5334bc35e4fa9aa712064c8071e8f Mon Sep 17 00:00:00 2001
From: wushengyeyouya <690574002@qq.com>
Date: Mon, 23 Aug 2021 11:06:58 +0800
Subject: [PATCH 1/2] Delete all useless modules to adapt to the new
architecture of DSS1.0
---
bin/checkEnv.sh | 45 -
bin/checkServices.sh | 91 --
bin/install.sh | 583 ------------
bin/start-all.sh | 189 ----
bin/stop-all.sh | 133 ---
datachecker-appjoint/pom.xml | 139 ---
.../src/main/assembly/distribution.xml | 136 ---
.../jobtype/connector/DataCheckerDao.java | 195 ----
.../jobtype/connector/DataDruidFactory.java | 122 ---
.../schedulis/jobtype/entity/DataChecker.java | 90 --
.../src/main/resources/appjoint.properties | 24 -
.../src/main/resources/log4j.properties | 37 -
.../src/main/resources/log4j2.xml | 39 -
.../execution/DataCheckerAppJoint.scala | 51 -
.../execution/DataCheckerExecution.scala | 157 ----
.../DataCheckerNodeExecutionAction.scala | 46 -
dss-appjoint-auth/pom.xml | 75 --
.../dss/appjoint/auth/AppJointAuth.java | 38 -
.../dss/appjoint/auth/RedirectMsg.java | 33 -
.../appjoint/auth/impl/AppJointAuthImpl.scala | 99 --
.../appjoint/auth/impl/RedirectMsgImpl.scala | 37 -
.../appjoint/auth/impl/UserInfoAction.scala | 28 -
.../appjoint/auth/impl/UserInfoResult.scala | 33 -
dss-appjoint-core/pom.xml | 93 --
.../wedatasphere/dss/appjoint/AppJoint.java | 73 --
.../exception/AppJointErrorException.java | 35 -
.../dss/appjoint/execution/NodeExecution.java | 53 --
.../async/NodeExecutionListener.java | 40 -
.../async/NodeExecutionLogListener.java | 26 -
.../async/NodeExecutionProgressListener.java | 26 -
.../async/NodeExecutionResponseListener.java | 30 -
.../async/NodeExecutionStatusListener.java | 26 -
.../common/AbstractNodeExecutionAction.java | 35 -
.../common/AsyncNodeExecutionResponse.java | 116 ---
.../CompletedNodeExecutionResponse.java | 66 --
.../common/LongTermNodeExecutionAction.java | 26 -
.../execution/common/NodeExecutionAction.java | 25 -
.../common/NodeExecutionResponse.java | 25 -
.../execution/common/NodeExecutionState.java | 71 --
.../execution/core/AbstractAppJointNode.java | 144 ---
.../appjoint/execution/core/AppJointNode.java | 51 -
.../core/CallbackLongTermNodeExecution.java | 59 --
.../execution/core/CommonAppJointNode.java | 71 --
.../core/HttpLongTermNodeExecution.java | 9 -
.../dss/appjoint/execution/core/Killable.java | 28 -
.../execution/core/LongTermNodeExecution.java | 94 --
.../appjoint/execution/core/NodeContext.java | 112 ---
.../execution/core/NodeContextImpl.java | 94 --
.../appjoint/execution/core/ParamsNode.java | 28 -
.../appjoint/execution/core/Procedure.java | 33 -
.../execution/core/SchedulerManager.java | 38 -
.../AsyncNodeExecutionResponseEvent.java | 51 -
.../AsyncNodeExecutionSchedulerListener.java | 38 -
.../LongTermNodeExecutionScheduler.java | 39 -
.../dss/appjoint/service/AppJointUrl.java | 29 -
.../dss/appjoint/service/AppJointUrlImpl.java | 36 -
.../dss/appjoint/service/NodeService.java | 59 --
.../dss/appjoint/service/ProjectService.java | 43 -
.../dss/appjoint/service/SecurityService.java | 32 -
.../dss/appjoint/service/session/Session.java | 41 -
.../conf/NodeExecutionConfiguration.scala | 36 -
.../context/NodeExecutionContext.scala | 81 --
...stenerEventBusNodeExecutionScheduler.scala | 125 ---
dss-appjoint-loader/pom.xml | 71 --
.../clazzloader/AppJointClassLoader.java | 59 --
.../dss/appjoint/loader/AppJointLoader.java | 59 --
.../loader/AppJointLoaderFactory.java | 67 --
.../appjoint/loader/CommonAppJointLoader.java | 150 ---
.../dss/appjoint/utils/AppJointUtils.java | 160 ----
.../dss/appjoint/utils/ExceptionHelper.java | 32 -
.../exception/NoSuchAppJointException.scala | 26 -
dss-application/pom.xml | 86 --
.../dss/application/conf/ApplicationConf.java | 52 --
.../application/dao/ApplicationMapper.java | 36 -
.../dao/DSSApplicationUserMapper.java | 31 -
.../dss/application/dao/LinkisUserMapper.java | 12 -
.../dao/impl/ApplicationMapper.xml | 46 -
.../dao/impl/DSSApplicationUserMapper.xml | 41 -
.../application/dao/impl/LinkisUserMapper.xml | 34 -
.../dss/application/entity/Application.java | 135 ---
.../dss/application/entity/DSSUser.java | 68 --
.../dss/application/entity/DSSUserVO.java | 35 -
.../dss/application/entity/LinkisUser.java | 144 ---
.../application/entity/UserInitResult.java | 69 --
.../dss/application/entity/WorkSpacePath.java | 59 --
.../handler/ApplicationHandlerChain.java | 46 -
.../dss/application/handler/Handler.java | 27 -
.../handler/LinkisUserFirstLoginHandler.java | 63 --
.../dss/application/handler/Order.java | 27 -
.../handler/ProjectUserInitHandler.java | 43 -
.../handler/UserFirstLoginHandler.java | 62 --
.../restful/ApplicationRestfulApi.java | 104 ---
.../service/ApplicationService.java | 43 -
.../service/DSSApplicationUserService.java | 32 -
.../service/LinkisUserService.java | 31 -
.../service/impl/ApplicationServiceImpl.java | 110 ---
.../impl/DSSApplicationUserServiceImpl.java | 49 -
.../service/impl/LinkisUserServiceImpl.java | 60 --
.../application/util/ApplicationUtils.java | 85 --
dss-azkaban-scheduler-appjoint/pom.xml | 105 ---
.../src/main/assembly/distribution.xml | 136 ---
.../azkaban/AzkabanSchedulerAppJoint.java | 85 --
.../scheduler/azkaban/conf/AzkabanConf.java | 14 -
.../azkaban/constant/AzkabanConstant.java | 17 -
.../azkaban/entity/AzkabanSchedulerFlow.java | 17 -
.../azkaban/entity/AzkabanSchedulerNode.java | 22 -
.../entity/AzkabanSchedulerProject.java | 21 -
.../azkaban/entity/LinkisAzkabanReadNode.java | 37 -
.../entity/LinkisAzkabanSchedulerNode.java | 17 -
.../entity/LinkisAzkabanShareNode.java | 35 -
.../hooks/LinkisAzkabanFlowPublishHook.java | 113 ---
.../hooks/LinkisAzkabanNodePublishHook.java | 79 --
.../LinkisAzkabanProjectPublishHook.java | 127 ---
.../linkisjob/AzkabanSubFlowJobTuning.java | 23 -
.../azkaban/linkisjob/LinkisJob.java | 74 --
.../azkaban/linkisjob/LinkisJobConverter.java | 112 ---
.../azkaban/linkisjob/LinkisJobTuning.java | 11 -
.../azkaban/parser/AzkabanFlowParser.java | 38 -
.../azkaban/parser/AzkabanNodeParser.java | 17 -
.../azkaban/parser/AzkabanProjectParser.java | 32 -
.../parser/LinkisAzkabanNodeParser.java | 31 -
.../LinkisAzkabanSendEmailNodeParser.java | 27 -
.../service/AzkabanProjectService.java | 223 -----
.../service/AzkabanSecurityService.java | 160 ----
.../azkaban/service/AzkabanSession.java | 59 --
.../azkaban/tuning/AzkabanProjectTuning.java | 69 --
.../tuning/LinkisAzkabanFlowTuning.java | 98 --
.../tuning/LinkisShareNodeFlowTuning.java | 34 -
.../scheduler/azkaban/util/AzkabanUtils.java | 34 -
.../azkaban/util/AzkabanUtilsScala.scala | 17 -
.../src/main/resources/appjoint.properties | 21 -
.../src/main/resources/log4j.properties | 37 -
.../src/main/resources/log4j2.xml | 39 -
.../dss/common/entity/Resource.java | 62 --
.../dss/common/entity/flow/DSSFlow.java | 194 ----
.../entity/flow/DSSFlowPublishHistory.java | 24 -
.../common/entity/flow/DSSFlowVersion.java | 163 ----
.../dss/common/entity/flow/DSSJSONFlow.java | 48 -
.../common/entity/flow/FileFlowVersion.java | 27 -
.../dss/common/entity/flow/Flow.java | 53 --
.../dss/common/entity/flow/FlowVersion.java | 31 -
.../entity/flow/FlowVersionForNodes.java | 35 -
.../common/entity/flow/JSONFlowVersion.java | 27 -
.../dss/common/entity/node/DSSEdge.java | 40 -
.../common/entity/node/DSSEdgeDefault.java | 78 --
.../dss/common/entity/node/DSSNode.java | 49 -
.../common/entity/node/DSSNodeDefault.java | 162 ----
.../dss/common/entity/node/Layout.java | 70 --
.../dss/common/entity/node/Node.java | 46 -
.../common/entity/project/DSSJSONProject.java | 41 -
.../dss/common/entity/project/DSSProject.java | 294 ------
.../project/DSSProjectPublishHistory.java | 116 ---
.../entity/project/DSSProjectVersion.java | 126 ---
.../dss/common/entity/project/Project.java | 47 -
.../common/entity/project/ProjectVersion.java | 31 -
.../project/ProjectVersionForFlows.java | 36 -
.../common/exception/DSSErrorException.java | 34 -
.../common/exception/DSSRuntimeException.java | 30 -
.../common/exception/ThrowingConsumer.java | 26 -
.../common/exception/ThrowingFunction.java | 26 -
.../dss/common/utils/DSSExceptionUtils.java | 59 --
.../dss/common/utils/FileHelper.java | 33 -
.../dss/common/utils/ZipHelper.java | 126 ---
.../common/protocol/RequestDSSProject.scala | 25 -
.../bin/start-dss-flow-execution-entrance.sh | 49 -
.../bin/stop-dss-flow-execution-entrance.sh | 47 -
dss-flow-execution-entrance/pom.xml | 126 ---
.../src/main/assembly/distribution.xml | 303 ------
.../entrance/entity/FlowExecutionCode.java | 70 --
.../entrance/entity/FlowExecutionNode.java | 27 -
.../entrance/entity/FlowExecutonReadNode.java | 51 -
.../entity/FlowExecutonSharedNode.java | 51 -
.../job/FlowExecutionAppJointLinkisJob.java | 48 -
.../FlowExecutionAppJointLinkisReadJob.java | 62 --
.../FlowExecutionAppJointLinkisSharedJob.java | 49 -
.../FlowExecutionAppJointSignalSharedJob.java | 56 --
.../job/FlowExecutionCommonLinkisJob.java | 54 --
.../job/FlowExecutionCommonLinkisReadJob.java | 62 --
.../FlowExecutionCommonLinkisSharedJob.java | 47 -
.../job/FlowExecutionJobSignalKeyCreator.java | 39 -
.../parser/FlowExecutionFlowParser.java | 44 -
.../parser/FlowExecutionNodeParser.java | 50 -
.../parser/FlowExecutionProjectParser.java | 43 -
.../parser/FlowExecutionReadNodeParser.java | 55 --
.../restful/FlowExecutionRestfulApi.java | 95 --
.../tuning/FlowExecutionFlowTuning.java | 58 --
.../tuning/FlowExecutionProjectTuning.java | 37 -
.../src/main/resources/application.yml | 23 -
.../src/main/resources/linkis.properties | 42 -
.../src/main/resources/log4j.properties | 37 -
.../src/main/resources/log4j2.xml | 39 -
.../flow/execution/entrance/FlowContext.scala | 86 --
.../execution/entrance/FlowContextImpl.scala | 65 --
.../FlowExecutionEntranceConfiguration.scala | 95 --
...ExecutionEntranceSpringConfiguration.scala | 60 --
.../entrance/engine/FlowEntranceEngine.scala | 123 ---
.../FlowExecutionExecutorManagerImpl.scala | 78 --
.../entranceparser/FlowExecutionParser.scala | 50 -
.../FlowExecutionErrorException.scala | 32 -
.../execution/DefaultFlowExecution.scala | 85 --
.../entrance/execution/FlowExecution.scala | 29 -
.../execution/NodeExecutionStatusPoller.scala | 44 -
.../entrance/job/FlowEntranceJob.scala | 179 ----
.../entrance/job/FlowExecutionRequest.scala | 28 -
.../job/parser/FlowEntranceJobParser.scala | 29 -
.../job/parser/FlowJobFlowParser.scala | 84 --
.../job/parser/FlowJobNodeParser.scala | 99 --
.../listener/NodeRunnerListener.scala | 29 -
.../entrance/log/FlowExecutionLog.scala | 40 -
.../entrance/node/AppJointJobBuilder.scala | 180 ----
.../entrance/node/DefaultNodeRunner.scala | 164 ----
.../entrance/node/NodeExecutionState.scala | 44 -
.../execution/entrance/node/NodeRunner.scala | 105 ---
.../resolver/FlowDependencyResolver.scala | 28 -
.../resolver/FlowDependencyResolverImpl.scala | 66 --
.../entrance/utils/FlowExecutionUtils.scala | 92 --
dss-linkis-node-execution/pom.xml | 69 --
.../node/execution/WorkflowContext.java | 44 -
.../execution/WorkflowContextFactory.java | 59 --
.../node/execution/WorkflowContextImpl.java | 96 --
.../conf/LinkisJobExecutionConfiguration.java | 101 --
.../node/execution/entity/BMLResource.java | 52 --
.../node/execution/entity/ContextInfo.java | 52 --
.../LinkisJobExecutionErrorException.java | 30 -
.../LinkisJobExecutionWarnException.java | 35 -
.../execution/LinkisNodeExecution.java | 46 -
.../impl/LinkisNodeExecutionImpl.java | 203 ----
.../job/AbstractAppJointLinkisJob.java | 198 ----
.../job/AbstractCommonLinkisJob.java | 240 -----
.../node/execution/job/AppJointLinkisJob.java | 24 -
.../linkis/node/execution/job/Builder.java | 150 ---
.../node/execution/job/CommonLinkisJob.java | 42 -
.../dss/linkis/node/execution/job/Job.java | 68 --
.../execution/job/JobSignalKeyCreator.java | 25 -
.../node/execution/job/JobTypeEnum.java | 25 -
.../linkis/node/execution/job/LinkisJob.java | 46 -
.../linkis/node/execution/job/ReadJob.java | 35 -
.../linkis/node/execution/job/RuntimeJob.java | 24 -
.../linkis/node/execution/job/SharedJob.java | 29 -
.../node/execution/job/SignalSharedJob.java | 42 -
.../listener/LinkisExecutionListener.java | 28 -
.../execution/log/LinkisJobExecutionLog.java | 41 -
.../node/execution/parser/CodeParser.java | 235 -----
.../execution/parser/JobParamsParser.java | 89 --
.../node/execution/parser/JobParser.java | 30 -
.../parser/JobRuntimeParamsParser.java | 41 -
.../execution/service/BuildJobAction.java | 32 -
.../service/impl/BuildJobActionImpl.java | 65 --
.../utils/LinkisJobExecutionUtils.java | 59 --
.../utils/LinkisUjesClientUtils.java | 55 --
dss-scheduler-appjoint-core/pom.xml | 76 --
.../appjoint/scheduler/SchedulerAppJoint.java | 44 -
.../constant/SchedulerAppJointConstant.java | 30 -
.../entity/AbstractSchedulerNode.java | 90 --
.../entity/AbstractSchedulerProject.java | 112 ---
.../scheduler/entity/FileProjectVersion.java | 32 -
.../appjoint/scheduler/entity/ReadNode.java | 28 -
.../scheduler/entity/SchedulerEdge.java | 29 -
.../entity/SchedulerEdgeDefault.java | 38 -
.../scheduler/entity/SchedulerFlow.java | 161 ----
.../scheduler/entity/SchedulerNode.java | 31 -
.../scheduler/entity/SchedulerProject.java | 29 -
.../SchedulerProjectVersionForFlows.java | 73 --
.../appjoint/scheduler/entity/ShareNode.java | 28 -
.../hooks/AbstractFlowPublishHook.java | 64 --
.../hooks/AbstractNodePublishHook.java | 36 -
.../hooks/AbstractProjectPublishHook.java | 64 --
.../scheduler/hooks/FlowPublishHook.java | 32 -
.../scheduler/hooks/NodePublishHook.java | 30 -
.../scheduler/hooks/ProjectPublishHook.java | 31 -
.../dss/appjoint/scheduler/order/Order.java | 28 -
.../scheduler/parser/AbstractFlowParser.java | 117 ---
.../scheduler/parser/AbstractNodeParser.java | 40 -
.../parser/AbstractProjectParser.java | 105 ---
.../parser/AbstractReadNodeParser.java | 77 --
.../scheduler/parser/ContextNodeParser.java | 30 -
.../appjoint/scheduler/parser/FlowParser.java | 36 -
.../appjoint/scheduler/parser/NodeParser.java | 31 -
.../scheduler/parser/ProjectParser.java | 31 -
.../scheduler/parser/SendEmailNodeParser.java | 48 -
.../service/SchedulerProjectService.java | 31 -
.../service/SchedulerSecurityService.java | 27 -
.../scheduler/tuning/AbstractFlowTuning.java | 120 ---
.../scheduler/tuning/AbstractNodeTuning.java | 30 -
.../tuning/AbstractProjectTuning.java | 70 --
.../tuning/AbstractShareNodeFlowTuning.java | 96 --
.../scheduler/tuning/ContextNodeTuning.java | 28 -
.../tuning/ContextShareableFlowTuning.java | 34 -
.../appjoint/scheduler/tuning/FlowTuning.java | 31 -
.../appjoint/scheduler/tuning/NodeTuning.java | 28 -
.../scheduler/tuning/ProjectTuning.java | 29 -
dss-server/bin/start-dss-server.sh | 39 -
dss-server/bin/stop-dss-server.sh | 47 -
dss-server/pom.xml | 237 -----
dss-server/src/main/assembly/distribution.xml | 340 -------
.../dss/DSSSpringApplication.java | 222 -----
.../dss/server/conf/DSSServerConf.java | 49 -
.../server/constant/DSSServerConstant.java | 33 -
.../dss/server/dao/DSSUserMapper.java | 32 -
.../dss/server/dao/FlowMapper.java | 71 --
.../dss/server/dao/FlowTaxonomyMapper.java | 51 -
.../dss/server/dao/NodeInfoMapper.java | 35 -
.../dss/server/dao/ProjectMapper.java | 66 --
.../dss/server/dao/ProjectTaxonomyMapper.java | 49 -
.../dss/server/dao/WorkspaceMapper.java | 68 --
.../dss/server/dao/impl/dwsUserMapper.xml | 31 -
.../dss/server/dao/impl/flowMapper.xml | 256 ------
.../server/dao/impl/flowTaxonomyMapper.xml | 95 --
.../dss/server/dao/impl/nodeInfoMapper.xml | 52 --
.../dss/server/dao/impl/projectMapper.xml | 177 ----
.../server/dao/impl/projectTaxonomyMapper.xml | 97 --
.../dss/server/dao/impl/workspaceMapper.xml | 200 ----
.../dss/server/db/DSSMybatisConfig.java | 148 ---
.../dto/response/HomepageDemoInstanceVo.java | 96 --
.../dto/response/HomepageDemoMenuVo.java | 89 --
.../server/dto/response/HomepageVideoVo.java | 78 --
.../response/OnestopMenuAppInstanceVo.java | 140 ---
.../server/dto/response/OnestopMenuVo.java | 62 --
.../dto/response/WorkspaceDepartmentVo.java | 44 -
.../dto/response/WorkspaceFavoriteVo.java | 82 --
.../dss/server/entity/ApplicationArea.java | 53 --
.../dss/server/entity/BaseEntity.java | 49 -
.../dss/server/entity/DSSFavorite.java | 73 --
.../dss/server/entity/DSSFlowTaxonomy.java | 99 --
.../dss/server/entity/DSSProjectTaxonomy.java | 90 --
.../entity/DSSProjectTaxonomyRelation.java | 49 -
.../dss/server/entity/DSSWorkspace.java | 93 --
.../dss/server/entity/NodeInfo.java | 103 ---
.../dss/server/function/FunctionInvoker.java | 104 ---
.../dss/server/function/FunctionPool.java | 39 -
.../server/function/NodeServiceFunction.java | 30 -
.../function/ProjectServiceAddFunction.java | 28 -
.../function/ProjectServiceFunction.java | 28 -
.../wedatasphere/dss/server/lock/Lock.java | 30 -
.../dss/server/lock/LockAspect.java | 110 ---
.../dss/server/lock/LockEnum.java | 24 -
.../server/operate/AppJointNodeOperate.java | 66 --
.../wedatasphere/dss/server/operate/Op.java | 60 --
.../dss/server/operate/Operate.java | 36 -
.../dss/server/operate/SubFlowOperate.java | 73 --
.../dss/server/publish/PublishJob.java | 45 -
.../dss/server/publish/PublishJobEnum.java | 23 -
.../dss/server/publish/PublishJobFactory.java | 47 -
.../dss/server/publish/PublishListner.java | 28 -
.../dss/server/publish/PublishManager.java | 166 ----
.../server/publish/PublishProjectCache.java | 81 --
.../dss/server/publish/PublishSubmitJob.java | 50 -
.../publish/PublishSubmitJobDeamon.java | 48 -
.../dss/server/publish/PublishThreadPool.java | 37 -
.../dss/server/restful/FlowRestfulApi.java | 180 ----
.../restful/FlowTaxonomyRestfulApi.java | 113 ---
.../dss/server/restful/NodeRestfulApi.java | 115 ---
.../dss/server/restful/ProjectRestfulApi.java | 201 ----
.../restful/ProjectTaxonomyRestfulApi.java | 98 --
.../dss/server/restful/TreeRestfulApi.java | 59 --
.../dss/server/restful/UserManagerApi.java | 92 --
.../server/restful/WorkspaceRestfulApi.java | 172 ----
.../dss/server/service/DSSFlowService.java | 74 --
.../service/DSSFlowTaxonomyService.java | 41 -
.../server/service/DSSNodeInfoService.java | 33 -
.../dss/server/service/DSSProjectService.java | 67 --
.../service/DSSProjectTaxonomyService.java | 46 -
.../dss/server/service/DSSUserService.java | 23 -
.../server/service/DSSWorkspaceService.java | 63 --
.../service/impl/DSSFlowServiceImpl.java | 282 ------
.../impl/DSSFlowTaxonomyServiceImpl.java | 138 ---
.../service/impl/DSSNodeInfoServiceImpl.java | 40 -
.../service/impl/DSSProjectServiceImpl.java | 609 ------------
.../impl/DSSProjectTaxonomyServiceImpl.java | 132 ---
.../service/impl/DSSUserServiceImpl.java | 37 -
.../service/impl/DSSWorkspaceServiceImpl.java | 155 ----
.../dss/server/util/ThreadPoolTool.java | 132 ---
dss-server/src/main/resources/application.yml | 22 -
.../resources/default/AddschedulerUser.sh | 13 -
.../resources/default/CreateLdapAccount.sh | 18 -
.../main/resources/default/CreateLinuxUser.sh | 35 -
.../src/main/resources/default/HdfsPath.sh | 6 -
.../src/main/resources/default/LinuxPath.sh | 7 -
.../src/main/resources/linkis.properties | 71 --
.../src/main/resources/log4j.properties | 37 -
dss-server/src/main/resources/log4j2.xml | 39 -
.../src/main/resources/token.properties | 2 -
.../dss/server/crumb/CrumbFactory.scala | 144 ---
.../dss/server/crumb/QuerParamsParser.scala | 80 --
.../dss/server/entity/Crumb.scala | 28 -
.../dss/server/entity/CrumbType.scala | 24 -
.../server/receiver/DSSServerReceiver.scala | 49 -
.../dss/server/service/BMLService.scala | 111 ---
dss-server/src/main/test/HttpTest.java | 185 ----
dss-server/src/main/test/com/webank/Adf.scala | 9 -
.../src/main/test/com/webank/HttpTest.java | 141 ---
.../src/main/test/com/webank/JobParam.java | 11 -
.../src/main/test/com/webank/ReqTest.scala | 9 -
.../src/main/test/com/webank/TestUnit.java | 14 -
dss-user-manager/pom.xml | 87 --
.../dss/user/conf/DSSUserManagerConfig.java | 60 --
.../user/dto/request/AuthorizationBody.java | 99 --
.../dss/user/dto/request/LinuxServer.java | 53 --
.../dss/user/service/AbsCommand.java | 114 ---
.../dss/user/service/Command.java | 58 --
.../dss/user/service/MacroCommand.java | 33 -
.../dss/user/service/impl/AzkabanCommand.java | 110 ---
.../user/service/impl/KerberosCommand.java | 69 --
.../dss/user/service/impl/LdapCommand.java | 58 --
.../user/service/impl/LinuxUserCommand.java | 60 --
.../user/service/impl/MetastoreCommand.java | 56 --
.../user/service/impl/SchedulisCommand.java | 146 ---
.../service/impl/UserAuthorizationClient.java | 57 --
.../user/service/impl/UserMacroCommand.java | 118 ---
.../user/service/impl/WorkspaceCommand.java | 70 --
.../dss/user/service/impl/YarnCommand.java | 39 -
.../src/main/resources/config/properties.conf | 14 -
.../resources/default/AddschedulerUser.sh | 18 -
.../resources/default/CreateLdapAccount.sh | 7 -
.../main/resources/default/CreateLinuxUser.sh | 34 -
.../src/main/resources/default/HdfsPath.sh | 13 -
.../src/main/resources/default/Kerberos.sh | 146 ---
.../src/main/resources/default/LinuxPath.sh | 12 -
.../src/main/resources/default/Metastore.sh | 44 -
.../src/main/resources/read_anlexander.txt | 20 -
.../service/impl/KerberosCommandTest.java | 43 -
.../service/impl/MetastoreCommandTest.java | 43 -
.../service/impl/WorkspaceCommandTest.java | 46 -
eventchecker-appjoint/pom.xml | 139 ---
.../src/main/assembly/distribution.xml | 136 ---
.../jobtype/adapter/EventCheckAdapter.java | 37 -
.../jobtype/connector/EventDruidFactory.java | 113 ---
.../jobtype/entity/EventChecker.java | 277 ------
.../exception/UndefinedPropertyException.java | 31 -
.../jobtype/service/AbstractEventCheck.java | 207 -----
.../service/AbstractEventCheckReceiver.java | 225 -----
.../service/DefaultEventcheckReceiver.java | 151 ---
.../jobtype/service/EventCheckSender.java | 75 --
.../jobtype/service/EventCheckerService.java | 72 --
.../schedulis/jobtype/utils/Props.java | 869 ------------------
.../schedulis/jobtype/utils/Utils.java | 35 -
.../src/main/resources/appjoint.properties | 24 -
.../src/main/resources/log4j.properties | 37 -
.../src/main/resources/log4j2.xml | 39 -
.../execution/EventCheckerAppJoint.scala | 51 -
.../execution/EventCheckerNodeExecution.scala | 165 ----
.../EventCheckerNodeExecutionAction.scala | 66 --
.../bin/start-linkis-appjoint-entrance.sh | 37 -
.../bin/stop-linkis-appjoint-entrance.sh | 47 -
.../conf/application.yml | 22 -
.../conf/linkis.properties | 38 -
.../linkis-appjoint-entrance/conf/log4j2.xml | 39 -
.../linkis/linkis-appjoint-entrance/pom.xml | 141 ---
.../src/main/assembly/distribution.xml | 335 -------
.../entrance/AppJointEntranceRestfulApi.java | 96 --
.../entrance/appjoint/AppJointManager.scala | 75 --
.../entrance/conf/AppJointConst.scala | 39 -
.../conf/AppJointEntranceConfiguration.scala | 40 -
.../AppJointEntranceSpringConfiguration.scala | 53 --
...ppJointEntranceIllegalParamException.scala | 28 -
.../OperateNotSupportedException.scala | 26 -
.../exception/RPCFailedException.scala | 27 -
.../AppJointEngineExecutorManagerImpl.scala | 70 --
.../execute/AppJointEntranceEngine.scala | 228 -----
.../execute/AppJointNodeContextImpl.scala | 239 -----
.../entrance/job/AppJointEntranceJob.scala | 100 --
.../entrance/job/AppJointExecuteRequest.scala | 33 -
.../parser/AppJointEntranceParser.scala | 95 --
pom.xml | 172 +++-
qualitis-appjoint/appjoint/pom.xml | 126 ---
.../src/main/assembly/distribution.xml | 67 --
.../com.webank/wedatasphere/Md5Utils.java | 27 -
.../appjoint/QualitisAppJoint.java | 56 --
.../appjoint/QualitisNodeExecution.java | 326 -------
.../appjoint/QualitisNodeExecutionAction.java | 19 -
.../appjoint/QualitisSubmitRequest.java | 55 --
.../appjoint/QualitisTaskStatusEnum.java | 43 -
.../project/QualitisAddProjectRequest.java | 41 -
.../project/QualitisDeleteProjectRequest.java | 32 -
.../project/QualitisProjectServiceImpl.java | 261 ------
.../project/QualitisUpdateProjectRequest.java | 51 -
.../src/main/resources/appjoint.properties | 19 -
.../src/main/resources/log4j.properties | 37 -
.../appjoint/src/main/resources/log4j2.xml | 39 -
sendemail-appjoint/sendemail-core/pom.xml | 129 ---
.../dss/appjoint/sendemail/Email.java | 45 -
.../dss/appjoint/sendemail/EmailContent.java | 29 -
.../SendEmailAppJointSpringConfiguration.java | 80 --
.../exception/EmailSendFailedException.java | 29 -
.../sendemail/sender/AbstractEmailSender.java | 40 -
.../sender/SpringJavaEmailSender.java | 99 --
.../dss/appjoint/sendemail/Attachment.scala | 32 -
.../sendemail/EmailContentGenerator.scala | 27 -
.../sendemail/EmailContentParser.scala | 27 -
.../appjoint/sendemail/EmailGenerator.scala | 29 -
.../dss/appjoint/sendemail/EmailSender.scala | 35 -
.../sendemail/SendEmailAppJoint.scala | 51 -
.../sendemail/SendEmailNodeExecution.scala | 85 --
.../SendEmailNodeExecutionHook.scala | 31 -
.../conf/SendEmailAppJointConfiguration.scala | 43 -
.../conf/SendEmailAppJointUtils.scala | 33 -
.../sendemail/email/AbstractEmail.scala | 60 --
.../sendemail/email/MultiContentEmail.scala | 38 -
.../sendemail/email/PngAttachment.scala | 38 -
.../generate/AbstractEmailGenerator.scala | 61 --
.../generate/MultiContentEmailGenerator.scala | 63 --
.../emailcontent/ArrayEmailContent.scala | 34 -
.../FsPathStoreEmailContent.scala | 30 -
.../emailcontent/StringEmailContent.scala | 32 -
.../AbstractEmailContentGenerator.scala | 64 --
.../MultiEmailContentGenerator.scala | 56 --
.../sendemail/emailcontent/package.scala | 86 --
.../parser/AbstractEmailContentParser.scala | 71 --
.../parser/FileEmailContentParser.scala | 44 -
.../parser/HtmlEmailContentParser.scala | 33 -
.../parser/PictureEmailContentParser.scala | 74 --
.../parser/TableEmailContentParser.scala | 69 --
visualis-appjoint/appjoint/pom.xml | 130 ---
.../src/main/assembly/distribution.xml | 226 -----
.../appjoint/visualis/VisualisAppJoint.java | 71 --
.../visualis/service/VisualisNodeService.java | 70 --
.../service/VisualisSecurityService.java | 42 -
.../visualis/service/VisualisSession.java | 74 --
.../nodeservice/DashboardNodeService.java | 151 ---
.../nodeservice/DisplayNodeService.java | 125 ---
.../service/nodeservice/HttpUtils.java | 153 ---
.../execution/VisualisNodeExecution.scala | 142 ---
.../VisualisNodeExecutionConfiguration.scala | 35 -
.../linkis/server/JSONUtils.scala | 27 -
524 files changed, 121 insertions(+), 38246 deletions(-)
delete mode 100644 bin/checkEnv.sh
delete mode 100644 bin/checkServices.sh
delete mode 100644 bin/install.sh
delete mode 100644 bin/start-all.sh
delete mode 100644 bin/stop-all.sh
delete mode 100644 datachecker-appjoint/pom.xml
delete mode 100644 datachecker-appjoint/src/main/assembly/distribution.xml
delete mode 100644 datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/DataCheckerDao.java
delete mode 100644 datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/DataDruidFactory.java
delete mode 100644 datachecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/entity/DataChecker.java
delete mode 100644 datachecker-appjoint/src/main/resources/appjoint.properties
delete mode 100644 datachecker-appjoint/src/main/resources/log4j.properties
delete mode 100644 datachecker-appjoint/src/main/resources/log4j2.xml
delete mode 100644 datachecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/DataCheckerAppJoint.scala
delete mode 100644 datachecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/DataCheckerExecution.scala
delete mode 100644 datachecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/DataCheckerNodeExecutionAction.scala
delete mode 100644 dss-appjoint-auth/pom.xml
delete mode 100644 dss-appjoint-auth/src/main/java/com/webank/wedatasphere/dss/appjoint/auth/AppJointAuth.java
delete mode 100644 dss-appjoint-auth/src/main/java/com/webank/wedatasphere/dss/appjoint/auth/RedirectMsg.java
delete mode 100644 dss-appjoint-auth/src/main/scala/com/webank/wedatasphere/dss/appjoint/auth/impl/AppJointAuthImpl.scala
delete mode 100644 dss-appjoint-auth/src/main/scala/com/webank/wedatasphere/dss/appjoint/auth/impl/RedirectMsgImpl.scala
delete mode 100644 dss-appjoint-auth/src/main/scala/com/webank/wedatasphere/dss/appjoint/auth/impl/UserInfoAction.scala
delete mode 100644 dss-appjoint-auth/src/main/scala/com/webank/wedatasphere/dss/appjoint/auth/impl/UserInfoResult.scala
delete mode 100644 dss-appjoint-core/pom.xml
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/AppJoint.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/exception/AppJointErrorException.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/NodeExecution.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/async/NodeExecutionListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/async/NodeExecutionLogListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/async/NodeExecutionProgressListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/async/NodeExecutionResponseListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/async/NodeExecutionStatusListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/AbstractNodeExecutionAction.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/AsyncNodeExecutionResponse.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/CompletedNodeExecutionResponse.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/LongTermNodeExecutionAction.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/NodeExecutionAction.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/NodeExecutionResponse.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/common/NodeExecutionState.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/AbstractAppJointNode.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/AppJointNode.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/CallbackLongTermNodeExecution.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/CommonAppJointNode.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/HttpLongTermNodeExecution.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/Killable.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/LongTermNodeExecution.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/NodeContext.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/NodeContextImpl.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/ParamsNode.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/Procedure.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/core/SchedulerManager.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/scheduler/AsyncNodeExecutionResponseEvent.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/scheduler/AsyncNodeExecutionSchedulerListener.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/execution/scheduler/LongTermNodeExecutionScheduler.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/AppJointUrl.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/AppJointUrlImpl.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/NodeService.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/ProjectService.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/SecurityService.java
delete mode 100644 dss-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/service/session/Session.java
delete mode 100644 dss-appjoint-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/execution/conf/NodeExecutionConfiguration.scala
delete mode 100644 dss-appjoint-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/execution/context/NodeExecutionContext.scala
delete mode 100644 dss-appjoint-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/execution/scheduler/ListenerEventBusNodeExecutionScheduler.scala
delete mode 100644 dss-appjoint-loader/pom.xml
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/clazzloader/AppJointClassLoader.java
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/loader/AppJointLoader.java
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/loader/AppJointLoaderFactory.java
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/loader/CommonAppJointLoader.java
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/utils/AppJointUtils.java
delete mode 100644 dss-appjoint-loader/src/main/java/com/webank/wedatasphere/dss/appjoint/utils/ExceptionHelper.java
delete mode 100644 dss-appjoint-loader/src/main/scala/com/webank/wedatasphere/dss/appjoint/exception/NoSuchAppJointException.scala
delete mode 100644 dss-application/pom.xml
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/conf/ApplicationConf.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/ApplicationMapper.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/DSSApplicationUserMapper.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/LinkisUserMapper.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/impl/ApplicationMapper.xml
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/impl/DSSApplicationUserMapper.xml
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/dao/impl/LinkisUserMapper.xml
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/Application.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/DSSUser.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/DSSUserVO.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/LinkisUser.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/UserInitResult.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/entity/WorkSpacePath.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/ApplicationHandlerChain.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/Handler.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/LinkisUserFirstLoginHandler.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/Order.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/ProjectUserInitHandler.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/handler/UserFirstLoginHandler.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/restful/ApplicationRestfulApi.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/ApplicationService.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/DSSApplicationUserService.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/LinkisUserService.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/impl/ApplicationServiceImpl.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/impl/DSSApplicationUserServiceImpl.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/service/impl/LinkisUserServiceImpl.java
delete mode 100644 dss-application/src/main/java/com/webank/wedatasphere/dss/application/util/ApplicationUtils.java
delete mode 100644 dss-azkaban-scheduler-appjoint/pom.xml
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/assembly/distribution.xml
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/AzkabanSchedulerAppJoint.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/conf/AzkabanConf.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/constant/AzkabanConstant.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/AzkabanSchedulerFlow.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/AzkabanSchedulerNode.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/AzkabanSchedulerProject.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/LinkisAzkabanReadNode.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/LinkisAzkabanSchedulerNode.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/entity/LinkisAzkabanShareNode.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/hooks/LinkisAzkabanFlowPublishHook.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/hooks/LinkisAzkabanNodePublishHook.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/hooks/LinkisAzkabanProjectPublishHook.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/linkisjob/AzkabanSubFlowJobTuning.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/linkisjob/LinkisJob.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/linkisjob/LinkisJobConverter.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/linkisjob/LinkisJobTuning.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/parser/AzkabanFlowParser.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/parser/AzkabanNodeParser.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/parser/AzkabanProjectParser.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/parser/LinkisAzkabanNodeParser.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/parser/LinkisAzkabanSendEmailNodeParser.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/service/AzkabanProjectService.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/service/AzkabanSecurityService.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/service/AzkabanSession.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/tuning/AzkabanProjectTuning.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/tuning/LinkisAzkabanFlowTuning.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/tuning/LinkisShareNodeFlowTuning.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/util/AzkabanUtils.java
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/azkaban/util/AzkabanUtilsScala.scala
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/resources/appjoint.properties
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/resources/log4j.properties
delete mode 100644 dss-azkaban-scheduler-appjoint/src/main/resources/log4j2.xml
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/Resource.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/DSSFlow.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/DSSFlowPublishHistory.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/DSSFlowVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/DSSJSONFlow.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/FileFlowVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/Flow.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/FlowVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/FlowVersionForNodes.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/flow/JSONFlowVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/DSSEdge.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/DSSEdgeDefault.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/DSSNode.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/DSSNodeDefault.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/Layout.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/node/Node.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/DSSJSONProject.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/DSSProject.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/DSSProjectPublishHistory.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/DSSProjectVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/Project.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/ProjectVersion.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/project/ProjectVersionForFlows.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/exception/DSSErrorException.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/exception/DSSRuntimeException.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/exception/ThrowingConsumer.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/exception/ThrowingFunction.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/utils/DSSExceptionUtils.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/utils/FileHelper.java
delete mode 100644 dss-common/src/main/java/com/webank/wedatasphere/dss/common/utils/ZipHelper.java
delete mode 100644 dss-common/src/main/scala/com/webank/wedatasphere/dss/common/protocol/RequestDSSProject.scala
delete mode 100644 dss-flow-execution-entrance/bin/start-dss-flow-execution-entrance.sh
delete mode 100644 dss-flow-execution-entrance/bin/stop-dss-flow-execution-entrance.sh
delete mode 100644 dss-flow-execution-entrance/pom.xml
delete mode 100644 dss-flow-execution-entrance/src/main/assembly/distribution.xml
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/entity/FlowExecutionCode.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/entity/FlowExecutionNode.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/entity/FlowExecutonReadNode.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/entity/FlowExecutonSharedNode.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionAppJointLinkisJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionAppJointLinkisReadJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionAppJointLinkisSharedJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionAppJointSignalSharedJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionCommonLinkisJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionCommonLinkisReadJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionCommonLinkisSharedJob.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionJobSignalKeyCreator.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/parser/FlowExecutionFlowParser.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/parser/FlowExecutionNodeParser.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/parser/FlowExecutionProjectParser.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/parser/FlowExecutionReadNodeParser.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/restful/FlowExecutionRestfulApi.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/tuning/FlowExecutionFlowTuning.java
delete mode 100644 dss-flow-execution-entrance/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/tuning/FlowExecutionProjectTuning.java
delete mode 100644 dss-flow-execution-entrance/src/main/resources/application.yml
delete mode 100644 dss-flow-execution-entrance/src/main/resources/linkis.properties
delete mode 100644 dss-flow-execution-entrance/src/main/resources/log4j.properties
delete mode 100644 dss-flow-execution-entrance/src/main/resources/log4j2.xml
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/FlowContext.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/FlowContextImpl.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/conf/FlowExecutionEntranceConfiguration.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/conf/FlowExecutionEntranceSpringConfiguration.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowExecutionExecutorManagerImpl.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/entranceparser/FlowExecutionParser.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/exception/FlowExecutionErrorException.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/execution/DefaultFlowExecution.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/execution/FlowExecution.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/execution/NodeExecutionStatusPoller.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowEntranceJob.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/job/FlowExecutionRequest.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/job/parser/FlowEntranceJobParser.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/job/parser/FlowJobFlowParser.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/job/parser/FlowJobNodeParser.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/listener/NodeRunnerListener.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/log/FlowExecutionLog.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/node/AppJointJobBuilder.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/node/DefaultNodeRunner.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/node/NodeExecutionState.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/node/NodeRunner.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/resolver/FlowDependencyResolver.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/resolver/FlowDependencyResolverImpl.scala
delete mode 100644 dss-flow-execution-entrance/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/utils/FlowExecutionUtils.scala
delete mode 100644 dss-linkis-node-execution/pom.xml
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/WorkflowContext.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/WorkflowContextFactory.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/WorkflowContextImpl.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/conf/LinkisJobExecutionConfiguration.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/entity/BMLResource.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/entity/ContextInfo.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/exception/LinkisJobExecutionErrorException.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/exception/LinkisJobExecutionWarnException.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/execution/LinkisNodeExecution.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/execution/impl/LinkisNodeExecutionImpl.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/AbstractAppJointLinkisJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/AbstractCommonLinkisJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/AppJointLinkisJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/Builder.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/CommonLinkisJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/Job.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/JobSignalKeyCreator.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/JobTypeEnum.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/LinkisJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/ReadJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/RuntimeJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/SharedJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/job/SignalSharedJob.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/listener/LinkisExecutionListener.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/log/LinkisJobExecutionLog.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/parser/CodeParser.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/parser/JobParamsParser.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/parser/JobParser.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/parser/JobRuntimeParamsParser.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/BuildJobAction.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/utils/LinkisJobExecutionUtils.java
delete mode 100644 dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/utils/LinkisUjesClientUtils.java
delete mode 100644 dss-scheduler-appjoint-core/pom.xml
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/SchedulerAppJoint.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/constant/SchedulerAppJointConstant.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/AbstractSchedulerNode.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/AbstractSchedulerProject.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/FileProjectVersion.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/ReadNode.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerEdge.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerEdgeDefault.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerFlow.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerNode.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerProject.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/SchedulerProjectVersionForFlows.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/entity/ShareNode.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/AbstractFlowPublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/AbstractNodePublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/AbstractProjectPublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/FlowPublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/NodePublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/hooks/ProjectPublishHook.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/order/Order.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/AbstractFlowParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/AbstractNodeParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/AbstractProjectParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/AbstractReadNodeParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/ContextNodeParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/FlowParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/NodeParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/ProjectParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/parser/SendEmailNodeParser.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/service/SchedulerProjectService.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/service/SchedulerSecurityService.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/AbstractFlowTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/AbstractNodeTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/AbstractProjectTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/AbstractShareNodeFlowTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/ContextNodeTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/ContextShareableFlowTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/FlowTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/NodeTuning.java
delete mode 100644 dss-scheduler-appjoint-core/src/main/java/com/webank/wedatasphere/dss/appjoint/scheduler/tuning/ProjectTuning.java
delete mode 100644 dss-server/bin/start-dss-server.sh
delete mode 100644 dss-server/bin/stop-dss-server.sh
delete mode 100644 dss-server/pom.xml
delete mode 100644 dss-server/src/main/assembly/distribution.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/DSSSpringApplication.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/conf/DSSServerConf.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/constant/DSSServerConstant.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/DSSUserMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/FlowMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/FlowTaxonomyMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/NodeInfoMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/ProjectMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/ProjectTaxonomyMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/WorkspaceMapper.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/dwsUserMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/flowMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/flowTaxonomyMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/nodeInfoMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/projectMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/projectTaxonomyMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dao/impl/workspaceMapper.xml
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/db/DSSMybatisConfig.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/HomepageDemoInstanceVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/HomepageDemoMenuVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/HomepageVideoVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/OnestopMenuAppInstanceVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/OnestopMenuVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/WorkspaceDepartmentVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/dto/response/WorkspaceFavoriteVo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/ApplicationArea.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/BaseEntity.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/DSSFavorite.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/DSSFlowTaxonomy.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/DSSProjectTaxonomy.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/DSSProjectTaxonomyRelation.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/DSSWorkspace.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/entity/NodeInfo.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/function/FunctionInvoker.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/function/FunctionPool.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/function/NodeServiceFunction.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/function/ProjectServiceAddFunction.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/function/ProjectServiceFunction.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/lock/Lock.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/lock/LockAspect.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/lock/LockEnum.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/operate/AppJointNodeOperate.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/operate/Op.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/operate/Operate.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/operate/SubFlowOperate.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishJob.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishJobEnum.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishJobFactory.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishListner.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishManager.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishProjectCache.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishSubmitJob.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishSubmitJobDeamon.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/publish/PublishThreadPool.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/FlowRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/FlowTaxonomyRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/NodeRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/ProjectRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/ProjectTaxonomyRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/TreeRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/UserManagerApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/restful/WorkspaceRestfulApi.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSFlowService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSFlowTaxonomyService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSNodeInfoService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSProjectService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSProjectTaxonomyService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSUserService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/DSSWorkspaceService.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSFlowServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSFlowTaxonomyServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSNodeInfoServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSProjectServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSProjectTaxonomyServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSUserServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/service/impl/DSSWorkspaceServiceImpl.java
delete mode 100644 dss-server/src/main/java/com/webank/wedatasphere/dss/server/util/ThreadPoolTool.java
delete mode 100644 dss-server/src/main/resources/application.yml
delete mode 100644 dss-server/src/main/resources/default/AddschedulerUser.sh
delete mode 100644 dss-server/src/main/resources/default/CreateLdapAccount.sh
delete mode 100644 dss-server/src/main/resources/default/CreateLinuxUser.sh
delete mode 100644 dss-server/src/main/resources/default/HdfsPath.sh
delete mode 100644 dss-server/src/main/resources/default/LinuxPath.sh
delete mode 100644 dss-server/src/main/resources/linkis.properties
delete mode 100644 dss-server/src/main/resources/log4j.properties
delete mode 100644 dss-server/src/main/resources/log4j2.xml
delete mode 100644 dss-server/src/main/resources/token.properties
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/crumb/CrumbFactory.scala
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/crumb/QuerParamsParser.scala
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/entity/Crumb.scala
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/entity/CrumbType.scala
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/receiver/DSSServerReceiver.scala
delete mode 100644 dss-server/src/main/scala/com/webank/wedatasphere/dss/server/service/BMLService.scala
delete mode 100644 dss-server/src/main/test/HttpTest.java
delete mode 100644 dss-server/src/main/test/com/webank/Adf.scala
delete mode 100644 dss-server/src/main/test/com/webank/HttpTest.java
delete mode 100644 dss-server/src/main/test/com/webank/JobParam.java
delete mode 100644 dss-server/src/main/test/com/webank/ReqTest.scala
delete mode 100644 dss-server/src/main/test/com/webank/TestUnit.java
delete mode 100644 dss-user-manager/pom.xml
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/conf/DSSUserManagerConfig.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/dto/request/AuthorizationBody.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/dto/request/LinuxServer.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/AbsCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/Command.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/MacroCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/AzkabanCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/KerberosCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/LdapCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/LinuxUserCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/MetastoreCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/SchedulisCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/UserAuthorizationClient.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/UserMacroCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/WorkspaceCommand.java
delete mode 100644 dss-user-manager/src/main/java/com/webank/wedatasphpere/dss/user/service/impl/YarnCommand.java
delete mode 100644 dss-user-manager/src/main/resources/config/properties.conf
delete mode 100644 dss-user-manager/src/main/resources/default/AddschedulerUser.sh
delete mode 100644 dss-user-manager/src/main/resources/default/CreateLdapAccount.sh
delete mode 100644 dss-user-manager/src/main/resources/default/CreateLinuxUser.sh
delete mode 100644 dss-user-manager/src/main/resources/default/HdfsPath.sh
delete mode 100644 dss-user-manager/src/main/resources/default/Kerberos.sh
delete mode 100644 dss-user-manager/src/main/resources/default/LinuxPath.sh
delete mode 100644 dss-user-manager/src/main/resources/default/Metastore.sh
delete mode 100644 dss-user-manager/src/main/resources/read_anlexander.txt
delete mode 100644 dss-user-manager/src/test/java/com/webank/wedatasphpere/dss/user/service/impl/KerberosCommandTest.java
delete mode 100644 dss-user-manager/src/test/java/com/webank/wedatasphpere/dss/user/service/impl/MetastoreCommandTest.java
delete mode 100644 dss-user-manager/src/test/java/com/webank/wedatasphpere/dss/user/service/impl/WorkspaceCommandTest.java
delete mode 100644 eventchecker-appjoint/pom.xml
delete mode 100644 eventchecker-appjoint/src/main/assembly/distribution.xml
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/adapter/EventCheckAdapter.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/connector/EventDruidFactory.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/entity/EventChecker.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/exception/UndefinedPropertyException.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/service/AbstractEventCheck.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/service/AbstractEventCheckReceiver.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/service/DefaultEventcheckReceiver.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/service/EventCheckSender.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/service/EventCheckerService.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/utils/Props.java
delete mode 100644 eventchecker-appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/utils/Utils.java
delete mode 100644 eventchecker-appjoint/src/main/resources/appjoint.properties
delete mode 100644 eventchecker-appjoint/src/main/resources/log4j.properties
delete mode 100644 eventchecker-appjoint/src/main/resources/log4j2.xml
delete mode 100644 eventchecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/EventCheckerAppJoint.scala
delete mode 100644 eventchecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/EventCheckerNodeExecution.scala
delete mode 100644 eventchecker-appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/schedulis/jobtype/execution/EventCheckerNodeExecutionAction.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/bin/start-linkis-appjoint-entrance.sh
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/bin/stop-linkis-appjoint-entrance.sh
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/conf/application.yml
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/conf/linkis.properties
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/conf/log4j2.xml
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/pom.xml
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/assembly/distribution.xml
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/java/com/webank/wedatasphere/dss/linkis/appjoint/entrance/AppJointEntranceRestfulApi.java
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/appjoint/AppJointManager.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/conf/AppJointConst.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/conf/AppJointEntranceConfiguration.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/conf/AppJointEntranceSpringConfiguration.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/exception/AppJointEntranceIllegalParamException.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/exception/OperateNotSupportedException.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/exception/RPCFailedException.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/execute/AppJointEngineExecutorManagerImpl.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/execute/AppJointEntranceEngine.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/execute/AppJointNodeContextImpl.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/job/AppJointEntranceJob.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/job/AppJointExecuteRequest.scala
delete mode 100644 plugins/linkis/linkis-appjoint-entrance/src/main/scala/com/webank/wedatasphere/dss/linkis/appjoint/entrance/parser/AppJointEntranceParser.scala
delete mode 100644 qualitis-appjoint/appjoint/pom.xml
delete mode 100644 qualitis-appjoint/appjoint/src/main/assembly/distribution.xml
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/Md5Utils.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/appjoint/QualitisAppJoint.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/appjoint/QualitisNodeExecution.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/appjoint/QualitisNodeExecutionAction.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/appjoint/QualitisSubmitRequest.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/appjoint/QualitisTaskStatusEnum.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/project/QualitisAddProjectRequest.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/project/QualitisDeleteProjectRequest.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/project/QualitisProjectServiceImpl.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/java/com.webank/wedatasphere/project/QualitisUpdateProjectRequest.java
delete mode 100644 qualitis-appjoint/appjoint/src/main/resources/appjoint.properties
delete mode 100644 qualitis-appjoint/appjoint/src/main/resources/log4j.properties
delete mode 100644 qualitis-appjoint/appjoint/src/main/resources/log4j2.xml
delete mode 100644 sendemail-appjoint/sendemail-core/pom.xml
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/Email.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/EmailContent.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/conf/SendEmailAppJointSpringConfiguration.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/exception/EmailSendFailedException.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/sender/AbstractEmailSender.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/java/com/webank/wedatasphere/dss/appjoint/sendemail/sender/SpringJavaEmailSender.java
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/Attachment.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/EmailContentGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/EmailContentParser.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/EmailGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/EmailSender.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/SendEmailAppJoint.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/SendEmailNodeExecution.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/SendEmailNodeExecutionHook.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/conf/SendEmailAppJointConfiguration.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/conf/SendEmailAppJointUtils.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/email/AbstractEmail.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/email/MultiContentEmail.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/email/PngAttachment.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/email/generate/AbstractEmailGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/email/generate/MultiContentEmailGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/ArrayEmailContent.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/FsPathStoreEmailContent.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/StringEmailContent.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/generator/AbstractEmailContentGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/generator/MultiEmailContentGenerator.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/package.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/parser/AbstractEmailContentParser.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/parser/FileEmailContentParser.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/parser/HtmlEmailContentParser.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/parser/PictureEmailContentParser.scala
delete mode 100644 sendemail-appjoint/sendemail-core/src/main/scala/com/webank/wedatasphere/dss/appjoint/sendemail/emailcontent/parser/TableEmailContentParser.scala
delete mode 100644 visualis-appjoint/appjoint/pom.xml
delete mode 100644 visualis-appjoint/appjoint/src/main/assembly/distribution.xml
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/VisualisAppJoint.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/VisualisNodeService.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/VisualisSecurityService.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/VisualisSession.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/nodeservice/DashboardNodeService.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/nodeservice/DisplayNodeService.java
delete mode 100644 visualis-appjoint/appjoint/src/main/java/com/webank/wedatasphere/dss/appjoint/visualis/service/nodeservice/HttpUtils.java
delete mode 100644 visualis-appjoint/appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/visualis/execution/VisualisNodeExecution.scala
delete mode 100644 visualis-appjoint/appjoint/src/main/scala/com/webank/wedatasphere/dss/appjoint/visualis/execution/VisualisNodeExecutionConfiguration.scala
delete mode 100644 visualis-appjoint/appjoint/src/main/scala/com/webank/wedatasphere/linkis/server/JSONUtils.scala
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