You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2022/10/28 09:12:08 UTC
[incubator-linkis] 01/01: Merge dev-1.3.1 into master
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 <wp...@gmail.com>
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: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org