This is an automated email from the ASF dual-hosted git repository. peacewong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 001f07a956da5b61233f56432e8c3e569f1f845b Merge: 130718490 15a4b398f Author: peacewong <[email protected]> AuthorDate: Fri Oct 28 17:11:50 2022 +0800 Merge dev-1.3.1 into master Merge dev-1.3.1 into master .asf.yaml | 8 +- .github/workflows/auto-format-pr.yaml | 3 +- .github/workflows/build-backend.yml | 10 +- .github/workflows/check-code-format.yml | 3 +- .github/workflows/check-license.yml | 3 - .../workflows/check-third-party-dependencies.yml | 7 +- .github/workflows/codeql-analysis.yml | 5 +- .github/workflows/publish-docker.yaml | 16 +- .github/workflows/publish-snapshot.yml | 4 +- CONTRIBUTING.md | 27 +- CONTRIBUTING_CN.md | 41 +- README.md | 22 +- README_CN.md | 25 +- .../accessible-executor.md | 0 docs/{configure => configuration}/elasticsearch.md | 0 docs/{configure => configuration}/executor-core.md | 0 docs/{configure => configuration}/flink.md | 0 docs/configuration/jdbc.md | 9 + .../linkis-application-manager.md | 0 .../linkis-bml-server.md | 0 docs/{configure => configuration}/linkis-common.md | 0 docs/configuration/linkis-computation-client.md | 5 + .../linkis-computation-engineconn.md | 0 .../linkis-computation-governance-common.md | 0 .../linkis-computation-orchestrator.md | 0 .../linkis-configuration.md | 0 .../linkis-engineconn-common.md | 0 .../linkis-engineconn-manager-core.md | 5 + .../linkis-engineconn-manager-server.md | 0 .../linkis-engineconn-plugin-core.md | 0 .../linkis-engineconn-plugin-server.md | 14 + .../linkis-entrance.md | 0 .../linkis-gateway-core.md | 0 .../linkis-gateway-httpclient-support.md | 5 + .../linkis-hadoop-common.md | 0 docs/configuration/linkis-httpclient.md | 6 + docs/configuration/linkis-instance-label-client.md | 5 + docs/configuration/linkis-io-file-client.md | 11 + docs/configuration/linkis-jdbc-driver.md | 5 + docs/configuration/linkis-jobhistory.md | 17 + docs/configuration/linkis-manager-common.md | 38 ++ .../linkis-metadata.md | 0 docs/configuration/linkis-module.md | 49 ++ docs/configuration/linkis-orchestrator-core.md | 26 + docs/configuration/linkis-protocol.md | 6 + docs/configuration/linkis-rpc.md | 25 + docs/configuration/linkis-scheduler.md | 9 + docs/configuration/linkis-spring-cloud-gateway.md | 5 + docs/configuration/linkis-storage.md | 32 ++ docs/configuration/linkis-udf.md | 10 + docs/configuration/pipeline.md | 10 + docs/configuration/presto.md | 21 + docs/configuration/python.md | 9 + docs/configuration/spark.md | 27 ++ docs/{configure => configuration}/sqoop.md | 0 docs/configuration/trino.md | 22 + docs/configure/jdbc.md | 10 - docs/configure/linkis-computation-client.md | 7 - docs/configure/linkis-engineconn-manager-core.md | 7 - docs/configure/linkis-engineconn-plugin-server.md | 27 -- .../configure/linkis-gateway-httpclient-support.md | 6 - docs/configure/linkis-httpclient.md | 9 - docs/configure/linkis-instance-label-client.md | 8 - docs/configure/linkis-io-file-client.md | 17 - docs/configure/linkis-jdbc-driver.md | 7 - docs/configure/linkis-jobhistory.md | 21 - docs/configure/linkis-manager-common.md | 44 -- docs/configure/linkis-module.md | 51 -- docs/configure/linkis-orchestrator-core.md | 28 -- docs/configure/linkis-protocol.md | 8 - docs/configure/linkis-rpc.md | 28 -- docs/configure/linkis-scheduler.md | 10 - docs/configure/linkis-spring-cloud-gateway.md | 7 - docs/configure/linkis-storage.md | 35 -- docs/configure/linkis-udf.md | 11 - docs/configure/pipeline.md | 13 - docs/configure/presto.md | 23 - docs/configure/python.md | 10 - docs/configure/spark.md | 31 -- docs/errorcode/elasticsearch-errorcode.md | 8 + docs/errorcode/flink-errorcode.md | 63 +++ docs/errorcode/linkis-bml-client.md | 9 + docs/errorcode/linkis-bml-server-errorcode.md | 28 ++ docs/errorcode/linkis-common-errorcode.md | 12 + docs/errorcode/linkis-configuration-errorcode.md | 26 + docs/errorcode/linkis-cs-client-errorcode.md | 16 + docs/errorcode/linkis-cs-server-errorcode.md | 8 + .../linkis-datasource-client-errorcode.md | 16 + .../linkis-datasource-manager-errorcode.md | 12 + docs/errorcode/linkis-engineconn-core-errorcode.md | 8 + .../linkis-engineconn-manager-core-errorcode.md | 7 + .../linkis-engineconn-manager-server-errorcode.md | 13 + .../linkis-engineconn-plugin-core-errorcode.md | 29 ++ docs/errorcode/linkis-engineplugin-hive.md | 9 + docs/errorcode/linkis-engineplugin-jdbc.md | 30 ++ .../linkis-engineplugin-openlookeng-errorcode.md | 11 + docs/errorcode/linkis-engineplugin-presto.md | 8 + docs/errorcode/linkis-entrance-errorcode.md | 34 ++ .../linkis-gateway-authentication-errorcode.md | 12 + docs/errorcode/linkis-gateway-core-errorcode.md | 10 + .../linkis-gateway-httpclient-support_errorcode.md | 13 + docs/errorcode/linkis-httpclient-errorcode.md | 8 + docs/errorcode/linkis-instance-label-errorcode.md | 8 + docs/errorcode/linkis-label-common-errorcode.md | 13 + docs/errorcode/linkis-manager-common-errorcode.md | 23 + .../linkis-manager-persistence-errorcode.md | 9 + docs/errorcode/linkis-metadata-errorcode.md | 9 + docs/errorcode/linkis-metadata-query-errorcode.md | 21 + docs/errorcode/linkis-module-errorcode.md | 15 + docs/errorcode/linkis-rpc-errorcode.md | 23 + docs/errorcode/linkis-scheduler-errorcode.md | 11 + docs/errorcode/linkis-spring-cloud-gateway.md | 6 + docs/errorcode/linkis-storage -errorcode.md | 26 + docs/errorcode/pipeline -errorcode.md | 18 + docs/errorcode/python-errorcode.md | 7 + docs/errorcode/shell-errorcode.md | 6 + docs/errorcode/spark-errorcode.md | 19 + docs/errorcode/sqoop-errorcode.md | 9 + docs/index.md | 6 +- docs/info-1.1.3.md | 6 + docs/info-1.2.1.md | 28 ++ docs/trino-usage.md | 150 ++++++ linkis-commons/linkis-common/pom.xml | 3 +- .../errorcode/LinkisCommonsErrorCodeSummary.java | 22 +- ...inkisComputationGovernanceErrorCodeSummary.java | 29 +- .../common/errorcode/LinkisErrorCodeSummary.java | 7 +- .../errorcode/LinkisFrameErrorCodeSummary.java | 6 +- .../linkis/common/conf/BDPConfiguration.scala | 14 +- .../org/apache/linkis/common/conf/CommonVars.scala | 12 +- .../linkis/common/listener/ListenerEventBus.scala | 6 +- .../apache/linkis/common/utils/ArrayUtils.scala | 4 +- .../linkis/common/utils/CodeAndRunTypeUtils.scala | 10 +- .../apache/linkis/common/utils/FileService.scala | 2 +- .../linkis/common/utils/ShutdownHookManager.scala | 139 ++++++ .../apache/linkis/common/utils/ShutdownUtils.scala | 87 ---- .../org/apache/linkis/common/utils/Utils.scala | 6 +- .../org/apache/linkis/common/utils/ZipUtils.scala | 47 +- .../LinkisCommonsErrorCodeSummaryTest.java | 42 +- ...sComputationGovernanceErrorCodeSummaryTest.java | 51 +- .../errorcode/LinkisErrorCodeSummaryTest.java | 17 +- .../errorcode/LinkisFrameErrorCodeSummaryTest.java | 23 +- .../linkis/common/utils/ClassUtilsTest.scala | 11 +- linkis-commons/linkis-hadoop-common/pom.xml | 3 +- linkis-commons/linkis-httpclient/pom.xml | 3 +- .../linkis/httpclient/AbstractHttpClient.scala | 105 ++-- .../AbstractAuthenticationStrategy.scala | 3 +- .../httpclient/discovery/AbstractDiscovery.scala | 11 +- .../LinkisHttpclientErrorCodeSummary.java | 71 +++ .../httpclient/exception/DiscoveryException.scala | 4 +- .../exception/HttpClientResultException.scala | 4 +- .../exception/HttpClientRetryException.scala | 4 +- .../exception/HttpMessageParseException.scala | 9 +- .../linkis/httpclient/request/UploadAction.scala | 4 +- .../httpclient/response/HashMapHttpResult.scala | 3 +- linkis-commons/linkis-module/pom.xml | 2 +- .../errorcode/LinkisModuleErrorCodeSummary.java | 74 +++ .../scala/org/apache/linkis/server/Message.scala | 3 +- .../linkis/server/conf/ServerConfiguration.scala | 11 +- .../exception/IllegalUserTicketException.scala | 4 +- .../server/exception/NonLoginException.scala | 4 +- .../scala/org/apache/linkis/server/package.scala | 12 +- .../server/restful/SpringRestfulCatchAOP.scala | 14 +- .../linkis/server/security/ProxyUserSSOUtils.scala | 3 +- .../linkis/server/security/SecurityFilter.scala | 8 +- .../linkis/server/socket/ControllerServer.scala | 21 +- .../apache/linkis/server/socket/ServerSocket.scala | 2 +- .../server/socket/controller/ServerEvent.scala | 20 +- .../socket/controller/ServerListenerEventBus.scala | 13 +- .../linkis/server/utils/LinkisMainHelper.scala | 5 +- linkis-commons/linkis-mybatis/pom.xml | 2 +- linkis-commons/linkis-protocol/pom.xml | 2 +- .../apache/linkis/protocol/utils/TaskUtils.scala | 34 +- .../linkis/protocol/utils/ZuulEntranceUtils.scala | 11 +- linkis-commons/linkis-rpc/pom.xml | 3 +- .../rpc/errorcode/LinkisRpcErrorCodeSummary.java | 61 +++ .../linkis/rpc/message/method/MessageExecutor.java | 4 +- .../org/apache/linkis/rpc/BaseRPCSender.scala | 14 +- .../org/apache/linkis/rpc/MessageReceiver.scala | 3 +- .../scala/org/apache/linkis/rpc/RPCMapCache.scala | 8 +- .../org/apache/linkis/rpc/RPCReceiveRestful.scala | 3 +- .../org/apache/linkis/rpc/RPCSpringBeanCache.scala | 23 +- .../main/scala/org/apache/linkis/rpc/Sender.scala | 2 + .../apache/linkis/rpc/conf/RPCConfiguration.scala | 21 +- .../linkis/rpc/interceptor/RPCServerLoader.scala | 25 +- .../common/BroadcastRPCInterceptor.scala | 4 +- .../common/CacheableRPCInterceptor.scala | 8 +- .../SpringCloudFeignConfigurationCache.scala | 6 +- .../linkis/rpc/sender/SpringMVCRPCSender.scala | 10 +- .../org/apache/linkis/rpc/sender/UnionSender.scala | 3 +- .../sender/eureka/EurekaClientRefreshUtils.scala | 30 +- .../rpc/sender/eureka/EurekaRPCServerLoader.scala | 8 +- .../rpc/transform/JavaCollectionSerializer.scala | 2 +- .../apache/linkis/rpc/transform/RPCConsumer.scala | 12 +- .../apache/linkis/rpc/transform/RPCProduct.scala | 9 +- .../org/apache/linkis/rpc/utils/RPCUtils.scala | 24 +- .../linkis/rpc/message/utils/MessageUtilsTest.java | 2 +- linkis-commons/linkis-scheduler/pom.xml | 2 +- .../errorcode/LinkisSchedulerErrorCodeSummary.java | 64 +++ .../linkis/scheduler/AbstractScheduler.scala | 12 +- .../scheduler/executer/AbstractExecutor.scala | 23 +- .../linkis/scheduler/queue/AbstractGroup.scala | 10 +- .../org/apache/linkis/scheduler/queue/Job.scala | 27 +- .../apache/linkis/scheduler/queue/LockJob.scala | 4 +- .../linkis/scheduler/queue/LoopArrayQueue.scala | 9 +- .../linkis/scheduler/queue/SchedulerEvent.scala | 20 +- .../apache/linkis/scheduler/queue/UserJob.scala | 8 +- .../queue/fifoqueue/FIFOConsumerManager.scala | 6 +- .../scheduler/queue/fifoqueue/FIFOGroup.scala | 33 +- .../queue/fifoqueue/FIFOUserConsumer.scala | 25 +- .../parallelqueue/ParallelConsumerManager.scala | 17 +- linkis-commons/linkis-storage/pom.xml | 7 +- .../LinkisIoFileClientErrorCodeSummary.java | 77 +++ .../errorcode/LinkisIoFileErrorCodeSummary.java | 72 +++ .../errorcode/LinkisStorageErrorCodeSummary.java | 70 +++ .../storage/exception/FSNotInitException.java | 4 +- .../linkis/storage/exception/StorageErrorCode.java | 2 +- .../linkis/storage/fs/impl/HDFSFileSystem.java | 4 + .../linkis/storage/fs/impl/LocalFileSystem.java | 13 +- .../org/apache/linkis/storage/FSFactory.scala | 11 +- .../org/apache/linkis/storage/domain/Dolphin.scala | 9 +- .../linkis/storage/excel/StorageExcelWriter.scala | 4 +- .../org/apache/linkis/storage/io/IOClient.scala | 8 +- .../storage/io/IOMethodInterceptorCreator.scala | 8 +- .../resultset/DefaultResultSetFactory.scala | 28 +- .../linkis/storage/resultset/ResultSetReader.scala | 9 +- .../storage/resultset/StorageResultSetReader.scala | 6 +- .../storage/resultset/StorageResultSetWriter.scala | 57 ++- .../resultset/table/TableResultDeserializer.scala | 17 +- .../linkis/storage/script/ScriptFsWriter.scala | 6 +- .../linkis/storage/script/VariableParser.scala | 75 ++- .../storage/script/parser/CommonScriptParser.scala | 28 +- .../script/reader/StorageScriptFsReader.scala | 3 +- .../script/writer/StorageScriptFsWriter.scala | 8 +- .../apache/linkis/storage/source/FileSource.scala | 17 +- .../apache/linkis/storage/source/FileSplit.scala | 6 +- .../linkis/storage/source/TextFileSource.scala | 4 +- .../linkis/storage/utils/FileSystemUtils.scala | 3 +- .../storage/utils/StorageConfiguration.scala | 3 + .../linkis/storage/utils/StorageHelper.scala | 31 +- .../apache/linkis/storage/utils/StorageUtils.scala | 5 +- linkis-commons/pom.xml | 2 +- .../linkis-cli/linkis-cli-application/pom.xml | 2 +- .../src/main/assembly/distribution.xml | 8 +- .../linkis-cli/linkis-cli-common/pom.xml | 2 +- .../linkis-cli/linkis-cli-core/pom.xml | 2 +- .../linkis-client/linkis-cli/pom.xml | 3 +- .../linkis-computation-client/pom.xml | 3 +- .../computation/client/LinkisJobBuilder.scala | 3 +- .../computation/client/job/AbstractLinkisJob.scala | 3 +- .../client/once/simple/SimpleOnceJob.scala | 6 +- .../request/GetPartitionStatisticInfoAction.scala | 6 +- .../request/GetTableStatisticInfoAction.scala | 3 +- .../ujes/client/request/JobExecIdAction.scala | 3 +- .../ujes/client/request/JobExecuteAction.scala | 16 +- .../linkis/ujes/client/request/JobListAction.scala | 3 +- .../ujes/client/request/JobSubmitAction.scala | 3 +- .../linkis/ujes/client/response/GetDBSResult.scala | 4 +- .../ujes/client/response/JobInfoResult.scala | 7 +- .../ujes/client/response/JobProgressResult.scala | 8 +- .../ujes/client/response/ResultSetListResult.scala | 13 +- .../ujes/client/response/ResultSetResult.scala | 4 +- .../ujes/client/response/image/ShowImage.scala | 4 +- .../linkis/ujes/client/utils/UJESClientUtils.scala | 2 + .../linkis-computation-governance-common/pom.xml | 3 +- .../engineconn/EngineConnExecutorErrorCode.java | 40 ++ .../EngineConnExecutorErrorException.java | 37 ++ .../common/conf/GovernaceCommonConf.scala | 3 + .../engineconn/EngineConnExecutorErrorCode.java | 40 -- .../EngineConnExecutorErrorException.java | 38 -- .../governance/common/paser/CodeParser.scala | 33 +- .../common/protocol/task/RequestTask.scala | 2 +- .../common/utils/GovernanceConstant.scala | 2 +- .../common/utils/OnceExecutorContentUtils.scala | 6 +- .../common/paser/PythonCodeParseTest.scala | 24 + .../linkis-engineconn-linux-launch/pom.xml | 2 +- .../linkis-engineconn-manager-core/pom.xml | 4 +- .../core/errorcode/LinkisECMErrorCodeSummary.java | 57 +++ .../ecm/core/launch/DiscoveryMsgGenerator.scala | 3 +- .../core/launch/ProcessEngineCommandBuilder.scala | 2 +- .../ecm/core/launch/ProcessEngineConnLaunch.scala | 13 +- .../linkis-engineconn-manager-server/pom.xml | 4 +- .../src/main/assembly/distribution.xml | 8 +- .../EngineconnServerErrorCodeSummary.java | 93 ++++ .../ecm/server/engineConn/DefaultEngineConn.scala | 2 +- .../ecm/server/errorcode/ECMErrorConstants.scala | 22 - .../apache/linkis/ecm/server/hook/ECMHook.scala | 2 +- .../ecm/server/metrics/DefaultECMMetrics.scala | 4 +- .../server/operator/EngineConnLogOperator.scala | 15 +- .../operator/EngineConnYarnLogOperator.scala | 13 +- .../impl/BmlResourceLocalizationService.scala | 5 +- .../service/impl/DefaultECMMetricsService.scala | 2 +- .../service/impl/DefaultECMRegisterService.scala | 4 +- .../impl/DefaultEngineConnListService.scala | 10 +- .../impl/ProcessEngineConnLaunchService.scala | 12 +- .../apache/linkis/ecm/server/util/ECMUtils.scala | 11 +- .../linkis-engineconn-manager/pom.xml | 3 +- .../linkis-once-engineconn/pom.xml | 3 +- .../engineconn/once/executor/OnceExecutor.scala | 3 +- .../executor/creation/OnceExecutorManager.scala | 7 +- .../execution/OnceEngineConnExecution.scala | 3 +- .../linkis-streaming-engineconn/pom.xml | 3 +- .../linkis-computation-engineconn/pom.xml | 4 +- .../async/AsyncConcurrentComputationExecutor.scala | 4 +- .../creation/ComputationExecutorManager.scala | 4 +- .../computation/executor/cs/CSResourceParser.scala | 5 +- .../computation/executor/cs/CSTableRegister.scala | 4 +- .../execute/ComputationEngineConnExecution.scala | 3 +- .../executor/execute/ComputationExecutor.scala | 19 +- .../executor/execute/EngineExecutionContext.scala | 6 +- .../executor/hook/UDFLoadEngineConnHook.scala | 4 +- .../EngineResultsetPrefixExecutorHook.scala | 57 --- .../computation/executor/rs/RsOutputStream.scala | 10 +- .../executor/service/TaskExecutionService.scala | 4 +- .../service/TaskExecutionServiceImpl.scala | 41 +- .../upstream/access/ECTaskEntranceInfoAccess.scala | 24 +- .../upstream/entity/ECTaskEntranceConnection.scala | 21 +- .../upstream/handler/ECTaskKillHandler.scala | 6 +- .../wrapper/ECTaskEntranceConnectionWrapper.scala | 5 +- .../executor/utlis/ComputationEngineConstant.scala | 8 +- .../linkis-engineconn-common/pom.xml | 2 +- .../common/creation/EngineCreationContext.scala | 2 +- .../linkis-engineconn-core/pom.xml | 2 +- .../LinkisEngineconnCoreErrorCodeSummary.java | 56 +++ .../AbstractCodeLanguageLabelExecutorFactory.scala | 5 +- .../core/engineconn/EngineConnManager.scala | 5 +- .../core/execution/EngineConnExecution.scala | 7 +- .../engineconn/core/executor/ExecutorManager.scala | 10 +- .../accessible-executor/pom.xml | 4 +- .../AccessibleExecutorSpringConfiguration.scala | 4 +- .../executor/entity/AccessibleExecutor.scala | 21 +- .../executor/lock/EngineConnTimedLock.scala | 4 +- .../acessible/executor/log/LogHelper.scala | 7 +- .../service/EngineConnTimedLockService.scala | 8 +- .../callback/service/EngineConnCallback.scala | 3 +- .../executor-core/pom.xml | 3 +- .../linkis-engineconn-plugin-core/pom.xml | 4 +- .../errorcode/EngineconnCoreErrorCodeSummary.java | 95 ++++ .../common/conf/EnvConfiguration.scala | 10 +- .../common/creation/EngineConnFactory.scala | 6 +- .../exception/EngineConnPluginLoadException.scala | 3 +- .../EngineConnPluginLoadResourceException.scala | 3 +- .../EngineConnPluginNotFoundException.scala | 3 +- .../JavaProcessEngineConnLaunchBuilder.scala | 8 +- .../process/ProcessEngineConnLaunchBuilder.scala | 9 +- .../exception/EngineConnPluginLoadException.scala | 3 +- .../EngineConnPluginLoadResourceException.scala | 3 +- .../EngineConnPluginNotFoundException.scala | 3 +- .../resource/AbstractEngineResourceFactory.scala | 11 +- .../linkis-engineconn-plugin-server/pom.xml | 2 +- .../src/main/assembly/distribution.xml | 9 +- .../classloader/EngineConnPluginClassLoader.java | 3 - .../AbstractEngineConnBmlResourceGenerator.scala | 41 +- .../DefaultEngineConnBmlResourceGenerator.scala | 10 +- .../service/DefaultEngineConnLaunchService.scala | 14 +- .../DefaultEngineConnResourceFactoryService.scala | 11 +- .../service/DefaultEngineConnResourceService.scala | 26 +- .../linkis-engineconn/pom.xml | 3 +- .../linkis-entrance/pom.xml | 3 +- .../src/main/assembly/distribution.xml | 8 +- .../errorcode/EntranceErrorCodeSummary.java | 104 ++++ .../entrance/job/EntranceExecuteRequest.java | 35 +- .../linkis/entrance/job/EntranceExecutionJob.java | 159 +----- .../entrance/parser/AbstractEntranceParser.java | 9 +- .../persistence/QueryPersistenceEngine.java | 109 +---- .../persistence/QueryPersistenceManager.java | 44 +- .../apache/linkis/entrance/EntranceServer.scala | 28 +- .../linkis/entrance/EntranceWebSocketService.scala | 44 +- .../cli/heartbeat/CliHeartbeatMonitor.scala | 4 +- .../entrance/conf/EntranceConfiguration.scala | 2 + .../exception/JobHistoryFailedException.scala | 4 +- .../exception/SensitiveTablesCheckException.scala | 4 +- .../entrance/execute/DefaultEntranceExecutor.scala | 139 ++---- .../linkis/entrance/execute/EntranceExecutor.scala | 15 +- .../entrance/execute/EntranceExecutorManager.scala | 39 +- .../linkis/entrance/execute/EntranceJob.scala | 61 +-- .../execute/ExecuteRequestInterceptor.scala | 4 +- .../apache/linkis/entrance/execute/MarkReq.scala | 89 ---- .../interceptor/impl/CommentInterceptor.scala | 2 + .../impl/ShellDangerousGrammerInterceptor.scala | 7 +- .../linkis/entrance/log/CacheLogManager.scala | 8 +- .../linkis/entrance/log/ErrorCodeListener.scala | 4 +- .../linkis/entrance/log/HDFSCacheLogWriter.scala | 5 +- .../apache/linkis/entrance/log/LogManager.scala | 4 +- .../org/apache/linkis/entrance/log/LogReader.scala | 2 +- .../org/apache/linkis/entrance/log/LogWriter.scala | 6 +- .../org/apache/linkis/entrance/log/LoopArray.scala | 5 +- .../linkis/entrance/log/WebSocketLogWriter.scala | 3 +- .../EntranceUserParallelOrchestratorPlugin.scala | 2 +- .../entrance/parser/CommonEntranceParser.scala | 49 +- .../entrance/persistence/PersistenceEngine.scala | 11 +- .../entrance/scheduler/EntranceGroupFactory.scala | 39 +- .../scheduler/cache/ReadCacheConsumer.scala | 31 +- .../entrance/timeout/JobTimeoutManager.scala | 22 +- .../linkis/entrance/utils/JobHistoryHelper.scala | 26 +- .../linkis-jdbc-driver/pom.xml | 2 +- .../linkis-manager/distribution.xml | 297 ++++++++++++ .../linkis-application-manager/pom.xml | 4 +- .../src/main/assembly/distribution.xml | 8 +- .../am/restful/ECResourceInfoRestfulApi.java | 1 + .../linkis/manager/am/restful/EMRestfulApi.java | 44 +- .../manager/am/restful/EngineRestfulApi.java | 22 +- .../manager/am/service/ECResourceInfoService.java | 2 + .../am/service/impl/ECResourceInfoServiceImpl.java | 12 +- .../manager/am/util/ECResourceInfoUtils.java | 46 +- .../manager/am/vo/ECResourceInfoRecordVo.java | 10 + .../service/impl/ExternalResourceServiceImpl.java | 23 +- .../am/conf/EngineConnConfigurationService.scala | 6 +- .../linkis/manager/am/label/AMLabelChecker.scala | 4 +- .../linkis/manager/am/label/AMLabelFilter.scala | 10 +- .../am/label/DefaultManagerLabelService.scala | 8 +- .../manager/am/manager/DefaultEMNodeManager.scala | 18 +- .../am/manager/DefaultEngineNodeManager.scala | 36 +- .../manager/am/manager/EngineNodeManager.scala | 2 + .../am/selector/rule/OverLoadNodeSelectRule.scala | 5 +- .../am/selector/rule/TaskInfoNodeSelectRule.scala | 5 +- .../am/service/em/DefaultEMEngineService.scala | 16 +- .../am/service/em/DefaultEMInfoService.scala | 8 +- .../engine/DefaultEngineAskEngineService.scala | 7 +- .../DefaultEngineConnStatusCallbackService.scala | 3 +- .../engine/DefaultEngineCreateService.scala | 63 +-- .../service/engine/DefaultEngineInfoService.scala | 13 +- .../engine/DefaultEngineRecycleService.scala | 6 +- .../service/engine/DefaultEngineReuseService.scala | 33 +- .../service/engine/DefaultEngineStopService.scala | 3 +- .../am/service/engine/EngineCreateService.scala | 2 - .../am/service/monitor/NodeHeartbeatMonitor.scala | 51 +- .../apache/linkis/manager/am/utils/AMUtils.scala | 103 ++-- .../label/score/DefaultNodeLabelScorer.scala | 24 +- .../impl/DefaultNodeLabelRemoveService.scala | 5 +- .../service/impl/DefaultNodeLabelService.scala | 89 ++-- .../service/impl/DefaultResourceLabelService.scala | 14 +- .../service/impl/DefaultUserLabelService.scala | 37 +- .../rm/external/yarn/YarnResourceRequester.scala | 38 +- .../manager/rm/message/RMMessageService.scala | 3 +- .../linkis/manager/rm/restful/RMMonitorRest.scala | 57 ++- .../rm/service/RequestResourceService.scala | 204 ++++++-- .../manager/rm/service/ResourceLockService.scala | 4 +- .../rm/service/impl/DefaultResourceManager.scala | 98 ++-- .../impl/DriverAndYarnReqResourceService.scala | 37 +- .../rm/service/impl/LabelResourceServiceImpl.scala | 4 +- .../rm/service/impl/ResourceLogService.scala | 48 +- .../rm/service/impl/UserResourceService.scala | 8 +- .../apache/linkis/manager/rm/utils/RMUtils.scala | 81 +++- .../manager/rm/utils/UserConfiguration.scala | 7 +- .../service/common/pointer/NodePointer.scala | 1 + .../external/yarn/YarnResourceRequesterTest.scala | 38 ++ .../linkis-manager/linkis-label-common/pom.xml | 4 +- .../label/builder/CombinedLabelBuilder.java | 7 +- .../label/builder/DefaultGlobalLabelBuilder.java | 13 +- .../linkis/manager/label/entity/TenantLabel.java | 7 +- .../manager/label/entity/cluster/EnvLabel.java | 7 +- .../label/entity/engine/UserCreatorLabel.java | 8 +- .../manager/label/entity/route/RouteLabel.java | 7 +- .../errorcode/LabelCommonErrorCodeSummary.java | 63 +++ .../linkis-manager/linkis-manager-common/pom.xml | 4 +- .../linkis/manager/common/constant/RMConstant.java | 33 ++ .../entity/persistence/ECResourceInfoRecord.java | 10 + .../errorcode/ManagerCommonErrorCodeSummary.java | 86 ++++ .../manager/common/entity/resource/Resource.scala | 83 +++- .../manager/common/utils/ResourceUtils.scala | 93 ++-- .../linkis-manager-persistence/pom.xml | 4 +- .../linkis/manager/dao/ECResourceRecordMapper.java | 2 + .../linkis/manager/dao/LockManagerMapper.java | 23 +- .../linkis/manager/dao/NodeManagerMapper.java | 98 +--- .../manager/dao/NodeMetricManagerMapper.java | 57 +-- .../linkis/manager/dao/ResourceManagerMapper.java | 44 +- .../manager/dao/impl/ECResourceRecordMapper.xml | 9 +- .../linkis/manager/dao/impl/LockManagerMapper.xml | 14 + .../linkis/manager/dao/impl/NodeManagerMapper.xml | 83 +++- .../manager/dao/impl/NodeMetricManagerMapper.xml | 94 ++-- .../manager/dao/impl/ResourceManagerMapper.xml | 59 +++ .../LinkisManagerPersistenceErrorCodeSummary.java | 56 +++ .../impl/DefaultLabelManagerPersistence.java | 8 +- .../impl/DefaultNodeManagerPersistence.java | 34 +- .../test/java/org/apache/linkis/manager/Scan.java | 26 +- .../linkis/manager/WebApplicationServer.java | 34 ++ .../org/apache/linkis/manager/dao/BaseDaoTest.java | 31 ++ .../linkis/manager/dao/LockManagerMapperTest.java | 59 +++ .../linkis/manager/dao/NodeManagerMapperTest.java | 181 +++++++ .../manager/dao/NodeMetricManagerMapperTest.java | 113 +++++ .../manager/dao/ResourceManagerMapperTest.java | 184 +++++++ .../manager/persistence/PersistenceTest.java | 303 ------------ .../src/test/resources/application.properties | 41 ++ .../src/test/resources/create.sql | 126 +++++ .../linkis-manager/pom.xml | 47 +- linkis-computation-governance/pom.xml | 2 +- linkis-dist/bin/checkEnv.sh | 4 - linkis-dist/bin/common.sh | 2 +- linkis-dist/bin/install.sh | 21 +- linkis-dist/deploy-config/db.sh | 2 +- linkis-dist/deploy-config/linkis-env.sh | 8 +- linkis-dist/docker/scripts/entry-point-ldh.sh | 2 +- linkis-dist/docker/scripts/prepare-ldh-image.sh | 2 +- linkis-dist/helm/README.md | 64 +-- linkis-dist/helm/README_CN.md | 4 +- linkis-dist/helm/charts/linkis/Chart.yaml | 2 +- linkis-dist/helm/scripts/common.sh | 2 +- linkis-dist/helm/scripts/create-kind-cluster.sh | 2 +- linkis-dist/helm/scripts/install-charts.sh | 2 +- linkis-dist/helm/scripts/install-ldh.sh | 2 +- linkis-dist/helm/scripts/install-mysql.sh | 2 +- linkis-dist/helm/scripts/login-pod.sh | 2 +- linkis-dist/helm/scripts/remote-debug-proxy.sh | 106 ++++ linkis-dist/package/bin/linkis-cli | 2 +- linkis-dist/package/bin/linkis-cli-hive | 2 +- linkis-dist/package/bin/linkis-cli-pre | 2 +- linkis-dist/package/bin/linkis-cli-spark-sql | 2 +- linkis-dist/package/bin/linkis-cli-spark-submit | 2 +- linkis-dist/package/bin/linkis-cli-sqoop | 2 +- .../package/conf/linkis-cg-engineplugin.properties | 28 -- .../conf/linkis-cg-linkismanager.properties | 16 +- .../conf/linkis-ps-publicservice.properties | 8 +- linkis-dist/package/db/linkis_ddl.sql | 12 +- linkis-dist/package/db/linkis_dml.sql | 82 +++- .../db/upgrade/1.2.1_schema/mysql/linkis_dml.sql | 85 ++++ .../db/upgrade/1.3.1_schema/mysql/linkis_ddl.sql | 34 ++ .../db/upgrade/1.3.1_schema/mysql/linkis_dml.sql | 19 + linkis-dist/package/sbin/common.sh | 2 +- .../package/sbin/ext/linkis-cg-engineconnmanager | 2 +- .../package/sbin/ext/linkis-cg-engineplugin | 33 -- linkis-dist/package/sbin/ext/linkis-cg-entrance | 2 +- .../package/sbin/ext/linkis-cg-linkismanager | 2 +- linkis-dist/package/sbin/ext/linkis-common-start | 2 +- linkis-dist/package/sbin/ext/linkis-mg-eureka | 2 +- linkis-dist/package/sbin/ext/linkis-mg-gateway | 2 +- .../package/sbin/ext/linkis-ps-publicservice | 2 +- linkis-dist/package/sbin/graceful-upgrade.sh | 2 +- linkis-dist/package/sbin/kill-process-by-pid.sh | 2 +- linkis-dist/package/sbin/linkis-daemon.sh | 28 +- linkis-dist/package/sbin/linkis-start-all.sh | 10 - linkis-dist/package/sbin/linkis-stop-all.sh | 7 +- linkis-dist/pom.xml | 232 ++++----- .../{License-druid.txt => LICENSE-druid.txt} | 0 .../release-docs/licenses/LICENSE-failsafe.txt | 177 +++++++ .../release-docs/licenses/LICENSE-trino-client.txt | 202 ++++++++ .../release-docs/licenses/LICENSE-units.txt | 202 ++++++++ linkis-dist/src/main/assembly/distribution.xml | 20 +- linkis-engineconn-plugins/elasticsearch/pom.xml | 2 +- .../src/main/assembly/distribution.xml | 6 +- .../errorcode/EasticsearchErrorCodeSummary.java | 68 +++ .../exception/EsConvertResponseException.scala | 4 +- .../exception/EsParamsIllegalException.scala | 4 +- .../executer/ElasticSearchEngineConnExecutor.scala | 238 --------- .../executer/ElasticSearchExecutorOrder.scala | 25 - .../executer/client/ElasticSearchExecutor.scala | 46 -- .../executer/client/ElasticSearchResponse.scala | 31 -- .../elasticsearch/executer/client/EsClient.scala | 131 ----- .../executer/client/EsClientFactory.scala | 185 ------- .../executer/client/ResponseHandler.scala | 80 --- .../client/impl/ElasticSearchExecutorImpl.scala | 111 ----- .../executer/client/impl/ResponseHandlerImpl.scala | 171 ------- .../executor/ElasticSearchEngineConnExecutor.scala | 238 +++++++++ .../executor/ElasticSearchExecutorOrder.scala | 25 + .../executor/client/ElasticSearchExecutor.scala | 46 ++ .../executor/client/ElasticSearchResponse.scala | 31 ++ .../elasticsearch/executor/client/EsClient.scala | 131 +++++ .../executor/client/EsClientFactory.scala | 185 +++++++ .../executor/client/ResponseHandler.scala | 82 ++++ .../client/impl/ElasticSearchExecutorImpl.scala | 112 +++++ .../executor/client/impl/ResponseHandlerImpl.scala | 170 +++++++ .../factory/ElasticSearchJsonExecutorFactory.scala | 2 +- .../factory/ElasticSearchSqlExecutorFactory.scala | 2 +- .../TestElasticSearchEngineConnPlugin.scala | 34 ++ linkis-engineconn-plugins/flink/pom.xml | 2 +- .../flink/src/main/assembly/distribution.xml | 8 +- .../flink/client/config/Environment.java | 23 +- .../flink/client/config/entries/ConfigEntry.java | 4 +- .../flink/client/context/ExecutionContext.java | 13 +- .../deployment/ClusterDescriptorAdapter.java | 17 +- .../flink/client/result/BatchResult.java | 8 +- .../flink/client/result/ChangelogResult.java | 8 +- .../flink/client/result/ResultUtil.java | 15 +- .../client/sql/operation/AbstractJobOperation.java | 4 +- .../client/sql/operation/OperationFactoryImpl.java | 10 +- .../sql/operation/impl/CreateViewOperation.java | 7 +- .../sql/operation/impl/DescribeTableOperation.java | 4 +- .../sql/operation/impl/DropViewOperation.java | 4 +- .../sql/operation/impl/ExplainOperation.java | 6 +- .../client/sql/operation/impl/InsertOperation.java | 4 +- .../client/sql/operation/impl/SelectOperation.java | 11 +- .../sql/operation/impl/UseCatalogOperation.java | 7 +- .../sql/operation/impl/UseDatabaseOperation.java | 7 +- .../client/sql/parser/SqlCommandParserImpl.java | 10 +- .../flink/errorcode/FlinkErrorCodeSummary.java | 203 ++++++++ .../flink/exception/ExecutorInitException.java | 8 +- .../flink/exception/FlinkInitFailedException.java | 8 +- .../flink/exception/JobExecutionException.java | 8 +- .../flink/exception/SqlExecutionException.java | 8 +- .../flink/exception/SqlParseException.java | 8 +- .../flink/FlinkEngineConnPlugin.scala | 3 +- .../flink/executor/FlinkCodeOnceExecutor.scala | 19 +- .../flink/executor/FlinkExecutor.scala | 9 +- .../flink/executor/FlinkOnceExecutor.scala | 12 +- .../executor/FlinkSQLComputationExecutor.scala | 21 +- .../executormanager/FlinkExecutorManager.scala | 12 +- .../flink/factory/FlinkEngineConnFactory.scala | 42 +- .../flink/listener/FlinkListenerGroup.scala | 4 +- .../flink/operator/TriggerSavepointOperator.scala | 5 +- .../engineconnplugin/flink/ql/GrammarFactory.scala | 7 +- .../resource/FlinkEngineConnResourceFactory.scala | 3 +- .../flink/setting/HudiSettings.scala | 6 +- .../engineconnplugin/flink/util/ClassUtil.scala | 8 +- linkis-engineconn-plugins/hive/pom.xml | 2 +- .../hive/src/main/assembly/distribution.xml | 8 +- .../hive/errorcode/HiveErrorCodeSummary.java | 64 +++ .../engineplugin/hive/common/HiveUtils.scala | 2 + .../hive/creation/HiveEngineConnFactory.scala | 23 +- .../exception/NotSupportedHiveTypeException.scala | 16 +- .../hive/executor/HiveEngineConnExecutor.scala | 56 ++- .../hive/hook/HiveAddJarsEngineHook.scala | 4 +- .../hive/hook/HiveAddMetaTableNameHook.scala | 5 +- .../linkis/engineplugin/hive/log/LogHelper.scala | 2 + .../hive/progress/HiveProgressHelper.scala | 4 +- .../common/errorcode/HiveErrorCodeSummaryTest.java | 97 ++++ linkis-engineconn-plugins/io_file/pom.xml | 2 +- .../io_file/src/main/assembly/distribution.xml | 8 +- .../engineplugin/io/IoEngineConnPlugin.scala | 9 +- .../manager/engineplugin/io/domain/FSInfo.scala | 2 +- .../io/executor/IoEngineConnExecutor.scala | 52 +- .../engineplugin/io/service/FsProxyService.scala | 11 +- .../manager/engineplugin/io/utils/IOHelp.scala | 38 +- linkis-engineconn-plugins/jdbc/pom.xml | 20 +- .../jdbc/src/main/assembly/distribution.xml | 8 +- .../engineplugin/jdbc/ConnectionManager.java | 27 +- .../jdbc/errorcode/JDBCErrorCodeSummary.java | 95 ++++ .../engineplugin/jdbc/monitor/ProgressMonitor.java | 86 ++++ .../jdbc/monitor/impl/TrinoProgressMonitor.java | 88 ++++ .../engineplugin/jdbc/utils/JdbcParamUtils.java | 8 +- .../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 4 +- .../jdbc/exception/JDBCDatasourceException.scala | 7 +- .../exception/JDBCParamsIllegalException.scala | 9 +- .../jdbc/executer/JDBCEngineConnExecutor.scala | 383 --------------- .../engineplugin/jdbc/executer/JDBCHelper.java | 168 ------- .../jdbc/executer/JDBCMultiDatasourceParser.scala | 223 --------- .../jdbc/executer/JDBCSQLCodeParser.scala | 74 --- .../jdbc/executor/JDBCEngineConnExecutor.scala | 417 ++++++++++++++++ .../engineplugin/jdbc/executor/JDBCHelper.java | 168 +++++++ .../jdbc/executor/JDBCMultiDatasourceParser.scala | 256 ++++++++++ .../jdbc/executor/JDBCSQLCodeParser.scala | 78 +++ .../jdbc/factory/JDBCEngineConnFactory.scala | 2 +- .../engineplugin/jdbc/ProgressMonitorTest.java | 74 +++ .../jdbc/errorcode/JDBCErrorCodeSummaryTest.java | 71 +++ .../executer/JDBCMultiDatasourceParserTest.scala | 144 ------ .../executor/JDBCMultiDatasourceParserTest.scala | 144 ++++++ .../TestJDBCEngineConnExecutor.scala | 168 ------- .../jdbc/executor/TestJDBCEngineConnExecutor.scala | 198 ++++++++ linkis-engineconn-plugins/openlookeng/pom.xml | 4 +- .../openlookeng/src/main/assembly/distribution.xml | 8 +- .../errorcode/OpenLooKengErrorCodeSummary.java | 67 +++ .../exception/OpenLooKengSourceGroupException.java | 27 -- .../executor/OpenLooKengEngineConnExecutor.java | 10 +- .../errorcode/OpenLooKengErrorCodeSummaryTest.java | 71 +++ linkis-engineconn-plugins/pipeline/pom.xml | 2 +- .../pipeline/src/main/assembly/distribution.xml | 8 +- .../errorcode/PopelineErrorCodeSummary.java | 62 +++ .../pipeline/executor/CSVExecutor.scala | 14 +- .../pipeline/executor/ExcelExecutor.scala | 12 +- .../pipeline/executor/PipeLineExecutor.scala | 2 +- .../executor/PipelineEngineConnExecutor.scala | 12 +- .../executor/PipelineExecutorSelector.scala | 15 +- linkis-engineconn-plugins/pom.xml | 3 +- linkis-engineconn-plugins/presto/pom.xml | 2 +- .../presto/src/main/assembly/distribution.xml | 6 +- .../presto/errorcode/PrestoErrorCodeSummary.java | 66 +++ .../presto/exception/PrestoException.scala | 10 +- .../presto/executor/PrestoEngineConnExecutor.scala | 22 +- .../errorcode/PrestoErrorCodeSummaryTest.java | 69 +++ linkis-engineconn-plugins/python/pom.xml | 2 +- .../python/src/main/assembly/distribution.xml | 8 +- .../errorcode/LinkisPythonErrorCodeSummary.java | 55 +++ .../exception/NoSupportEngineException.scala | 4 +- .../python/executor/PythonSession.scala | 13 +- .../python/factory/PythonEngineConnFactory.scala | 3 +- .../manager/engineplugin/python/utils/Kind.scala | 6 +- .../manager/engineplugin/python/utils/State.scala | 18 +- linkis-engineconn-plugins/shell/pom.xml | 2 +- .../shell/src/main/assembly/distribution.xml | 8 +- .../errorcode/LinkisCommonsErrorCodeSummary.java | 68 +++ .../resources/conf/linkis-engineconn.properties | 3 +- .../shell/exception/NoCorrectUserException.scala | 6 +- .../shell/executor/ErrorStreamReaderThread.scala | 78 --- .../engineplugin/shell/executor/ReaderThread.scala | 101 ++++ .../shell/executor/ShellEngineConnExecutor.scala | 80 +-- linkis-engineconn-plugins/spark/pom.xml | 8 +- .../spark/src/main/assembly/distribution.xml | 8 +- .../spark/errorcode/SparkErrorCodeSummary.java | 74 +++ .../spark/Interpreter/Interpreter.scala | 2 +- .../spark/Interpreter/ProcessInterpreter.scala | 4 +- .../spark/Interpreter/PythonInterpreter.scala | 8 +- .../args/SparkPythonArgsPreExecutionHook.scala | 4 +- .../linkis/engineplugin/spark/common/Kind.scala | 6 +- .../spark/common/LineBufferedStream.scala | 6 +- .../engineplugin/spark/common/LogContainer.scala | 6 +- .../engineplugin/spark/common/SparkKind.scala | 4 +- .../spark/config/SparkConfiguration.scala | 6 +- .../spark/cs/CSSparkPreExecutionHook.scala | 7 +- .../engineplugin/spark/cs/CSTableParser.scala | 8 +- .../spark/exception/NoSupportEngineException.scala | 7 +- .../engineplugin/spark/executor/SQLSession.scala | 24 +- .../spark/executor/SparkEngineConnExecutor.scala | 42 +- .../spark/executor/SparkPythonExecutor.scala | 53 +- .../spark/executor/SparkScalaExecutor.scala | 18 +- .../spark/factory/SparkEngineConnFactory.scala | 23 +- .../spark/factory/SparkPythonExecutorFactory.scala | 5 +- .../spark/factory/SparkSqlExecutorFactory.scala | 5 +- .../engineplugin/spark/imexport/CsvRelation.scala | 19 +- .../engineplugin/spark/imexport/ExportData.scala | 6 +- .../engineplugin/spark/imexport/LoadData.scala | 31 +- .../spark/mdq/MDQPostExecutionHook.scala | 6 +- .../spark/mdq/MDQPreExecutionHook.scala | 14 +- .../engineplugin/spark/utils/EngineUtils.scala | 2 +- .../spark/sql/execution/datasources/csv/UDF.scala | 1 + .../engineplugin/spark/cs/TestCSSparkHelper.scala | 59 +++ .../spark/cs/TestCSSparkPostExecutionHook.scala | 74 +++ .../spark/executor/TestSparkSqlExecutor.scala | 121 +++++ linkis-engineconn-plugins/sqoop/pom.xml | 2 +- .../sqoop/src/main/assembly/distribution.xml | 6 +- .../engineconnplugin/sqoop/client/Sqoop.java | 8 +- .../client/errorcode/SqoopErrorCodeSummary.java | 61 +++ .../client/exception/JobClosableException.java | 8 +- .../client/exception/JobExecutionException.java | 8 +- .../sqoop/client/utils/JarLoader.java | 3 - .../sqoop/executor/SqoopExecutor.scala | 3 +- .../sqoop/executor/SqoopOnceCodeExecutor.scala | 9 +- .../engineconnplugin/sqoop/util/ClassUtil.scala | 8 +- linkis-engineconn-plugins/trino/pom.xml | 128 +++++ .../trino/src/main/assembly/distribution.xml | 70 +++ .../trino/interceptor/PasswordInterceptor.java | 55 +++ .../trino/password/CommandPasswordCallback.java | 75 +++ .../trino/password/StaticPasswordCallback.java | 40 ++ .../trino/socket/SocketChannelSocketFactory.java | 57 +++ .../main/resources/linkis-engineconn.properties | 21 + .../trino/src/main/resources/log4j2.xml | 75 +++ .../engineplugin/trino/TrinoEngineConnPlugin.scala | 66 +++ .../TrinoProcessEngineConnLaunchBuilder.scala | 37 ++ .../trino/conf/TrinoConfiguration.scala | 71 +++ .../trino/conf/TrinoEngineConfig.scala | 48 ++ .../trino/exception/TrinoException.scala | 32 ++ .../trino/executor/TrinoEngineConnExecutor.scala | 540 +++++++++++++++++++++ .../trino/factory/TrinoEngineConnFactory.scala | 44 ++ .../engineplugin/trino/utils/TrinoCode.scala | 53 ++ .../engineplugin/trino/utils/TrinoSQLHook.scala | 36 ++ .../executer/TestTrinoEngineConnExecutor.scala | 142 ++++++ linkis-extensions/linkis-io-file-client/pom.xml | 2 +- .../io/iteraceptor/IOMethodInterceptor.scala | 53 +- linkis-extensions/pom.xml | 2 +- .../linkis-code-orchestrator/pom.xml | 3 +- .../orchestrator/code/plans/ast/CodeJob.scala | 2 +- .../code/plans/logical/CacheTask.scala | 7 +- .../linkis-computation-orchestrator/pom.xml | 2 +- .../ComputationOrchestratorSessionFactory.scala | 4 +- .../parser/EnrichLabelParserTransform.scala | 4 +- .../physical/ComputePhysicalTransform.scala | 15 +- .../catalyst/planner/TaskPlannerTransform.scala | 17 +- .../reheater/PruneTaskReheaterTransform.scala | 12 +- .../computation/entity/ComputationJobReq.scala | 13 +- .../DefaultCodeExecTaskExecutorManager.scala | 2 +- .../computation/physical/CacheExecTask.scala | 12 +- .../physical/CodeLogicalUnitExecTask.scala | 26 +- .../service/ComputationTaskExecutionReceiver.scala | 7 - .../computation/utils/TreeNodeUtil.scala | 8 +- .../linkis-orchestrator-core/pom.xml | 5 +- .../apache/linkis/orchestrator/Orchestrator.scala | 4 +- .../orchestrator/core/AbstractOrchestration.scala | 1 + .../orchestrator/core/AbstractOrchestrator.scala | 6 +- .../apache/linkis/orchestrator/domain/JobReq.scala | 12 +- .../orchestrator/domain/req/DataViewReq.scala | 2 +- .../orchestrator/execution/AbstractExecution.scala | 4 +- .../orchestrator/execution/ExecTaskRunner.scala | 8 +- .../orchestrator/execution/ExecutionFactory.scala | 4 +- .../execution/impl/BaseExecutionTask.scala | 7 +- .../execution/impl/DefaultTaskManager.scala | 5 +- .../execution/impl/UserRunningNumber.scala | 2 +- .../execution/impl/UserTaskRunnerQueue.scala | 8 +- .../listener/OrchestratorListenerBusContext.scala | 2 +- .../orchestrator/listener/task/TaskInfoEvent.scala | 2 +- .../orchestrator/plans/ast/AbstractJob.scala | 10 +- .../orchestrator/plans/ast/AbstractStage.scala | 2 +- .../orchestrator/plans/ast/QueryParams.scala | 4 +- .../orchestrator/plans/ast/RuntimeParams.scala | 7 +- .../orchestrator/plans/logical/AbstractTask.scala | 4 +- .../orchestrator/plans/logical/JobTask.scala | 3 +- .../linkis/orchestrator/plans/logical/Origin.scala | 3 +- .../orchestrator/plans/physical/JobExecTask.scala | 5 +- .../orchestrator/plans/unit/CodeLogicalUnit.scala | 4 +- .../orchestrator/strategy/ResultSetExecTask.scala | 2 +- .../strategy/async/AsyncExecTaskRunnerImpl.scala | 1 - .../linkis/orchestrator/utils/TreeOperator.scala | 4 +- .../linkis/orchestrator/OrchestratorSuite.scala | 1 + .../plugin/linkis-orchestrator-ecm-plugin/pom.xml | 6 +- .../ecm/ComputationEngineConnManager.scala | 6 +- .../orchestrator/ecm/EngineConnManager.scala | 21 +- .../ecm/LoadBalanceLabelEngineConnManager.scala | 39 +- .../linkis/orchestrator/ecm/entity/MarkReq.scala | 20 +- linkis-orchestrator/pom.xml | 2 +- linkis-public-enhancements/distribution.xml | 65 +-- .../linkis-basedata-manager/pom.xml | 112 +++++ .../src/main/assembly/distribution.xml | 190 ++++++++ .../server/LinkisBasedataManagerApplication.java | 32 ++ .../server/dao/DatasourceAccessMapper.java | 39 ++ .../server/dao/DatasourceEnvMapper.java | 32 ++ .../server/dao/DatasourceTypeMapper.java | 32 ++ .../server/dao/GatewayAuthTokenMapper.java | 29 ++ .../server/dao/PsErrorCodeMapper.java | 32 ++ .../dao/RmExternalResourceProviderMapper.java | 34 ++ .../server/dao/UdfManagerMapper.java | 34 ++ .../basedatamanager/server/dao/UdfTreeMapper.java | 33 ++ .../server/dao/mapper/DatasourceAccessMapper.xml | 49 ++ .../server/dao/mapper/DatasourceEnvMapper.xml | 51 ++ .../server/dao/mapper/DatasourceTypeMapper.xml | 50 ++ .../server/dao/mapper/GatewayAuthTokenMapper.xml | 51 ++ .../server/dao/mapper/PsErrorCodeMapper.xml | 47 ++ .../mapper/RmExternalResourceProviderMapper.xml | 47 ++ .../server/dao/mapper/UdfManagerMapper.xml | 40 ++ .../server/dao/mapper/UdfTreeMapper.xml | 50 ++ .../server/domain/DatasourceAccessEntity.java | 171 +++++++ .../server/domain/DatasourceEnvEntity.java | 227 +++++++++ .../server/domain/DatasourceTypeEntity.java | 189 ++++++++ .../server/domain/ErrorCodeEntity.java | 153 ++++++ .../server/domain/GatewayAuthTokenEntity.java | 219 +++++++++ .../domain/RmExternalResourceProviderEntity.java | 148 ++++++ .../server/domain/UdfManagerEntity.java | 99 ++++ .../server/domain/UdfTreeEntity.java | 208 ++++++++ .../server/restful/DatasourceAccessRestfulApi.java | 64 +++ .../server/restful/DatasourceEnvRestfulApi.java | 91 ++++ .../server/restful/DatasourceTypeRestfulApi.java | 91 ++++ .../server/restful/ErrorCodeRestfulApi.java | 91 ++++ .../server/restful/GatewayAuthTokenRestfulApi.java | 95 ++++ .../RmExternalResourceProviderRestfulApi.java | 97 ++++ .../server/restful/UdfManagerRestfulApi.java | 91 ++++ .../server/restful/UdfTreeRestfulApi.java | 91 ++++ .../server/service/DatasourceAccessService.java | 31 ++ .../server/service/DatasourceEnvService.java | 31 ++ .../server/service/DatasourceTypeService.java | 32 ++ .../server/service/ErrorCodeService.java | 31 ++ .../server/service/GatewayAuthTokenService.java | 30 ++ .../service/RmExternalResourceProviderService.java | 31 ++ .../server/service/UdfManagerService.java | 31 ++ .../server/service/UdfTreeService.java | 31 ++ .../service/impl/DatasourceAccessServiceImpl.java | 47 ++ .../service/impl/DatasourceEnvServiceImpl.java | 47 ++ .../service/impl/DatasourceTypeServiceImpl.java | 47 ++ .../server/service/impl/ErrorCodeServiceImpl.java | 47 ++ .../service/impl/GatewayAuthTokenServiceImpl.java | 42 ++ .../RmExternalResourceProviderServiceImpl.java | 43 ++ .../server/service/impl/UdfManagerServiceImpl.java | 46 ++ .../server/service/impl/UdfTreeServiceImpl.java | 46 ++ .../linkis-bml/linkis-bml-client/pom.xml | 3 +- .../errorcode/BmlClientErrorCodeSummary.java | 93 ++++ .../linkis/bml/client/impl/HttpBmlClient.scala | 143 ++++-- .../bml/common/POSTActionFailException.scala | 29 +- .../errorcode/BmlClientErrorCodeSummaryTest.java | 147 ++++++ .../linkis-bml/linkis-bml-common/pom.xml | 3 +- .../apache/linkis/bml/protocol/BmlProtocol.scala | 6 +- .../linkis-bml/linkis-bml-server/pom.xml | 3 +- .../src/main/assembly/distribution.xml | 8 +- .../org/apache/linkis/bml/dao/BmlProjectDao.java | 41 +- .../org/apache/linkis/bml/dao/ResourceDao.java | 7 - .../java/org/apache/linkis/bml/dao/VersionDao.java | 16 - .../linkis/bml/dao/impl/BmlProjectMapper.xml | 62 +++ .../apache/linkis/bml/dao/impl/ResourceMapper.xml | 10 + .../apache/linkis/bml/dao/impl/VersionMapper.xml | 27 ++ .../bml/errorcode/BmlServerErrorCodeSummary.java | 114 +++++ .../linkis/bml/restful/BmlProjectRestful.java | 4 +- .../apache/linkis/bml/restful/BmlRestfulApi.java | 42 +- .../linkis/bml/common/BmlAuthorityException.scala | 12 +- .../bml/common/BmlPermissionDeniedException.scala | 7 +- .../linkis/bml/common/BmlQueryFailException.scala | 4 +- .../bml/common/BmlResourceExpiredException.scala | 6 +- .../bml/common/BmlServerParaErrorException.scala | 4 +- .../org/apache/linkis/bml/rpc/BmlReceiver.scala | 6 +- .../src/test/java/org/apache/linkis/bml/Scan.java | 26 + .../apache/linkis/bml/WebApplicationServer.java | 34 ++ .../org/apache/linkis/bml/dao/BaseDaoTest.java | 31 ++ .../apache/linkis/bml/dao/BmlProjectDaoTest.java | 127 +++++ .../org/apache/linkis/bml/dao/DownloadDaoTest.java | 47 ++ .../org/apache/linkis/bml/dao/ResourceDaoTest.java | 117 +++++ .../org/apache/linkis/bml/dao/TaskDaoTest.java | 89 ++++ .../org/apache/linkis/bml/dao/VersionDaoTest.java | 218 +++++++++ .../linkis/bml/service/BmlProjectServiceTest.java | 166 +++++++ .../bml/service/DownloadServiceImplTest.java | 55 +++ .../bml/service/ResourceServiceImplTest.java | 159 ++++++ .../linkis/bml/service/TaskServiceImplTest.java | 161 ++++++ .../linkis/bml/service/VersionServiceImplTest.java | 201 ++++++++ .../src/test/resources/application.properties | 42 ++ .../src/test/resources/create.sql | 134 +++++ linkis-public-enhancements/linkis-bml/pom.xml | 2 +- .../linkis-configuration/pom.xml | 3 +- .../linkis/configuration/dao/ConfigMapper.java | 2 +- .../linkis/configuration/dao/impl/ConfigMapper.xml | 2 +- .../LinkisConfigurationErrorCodeSummary.java | 79 +++ .../exception/ConfigurationException.java | 8 +- .../restful/api/ConfigurationRestfulApi.java | 20 +- .../service/impl/ConfigKeyServiceImpl.java | 24 +- .../configuration/service/CategoryService.scala | 20 +- .../service/ConfigurationService.scala | 2 +- .../configuration/util/LabelParameterParser.scala | 18 +- .../configuration/validate/FloatValidator.scala | 7 +- .../validate/NumericalValidator.scala | 9 +- .../configuration/validate/OneOfValidator.scala | 4 +- .../validate/ValidatorManagerImpl.scala | 2 +- .../linkis/configuration/dao/ConfigMapperTest.java | 4 +- .../linkis-cs-client/pom.xml | 4 +- .../client/errorcode/CsClientErrorCodeSummary.java | 62 +++ .../linkis/cs/client/http/HttpContextClient.java | 47 +- .../exception/ProtocolNotMatchException.scala | 22 - .../linkis-cs-common/pom.xml | 4 +- .../linkis-cs-listener/pom.xml | 4 +- .../linkis-cs-server/pom.xml | 2 +- .../src/main/assembly/distribution.xml | 8 +- .../org/apache/linkis/cs/DefaultContextSearch.java | 5 +- .../cs/contextcache/metric/ClassIntrospector.java | 226 --------- .../cs/contextcache/metric/SizeEstimator.java | 16 - .../errorcode/LinkisCsServerErrorCodeSummary.java | 53 ++ .../persistence/dao/impl/contextHistoryMapper.xml | 6 +- .../dao/impl/contextIDListenerMapper.xml | 2 +- .../cs/persistence/dao/impl/contextIDMapper.xml | 15 + .../dao/impl/contextKeyListenerMapper.xml | 4 +- .../impl/DefaultInstanceAliasConverter.scala | 4 +- .../cs/server/scheduler/impl/CsExecutor.scala | 2 +- .../src/test/java/org/apache/linkis/cs/Scan.java | 26 + .../org/apache/linkis/cs/WebApplicationServer.java | 34 ++ .../LinkisCsServerErrorCodeSummaryTest.java | 36 ++ .../ContextSearchFailedExceptionTest.java | 37 ++ .../cs/persistence/conf/PersistenceConfTest.java | 44 ++ .../linkis/cs/persistence/dao/BaseDaoTest.java | 31 ++ .../persistence/dao/ContextHistoryMapperTest.java | 157 ++++++ .../dao/ContextIDListenerMapperTest.java | 90 ++++ .../cs/persistence/dao/ContextIDMapperTest.java | 104 ++++ .../dao/ContextKeyListenerMapperTest.java | 112 +++++ .../cs/persistence/utils/PersistenceUtilsTest.java | 36 ++ .../cs/server/conf/ContextServerConfTest.java | 40 ++ .../src/test/resources/application.properties | 59 +++ .../linkis-cs-server/src/test/resources/create.sql | 72 +++ .../linkis-context-service/pom.xml | 2 +- .../linkis-datasource-client/pom.xml | 2 +- .../DatasourceClientErrorCodeSummary.java | 63 +++ .../DataSourceClientBuilderException.scala | 4 +- .../client/impl/LinkisDataSourceRemoteClient.scala | 6 +- .../request/DataSourceTestConnectAction.scala | 10 +- .../client/request/DeleteDataSourceAction.scala | 8 +- .../client/request/ExpireDataSourceAction.scala | 8 +- .../GetConnectParamsByDataSourceIdAction.scala | 8 +- .../GetConnectParamsByDataSourceNameAction.scala | 13 +- .../request/GetDataSourceVersionsAction.scala | 8 +- .../request/GetInfoByDataSourceIdAction.scala | 10 +- .../request/GetInfoByDataSourceNameAction.scala | 10 +- .../GetInfoPublishedByDataSourceNameAction.scala | 10 +- .../request/GetKeyTypeDatasourceAction.scala | 3 +- .../client/request/MetadataGetColumnsAction.scala | 14 +- .../request/MetadataGetDatabasesAction.scala | 10 +- .../request/MetadataGetPartitionsAction.scala | 12 +- .../request/MetadataGetTablePropsAction.scala | 14 +- .../client/request/MetadataGetTablesAction.scala | 12 +- .../request/PublishDataSourceVersionAction.scala | 11 +- .../client/request/QueryDataSourceAction.scala | 3 +- .../client/request/QueryDataSourceEnvAction.scala | 3 +- .../client/request/UpdateDataSourceAction.scala | 8 +- .../request/UpdateDataSourceParameterAction.scala | 8 +- .../datasource/client/TestDataSourceClient.scala | 16 +- .../linkis/datasource/client/TestHiveClient.scala | 6 +- .../linkis/datasource/client/TestMysqlClient.scala | 6 +- .../client/config/DatasourceClientConfigTest.java | 49 ++ .../DataSourceClientBuilderExceptionTest.java | 34 ++ .../imp/LinkisDataSourceRemoteClientTest.java | 37 ++ .../linkis-datasource-manager/common/pom.xml | 3 +- .../datasourcemanager/common/DataSources.java | 56 +++ .../LinkisDatasourceManagerErrorCodeSummary.java | 62 +++ .../datasourcemanager/common/util/json/Json.java | 9 +- .../linkis-datasource-manager/server/pom.xml | 3 +- .../server/src/main/assembly/distribution.xml | 6 +- .../core/dao/DataSourceEnvDao.java | 10 + .../core/dao/mapper/DataSouceMapper.xml | 1 + .../core/dao/mapper/DataSourceEnvMapper.xml | 10 + .../core/restful/DataSourceAdminRestfulApi.java | 129 ++++- .../core/restful/DataSourceCoreRestfulApi.java | 20 +- .../core/restful/DataSourceOperateRestfulApi.java | 4 +- .../core/service/DataSourceInfoService.java | 37 +- .../core/service/impl/BmlAppServiceImpl.java | 9 +- .../service/impl/DataSourceInfoServiceImpl.java | 136 ++++-- .../service/impl/MetadataOperateServiceImpl.java | 17 +- .../validate/DataSourceParameterValidator.java | 5 +- .../core/validate/ParameterValidateException.java | 6 +- .../strategy/RegExpParameterValidateStrategy.java | 5 +- .../strategy/TypeParameterValidateStrategy.java | 10 +- .../core/dao/DataSourceVersionDaoTest.java | 7 +- .../core/service/DataSourceInfoServiceTest.java | 55 +++ .../linkis-metadata-query/common/pom.xml | 8 +- .../query/common/cache/CacheConfiguration.java | 5 + .../query/common/domain/MetaColumnInfo.java | 18 + .../LinkisMetadataQueryErrorCodeSummary.java | 67 +++ .../common/exception/MetaRuntimeException.java | 7 +- .../common/service/AbstractCacheMetaService.java | 247 ++++++++++ .../common/service/AbstractDbMetaService.java | 152 ++++++ .../common/service/AbstractFsMetaService.java | 38 ++ .../query/common/service/AbstractMetaService.java | 330 ------------- .../query/common/service/BaseMetadataService.java | 14 + .../query/common/service/MetadataFsService.java | 32 ++ .../query/common/service/MetadataService.java | 20 - .../query/common/MdmConfigurationTest.java | 37 ++ .../query/common/cache/CacheConfigurationTest.java | 40 ++ .../query/common/cache/ConnCacheManagerTest.java | 48 ++ .../exception/MetaMethodInvokeExceptionTest.java | 34 ++ .../common/exception/MetaRuntimeExceptionTest.java | 34 ++ .../linkis-metadata-query/server/pom.xml | 3 +- .../server/src/main/assembly/distribution.xml | 17 +- .../server/loader/MetaClassLoaderManager.java | 101 +++- .../query/server/restful/MetadataCoreRestful.java | 52 ++ .../query/server/restful/MetadataQueryRestful.java | 77 ++- .../query/server/service/MetadataQueryService.java | 13 + .../service/impl/MetadataQueryServiceImpl.java | 56 ++- .../metadata/query/server/utils/MetadataUtils.java | 59 ++- .../server/loader/MetaClassLoaderManagerTest.java | 36 ++ .../server/receiver/BaseMetaReceiverTest.java | 61 +++ .../src/test/resources/application.properties | 30 +- .../service/elasticsearch/pom.xml | 3 +- .../src/main/assembly/distribution.xml | 6 +- .../metadata/query/service/EsMetaService.java | 4 +- .../linkis-metadata-query/service/hdfs/pom.xml | 110 +++++ .../hdfs/src/main/assembly/distribution.xml | 57 +++ .../metadata/query/service/HdfsConnection.java | 108 +++++ .../metadata/query/service/HdfsMetaService.java | 121 +++++ .../metadata/query/service/HdfsParamsMapper.java | 29 ++ .../query/service/conf/ConfigurationUtils.java | 141 ++++++ .../linkis-metadata-query/service/hive/pom.xml | 7 +- .../hive/src/main/assembly/distribution.xml | 6 +- .../metadata/query/service/HiveMetaService.java | 4 +- .../linkis-metadata-query/service/kafka/pom.xml | 3 +- .../kafka/src/main/assembly/distribution.xml | 6 +- .../metadata/query/service/KafkaMetaService.java | 4 +- .../linkis-metadata-query/service/mysql/pom.xml | 10 +- .../mysql/src/main/assembly/distribution.xml | 6 +- .../metadata/query/service/Db2MetaService.java | 95 ++++ .../metadata/query/service/DmMetaService.java | 92 ++++ .../query/service/GreenplumMetaService.java | 101 ++++ .../query/service/KingbaseMetaService.java | 93 ++++ .../metadata/query/service/MysqlMetaService.java | 6 +- .../metadata/query/service/OracleMetaService.java | 105 ++++ .../query/service/PostgresqlMetaService.java | 103 ++++ .../query/service/SqlserverMetaService.java | 88 ++++ .../query/service/conf/SqlParamsMapper.java | 40 ++ .../metadata/query/service/db2/SqlConnection.java | 243 ++++++++++ .../metadata/query/service/dm/SqlConnection.java | 256 ++++++++++ .../query/service/greenplum/SqlConnection.java | 237 +++++++++ .../query/service/kingbase/SqlConnection.java | 256 ++++++++++ .../query/service/mysql/SqlConnection.java | 227 +++++++++ .../query/service/oracle/SqlConnection.java | 254 ++++++++++ .../query/service/postgres/SqlConnection.java | 233 +++++++++ .../query/service/sqlserver/SqlConnection.java | 246 ++++++++++ .../linkis-datasource/linkis-metadata/pom.xml | 3 +- .../src/main/assembly/distribution.xml | 8 +- .../errorcode/LinkisMetadataErrorCodeSummary.java | 59 +++ .../linkis/metadata/ddl/ImportDDLCreator.scala | 54 ++- .../linkis/metadata/ddl/ScalaDDLCreator.scala | 21 +- .../exception/MdqIllegalParamException.scala | 4 +- .../test/java/org/apache/linkis/metadata/Scan.java | 27 ++ .../linkis/metadata/WebApplicationServer.java | 34 ++ .../condition/DataSourceConditionTest.java | 33 ++ .../apache/linkis/metadata/dao/BaseDaoTest.java | 31 ++ .../org/apache/linkis/metadata/dao/MdqDaoTest.java | 157 ++++++ .../LinkisMetadataErrorCodeSummaryTest.java | 45 ++ .../linkis/metadata/hive/dao/HiveMetaDaoTest.java | 161 ++++++ .../apache/linkis/metadata/type/LifecycleTest.java | 42 ++ .../linkis/metadata/type/ModelLevelTest.java | 40 ++ .../linkis/metadata/type/UseWayTypeTest.java | 40 ++ .../apache/linkis/metadata/util/ConstantsTest.java | 48 ++ .../apache/linkis/metadata/util/DWSConfigTest.java | 54 +++ .../apache/linkis/metadata/util/HiveUtilsTest.java | 43 ++ .../src/test/resources/application.properties | 59 +++ .../linkis-metadata/src/test/resources/create.sql | 235 +++++++++ .../src/test/resources/linkis.properties | 21 + .../linkis-datasource/pom.xml | 3 +- .../linkis-error-code-client/pom.xml | 3 +- .../errorcode/client/result/ErrorCodeResult.scala | 4 +- .../errorcode/client/utils/ErrorCodeMatcher.scala | 8 +- .../errorcode/client/ClientConfigurationTest.java | 46 ++ .../client/ErrorCodeClientBuilderTest.java | 42 ++ .../client/LinkisErrorCodeClientTest.java | 44 ++ .../client/handler/ErrorCodeHandlerTest.java | 37 ++ .../client/handler/LinkisErrorCodeHandlerTest.java | 48 ++ .../client/manager/LinkisErrorCodeManagerTest.java | 45 ++ .../LinkisErrorCodeSynchronizerTest.java | 46 ++ .../client/action/ErrorCodeActionTest.scala | 41 ++ .../linkis-error-code-common/pom.xml | 3 +- .../linkis/errorcode/common/LinkisErrorCode.scala | 2 - .../linkis/errorcode/common/CommonConfTest.java | 33 ++ .../errorcode/common/LinkisErrorCodeTest.scala | 35 ++ .../linkis-error-code-server/pom.xml | 3 +- .../org/apache/linkis/errorcode/server/Scan.java | 26 + .../errorcode/server/WebApplicationServer.java | 34 ++ .../linkis/errorcode/server/dao/BaseDaoTest.java | 31 ++ .../src/test/resources/application.properties | 62 +++ .../src/test/resources/create.sql | 30 ++ .../src/test/resources/data.sql | 20 + .../src/test/resources/linkis.properties | 21 + .../linkis-error-code/pom.xml | 3 +- .../linkis-instance-label-client/pom.xml | 3 +- .../linkis-instance-label-server/pom.xml | 2 +- .../instance/label/dao/InsLabelRelationDao.java | 3 +- .../label/dao/impl/InstanceLabelMapper.xml | 10 +- .../LinkisInstanceLabelErrorCodeSummary.java | 57 +++ .../label/exception/InstanceErrorException.java | 4 +- .../instance/label/restful/InstanceRestful.java | 8 +- .../label/service/impl/DefaultInsLabelService.java | 3 +- .../service/rpc/DefaultInsLabelRpcService.scala | 6 +- .../org/apache/linkis/instance/label/Scan.java | 26 + .../instance/label/WebApplicationServer.java | 34 ++ .../linkis/instance/label/dao/BaseDaoTest.java | 31 ++ .../label/dao/InsLabelRelationDaoTest.java | 154 ++++++ .../instance/label/dao/InstanceInfoDaoTest.java | 86 ++++ .../instance/label/dao/InstanceLabelDaoTest.java | 147 ++++++ .../service/impl/DefaultInsLabelServiceTest.java | 134 +++++ .../instance/label/utils/EntityParserTest.java | 56 +++ .../src/test/resources/application.properties | 42 ++ .../src/test/resources/create.sql | 64 +++ .../linkis-jobhistory/pom.xml | 3 +- .../jobhistory/dao/impl/JobHistoryMapper.xml | 14 +- .../jobhistory/restful/api/QueryRestfulApi.java | 24 +- .../jobhistory/conversions/TaskConversions.scala | 31 +- .../jobhistory/receiver/QueryReceiverChooser.scala | 44 -- .../impl/JobHistoryDetailQueryServiceImpl.scala | 47 +- .../service/impl/JobHistoryQueryServiceImpl.scala | 35 +- .../apache/linkis/jobhistory/util/QueryUtils.scala | 6 +- .../jobhistory/dao/JobHistoryMapperTest.java | 168 +++++++ .../service/JobHistoryQueryServiceTest.java | 130 +++++ .../src/test/resources/create.sql | 31 +- .../conf/JobhistoryConfigurationTest.scala | 49 ++ .../linkis/jobhistory/util/QueryConfigTest.scala | 38 ++ .../linkis/jobhistory/util/QueryUtilsTest.scala | 60 +++ .../linkis-ps-common-lock/pom.xml | 2 +- .../linkis/publicservice/common/lock/Scan.java | 26 + .../common/lock/WebApplicationServer.java | 34 ++ .../publicservice/common/lock/dao/BaseDaoTest.java | 31 ++ .../common/lock/dao/CommonLockMapperTest.java | 61 +++ .../service/impl/DefaultCommonLockServiceTest.java | 59 +++ .../src/test/resources/application.properties | 61 +++ .../src/test/resources/create.sql | 32 ++ .../src/test/resources/data.sql | 22 + .../src/test/resources/linkis.properties | 21 + .../linkis-storage-script-dev-client/pom.xml | 3 +- .../linkis/filesystem/WorkspaceClientImpl.scala | 6 +- .../filesystem/WorkspaceClientFactoryTest.scala | 36 ++ .../filesystem/WorkspaceClientImplTest.scala | 36 ++ .../action/OpenScriptFromBMLActionTest.scala | 35 ++ .../filesystem/conf/WorkspaceClientConfTest.scala | 45 ++ .../response/ScriptFromBMLResponseTest.scala | 38 ++ .../linkis-storage-script-dev-server/pom.xml | 9 +- .../filesystem/conf/WorkSpaceConfiguration.java | 7 + .../exception/WorkspaceExceptionManager.java | 1 + .../filesystem/restful/api/FsRestfulApi.java | 32 +- .../apache/linkis/filesystem/bml/BMLHelper.scala | 37 +- .../apache/linkis/filesystem/entity/FSInfo.scala | 2 +- .../linkis/filesystem/service/FsService.scala | 22 +- .../linkis/filesystem/utils/UserGroupInfo.scala | 118 +++++ .../filesystem/validator/PathValidator.scala | 7 +- .../java/org/apache/linkis/filesystem/Scan.java | 23 + .../linkis/filesystem/WebApplicationServer.java | 34 ++ .../conf/WorkSpaceConfigurationTest.java | 69 +++ .../constant/WorkSpaceConstantsTest.java | 40 ++ .../exception/WorkSpaceExceptionTest.java | 47 ++ .../exception/WorkspaceExceptionManagerTest.java | 44 ++ .../restful/api/BMLFsRestfulApiTest.java | 124 +++++ .../filesystem/restful/api/FsRestfulApiTest.java | 227 +++++++++ .../linkis/filesystem/util/WorkspaceUtilTest.java | 74 +++ .../src/test/resources/application.properties | 63 +++ .../src/test/resources/deleteFile.sql | 17 + .../src/test/resources/existsSql.sql | 17 + .../src/test/resources/info.log | 19 + .../src/test/resources/linkis.properties | 22 + .../src/test/resources/query.sql | 17 + .../linkis/filesystem/entity/FSInfoTest.scala | 36 ++ .../linkis-udf/linkis-udf-client/pom.xml | 3 +- .../scala/org/apache/linkis/udf/UDFClient.scala | 13 +- .../linkis/udf/UDFClientConfigurationTest.scala | 33 ++ .../linkis-udf/linkis-udf-common/pom.xml | 3 +- .../apache/linkis/udf/excepiton/UDFException.java | 12 +- .../linkis/udf/excepiton/UDFExceptionTest.java | 33 ++ .../apache/linkis/udf/utils/ConstantVarTest.java | 48 ++ .../linkis-udf/linkis-udf-service/pom.xml | 3 +- .../org/apache/linkis/udf/api/UDFRestfulApi.java | 2 - .../java/org/apache/linkis/udf/dao/impl/UDFDao.xml | 5 +- .../linkis/udf/service/impl/UDFServiceImpl.java | 1 - .../src/test/java/org/apache/linkis/udf/Scan.java | 26 + .../apache/linkis/udf/WebApplicationServer.java | 34 ++ .../apache/linkis/udf/api/UDFRestfulApiTest.java | 445 +++++++++++++++++ .../org/apache/linkis/udf/dao/BaseDaoTest.java | 31 ++ .../java/org/apache/linkis/udf/dao/UDFDaoTest.java | 341 +++++++++++++ .../org/apache/linkis/udf/dao/UDFTreeDaoTest.java | 127 +++++ .../apache/linkis/udf/dao/UDFVersionDaoTest.java | 148 ++++++ .../apache/linkis/udf/service/UDFServiceTest.java | 251 ++++++++++ .../linkis/udf/service/UDFTreeServiceTest.java | 126 +++++ .../src/test/resources/application.properties | 62 +++ .../src/test/resources/create.sql | 88 ++++ .../linkis-udf-service/src/test/resources/data.sql | 61 +++ .../src/test/resources/linkis.properties | 21 + .../linkis/udf/utils/UdfConfigurationTest.scala | 38 ++ linkis-public-enhancements/linkis-variable/pom.xml | 3 +- .../variable/service/VariableServiceImpl.scala | 19 +- .../apache/linkis/variable/restful/MvcUtils.java | 115 +++++ .../restful/api/VariableRestfulApiTest.java | 112 +++++ .../src/test/resources/application.properties | 2 +- .../src/test/resources/linkis.properties | 21 + linkis-public-enhancements/pom.xml | 8 +- .../linkis-service-discovery/linkis-eureka/pom.xml | 3 +- .../src/main/assembly/distribution.xml | 8 +- .../linkis-gateway-authentication/pom.xml | 5 +- .../LinkisGwAuthenticationErrorCodeSummary.java | 58 +++ .../gateway/authentication/bo/impl/TokenImpl.scala | 2 +- .../service/CachedTokenService.scala | 27 +- .../linkis-gateway-core/pom.xml | 3 +- .../LinkisGatewayCoreErrorCodeSummary.java | 65 +++ .../exception/TooManyServiceException.scala | 4 +- .../linkis/gateway/parser/GatewayParser.scala | 9 +- .../linkis/gateway/route/GatewayRouter.scala | 40 +- .../linkis/gateway/security/GatewaySSOUtils.scala | 13 +- .../linkis/gateway/security/LinkisPreFilter.scala | 2 +- .../linkis/gateway/security/ProxyUserUtils.scala | 8 +- .../linkis/gateway/security/SecurityFilter.scala | 2 +- .../linkis/gateway/security/UserRestful.scala | 39 +- .../gateway/security/sso/SSOInterceptor.scala | 4 +- .../security/token/TokenAuthentication.scala | 2 - .../linkis-gateway-httpclient-support/pom.xml | 3 +- .../LinkisGwHttpclientSupportErrorCodeSummary.java | 58 +++ .../linkis/httpclient/dws/DWSHttpClient.scala | 16 +- .../StaticAuthenticationStrategy.scala | 9 +- .../TokenAuthenticationStrategy.scala | 12 +- .../exception/AuthenticationFailedException.scala | 4 +- .../dws/exception/UnknownVersionException.scala | 6 +- .../linkis-gateway-server-support/pom.xml | 8 +- .../src/main/assembly/distribution.xml | 8 +- .../ujes/parser/ResultSetCacheGatewayParser.scala | 5 +- .../ujes/route/AbstractLabelGatewayRouter.scala | 19 +- .../ujes/route/DefaultLabelGatewayRouter.scala | 21 +- .../gateway/ujes/route/EntranceGatewayRouter.scala | 9 +- .../ujes/route/HaContextGatewayRouter.scala | 2 +- .../ujes/route/label/RouteLabelParser.scala | 7 +- .../linkis-spring-cloud-gateway/pom.xml | 2 +- .../errorcode/GatewayErrorCodeSummary.java | 86 ++++ .../http/GatewayAuthorizationFilter.java | 6 +- .../errorcode/GatewayErrorConstants.scala | 22 - .../websocket/WebsocketGatewaySession.scala | 6 +- .../src/test/java/GatewayErrorCodeSummaryTest.java | 86 ++++ .../linkis-gateway-datasource-ruler/pom.xml | 3 +- .../linkis-service-gateway/pom.xml | 2 +- linkis-spring-cloud-services/pom.xml | 2 +- linkis-web/.env | 2 +- linkis-web/.gitignore | 3 +- linkis-web/config.sh | 2 +- linkis-web/install.sh | 4 +- linkis-web/package.json | 3 +- linkis-web/pom.xml | 2 +- linkis-web/src/apps/URM/i18n/common/en.json | 4 +- .../src/apps/linkis/components/progress/index.vue | 6 +- linkis-web/src/apps/linkis/i18n/common/en.json | 89 ++-- linkis-web/src/apps/linkis/i18n/common/zh.json | 21 +- .../src/apps/linkis/module/ECM/engineConn.vue | 54 +-- linkis-web/src/apps/linkis/module/ECM/search.vue | 8 +- .../src/apps/linkis/module/datasource/index.vue | 1 + .../module/datasourceAccess/EditForm/index.vue | 153 ++++++ .../apps/linkis/module/datasourceAccess/index.js | 25 + .../apps/linkis/module/datasourceAccess/index.scss | 65 +++ .../apps/linkis/module/datasourceAccess/index.vue | 282 +++++++++++ .../apps/linkis/module/datasourceAccess/service.js | 44 ++ .../linkis/module/datasourceEnv/EditForm/index.vue | 210 ++++++++ .../src/apps/linkis/module/datasourceEnv/index.js | 25 + .../apps/linkis/module/datasourceEnv/index.scss | 65 +++ .../src/apps/linkis/module/datasourceEnv/index.vue | 336 +++++++++++++ .../apps/linkis/module/datasourceEnv/service.js | 49 ++ .../module/datasourceType/EditForm/index.vue | 189 ++++++++ .../src/apps/linkis/module/datasourceType/index.js | 25 + .../apps/linkis/module/datasourceType/index.scss | 65 +++ .../apps/linkis/module/datasourceType/index.vue | 291 +++++++++++ .../apps/linkis/module/datasourceType/service.js | 44 ++ .../module/errorCode/errorCodeForm/index.vue | 135 ++++++ .../src/apps/linkis/module/errorCode/index.js | 25 + .../src/apps/linkis/module/errorCode/index.scss | 65 +++ .../src/apps/linkis/module/errorCode/index.vue | 252 ++++++++++ .../src/apps/linkis/module/errorCode/service.js | 44 ++ .../module/gatewayAuthToken/EditForm/index.vue | 153 ++++++ .../apps/linkis/module/gatewayAuthToken/index.js | 25 + .../apps/linkis/module/gatewayAuthToken/index.scss | 65 +++ .../apps/linkis/module/gatewayAuthToken/index.vue | 295 +++++++++++ .../apps/linkis/module/gatewayAuthToken/service.js | 44 ++ .../module/globalHistoryManagement/index.vue | 7 +- .../linkis/module/resourceManagement/index.scss | 3 + .../linkis/module/resourceManagement/index.vue | 19 +- .../linkis/module/resourceManagement/search.vue | 2 + .../rmExternalResourceProvider/EditForm/index.vue | 150 ++++++ .../module/rmExternalResourceProvider/index.js | 25 + .../module/rmExternalResourceProvider/index.scss | 65 +++ .../module/rmExternalResourceProvider/index.vue | 259 ++++++++++ .../module/rmExternalResourceProvider/service.js | 44 ++ .../linkis/module/udfManager/EditForm/index.vue | 99 ++++ .../src/apps/linkis/module/udfManager/index.js | 25 + .../src/apps/linkis/module/udfManager/index.scss | 65 +++ .../src/apps/linkis/module/udfManager/index.vue | 240 +++++++++ .../src/apps/linkis/module/udfManager/service.js | 44 ++ .../apps/linkis/module/udfTree/EditForm/index.vue | 153 ++++++ linkis-web/src/apps/linkis/module/udfTree/index.js | 25 + .../src/apps/linkis/module/udfTree/index.scss | 65 +++ .../src/apps/linkis/module/udfTree/index.vue | 290 +++++++++++ .../src/apps/linkis/module/udfTree/service.js | 44 ++ linkis-web/src/apps/linkis/router.js | 80 +++ linkis-web/src/apps/linkis/view/linkis/index.vue | 124 +++-- linkis-web/src/common/i18n/en.json | 76 +-- linkis-web/src/common/service/mixin.js | 2 +- .../src/components/consoleComponent/result.vue | 46 +- .../src/components/consoleComponent/toolbar.vue | 3 +- linkis-web/src/components/virtualTable/index.scss | 3 +- linkis-web/src/dss/assets/images/Linkis.svg | 15 +- .../src/dss/module/resourceSimple/engine.vue | 14 +- linkis-web/src/dss/view/login/index.vue | 32 +- linkis-web/src/main.js | 2 + linkis-web/vue.config.js | 2 +- pom.xml | 86 ++-- scalastyle-config.xml | 5 +- tool/dependencies/known-dependencies.txt | 3 + tool/modify_license.sh | 2 +- 1318 files changed, 39575 insertions(+), 8843 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
