This is an automated email from the ASF dual-hosted git repository. casion pushed a commit to branch dev-1.3.2 in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 4127826c5692dde140ca19a023e1ecab3b6d5d76 Merge: b30064d05 0b5f6aa77 Author: Casion <[email protected]> AuthorDate: Fri Nov 4 21:11:10 2022 +0800 Merge pull request #3784 from apache/master Merge master to dev-1.3.2 .github/workflows/build-backend.yml | 4 +- .github/workflows/publish-docker.yaml | 4 +- README.md | 18 +- README_CN.md | 14 +- .../linkis-engineconn-plugin-core-errorcode.md | 3 +- linkis-commons/linkis-common/pom.xml | 2 +- .../linkis/common/errorcode/ErrorCodeUtils.java | 2 +- .../errorcode/LinkisCommonsErrorCodeSummary.java | 2 +- ...inkisComputationGovernanceErrorCodeSummary.java | 2 +- .../LinkisEngineConnErrorCodeSummary.java | 2 +- .../common/errorcode/LinkisErrorCodeSummary.java | 2 +- .../errorcode/LinkisExtensionErrorCodeSummary.java | 2 +- .../errorcode/LinkisFrameErrorCodeSummary.java | 2 +- .../LinkisPublicEnhancementErrorCodeSummary.java | 2 +- .../LinkisSpringCloudServiceErrorCodeSummary.java | 2 +- .../linkis/common/exception/ErrorException.java | 2 +- .../linkis/common/exception/ExceptionLevel.java | 2 +- .../linkis/common/exception/ExceptionManager.java | 2 +- .../linkis/common/exception/FatalException.java | 2 +- .../exception/LinkisCommonErrorException.java | 2 +- .../linkis/common/exception/LinkisException.java | 2 +- .../common/exception/LinkisRetryException.java | 2 +- .../common/exception/LinkisRuntimeException.java | 2 +- .../VariableOperationFailedException.java | 2 +- .../linkis/common/exception/WarnException.java | 2 +- .../main/java/org/apache/linkis/common/io/Fs.java | 2 +- .../java/org/apache/linkis/common/io/FsPath.java | 2 +- .../apache/linkis/common/utils/ByteTimeUtils.java | 2 +- .../org/apache/linkis/common/utils/DESUtil.java | 2 +- .../common/utils/VariableOperationUtils.java | 3 +- .../org/apache/linkis/common/ServiceInstance.scala | 5 +- .../apache/linkis/common/utils/ClassUtils.scala | 10 +- .../common/errorcode/ErrorCodeUtilsTest.java | 2 +- .../LinkisCommonsErrorCodeSummaryTest.java | 2 +- ...sComputationGovernanceErrorCodeSummaryTest.java | 2 +- .../errorcode/LinkisErrorCodeSummaryTest.java | 2 +- .../errorcode/LinkisFrameErrorCodeSummaryTest.java | 2 +- .../common/exception/ErrorExceptionTest.java | 2 +- .../common/exception/ExceptionLevelTest.java | 2 +- .../common/exception/ExceptionManagerTest.java | 2 +- .../common/exception/FatalExceptionTest.java | 2 +- .../exception/LinkisCommonErrorExceptionTest.java | 2 +- .../common/exception/LinkisExceptionTest.java | 2 +- .../common/exception/LinkisRetryExceptionTest.java | 2 +- .../exception/LinkisRuntimeExceptionTest.java | 2 +- .../linkis/common/exception/WarnExceptionTest.java | 2 +- .../common/variable/VariableOperationTest.java | 3 +- .../linkis/common/utils/ClassUtilsTest.scala | 1 - linkis-commons/linkis-hadoop-common/pom.xml | 2 +- .../linkis/hadoop/common/utils/KerberosUtils.java | 2 +- linkis-commons/linkis-httpclient/pom.xml | 2 +- linkis-commons/linkis-module/pom.xml | 2 +- .../apache/linkis/DataWorkCloudApplication.java | 2 +- .../org/apache/linkis/LinkisBaseServerApp.java | 2 +- .../errorcode/LinkisModuleErrorCodeSummary.java | 2 +- .../org/apache/linkis/proxy/ProxyUserEntity.java | 2 +- .../org/apache/linkis/proxy/ProxyUserService.java | 2 +- .../apache/linkis/server/utils/AopTargetUtils.java | 2 +- .../linkis/server/utils/ModuleUserUtils.java | 2 +- linkis-commons/linkis-mybatis/pom.xml | 2 +- .../apache/linkis/mybatis/DataSourceConfig.java | 2 +- .../org/apache/linkis/mybatis/DataSourceUtils.java | 2 +- .../linkis/mybatis/MyBatisMapperScannerConfig.java | 2 +- .../mybatis/MybatisConfigurationFactory.java | 2 +- .../linkis/mybatis/conf/MybatisConfiguration.java | 2 +- linkis-commons/linkis-protocol/pom.xml | 2 +- .../linkis/protocol/AbstractRetryableProtocol.java | 2 +- .../linkis/protocol/constants/TaskConstant.java | 2 +- .../apache/linkis/protocol/engine/EngineInfo.java | 2 +- .../apache/linkis/protocol/engine/EngineState.java | 2 +- .../protocol/label/InsLabelAttachRequest.java | 2 +- .../protocol/label/InsLabelQueryRequest.java | 2 +- .../protocol/label/InsLabelQueryResponse.java | 2 +- .../protocol/label/InsLabelRefreshRequest.java | 2 +- .../protocol/label/InsLabelRemoveRequest.java | 2 +- .../protocol/label/LabelInsQueryRequest.java | 2 +- .../protocol/label/LabelInsQueryResponse.java | 2 +- .../apache/linkis/protocol/label/LabelRequest.java | 2 +- .../linkis/protocol/label/NodeLabelAddRequest.java | 2 +- .../protocol/label/NodeLabelRemoveRequest.java | 2 +- .../linkis/protocol/message/HttpProtocol.java | 2 +- .../linkis/protocol/message/RequestMethod.java | 2 +- .../linkis/protocol/message/RequestProtocol.java | 2 +- .../linkis/protocol/query/QueryProtocol.java | 2 +- .../linkis/protocol/query/cache/CacheNotFound.java | 2 +- .../protocol/query/cache/CacheTaskResult.java | 2 +- .../protocol/query/cache/FailedToDeleteCache.java | 2 +- .../protocol/query/cache/FailedToWriteCache.java | 2 +- .../protocol/query/cache/RequestDeleteCache.java | 2 +- .../protocol/query/cache/RequestReadCache.java | 2 +- .../protocol/query/cache/RequestWriteCache.java | 2 +- .../protocol/query/cache/ResponseDeleteCache.java | 2 +- .../protocol/query/cache/ResponseReadCache.java | 2 +- .../protocol/query/cache/ResponseWriteCache.java | 2 +- .../protocol/query/cache/SuccessDeletedCache.java | 2 +- .../protocol/query/cache/SuccessWriteCache.java | 2 +- .../linkis/protocol/usercontrol/RequestLogin.java | 2 +- .../protocol/usercontrol/RequestRegister.java | 2 +- .../usercontrol/RequestUserListFromWorkspace.java | 2 +- .../protocol/usercontrol/RequestUserWorkspace.java | 2 +- .../linkis/protocol/usercontrol/ResponseLogin.java | 2 +- .../protocol/usercontrol/ResponseRegister.java | 2 +- .../usercontrol/ResponseUserWorkspace.java | 2 +- .../usercontrol/ResponseWorkspaceUserList.java | 2 +- .../usercontrol/UserControlLoginProtocol.java | 2 +- .../usercontrol/UserControlRegtisterProtocol.java | 2 +- .../apache/linkis/protocol/util/ImmutablePair.java | 2 +- linkis-commons/linkis-rpc/pom.xml | 2 +- .../rpc/errorcode/LinkisRpcErrorCodeSummary.java | 2 +- .../linkis/rpc/message/annotation/Chain.java | 2 +- .../linkis/rpc/message/annotation/Method.java | 2 +- .../linkis/rpc/message/annotation/Order.java | 2 +- .../linkis/rpc/message/annotation/Receiver.java | 2 +- .../message/exception/MessageErrorException.java | 2 +- .../message/exception/MessageWarnException.java | 2 +- .../linkis/rpc/message/method/MessageExecutor.java | 2 +- .../rpc/message/method/MethodExecuteWrapper.java | 2 +- .../rpc/message/method/ReceiverMethodSearcher.java | 2 +- .../rpc/message/parser/DefaultServiceParser.java | 2 +- .../linkis/rpc/message/parser/ServiceMethod.java | 2 +- .../linkis/rpc/message/parser/ServiceParser.java | 2 +- .../message/registry/AbstractServiceRegistry.java | 2 +- .../rpc/message/registry/ServiceRegistry.java | 2 +- .../message/registry/SpringServiceRegistry.java | 2 +- .../message/utils/LoadBalancerOptionsUtils.java | 2 +- .../linkis/rpc/message/utils/MessageUtils.java | 2 +- .../apache/linkis/rpc/serializer/NoneDelegate.java | 2 +- .../rpc/serializer/ProtostuffSerializeUtil.java | 2 +- .../sender/eureka/EurekaClientRefreshUtils.scala | 3 +- .../rpc/sender/eureka/EurekaRPCServerLoader.scala | 2 +- .../linkis/rpc/message/utils/MessageUtilsTest.java | 2 +- linkis-commons/linkis-scheduler/pom.xml | 2 +- .../errorcode/LinkisSchedulerErrorCodeSummary.java | 2 +- linkis-commons/linkis-storage/pom.xml | 2 +- .../linkis/storage/domain/FsPathListWithError.java | 2 +- .../LinkisIoFileClientErrorCodeSummary.java | 2 +- .../errorcode/LinkisIoFileErrorCodeSummary.java | 2 +- .../errorcode/LinkisStorageErrorCodeSummary.java | 2 +- .../linkis/storage/excel/ExcelStorageReader.java | 2 +- .../org/apache/linkis/storage/excel/XlsUtils.java | 2 +- .../org/apache/linkis/storage/excel/XlsxUtils.java | 2 +- .../storage/exception/FSNotInitException.java | 2 +- .../linkis/storage/exception/StorageErrorCode.java | 2 +- .../storage/exception/StorageErrorException.java | 2 +- .../storage/exception/StorageFatalException.java | 2 +- .../storage/exception/StorageWarnException.java | 2 +- .../linkis/storage/factory/BuildFactory.java | 2 +- .../storage/factory/impl/BuildHDFSFileSystem.java | 2 +- .../storage/factory/impl/BuildLocalFileSystem.java | 2 +- .../org/apache/linkis/storage/fs/FileSystem.java | 2 +- .../linkis/storage/fs/impl/HDFSFileSystem.java | 2 +- .../linkis/storage/fs/impl/LocalFileSystem.java | 2 +- .../storage/pipeline/DefaultPipelineFactory.java | 2 +- .../linkis/storage/pipeline/PipelineReader.java | 2 +- .../linkis/storage/pipeline/PipelineWriter.java | 2 +- .../storage/resultset/StorageResultSetWriter.scala | 50 +- linkis-commons/pom.xml | 2 +- .../linkis-cli/linkis-cli-application/pom.xml | 2 +- .../cli/application/LinkisClientApplication.java | 2 +- .../cli/application/constants/AppConstants.java | 2 +- .../linkis/cli/application/constants/AppKeys.java | 2 +- .../cli/application/constants/LinkisConstants.java | 2 +- .../cli/application/constants/LinkisKeys.java | 2 +- .../linkis/cli/application/data/FinishedData.java | 2 +- .../linkis/cli/application/data/PreparedData.java | 2 +- .../linkis/cli/application/data/ProcessedData.java | 2 +- .../interactor/command/LinkisCmdType.java | 2 +- .../command/template/UniversalCmdTemplate.java | 2 +- .../cli/application/interactor/job/LinkisJob.java | 2 +- .../interactor/job/LinkisJobStatus.java | 2 +- .../interactor/job/LinkisManageJob.java | 2 +- .../application/interactor/job/LinkisOnceJob.java | 2 +- .../interactor/job/LinkisSubmitJob.java | 2 +- .../job/builder/LinkisManageJobBuilder.java | 2 +- .../job/builder/LinkisOnceJobBuilder.java | 2 +- .../job/builder/LinkisSubmitJobBuilder.java | 2 +- .../interactor/job/builder/ProcessKeyUtils.java | 2 +- .../interactor/job/data/LinkisJobData.java | 2 +- .../interactor/job/data/LinkisJobDataImpl.java | 2 +- .../interactor/job/data/LinkisLogData.java | 2 +- .../interactor/job/data/LinkisOnceJobData.java | 2 +- .../interactor/job/data/LinkisResultData.java | 2 +- .../interactor/job/data/LinkisResultSet.java | 2 +- .../interactor/job/data/SimpleOnceJobAdapter.java | 2 +- .../interactor/job/desc/LinkisJobManDesc.java | 2 +- .../interactor/job/desc/LinkisOnceDesc.java | 2 +- .../interactor/job/desc/LinkisSubmitDesc.java | 2 +- .../interactor/job/subtype/LinkisManSubType.java | 2 +- .../job/subtype/LinkisSubmitSubType.java | 2 +- .../interactor/validate/LinkisManageValidator.java | 2 +- .../validate/LinkisOnceSubmitValidator.java | 2 +- .../interactor/validate/LinkisSubmitValidator.java | 2 +- .../interactor/validate/UJESContextValidator.java | 2 +- .../observer/event/LinkisClientEvent.java | 2 +- .../application/observer/event/LogStartEvent.java | 2 +- .../observer/event/SingleObserverEvent.java | 2 +- .../application/observer/event/TriggerEvent.java | 2 +- .../observer/listener/LinkisClientListener.java | 2 +- .../observer/listener/TriggerEventListener.java | 2 +- .../cli/application/operator/OperatorUtils.java | 2 +- .../operator/once/LinkisNodeStatus.java | 2 +- .../operator/once/OnceJobConstants.java | 2 +- .../operator/ujes/LinkisJobOperator.java | 2 +- .../operator/ujes/LinkisOperResultAdapter.java | 2 +- .../operator/ujes/LinkisOperatorBuilder.java | 2 +- .../operator/ujes/UJESClientContext.java | 2 +- .../operator/ujes/UJESClientFactory.java | 2 +- .../application/operator/ujes/UJESConstants.java | 2 +- .../operator/ujes/UJESResultAdapter.java | 2 +- .../operator/ujes/result/OpenLogResult2.java | 2 +- .../operator/ujes/result/ResultSetResult2.java | 2 +- .../operator/ujes/result/UJESResult.java | 2 +- .../application/present/LinkisLogPresenter.java | 2 +- .../present/LinkisResultInfoPresenter.java | 2 +- .../application/present/LinkisResultPresenter.java | 2 +- .../present/model/LinkisJobInfoModel.java | 2 +- .../present/model/LinkisJobKillModel.java | 2 +- .../application/present/model/LinkisLogModel.java | 2 +- .../present/model/LinkisResultInfoModel.java | 2 +- .../present/model/LinkisResultModel.java | 2 +- .../present/model/LinkisSubmitResultModel.java | 2 +- .../cli/application/suite/ExecutionSuite.java | 2 +- .../application/suite/ExecutionSuiteFactory.java | 2 +- .../cli/application/utils/ExecutionUtils.java | 2 +- .../apache/linkis/cli/application/utils/Utils.java | 2 +- .../application/LinkisClientApplicationTest.java | 2 +- .../cli/application/constants/TestConstants.java | 2 +- .../command/template/ProcessInputUtil.java | 2 +- .../interactor/command/template/TestCmdType.java | 2 +- .../command/template/TestParamMapper.java | 2 +- .../command/template/TestSparkCmdTemplate.java | 2 +- .../interactor/execution/LinkisExecutorTest.java | 2 +- .../interactor/job/LinkisJobBuilderTest.java | 2 +- .../linkis-cli/linkis-cli-common/pom.xml | 2 +- .../cli/common/entity/command/CmdOption.java | 2 +- .../cli/common/entity/command/CmdTemplate.java | 2 +- .../linkis/cli/common/entity/command/CmdType.java | 2 +- .../cli/common/entity/command/ParamItem.java | 2 +- .../linkis/cli/common/entity/command/Params.java | 2 +- .../cli/common/entity/execution/Execution.java | 2 +- .../apache/linkis/cli/common/entity/job/Job.java | 2 +- .../linkis/cli/common/entity/job/JobData.java | 2 +- .../cli/common/entity/job/JobDescription.java | 2 +- .../linkis/cli/common/entity/job/JobStatus.java | 2 +- .../linkis/cli/common/entity/job/JobSubType.java | 2 +- .../cli/common/entity/operator/JobOperator.java | 2 +- .../linkis/cli/common/entity/present/Model.java | 2 +- .../cli/common/entity/present/PresentWay.java | 2 +- .../cli/common/entity/present/Presenter.java | 2 +- .../common/entity/properties/ClientProperties.java | 2 +- .../cli/common/entity/result/ExecutionResult.java | 2 +- .../cli/common/entity/result/ExecutionStatus.java | 2 +- .../cli/common/entity/result/ResultHandler.java | 2 +- .../cli/common/entity/validate/Validator.java | 2 +- .../linkis/cli/common/entity/var/VarAccess.java | 2 +- .../linkis/cli/common/entity/version/Version.java | 2 +- .../common/exception/LinkisClientException.java | 2 +- .../exception/LinkisClientRuntimeException.java | 2 +- .../cli/common/exception/error/ErrorLevel.java | 2 +- .../cli/common/exception/error/ErrorMsg.java | 2 +- .../common/exception/handler/ExceptionHandler.java | 2 +- .../linkis-cli/linkis-cli-core/pom.xml | 2 +- .../linkis/cli/core/builder/AbstractBuilder.java | 2 +- .../cli/core/builder/BuildableByVarAccess.java | 2 +- .../apache/linkis/cli/core/builder/Builder.java | 2 +- .../linkis/cli/core/constants/CommonConstants.java | 2 +- .../linkis/cli/core/constants/CommonKeys.java | 2 +- .../cli/core/exception/BuilderException.java | 2 +- .../cli/core/exception/CommandException.java | 2 +- .../exception/LinkisClientExecutionException.java | 2 +- .../cli/core/exception/PresenterException.java | 2 +- .../linkis/cli/core/exception/PropsException.java | 2 +- .../cli/core/exception/TransformerException.java | 2 +- .../cli/core/exception/UnknownException.java | 2 +- .../cli/core/exception/ValidateException.java | 2 +- .../cli/core/exception/VarAccessException.java | 2 +- .../cli/core/exception/error/CommonErrMsg.java | 2 +- .../exception/handler/CommandExceptionHandler.java | 2 +- .../exception/handler/DefaultExceptionHandler.java | 2 +- .../interactor/command/CmdTemplateFactory.java | 2 +- .../cli/core/interactor/command/SpecialMap.java | 2 +- .../interactor/command/fitter/AbstractFitter.java | 2 +- .../cli/core/interactor/command/fitter/Fitter.java | 2 +- .../interactor/command/fitter/FitterResult.java | 2 +- .../interactor/command/fitter/FitterUtils.java | 2 +- .../interactor/command/fitter/SingleTplFitter.java | 2 +- .../interactor/command/parser/AbstarctParser.java | 2 +- .../cli/core/interactor/command/parser/Parser.java | 2 +- .../interactor/command/parser/SingleCmdParser.java | 2 +- .../command/parser/result/ParseResult.java | 2 +- .../command/parser/transformer/ParamKeyMapper.java | 2 +- .../command/template/AbstractCmdTemplate.java | 2 +- .../command/template/option/BaseOption.java | 2 +- .../interactor/command/template/option/Flag.java | 2 +- .../command/template/option/MapOption.java | 2 +- .../command/template/option/Parameter.java | 2 +- .../command/template/option/SpecialMapOption.java | 2 +- .../command/template/option/StdOption.java | 2 +- .../core/interactor/execution/AsyncSubmission.java | 2 +- .../linkis/cli/core/interactor/execution/Help.java | 2 +- .../core/interactor/execution/JobManagement.java | 2 +- .../core/interactor/execution/SyncSubmission.java | 2 +- .../cli/core/interactor/job/AbstractJob.java | 2 +- .../cli/core/interactor/job/AsyncBackendJob.java | 2 +- .../linkis/cli/core/interactor/job/JobBuilder.java | 2 +- .../cli/core/interactor/job/LogAccessibleJob.java | 2 +- .../core/interactor/job/ManagableBackendJob.java | 2 +- .../core/interactor/job/ResultAccessibleJob.java | 2 +- .../cli/core/interactor/job/SyncBackendJob.java | 2 +- .../cli/core/interactor/job/TerminatableJob.java | 2 +- .../cli/core/interactor/job/TerminateToken.java | 2 +- .../interactor/properties/PropertiesLoader.java | 2 +- .../interactor/properties/PropsFilesScanner.java | 2 +- .../core/interactor/properties/StdPropsLoader.java | 2 +- .../properties/reader/PropertiesReader.java | 2 +- .../properties/reader/PropsFileReader.java | 2 +- .../interactor/properties/reader/SysEnvReader.java | 2 +- .../properties/reader/SysPropsReader.java | 2 +- .../interactor/result/DefaultResultHandler.java | 2 +- .../interactor/result/ExecutionResultImpl.java | 2 +- .../interactor/result/ExecutionStatusEnum.java | 2 +- .../interactor/result/PresentResultHandler.java | 2 +- .../core/interactor/validate/ParamValidator.java | 2 +- .../interactor/validate/ParsedTplValidator.java | 2 +- .../core/interactor/validate/PropsValidator.java | 2 +- .../cli/core/interactor/var/StdVarAccess.java | 2 +- .../cli/core/interactor/var/SysVarAccess.java | 2 +- .../cli/core/operator/JobOperatorBuilder.java | 2 +- .../cli/core/operator/JobOperatorFactory.java | 2 +- .../cli/core/present/DefaultStdOutPresenter.java | 2 +- .../linkis/cli/core/present/HelpInfoPresenter.java | 2 +- .../linkis/cli/core/present/PresentMode.java | 2 +- .../linkis/cli/core/present/PresentModeImpl.java | 2 +- .../linkis/cli/core/present/PresentWayImpl.java | 2 +- .../core/present/display/DisplayOperFactory.java | 2 +- .../cli/core/present/display/DisplayOperator.java | 2 +- .../core/present/display/PlainTextFileWriter.java | 2 +- .../cli/core/present/display/StdOutWriter.java | 2 +- .../cli/core/present/display/data/DisplayData.java | 2 +- .../core/present/display/data/FileDisplayData.java | 2 +- .../present/display/data/StdoutDisplayData.java | 2 +- .../cli/core/present/model/HelpInfoModel.java | 2 +- .../apache/linkis/cli/core/utils/CommonUtils.java | 2 +- .../org/apache/linkis/cli/core/utils/LogUtils.java | 2 +- .../linkis/cli/core/utils/SchedulerUtils.java | 2 +- .../utils/converter/AbstractStringConverter.java | 2 +- .../linkis/cli/core/utils/converter/Converter.java | 2 +- .../converter/PredefinedStringConverters.java | 2 +- .../linkis/cli/core/constants/TestConstants.java | 2 +- .../handler/CommandExceptionHandlerTest.java | 2 +- .../cli/core/interactor/command/TestCmdType.java | 2 +- .../command/fitter/SingleTplFitterTest.java | 2 +- .../command/parser/SingleCmdParserTest.java | 2 +- .../command/template/TestParamMapper.java | 2 +- .../command/template/TestSparkCmdTemplate.java | 2 +- .../interactor/properties/StdPropsLoaderTest.java | 2 +- .../cli/core/interactor/var/StdVarAccessTest.java | 2 +- .../apache/linkis/cli/core/utils/TestUtils.java | 2 +- .../linkis-client/linkis-cli/pom.xml | 2 +- .../linkis-computation-client/pom.xml | 2 +- .../linkis/computation/client/once/OnceJob.scala | 2 + .../once/action/ServiceInstanceBuilder.scala | 7 + .../client/once/simple/SimpleOnceJob.scala | 2 +- .../client/operator/OnceJobOperator.scala | 1 + .../computation/client/FlinkOnceJobTest.java | 2 +- .../computation/client/InteractiveJobTest.java | 2 +- .../linkis/computation/client/TestLogListener.java | 2 +- .../ujes/client/PythonImageJavaClientTest.java | 16 +- .../linkis/ujes/client/UJESClientImplTestJ.java | 2 +- .../linkis-computation-governance-common/pom.xml | 2 +- .../common/entity/ExecutionNodeStatus.java | 2 +- .../governance/common/entity/NodeExistStatus.java | 2 +- .../governance/common/entity/job/JobRequest.java | 2 +- .../common/entity/job/JobRequestWithDetail.java | 2 +- .../common/entity/job/QueryException.java | 2 +- .../governance/common/entity/job/SubJobDetail.java | 2 +- .../governance/common/entity/job/SubJobInfo.java | 2 +- .../common/entity/task/RequestInsertTask.java | 2 +- .../common/entity/task/RequestOneTask.java | 2 +- .../common/entity/task/RequestPersistTask.java | 2 +- .../common/entity/task/RequestQueryTask.java | 2 +- .../common/entity/task/RequestReadAllTask.java | 2 +- .../common/entity/task/RequestUpdateTask.java | 2 +- .../common/entity/task/ResponsePersist.java | 2 +- .../engineconn/EngineConnExecutorErrorCode.java | 2 +- .../EngineConnExecutorErrorException.java | 2 +- .../common/conf/GovernaceCommonConf.scala | 4 +- .../linkis-engineconn-linux-launch/pom.xml | 2 +- .../linkis-engineconn-manager-core/pom.xml | 2 +- .../core/errorcode/LinkisECMErrorCodeSummary.java | 2 +- .../core/launch/ProcessEngineCommandBuilder.scala | 3 +- .../linkis-engineconn-manager-server/pom.xml | 2 +- .../EngineconnServerErrorCodeSummary.java | 2 +- .../linkis/ecm/server/LinkisECMApplication.java | 2 +- .../linkis/ecm/server/conf/ECMConfiguration.scala | 2 +- .../impl/AbstractEngineConnLaunchService.scala | 38 +- .../service/impl/DefaultECMHealthService.scala | 2 +- .../service/impl/DefaultECMRegisterService.scala | 4 +- .../DefaultEngineConnStatusCallbackService.scala | 4 +- .../impl/ProcessEngineConnLaunchService.scala | 4 +- .../impl/DefaultEngineConnKillServiceTest.java | 2 +- .../linkis-engineconn-manager/pom.xml | 2 +- .../linkis-once-engineconn/pom.xml | 2 +- .../engineconn/once/executor/OnceExecutor.scala | 27 +- .../linkis-streaming-engineconn/pom.xml | 2 +- .../linkis-computation-engineconn/pom.xml | 2 +- .../executor/execute/ComputationExecutor.scala | 5 +- .../upstream/access/ECTaskEntranceInfoAccess.scala | 3 +- .../linkis-engineconn-common/pom.xml | 2 +- .../linkis-engineconn-core/pom.xml | 2 +- .../LinkisEngineconnCoreErrorCodeSummary.java | 2 +- .../accessible-executor/pom.xml | 2 +- .../acessible/executor/log/AbstractLogCache.java | 2 +- .../acessible/executor/log/LogCache.java | 2 +- .../acessible/executor/log/MountLogCache.java | 2 +- .../acessible/executor/log/SendAppender.java | 2 +- .../acessible/executor/log/TimeLogCache.java | 2 +- .../execution/AccessibleEngineConnExecution.scala | 2 + .../executor/service/DefaultManagerService.scala | 17 +- .../executor-core/pom.xml | 2 +- .../executor/entity/SensibleExecutor.scala | 2 +- .../linkis-engineconn-plugin-core/pom.xml | 2 +- .../errorcode/EngineconnCoreErrorCodeSummary.java | 7 +- .../linkis-engineconn-plugin-server/pom.xml | 2 +- .../engineplugin/cache/EngineConnPluginCache.java | 2 +- .../cache/GuavaEngineConnPluginCache.java | 2 +- .../cache/config/EngineConnPluginCacheConfig.java | 2 +- .../DefaultRefreshPluginCacheContainer.java | 2 +- .../cache/refresh/PluginCacheRefresher.java | 2 +- .../cache/refresh/RefreshPluginCacheContainer.java | 2 +- .../cache/refresh/RefreshPluginCacheOperation.java | 2 +- .../refresh/RefreshableEngineConnPluginCache.java | 2 +- .../classloader/EngineConnPluginClassLoader.java | 3 +- .../loaders/CacheablesEngineConnPluginLoader.java | 2 +- .../loaders/DefaultEngineConnPluginLoader.java | 2 +- .../loader/loaders/EngineConnPluginsLoader.java | 2 +- .../loaders/EngineConnPluginsResourceLoader.java | 2 +- .../BmlEngineConnPluginResourceLoader.java | 50 +- .../LocalEngineConnPluginResourceLoader.java | 13 +- .../loader/loaders/resource/PluginResource.java | 2 +- .../loader/utils/EngineConnPluginUtils.java | 2 +- .../engineplugin/loader/utils/ExceptionHelper.java | 2 +- .../server/LinkisEngineConnPluginServer.java | 2 +- .../conf/EngineConnPluginSpringConfiguration.java | 2 +- .../server/dao/EngineConnBmlResourceDao.java | 2 +- .../server/entity/EngineConnBmlResource.java | 2 +- .../linkis/engineplugin/vo/EnginePluginBMLVo.java | 2 +- .../apache/linkis/engineplugin/vo/PageViewVo.java | 2 +- .../conf/EngineConnPluginConfiguration.scala | 7 +- .../AbstractEngineConnBmlResourceGenerator.scala | 34 +- .../service/DefaultEngineConnLaunchService.scala | 2 +- .../loader/EngineConnPluginLoaderTest.java | 2 +- .../linkis-engineconn/pom.xml | 2 +- .../linkis-entrance/pom.xml | 8 +- .../linkis/entrance/LinkisEntranceApplication.java | 2 +- .../EntranceExecutorManagerBeanAnnotation.java | 2 +- .../annotation/EntranceParserBeanAnnotation.java | 2 +- .../annotation/EntranceServerBeanAnnotation.java | 2 +- .../PersistenceEngineBeanAnnotation.java | 2 +- .../entrance/conf/EntranceSpringConfiguration.java | 2 +- .../entrance/context/DefaultEntranceContext.java | 2 +- .../errorcode/EntranceErrorCodeSummary.java | 2 +- .../entrance/exception/EntranceErrorCode.java | 2 +- .../exception/EntranceIllegalParamException.java | 2 +- .../entrance/exception/EntranceRPCException.java | 2 +- .../entrance/exception/QueryFailedException.java | 2 +- .../entrance/job/EntranceExecuteRequest.java | 2 +- .../linkis/entrance/job/EntranceExecutionJob.java | 2 +- .../entrance/parser/AbstractEntranceParser.java | 2 +- .../apache/linkis/entrance/parser/ParserUtils.java | 2 +- .../persistence/AbstractPersistenceEngine.java | 2 +- .../persistence/QueryPersistenceEngine.java | 2 +- .../persistence/QueryPersistenceManager.java | 2 +- .../entrance/server/DefaultEntranceServer.java | 2 +- .../entrance/vo/YarnResourceWithStatusVo.java | 2 +- .../linkis-jdbc-driver/pom.xml | 2 +- .../linkis-application-manager/pom.xml | 2 +- .../manager/am/LinkisManagerApplication.java | 2 +- .../linkis/manager/am/exception/AMErrorCode.java | 2 +- .../manager/am/exception/AMErrorException.java | 2 +- .../manager/am/exception/AMRetryException.java | 2 +- .../manager/am/restful/EngineRestfulApi.java | 27 +- .../manager/am/service/ECResourceInfoService.java | 2 +- .../am/service/impl/ECResourceInfoServiceImpl.java | 2 +- .../manager/am/util/ECResourceInfoUtils.java | 8 +- .../linkis/manager/am/vo/AMEngineNodeVo.java | 2 +- .../manager/am/vo/ECResourceInfoRecordVo.java | 3 +- .../org/apache/linkis/manager/am/vo/EMNodeVo.java | 2 +- .../apache/linkis/manager/am/vo/ResourceVo.java | 3 +- .../linkis/manager/rm/conf/ResourceStatus.java | 2 +- .../linkis/manager/rm/domain/RMLabelContainer.java | 20 +- .../linkis/manager/rm/exception/RMErrorCode.java | 2 +- .../rm/exception/RMLockFailedRetryException.java | 13 +- .../external/dao/ExternalResourceProviderDao.java | 2 +- .../rm/external/domain/ExternalAppInfo.java | 2 +- .../domain/ExternalResourceIdentifier.java | 2 +- .../external/domain/ExternalResourceProvider.java | 2 +- .../parser/ExternalResourceIdentifierParser.java | 2 +- .../parser/YarnResourceIdentifierParser.java | 2 +- .../request/ExternalResourceRequester.java | 2 +- .../external/service/ExternalResourceService.java | 2 +- .../service/impl/ExternalResourceServiceImpl.java | 2 +- .../rm/external/yarn/YarnResourceIdentifier.java | 2 +- .../manager/rm/restful/vo/ApplicationListVo.java | 2 +- .../manager/rm/restful/vo/EngineInstanceVo.java | 2 +- .../rm/restful/vo/UserCreatorEngineType.java | 2 +- .../manager/rm/restful/vo/UserResourceVo.java | 2 +- .../apache/linkis/manager/rm/utils/AlertUtils.java | 2 +- .../manager/rm/utils/RequestKerberosUrlUtils.java | 2 +- .../am/service/monitor/NodeHeartbeatMonitor.scala | 44 +- .../manager/label/service/NodeLabelService.scala | 2 +- .../impl/DefaultNodeLabelRemoveService.scala | 5 +- .../service/impl/DefaultNodeLabelService.scala | 10 +- .../manager/rm/entity/LabelResourceMap.scala | 52 ++ .../manager/rm/entity/ResourceOperationType.scala | 12 +- .../linkis/manager/rm/restful/RMMonitorRest.scala | 6 +- .../manager/rm/service/ResourceLockService.scala | 72 +- .../rm/service/impl/DefaultResourceManager.scala | 793 ++++++++++----------- .../linkis-manager/linkis-label-common/pom.xml | 2 +- .../label/builder/AbstractGenericLabelBuilder.java | 2 +- .../label/builder/CombinedLabelBuilder.java | 2 +- .../label/builder/DefaultGlobalLabelBuilder.java | 2 +- .../label/builder/ExtensibleLabelBuilder.java | 2 +- .../manager/label/builder/GenericLabelBuilder.java | 2 +- .../linkis/manager/label/builder/LabelBuilder.java | 2 +- .../manager/label/builder/LabelBuilderAdapter.java | 2 +- .../label/builder/factory/LabelBuilderFactory.java | 2 +- .../factory/LabelBuilderFactoryContext.java | 2 +- .../builder/factory/StdLabelBuilderFactory.java | 2 +- .../manager/label/conf/LabelCommonConfig.java | 2 +- .../manager/label/constant/LabelConstant.java | 2 +- .../manager/label/constant/LabelKeyConstant.java | 2 +- .../manager/label/entity/CloneableLabel.java | 2 +- .../linkis/manager/label/entity/CombinedLabel.java | 2 +- .../manager/label/entity/CombinedLabelImpl.java | 2 +- .../linkis/manager/label/entity/EMNodeLabel.java | 2 +- .../manager/label/entity/EngineNodeLabel.java | 2 +- .../linkis/manager/label/entity/Feature.java | 2 +- .../linkis/manager/label/entity/FunctionLabel.java | 2 +- .../linkis/manager/label/entity/GenericLabel.java | 2 +- .../manager/label/entity/InheritableLabel.java | 2 +- .../apache/linkis/manager/label/entity/Label.java | 2 +- .../linkis/manager/label/entity/NodeLabel.java | 2 +- .../linkis/manager/label/entity/ResourceLabel.java | 2 +- .../manager/label/entity/SerializableLabel.java | 13 +- .../linkis/manager/label/entity/TenantLabel.java | 7 +- .../manager/label/entity/UserModifiable.java | 8 +- .../manager/label/entity/annon/KeyMethod.java | 2 +- .../manager/label/entity/annon/ValueSerialNum.java | 2 +- .../manager/label/entity/cache/CacheLabel.java | 2 +- .../manager/label/entity/cluster/ClusterLabel.java | 2 +- .../manager/label/entity/cluster/EnvLabel.java | 2 +- .../label/entity/config/ConfigurationLabel.java | 2 +- .../manager/label/entity/em/EMInstanceLabel.java | 2 +- .../label/entity/engine/CodeLanguageLabel.java | 2 +- .../entity/engine/ConcurrentEngineConnLabel.java | 2 +- .../label/entity/engine/EngineBaseInfoLabel.java | 2 +- .../label/entity/engine/EngineInstanceLabel.java | 2 +- .../manager/label/entity/engine/EngineType.scala | 3 - .../label/entity/engine/EngineTypeLabel.java | 2 +- .../label/entity/engine/ReuseExclusionLabel.java | 2 +- .../label/entity/engine/UserCreatorLabel.java | 7 +- .../label/entity/entrance/BindEngineLabel.java | 2 +- .../label/entity/entrance/ExecuteOnceLabel.java | 2 +- .../entity/entrance/JobQueuingTimeoutLabel.java | 2 +- .../entity/entrance/JobRunningTimeoutLabel.java | 2 +- .../label/entity/entrance/JobStrategyLabel.java | 2 +- .../label/entity/entrance/LoadBalanceLabel.java | 2 +- .../label/entity/entrance/RetryCountLabel.java | 2 +- .../entity/entrance/RetryWaitTimeOutLabel.java | 2 +- .../entity/node/AliasServiceInstanceLabel.java | 2 +- .../label/entity/node/NodeInstanceLabel.java | 2 +- .../manager/label/entity/route/RouteLabel.java | 7 +- .../label/entity/search/SearchableLabel.java | 2 +- .../errorcode/LabelCommonErrorCodeSummary.java | 2 +- .../label/exception/LabelErrorException.java | 2 +- .../label/exception/LabelRuntimeException.java | 2 +- .../label/utils/EngineTypeLabelCreator.java | 4 +- .../linkis/manager/label/utils/LabelUtils.java | 47 +- .../linkis/manager/label/TestLabelBuilder.java | 2 +- .../linkis-manager/linkis-manager-common/pom.xml | 2 +- .../linkis/manager/common/constant/AMConstant.java | 2 +- .../linkis/manager/common/constant/RMConstant.java | 2 +- .../common/entity/enumeration/MaintainType.java | 2 +- .../common/entity/enumeration/NodeHealthy.java | 4 +- .../common/entity/enumeration/NodeStatus.java | 30 +- .../manager/common/entity/label/LabelKeyValue.java | 2 +- .../common/entity/metrics/AMNodeMetrics.java | 2 +- .../common/entity/metrics/NodeHealthyInfo.java | 2 +- .../manager/common/entity/metrics/NodeMetrics.java | 2 +- .../common/entity/metrics/NodeOverLoadInfo.java | 2 +- .../common/entity/metrics/NodeTaskInfo.java | 2 +- .../manager/common/entity/node/AMEMNode.java | 2 +- .../manager/common/entity/node/AMEngineNode.java | 2 +- .../linkis/manager/common/entity/node/AMNode.java | 2 +- .../entity/node/DefaultScoreServiceInstance.java | 2 +- .../linkis/manager/common/entity/node/EMNode.java | 2 +- .../manager/common/entity/node/EngineNode.java | 2 +- .../manager/common/entity/node/InfoRMNode.java | 2 +- .../manager/common/entity/node/LabelNode.java | 2 +- .../linkis/manager/common/entity/node/Node.java | 2 +- .../linkis/manager/common/entity/node/RMNode.java | 2 +- .../common/entity/node/ScoreServiceInstance.java | 2 +- .../entity/persistence/ECResourceInfoRecord.java | 2 +- .../entity/persistence/PersistenceLabel.java | 2 +- .../entity/persistence/PersistenceLabelRel.java | 2 +- .../common/entity/persistence/PersistenceLock.java | 2 +- .../common/entity/persistence/PersistenceNode.java | 2 +- .../entity/persistence/PersistenceNodeEntity.java | 2 +- .../entity/persistence/PersistenceNodeMetrics.java | 2 +- .../persistence/PersistenceNodeMetricsEntity.java | 2 +- .../entity/persistence/PersistenceResource.java | 2 +- .../common/entity/resource/CommonNodeResource.java | 2 +- .../common/entity/resource/NodeResource.java | 2 +- .../entity/resource/ResourceActionRecord.java | 2 +- .../common/entity/resource/ResourceType.java | 2 +- .../common/entity/resource/UserResource.java | 2 +- .../errorcode/ManagerCommonErrorCodeSummary.java | 2 +- .../manager/common/exception/RMErrorException.java | 2 +- .../manager/common/exception/RMFatalException.java | 2 +- .../manager/common/exception/RMWarnException.java | 2 +- .../common/exception/ResourceWarnException.java | 2 +- .../manager/common/protocol/bml/BmlResource.java | 2 +- .../common/protocol/em/EMInfoClearRequest.java | 2 +- .../manager/common/protocol/em/EMRequest.java | 2 +- .../common/protocol/em/EMResourceClearRequest.java | 2 +- .../common/protocol/em/GetEMEnginesRequest.java | 2 +- .../common/protocol/em/GetEMInfoRequest.java | 2 +- .../manager/common/protocol/em/PauseEMRequest.java | 2 +- .../manager/common/protocol/em/StopEMRequest.java | 2 +- .../common/protocol/engine/ECCanKillRequest.java | 2 +- .../common/protocol/engine/ECCanKillResponse.java | 2 +- .../common/protocol/engine/EngineAskRequest.java | 2 +- .../protocol/engine/EngineConnReleaseRequest.java | 2 +- .../protocol/engine/EngineCreateRequest.java | 2 +- .../protocol/engine/EngineInfoClearRequest.java | 2 +- .../common/protocol/engine/EngineLockType.java | 2 +- .../protocol/engine/EngineRecyclingRequest.java | 2 +- .../protocol/engine/EngineReourceClearRequest.java | 2 +- .../common/protocol/engine/EngineRequest.java | 2 +- .../common/protocol/engine/EngineReuseRequest.java | 2 +- .../common/protocol/engine/EngineStopRequest.java | 2 +- .../common/protocol/engine/EngineStopResponse.java | 2 +- .../protocol/engine/EngineSuicideRequest.java | 2 +- .../protocol/engine/EngineSwitchRequest.java | 2 +- .../common/protocol/node/HeartbeatProtocol.java | 2 +- .../common/protocol/node/NodeHealthyRequest.java | 2 +- .../common/protocol/node/NodeHeartbeatMsg.java | 2 +- .../common/protocol/node/NodeHeartbeatRequest.java | 2 +- .../protocol/node/NodeHeartbeatResourceMsg.java | 2 +- .../common/protocol/node/NodeRequestProtocol.java | 2 +- .../common/protocol/node/NodeStatusProtocol.java | 2 +- .../common/protocol/node/RequestNodeStatus.java | 2 +- .../common/protocol/node/ResponseNodeStatus.java | 2 +- .../common/protocol/node/StopNodeRequest.java | 2 +- .../protocol/yarn/YarnAuthorizationRequest.java | 2 +- .../protocol/yarn/YarnAuthorizationResponse.java | 2 +- .../linkis/manager/common/utils/ManagerUtils.java | 2 +- .../manager/common/entity/resource/Resource.scala | 61 +- .../manager/common/utils/ResourceUtils.scala | 93 ++- .../linkis-manager-persistence/pom.xml | 2 +- .../manager/PersistenceSpringConfiguration.java | 2 +- .../linkis/manager/dao/ECResourceRecordMapper.java | 2 +- .../linkis/manager/dao/LabelManagerMapper.java | 2 +- .../linkis/manager/dao/LockManagerMapper.java | 15 +- .../linkis/manager/dao/NodeManagerMapper.java | 2 +- .../manager/dao/NodeMetricManagerMapper.java | 2 +- .../linkis/manager/dao/ResourceManagerMapper.java | 2 +- .../manager/dao/impl/ECResourceRecordMapper.xml | 5 +- .../linkis/manager/dao/impl/LockManagerMapper.xml | 89 +-- .../org/apache/linkis/manager/entity/Tunple.java | 2 +- .../LinkisManagerPersistenceErrorCodeSummary.java | 2 +- .../exception/NodeInstanceDuplicateException.java | 2 +- .../exception/NodeInstanceNotFoundException.java | 2 +- .../exception/PersistenceErrorException.java | 2 +- .../exception/PersistenceWarnException.java | 2 +- .../persistence/LabelManagerPersistence.java | 2 +- .../persistence/LockManagerPersistence.java | 5 +- .../manager/persistence/ManagerPersistence.java | 2 +- .../persistence/NodeManagerPersistence.java | 2 +- .../persistence/NodeMetricManagerPersistence.java | 2 +- .../persistence/ResourceLabelPersistence.java | 2 +- .../persistence/ResourceManagerPersistence.java | 2 +- .../impl/DefaultLabelManagerPersistence.java | 2 +- .../impl/DefaultLockManagerPersistence.java | 89 ++- .../impl/DefaultManagerPersistence.java | 2 +- .../impl/DefaultNodeManagerPersistence.java | 2 +- .../impl/DefaultNodeMetricManagerPersistence.java | 2 +- .../impl/DefaultResourceLabelPersistence.java | 2 +- .../impl/DefaultResourceManagerPersistence.java | 2 +- .../manager/util/PersistenceManagerConf.java | 17 +- .../linkis/manager/util/PersistenceUtils.java | 2 +- .../test/java/org/apache/linkis/manager/Scan.java | 2 +- .../org/apache/linkis/manager/dao/BaseDaoTest.java | 2 +- .../linkis/manager/dao/LockManagerMapperTest.java | 8 +- .../linkis/manager/dao/NodeManagerMapperTest.java | 2 +- .../manager/dao/NodeMetricManagerMapperTest.java | 2 +- .../manager/dao/ResourceManagerMapperTest.java | 2 +- .../linkis-manager/pom.xml | 2 +- linkis-computation-governance/pom.xml | 2 +- linkis-dist/bin/install.sh | 5 + linkis-dist/deploy-config/linkis-env.sh | 5 +- linkis-dist/helm/README.md | 4 +- linkis-dist/helm/README_CN.md | 4 +- linkis-dist/helm/charts/linkis/Chart.yaml | 2 +- linkis-dist/package/conf/application-eureka.yml | 9 +- linkis-dist/package/db/linkis_ddl.sql | 3 +- linkis-dist/package/db/linkis_dml.sql | 20 +- .../db/upgrade/1.3.1_schema/mysql/linkis_ddl.sql | 15 +- linkis-dist/package/sbin/linkis | 266 +++++++ linkis-dist/pom.xml | 8 +- linkis-engineconn-plugins/elasticsearch/pom.xml | 2 +- .../errorcode/EasticsearchErrorCodeSummary.java | 2 +- linkis-engineconn-plugins/flink/pom.xml | 2 +- .../flink/client/config/Environment.java | 2 +- .../flink/client/config/entries/ConfigEntry.java | 2 +- .../client/config/entries/ExecutionEntry.java | 2 +- .../flink/client/context/ExecutionContext.java | 2 +- .../deployment/ClusterDescriptorAdapter.java | 2 +- .../ClusterDescriptorAdapterFactory.java | 2 +- .../YarnApplicationClusterDescriptorAdapter.java | 2 +- .../YarnPerJobClusterDescriptorAdapter.java | 2 +- .../factory/LinkisYarnClusterClientFactory.java | 2 +- .../flink/client/result/AbstractResult.java | 2 +- .../flink/client/result/BatchResult.java | 2 +- .../flink/client/result/ChangelogResult.java | 2 +- .../flink/client/result/Result.java | 2 +- .../flink/client/result/ResultUtil.java | 2 +- .../flink/client/result/TypedResult.java | 2 +- .../client/sql/operation/AbstractJobOperation.java | 2 +- .../flink/client/sql/operation/JobOperation.java | 2 +- .../client/sql/operation/NonJobOperation.java | 2 +- .../flink/client/sql/operation/Operation.java | 2 +- .../client/sql/operation/OperationFactory.java | 2 +- .../client/sql/operation/OperationFactoryImpl.java | 2 +- .../flink/client/sql/operation/OperationUtil.java | 2 +- .../sql/operation/impl/CreateViewOperation.java | 2 +- .../client/sql/operation/impl/DDLOperation.java | 2 +- .../sql/operation/impl/DescribeTableOperation.java | 2 +- .../sql/operation/impl/DropViewOperation.java | 2 +- .../sql/operation/impl/ExplainOperation.java | 2 +- .../client/sql/operation/impl/InsertOperation.java | 2 +- .../client/sql/operation/impl/ResetOperation.java | 2 +- .../client/sql/operation/impl/SelectOperation.java | 2 +- .../client/sql/operation/impl/SetOperation.java | 2 +- .../sql/operation/impl/ShowCatalogsOperation.java | 2 +- .../impl/ShowCurrentCatalogOperation.java | 2 +- .../impl/ShowCurrentDatabaseOperation.java | 2 +- .../sql/operation/impl/ShowDatabasesOperation.java | 2 +- .../sql/operation/impl/ShowFunctionsOperation.java | 2 +- .../sql/operation/impl/ShowModulesOperation.java | 2 +- .../sql/operation/impl/ShowTablesOperation.java | 2 +- .../sql/operation/impl/ShowViewsOperation.java | 2 +- .../sql/operation/impl/UseCatalogOperation.java | 2 +- .../sql/operation/impl/UseDatabaseOperation.java | 2 +- .../client/sql/operation/result/ColumnInfo.java | 2 +- .../client/sql/operation/result/ConstantNames.java | 2 +- .../client/sql/operation/result/ResultKind.java | 2 +- .../client/sql/operation/result/ResultSet.java | 2 +- .../result/ResultSetJsonDeserializer.java | 2 +- .../operation/result/ResultSetJsonSerializer.java | 2 +- .../flink/client/sql/parser/SqlCommand.java | 2 +- .../flink/client/sql/parser/SqlCommandCall.java | 2 +- .../flink/client/sql/parser/SqlCommandParser.java | 2 +- .../client/sql/parser/SqlCommandParserImpl.java | 2 +- .../flink/client/utils/YarnConfLoader.java | 2 +- .../flink/errorcode/FlinkErrorCodeSummary.java | 2 +- .../flink/exception/ExecutorInitException.java | 2 +- .../flink/exception/FlinkInitFailedException.java | 2 +- .../flink/exception/JobExecutionException.java | 2 +- .../flink/exception/SqlExecutionException.java | 2 +- .../flink/exception/SqlParseException.java | 2 +- .../flink/config/FlinkResourceConfiguration.scala | 15 +- .../flink/executor/FlinkExecutor.scala | 9 +- linkis-engineconn-plugins/hive/pom.xml | 2 +- .../linkis/engineplugin/hive/log/HiveProgress.java | 2 +- .../hive/serde/CustomerDelimitedJSONSerDe.java | 2 +- .../hive/executor/HiveEngineConnExecutor.scala | 7 +- linkis-engineconn-plugins/io_file/pom.xml | 2 +- .../engineplugin/io/utils/ReflectionUtils.java | 2 +- .../engineplugin/io/service/FsProxyService.scala | 11 +- .../manager/engineplugin/io/utils/IOHelp.scala | 20 +- linkis-engineconn-plugins/jdbc/pom.xml | 2 +- .../engineplugin/jdbc/ConnectionManager.java | 2 +- .../jdbc/JDBCDataSourceConfigurations.java | 2 +- .../engineplugin/jdbc/JDBCPropertiesParser.java | 2 +- .../manager/engineplugin/jdbc/JdbcAuthType.java | 2 +- .../engineplugin/jdbc/PropertiesParser.java | 2 +- .../jdbc/constant/JDBCEngineConnConstant.java | 2 +- .../jdbc/errorcode/JDBCErrorCodeSummary.java | 2 +- .../engineplugin/jdbc/monitor/ProgressMonitor.java | 2 +- .../jdbc/monitor/impl/TrinoProgressMonitor.java | 2 +- .../engineplugin/jdbc/utils/JdbcParamUtils.java | 2 +- .../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 4 +- .../engineplugin/jdbc/ConnectionManagerTest.java | 2 +- .../engineplugin/jdbc/ProgressMonitorTest.java | 2 +- .../jdbc/errorcode/JDBCErrorCodeSummaryTest.java | 2 +- .../jdbc/utils/JdbcParamUtilsTest.java | 2 +- linkis-engineconn-plugins/openlookeng/pom.xml | 4 +- .../builder/OpenLooKengProcessECLaunchBuilder.java | 2 +- .../openlookeng/conf/OpenLooKengConfiguration.java | 20 +- .../conf/OpenLooKengEngineConfCache.java | 2 +- .../exception/OpenLooKengClientException.java | 2 +- .../OpenLooKengStateInvalidException.java | 2 +- .../executor/OpenLooKengEngineConnExecutor.java | 20 +- linkis-engineconn-plugins/pipeline/pom.xml | 2 +- .../errorcode/PopelineErrorCodeSummary.java | 2 +- linkis-engineconn-plugins/pom.xml | 2 +- linkis-engineconn-plugins/presto/pom.xml | 2 +- linkis-engineconn-plugins/python/pom.xml | 2 +- .../errorcode/LinkisPythonErrorCodeSummary.java | 2 +- linkis-engineconn-plugins/shell/pom.xml | 2 +- .../errorcode/LinkisCommonsErrorCodeSummary.java | 2 +- linkis-engineconn-plugins/spark/pom.xml | 2 +- .../spark/errorcode/SparkErrorCodeSummary.java | 2 +- .../spark/Interpreter/PythonInterpreter.scala | 7 +- .../linkis/engineplugin/spark/common/Kind.scala | 6 +- .../spark/common/LineBufferedStream.scala | 6 +- .../spark/config/SparkConfiguration.scala | 2 +- .../spark/factory/SparkEngineConnFactory.scala | 19 +- .../engineplugin/spark/utils/EngineUtils.scala | 10 + linkis-engineconn-plugins/sqoop/pom.xml | 2 +- .../sqoop/client/LinkisSqoopClient.java | 2 +- .../engineconnplugin/sqoop/client/Sqoop.java | 2 +- .../sqoop/client/config/ExecutionContext.java | 2 +- .../sqoop/client/config/ParamsMapping.java | 2 +- .../client/errorcode/SqoopErrorCodeSummary.java | 2 +- .../client/exception/JobClosableException.java | 2 +- .../client/exception/JobExecutionException.java | 2 +- .../sqoop/client/utils/JarLoader.java | 2 +- .../java/org/apache/sqoop/mapreduce/JobBase.java | 3 +- linkis-engineconn-plugins/trino/pom.xml | 2 +- .../trino/interceptor/PasswordInterceptor.java | 2 +- .../trino/password/CommandPasswordCallback.java | 2 +- .../trino/password/StaticPasswordCallback.java | 2 +- .../trino/socket/SocketChannelSocketFactory.java | 2 +- linkis-extensions/linkis-io-file-client/pom.xml | 2 +- linkis-extensions/pom.xml | 2 +- .../linkis-code-orchestrator/pom.xml | 5 +- .../linkis-computation-orchestrator/pom.xml | 12 +- .../computation/utils/TaskTreeUtil.java | 5 +- .../linkis/orchestrator/ecm/entity/Policy.java | 2 +- .../computation/monitor/EngineConnMonitor.scala | 41 +- .../progress/AbstractProgressOperation.scala | 8 +- .../physical/CodeLogicalUnitExecTask.scala | 2 +- .../ecm/ComputationEngineConnManager.scala | 50 +- .../orchestrator/ecm/EngineConnManager.scala | 54 +- .../ecm/EngineConnManagerBuilder.scala | 0 .../ecm/LoadBalanceLabelEngineConnManager.scala | 2 +- .../ecm/cache/EngineAsyncResponseCache.scala | 2 +- .../orchestrator/ecm/conf/ECMPluginConf.scala | 0 .../linkis/orchestrator/ecm/entity/Mark.scala | 0 .../linkis/orchestrator/ecm/entity/MarkReq.scala | 13 +- .../ecm/exception/ECMPluginErrorException.scala | 0 .../ecm/service/EngineAsyncResponseService.scala | 0 .../ecm/service/EngineConnExecutor.scala | 0 .../ecm/service/TaskExecutionReceiver.scala | 0 .../impl/ComputationEngineConnExecutor.scala | 44 +- .../impl/DefaultEngineAsyncResponseService.scala | 0 .../linkis/orchestrator/ecm/utils/ECMPUtils.scala | 0 .../linkis-orchestrator-core/pom.xml | 5 +- .../orchestrator/execution/ExecTaskRunner.scala | 8 +- .../orchestrator/listener/task/TaskInfoEvent.scala | 2 +- .../linkis/orchestrator/utils/TreeOperator.scala | 4 +- .../plugin/linkis-orchestrator-ecm-plugin/pom.xml | 83 --- linkis-orchestrator/pom.xml | 3 +- .../linkis-basedata-manager/pom.xml | 2 +- .../server/LinkisBasedataManagerApplication.java | 3 +- .../server/dao/DatasourceAccessMapper.java | 3 +- .../server/dao/DatasourceEnvMapper.java | 3 +- .../server/dao/DatasourceTypeMapper.java | 3 +- .../server/dao/GatewayAuthTokenMapper.java | 3 +- .../server/dao/PsErrorCodeMapper.java | 3 +- .../dao/RmExternalResourceProviderMapper.java | 2 +- .../server/dao/UdfManagerMapper.java | 2 +- .../basedatamanager/server/dao/UdfTreeMapper.java | 2 +- .../server/domain/DatasourceAccessEntity.java | 3 +- .../server/domain/DatasourceEnvEntity.java | 2 +- .../server/domain/DatasourceTypeEntity.java | 2 +- .../server/domain/ErrorCodeEntity.java | 2 +- .../server/domain/GatewayAuthTokenEntity.java | 3 +- .../domain/RmExternalResourceProviderEntity.java | 2 +- .../server/domain/UdfManagerEntity.java | 2 +- .../server/domain/UdfTreeEntity.java | 2 +- .../server/service/DatasourceAccessService.java | 3 +- .../server/service/DatasourceEnvService.java | 2 +- .../server/service/DatasourceTypeService.java | 2 +- .../server/service/ErrorCodeService.java | 2 +- .../server/service/GatewayAuthTokenService.java | 3 +- .../service/RmExternalResourceProviderService.java | 3 +- .../server/service/UdfManagerService.java | 2 +- .../server/service/UdfTreeService.java | 2 +- .../service/impl/DatasourceAccessServiceImpl.java | 3 +- .../service/impl/DatasourceEnvServiceImpl.java | 2 +- .../service/impl/DatasourceTypeServiceImpl.java | 2 +- .../server/service/impl/ErrorCodeServiceImpl.java | 2 +- .../service/impl/GatewayAuthTokenServiceImpl.java | 3 +- .../RmExternalResourceProviderServiceImpl.java | 3 +- .../server/service/impl/UdfManagerServiceImpl.java | 2 +- .../server/service/impl/UdfTreeServiceImpl.java | 2 +- .../linkis-bml/linkis-bml-client/pom.xml | 2 +- .../linkis/bml/client/AbstractBmlClient.java | 2 +- .../org/apache/linkis/bml/client/BmlClient.java | 2 +- .../apache/linkis/bml/client/BmlClientFactory.java | 2 +- .../linkis-bml/linkis-bml-common/pom.xml | 2 +- .../apache/linkis/bml/model/AbstractAuditable.java | 2 +- .../apache/linkis/bml/protocol/BmlProtocol.scala | 6 +- .../linkis-bml/linkis-bml-server/pom.xml | 2 +- .../apache/linkis/bml/LinkisBMLApplication.java | 2 +- .../org/apache/linkis/bml/common/Constant.java | 2 +- .../apache/linkis/bml/common/ExecutorManager.java | 2 +- .../linkis/bml/common/HdfsResourceHelper.java | 2 +- .../linkis/bml/common/LocalResourceHelper.java | 2 +- .../apache/linkis/bml/common/OperationEnum.java | 2 +- .../apache/linkis/bml/common/ResourceHelper.java | 2 +- .../linkis/bml/common/ResourceHelperFactory.java | 2 +- .../apache/linkis/bml/common/ScheduledTask.java | 2 +- .../org/apache/linkis/bml/dao/BmlProjectDao.java | 2 +- .../org/apache/linkis/bml/dao/DownloadDao.java | 2 +- .../org/apache/linkis/bml/dao/ResourceDao.java | 2 +- .../java/org/apache/linkis/bml/dao/TaskDao.java | 2 +- .../java/org/apache/linkis/bml/dao/VersionDao.java | 2 +- .../org/apache/linkis/bml/entity/BmlProject.java | 2 +- .../apache/linkis/bml/entity/DownloadModel.java | 2 +- .../org/apache/linkis/bml/entity/Resource.java | 2 +- .../org/apache/linkis/bml/entity/ResourceTask.java | 2 +- .../apache/linkis/bml/entity/ResourceVersion.java | 2 +- .../java/org/apache/linkis/bml/entity/Version.java | 2 +- .../bml/errorcode/BmlServerErrorCodeSummary.java | 2 +- .../apache/linkis/bml/restful/RestfulUtils.java | 2 +- .../linkis/bml/service/BmlProjectService.java | 2 +- .../org/apache/linkis/bml/service/BmlService.java | 2 +- .../bml/service/BmlShareResourceService.java | 2 +- .../apache/linkis/bml/service/DownloadService.java | 2 +- .../apache/linkis/bml/service/ResourceService.java | 2 +- .../org/apache/linkis/bml/service/TaskService.java | 2 +- .../apache/linkis/bml/service/VersionService.java | 2 +- .../bml/service/impl/BmlProjectServiceImpl.java | 2 +- .../linkis/bml/service/impl/BmlServiceImpl.java | 2 +- .../service/impl/BmlShareResourceServiceImpl.java | 2 +- .../bml/service/impl/DownloadServiceImpl.java | 2 +- .../bml/service/impl/ResourceServiceImpl.java | 2 +- .../linkis/bml/service/impl/TaskServiceImpl.java | 2 +- .../bml/service/impl/VersionServiceImpl.java | 2 +- .../org/apache/linkis/bml/threading/Scheduler.java | 2 +- .../java/org/apache/linkis/bml/threading/Task.java | 2 +- .../org/apache/linkis/bml/threading/TaskState.java | 2 +- .../apache/linkis/bml/util/HttpRequestHelper.java | 2 +- .../java/org/apache/linkis/bml/util/MD5Utils.java | 2 +- .../org/apache/linkis/bml/vo/ResourceBasicVO.java | 2 +- .../java/org/apache/linkis/bml/vo/ResourceVO.java | 2 +- .../apache/linkis/bml/vo/ResourceVersionsVO.java | 2 +- .../linkis/bml/common/HdfsResourceHelperTest.java | 2 +- .../linkis/bml/common/LocalResourceHelperTest.java | 2 +- .../linkis/bml/common/VersionServiceImplTest.java | 2 +- .../org/apache/linkis/bml/dao/BaseDaoTest.java | 2 +- .../apache/linkis/bml/dao/BmlProjectDaoTest.java | 2 +- .../org/apache/linkis/bml/dao/DownloadDaoTest.java | 2 +- .../org/apache/linkis/bml/dao/ResourceDaoTest.java | 2 +- .../org/apache/linkis/bml/dao/TaskDaoTest.java | 2 +- .../org/apache/linkis/bml/dao/VersionDaoTest.java | 2 +- linkis-public-enhancements/linkis-bml/pom.xml | 2 +- .../linkis-configuration/pom.xml | 2 +- .../configuration/LinkisConfigurationApp.java | 2 +- .../linkis/configuration/dao/ConfigMapper.java | 2 +- .../linkis/configuration/dao/LabelMapper.java | 2 +- .../linkis/configuration/entity/CategoryLabel.java | 2 +- .../configuration/entity/CategoryLabelVo.java | 2 +- .../linkis/configuration/entity/ConfigKey.java | 2 +- .../configuration/entity/ConfigKeyValue.java | 2 +- .../linkis/configuration/entity/ConfigLabel.java | 2 +- .../linkis/configuration/entity/ConfigTree.java | 2 +- .../linkis/configuration/entity/ConfigValue.java | 2 +- .../LinkisConfigurationErrorCodeSummary.java | 2 +- .../exception/ConfigurationException.java | 2 +- .../configuration/service/ConfigKeyService.java | 2 +- .../service/impl/ConfigKeyServiceImpl.java | 2 +- .../util/ConfigurationConfiguration.java | 2 +- .../configuration/util/LabelEntityParser.java | 8 +- .../linkis/configuration/dao/ConfigMapperTest.java | 17 + .../linkis/configuration/dao/LabelMapperTest.java | 17 + .../exception/ConfigurationExceptionTest.java | 17 + .../restful/api/ConfigurationRestfulApiTest.java | 17 + .../linkis-cs-client/pom.xml | 2 +- .../linkis/cs/client/AbstractContextClient.java | 2 +- .../java/org/apache/linkis/cs/client/Context.java | 2 +- .../org/apache/linkis/cs/client/ContextClient.java | 2 +- .../org/apache/linkis/cs/client/LinkisContext.java | 2 +- .../linkis/cs/client/LinkisWorkFlowContext.java | 2 +- .../cs/client/builder/ContextClientConfig.java | 2 +- .../cs/client/builder/ContextClientFactory.java | 2 +- .../cs/client/builder/HttpContextClientConfig.java | 2 +- .../client/builder/RPCHttpContextClientConfig.java | 2 +- .../client/errorcode/CsClientErrorCodeSummary.java | 2 +- .../cs/client/http/ContextPostActionBuilder.java | 2 +- .../linkis/cs/client/http/HttpContextClient.java | 2 +- .../linkis/cs/client/http/HttpHeartBeater.java | 2 +- .../cs/client/listener/ContextClientEvent.java | 2 +- .../cs/client/listener/ContextClientListener.java | 2 +- .../client/listener/ContextClientListenerBus.java | 2 +- .../listener/ContextClientListenerManager.java | 2 +- .../cs/client/listener/ContextIDListener.java | 2 +- .../cs/client/listener/ContextKeyListener.java | 2 +- .../cs/client/listener/ContextUpdateEvent.java | 2 +- .../linkis/cs/client/listener/HeartBeater.java | 2 +- .../cs/client/service/CSMetaDataService.java | 2 +- .../linkis/cs/client/service/CSNodeService.java | 2 +- .../cs/client/service/CSNodeServiceImpl.java | 2 +- .../cs/client/service/CSResourceService.java | 2 +- .../cs/client/service/CSResultDataService.java | 2 +- .../cs/client/service/CSResultDataServiceImpl.java | 2 +- .../linkis/cs/client/service/CSTableService.java | 2 +- .../cs/client/service/CSVariableService.java | 2 +- .../linkis/cs/client/service/CSWorkService.java | 2 +- .../cs/client/service/CSWorkServiceImpl.java | 2 +- .../service/ContextHistoryClientService.java | 2 +- .../service/ContextHistoryClientServiceImpl.java | 2 +- .../cs/client/service/DefaultSearchService.java | 2 +- .../cs/client/service/LinkisJobDataService.java | 2 +- .../client/service/LinkisJobDataServiceImpl.java | 2 +- .../linkis/cs/client/service/MetaDataService.java | 2 +- .../linkis/cs/client/service/ResourceService.java | 2 +- .../linkis/cs/client/service/SearchService.java | 2 +- .../linkis/cs/client/service/TableService.java | 2 +- .../linkis/cs/client/service/VariableService.java | 2 +- .../cs/client/utils/ContextServiceUtils.java | 2 +- .../linkis/cs/client/utils/ExceptionHelper.java | 2 +- .../linkis/cs/client/utils/SerializeHelper.java | 2 +- .../org/apache/linkis/cs/client/test/Test.java | 2 +- .../cs/client/test/bean/ClientTestContextKey.java | 2 +- .../client/test/bean/ClientTestContextValue.java | 2 +- .../cs/client/test/bean/ResourceValueBean.java | 2 +- .../test/listener/CommonContextKeyListener.java | 2 +- .../client/test/no_context_search/TestClear.java | 2 +- .../cs/client/test/restful/ListenerTest.java | 2 +- .../linkis/cs/client/test/restful/RestfulTest.java | 2 +- .../linkis/cs/client/test/service/TestInfo.java | 2 +- .../linkis/cs/client/test/service/TestRemove.java | 2 +- .../cs/client/test/service/TestSearchService.java | 2 +- .../test/test_multiuser/TestChangeContext.java | 2 +- .../test/test_multiuser/TestCreateContext.java | 2 +- .../linkis-cs-common/pom.xml | 2 +- .../linkis/cs/common/annotation/KeywordMethod.java | 2 +- .../linkis/cs/common/entity/data/CSResultData.java | 2 +- .../apache/linkis/cs/common/entity/data/Data.java | 2 +- .../linkis/cs/common/entity/data/JobData.java | 2 +- .../cs/common/entity/data/LinkisJobData.java | 2 +- .../cs/common/entity/enumeration/ContextScope.java | 2 +- .../cs/common/entity/enumeration/ContextType.java | 2 +- .../cs/common/entity/enumeration/DBType.java | 2 +- .../cs/common/entity/enumeration/ExpireType.java | 2 +- .../cs/common/entity/enumeration/WorkType.java | 2 +- .../apache/linkis/cs/common/entity/env/Env.java | 2 +- .../apache/linkis/cs/common/entity/env/OSEnv.java | 2 +- .../linkis/cs/common/entity/env/SoftWareEnv.java | 2 +- .../cs/common/entity/env/SoftwareLibEnv.java | 2 +- .../entity/history/AbstractContextHistory.java | 2 +- .../entity/history/CommonResourceHistory.java | 2 +- .../cs/common/entity/history/ContextHistory.java | 2 +- .../entity/history/ContextHistoryIndexer.java | 2 +- .../common/entity/history/EnvContextHistory.java | 2 +- .../history/GlobalPropertyContextHistory.java | 2 +- .../entity/history/KeywordContextHistroy.java | 2 +- .../entity/history/ResourceContextHistory.java | 2 +- .../history/metadata/CSTableLineageHistory.java | 2 +- .../metadata/CSTableMetadataContextHistory.java | 2 +- .../history/metadata/DBMetadataContextHistory.java | 2 +- .../history/metadata/MetadataContextHistory.java | 2 +- .../history/metadata/TableLineageHistory.java | 2 +- .../history/metadata/TableOperationType.java | 2 +- .../listener/CommonContextIDListenerDomain.java | 2 +- .../listener/CommonContextKeyListenerDomain.java | 2 +- .../entity/listener/ContextIDListenerDomain.java | 2 +- .../entity/listener/ContextKeyListenerDomain.java | 2 +- .../cs/common/entity/listener/ListenerDomain.java | 2 +- .../linkis/cs/common/entity/metadata/CSColumn.java | 2 +- .../linkis/cs/common/entity/metadata/CSDB.java | 2 +- .../cs/common/entity/metadata/CSPartition.java | 2 +- .../linkis/cs/common/entity/metadata/CSTable.java | 2 +- .../linkis/cs/common/entity/metadata/Column.java | 2 +- .../linkis/cs/common/entity/metadata/DB.java | 2 +- .../cs/common/entity/metadata/Partition.java | 2 +- .../linkis/cs/common/entity/metadata/Table.java | 2 +- .../cs/common/entity/object/CSFlowInfos.java | 2 +- .../linkis/cs/common/entity/object/CSInfos.java | 2 +- .../linkis/cs/common/entity/object/CSProperty.java | 2 +- .../entity/object/CommonGlobalConfiguration.java | 2 +- .../cs/common/entity/object/CommonProperty.java | 2 +- .../cs/common/entity/object/LinkisVariable.java | 2 +- .../cs/common/entity/resource/BMLResource.java | 2 +- .../common/entity/resource/CommonFxResource.java | 2 +- .../common/entity/resource/CommonUDFResource.java | 2 +- .../cs/common/entity/resource/FxResource.java | 2 +- .../common/entity/resource/LinkisBMLResource.java | 2 +- .../linkis/cs/common/entity/resource/Resource.java | 2 +- .../cs/common/entity/resource/UDFResource.java | 2 +- .../entity/source/CombinedNodeIDContextID.java | 2 +- .../cs/common/entity/source/CommonContextID.java | 2 +- .../cs/common/entity/source/CommonContextKey.java | 2 +- .../entity/source/CommonContextKeyValue.java | 2 +- .../common/entity/source/CommonContextValue.java | 2 +- .../cs/common/entity/source/CommonHAContextID.java | 2 +- .../linkis/cs/common/entity/source/ContextID.java | 2 +- .../cs/common/entity/source/ContextIDParser.java | 2 +- .../linkis/cs/common/entity/source/ContextKey.java | 2 +- .../cs/common/entity/source/ContextKeyValue.java | 2 +- .../cs/common/entity/source/ContextValue.java | 2 +- .../cs/common/entity/source/CreatorContextKey.java | 2 +- .../cs/common/entity/source/HAContextID.java | 2 +- .../entity/source/LinkisHAWorkFlowContextID.java | 2 +- .../entity/source/LinkisWorkflowContextID.java | 2 +- .../cs/common/entity/source/OrderContextKey.java | 2 +- .../linkis/cs/common/entity/source/Source.java | 2 +- .../cs/common/entity/source/UserContextID.java | 2 +- .../linkis/cs/common/entity/source/ValueBean.java | 2 +- .../cs/common/entity/source/VersionContextKey.java | 2 +- .../cs/common/entity/source/WorkflowContextID.java | 2 +- .../cs/common/entity/source/YMLContextKey.java | 2 +- .../cs/common/exception/CSErrorException.java | 2 +- .../cs/common/exception/CSWarnException.java | 2 +- .../linkis/cs/common/exception/ErrorCode.java | 2 +- .../cs/common/listener/ContextIDListener.java | 2 +- .../cs/common/listener/ContextKeyListener.java | 2 +- .../cs/common/protocol/ContextHTTPConstant.java | 2 +- .../cs/common/protocol/ContextHistoryType.java | 2 +- .../linkis/cs/common/protocol/ContextIDType.java | 2 +- .../linkis/cs/common/protocol/ContextKeyType.java | 2 +- .../cs/common/protocol/ContextKeyValueType.java | 2 +- .../cs/common/protocol/ContextValueType.java | 2 +- .../search/ContextSearchConditionMapBuilder.java | 2 +- .../cs/common/serialize/AbstractSerializer.java | 2 +- .../cs/common/serialize/ContextSerializer.java | 2 +- .../helper/AbstractSerializationHelper.java | 2 +- .../helper/ContextSerializationHelper.java | 2 +- .../serialize/helper/SerializationHelper.java | 2 +- .../context/CombinedNodeIDContextIDSerializer.java | 2 +- .../impl/context/CommonContextKeySerializer.java | 2 +- .../impl/context/ContextKeyValueSerializer.java | 2 +- .../impl/context/ContextValueSerializer.java | 2 +- .../LinkisHAWorkFlowContextIDSerializer.java | 2 +- .../impl/history/CommonHistorySerializer.java | 2 +- .../history/CommonResourceHistorySerializer.java | 2 +- .../history/metadata/CSTableLineageSerializer.java | 2 +- .../metadata/CSTableMetadataHistorySerializer.java | 2 +- .../impl/value/LinkisBMLResourceSerializer.java | 2 +- .../impl/value/data/CSResultDataSerializer.java | 2 +- .../impl/value/data/LinkisJobDataSerializer.java | 2 +- .../impl/value/metadata/CSTableSerializer.java | 2 +- .../impl/value/object/CSFlowInfosSerializer.java | 2 +- .../value/object/LinkisVariableSerializer.java | 2 +- .../linkis/cs/common/utils/CSCommonUtils.java | 2 +- .../cs/common/utils/CSHighAvailableUtils.java | 2 +- .../test/ContextSerializationHelperTest.java | 2 +- .../linkis-cs-listener/pom.xml | 2 +- .../apache/linkis/cs/listener/CSIDListener.java | 2 +- .../apache/linkis/cs/listener/CSKeyListener.java | 2 +- .../cs/listener/ContextAsyncEventListener.java | 2 +- .../ListenerBus/ContextAsyncListenerBus.java | 2 +- .../listener/callback/AbstractCallbackEngine.java | 2 +- .../cs/listener/callback/CallbackEngine.java | 2 +- .../listener/callback/ContextIDCallbackEngine.java | 2 +- .../callback/ContextKeyCallbackEngine.java | 2 +- .../cs/listener/callback/imp/ClientSource.java | 60 -- .../listener/callback/imp/ContextKeyValueBean.java | 2 +- .../imp/DefaultContextIDCallbackEngine.java | 2 +- .../imp/DefaultContextKeyCallbackEngine.java | 2 +- .../cs/listener/conf/ContextListenerConf.java | 2 +- .../linkis/cs/listener/event/ContextIDEvent.java | 2 +- .../linkis/cs/listener/event/ContextKeyEvent.java | 2 +- .../cs/listener/event/enumeration/OperateType.java | 2 +- .../listener/event/impl/DefaultContextIDEvent.java | 2 +- .../event/impl/DefaultContextKeyEvent.java | 2 +- .../cs/listener/manager/ListenerManager.java | 2 +- .../manager/imp/DefaultContextListenerManager.java | 2 +- .../linkis/cs/listener/test/TestContextID.java | 2 +- .../linkis/cs/listener/test/TestContextKey.java | 2 +- .../cs/listener/test/TestContextKeyValue.java | 2 +- .../linkis/cs/listener/test/TestContextValue.java | 2 +- .../linkis-cs-server/pom.xml | 2 +- .../java/org/apache/linkis/cs/ContextSearch.java | 2 +- .../org/apache/linkis/cs/DefaultContextSearch.java | 2 +- .../cs/condition/AbstractCommonCondition.java | 2 +- .../linkis/cs/condition/AtomicCondition.java | 2 +- .../linkis/cs/condition/BinaryLogicCondition.java | 2 +- .../org/apache/linkis/cs/condition/Condition.java | 2 +- .../apache/linkis/cs/condition/ConditionType.java | 2 +- .../linkis/cs/condition/UnaryLogicCondition.java | 2 +- .../condition/construction/AndConditionParser.java | 2 +- .../condition/construction/ConditionBuilder.java | 2 +- .../construction/ConditionBuilderImpl.java | 2 +- .../cs/condition/construction/ConditionParser.java | 2 +- .../construction/ContainsConditionParser.java | 2 +- .../construction/ContextScopeConditionParser.java | 2 +- .../construction/ContextTypeConditionParser.java | 2 +- .../ContextValueTypeConditionParser.java | 2 +- .../construction/NearestConditionParser.java | 2 +- .../condition/construction/NotConditionParser.java | 2 +- .../condition/construction/OrConditionParser.java | 2 +- .../construction/RegexConditionParser.java | 2 +- .../linkis/cs/condition/impl/AndCondition.java | 2 +- .../cs/condition/impl/ContainsCondition.java | 2 +- .../cs/condition/impl/ContextScopeCondition.java | 2 +- .../cs/condition/impl/ContextTypeCondition.java | 2 +- .../condition/impl/ContextValueTypeCondition.java | 2 +- .../linkis/cs/condition/impl/NearestCondition.java | 2 +- .../linkis/cs/condition/impl/NotCondition.java | 2 +- .../linkis/cs/condition/impl/OrCondition.java | 2 +- .../linkis/cs/condition/impl/RegexCondition.java | 2 +- .../cs/contextcache/ContextCacheService.java | 2 +- .../contextcache/DefaultContextCacheService.java | 2 +- .../linkis/cs/contextcache/cache/ContextCache.java | 2 +- .../cache/DefaultContextAddListener.java | 2 +- .../cs/contextcache/cache/DefaultContextCache.java | 2 +- .../cs/contextcache/cache/csid/ContextIDValue.java | 2 +- .../cache/csid/ContextIDValueGenerator.java | 2 +- .../csid/impl/ContextIDValueGeneratorImpl.java | 2 +- .../cache/csid/impl/ContextIDValueImpl.java | 2 +- .../cache/cskey/ContextKeyValueContext.java | 2 +- .../cache/cskey/ContextValueMapSet.java | 2 +- .../cache/cskey/impl/ContextValueMapSetImpl.java | 2 +- .../cskey/impl/DefaultContextKeyValueContext.java | 2 +- .../cache/guava/ContextIDRemoveListener.java | 2 +- .../cs/contextcache/cleaner/AUTOCleaner.java | 2 +- .../cs/contextcache/conf/ContextCacheConf.java | 2 +- .../contextcache/index/ContextInvertedIndex.java | 2 +- .../index/ContextInvertedIndexSet.java | 2 +- .../index/ContextInvertedIndexSetImpl.java | 2 +- .../index/DefaultContextInvertedIndex.java | 2 +- .../cs/contextcache/metric/ContextCacheMetric.java | 2 +- .../cs/contextcache/metric/ContextIDMetric.java | 2 +- .../metric/DefaultContextCacheMetric.java | 2 +- .../metric/DefaultContextIDMetric.java | 2 +- .../linkis/cs/contextcache/metric/Metrtic.java | 2 +- .../linkis/cs/contextcache/metric/ObjectInfo.java | 2 +- .../cs/contextcache/metric/SizeEstimator.java | 2 +- .../contextcache/parser/ContextKeyValueParser.java | 2 +- .../parser/DefaultContextKeyValueParser.java | 2 +- .../cs/contextcache/utils/ContextCacheUtils.java | 2 +- .../errorcode/LinkisCsServerErrorCodeSummary.java | 2 +- .../cs/exception/ContextSearchFailedException.java | 2 +- .../cs/execution/AbstractConditionExecution.java | 2 +- .../linkis/cs/execution/ConditionExecution.java | 2 +- .../fetcher/AbstractContextCacheFetcher.java | 2 +- .../cs/execution/fetcher/ContextCacheFetcher.java | 2 +- .../fetcher/ContextTypeContextSearchFetcher.java | 2 +- .../fetcher/IterateContextCacheFetcher.java | 2 +- .../cs/execution/impl/AndConditionExecution.java | 2 +- .../impl/BinaryLogicConditionExecution.java | 2 +- .../execution/impl/ContainsConditionExecution.java | 2 +- .../impl/ContextScopeConditionExecution.java | 2 +- .../impl/ContextTypeConditionExecution.java | 2 +- .../impl/ContextValueTypeConditionExecution.java | 2 +- .../execution/impl/NearestConditionExecution.java | 2 +- .../cs/execution/impl/NotConditionExecution.java | 2 +- .../cs/execution/impl/OrConditionExecution.java | 2 +- .../cs/execution/impl/RegexConditionExecution.java | 2 +- .../impl/UnaryLogicConditionExecution.java | 2 +- .../matcher/AbstractContextSearchMatcher.java | 2 +- .../matcher/AndLogicContextSearchMatcher.java | 2 +- .../matcher/BinaryLogicContextSearchMatcher.java | 2 +- .../matcher/ConditionMatcherResolver.java | 2 +- .../matcher/ContainsContextSearchMatcher.java | 2 +- .../matcher/ContextScopeContextSearchMatcher.java | 2 +- .../cs/execution/matcher/ContextSearchMatcher.java | 2 +- .../matcher/ContextTypeContextSearchMatcher.java | 2 +- .../ContextValueTypeContextSearchMatcher.java | 2 +- .../matcher/NearestLogicContextSearchMatcher.java | 2 +- .../matcher/NotLogicContextSearchMatcher.java | 2 +- .../matcher/OrLogicContextSearchMatcher.java | 2 +- .../matcher/RegexContextSearchMatcher.java | 2 +- .../execution/matcher/SkipContextSearchMather.java | 2 +- .../matcher/UnaryLogicContextSearchMatcher.java | 2 +- .../ruler/AbstractContextSearchRuler.java | 2 +- .../ruler/CommonListContextSearchRuler.java | 2 +- .../cs/execution/ruler/ContextSearchRuler.java | 2 +- .../execution/ruler/NearestContextSearchRuler.java | 2 +- .../cs/highavailable/AbstractContextHAManager.java | 2 +- .../linkis/cs/highavailable/ContextHAManager.java | 2 +- .../cs/highavailable/DefaultContextHAManager.java | 2 +- .../conf/ContextHighAvailableConf.java | 2 +- .../cs/highavailable/exception/CSErrorCode.java | 2 +- .../highavailable/ha/BackupInstanceGenerator.java | 2 +- .../cs/highavailable/ha/ContextHAChecker.java | 2 +- .../cs/highavailable/ha/ContextHAIDGenerator.java | 2 +- .../ha/impl/BackupInstanceGeneratorImpl.java | 2 +- .../ha/impl/ContextHACheckerImpl.java | 2 +- .../ha/impl/ContextHAIDGeneratorImpl.java | 2 +- .../pluggable/HAContextPersistenceManagerImpl.java | 2 +- .../highavailable/proxy/MethodInterceptorImpl.java | 2 +- .../linkis/cs/optimize/ConditionOptimizer.java | 2 +- .../linkis/cs/optimize/OptimizedCondition.java | 2 +- .../cs/optimize/cost/ConditionCostCalculator.java | 2 +- .../apache/linkis/cs/optimize/dfs/BinaryTree.java | 2 +- .../linkis/cs/optimize/dfs/MinCostBinaryTree.java | 2 +- .../org/apache/linkis/cs/optimize/dfs/Node.java | 2 +- .../optimize/impl/CostBasedConditionOptimizer.java | 2 +- .../cs/persistence/ContextPersistenceBeans.java | 2 +- .../cs/persistence/ContextPersistenceManager.java | 2 +- .../persistence/ContextPersistenceManagerImpl.java | 2 +- .../linkis/cs/persistence/annotation/Ignore.java | 2 +- .../linkis/cs/persistence/annotation/Tuning.java | 2 +- .../persistence/aop/PersistenceTuningAspect.java | 2 +- .../cs/persistence/conf/PersistenceConf.java | 2 +- .../cs/persistence/dao/ContextHistoryMapper.java | 2 +- .../persistence/dao/ContextIDListenerMapper.java | 2 +- .../linkis/cs/persistence/dao/ContextIDMapper.java | 2 +- .../persistence/dao/ContextKeyListenerMapper.java | 2 +- .../cs/persistence/dao/ContextMapMapper.java | 2 +- .../cs/persistence/entity/ExtraFieldClass.java | 2 +- .../entity/PersistenceContextHistory.java | 2 +- .../persistence/entity/PersistenceContextID.java | 2 +- .../entity/PersistenceContextIDListener.java | 2 +- .../persistence/entity/PersistenceContextKey.java | 2 +- .../entity/PersistenceContextKeyListener.java | 2 +- .../entity/PersistenceContextKeyValue.java | 2 +- .../entity/PersistenceContextValue.java | 2 +- .../cs/persistence/exception/ThrowingFunction.java | 2 +- .../persistence/ContextHistoryPersistence.java | 2 +- .../persistence/ContextIDListenerPersistence.java | 2 +- .../persistence/ContextIDPersistence.java | 2 +- .../persistence/ContextKeyListenerPersistence.java | 2 +- .../persistence/ContextMapPersistence.java | 2 +- .../persistence/ContextMetricsPersistence.java | 2 +- .../KeywordContextHistoryPersistence.java | 2 +- .../persistence/TransactionManager.java | 2 +- .../impl/ContextHistoryPersistenceImpl.java | 2 +- .../impl/ContextIDListenerPersistenceImpl.java | 2 +- .../persistence/impl/ContextIDPersistenceImpl.java | 2 +- .../impl/ContextKeyListenerPersistenceImpl.java | 2 +- .../impl/ContextMapPersistenceImpl.java | 2 +- .../impl/ContextMetricsPersistenceImpl.java | 2 +- .../impl/KeywordContextHistoryPersistenceImpl.java | 2 +- .../persistence/impl/TransactionManagerImpl.java | 2 +- .../cs/persistence/util/PersistenceUtils.java | 2 +- .../linkis/cs/server/LinkisCSApplication.java | 2 +- .../linkis/cs/server/conf/ContextServerConf.java | 2 +- .../cs/server/enumeration/ServiceMethod.java | 2 +- .../linkis/cs/server/enumeration/ServiceType.java | 2 +- .../cs/server/parser/DefaultKeywordParser.java | 2 +- .../cs/server/parser/KeywordMethodEntity.java | 2 +- .../linkis/cs/server/parser/KeywordParser.java | 2 +- .../protocol/AbstractHttpRequestProtocol.java | 2 +- .../cs/server/protocol/ContextHistoryProtocol.java | 2 +- .../cs/server/protocol/ContextIDProtocol.java | 2 +- .../server/protocol/ContextListenerProtocol.java | 2 +- .../linkis/cs/server/protocol/ContextProtocol.java | 2 +- .../linkis/cs/server/protocol/HttpProtocol.java | 2 +- .../cs/server/protocol/HttpRequestProtocol.java | 2 +- .../cs/server/protocol/HttpResponseProtocol.java | 2 +- .../cs/server/protocol/RestResponseProtocol.java | 2 +- .../linkis/cs/server/restful/CsRestfulParent.java | 2 +- .../linkis/cs/server/scheduler/CsScheduler.java | 2 +- .../cs/server/scheduler/DefaultCsScheduler.java | 2 +- .../linkis/cs/server/scheduler/HttpAnswerJob.java | 2 +- .../cs/server/scheduler/HttpAnswerJobBuilder.java | 2 +- .../apache/linkis/cs/server/scheduler/HttpJob.java | 2 +- .../linkis/cs/server/scheduler/HttpJobBuilder.java | 2 +- .../cs/server/scheduler/HttpPriorityJob.java | 2 +- .../linkis/cs/server/scheduler/RestJobBuilder.java | 2 +- .../cs/server/scheduler/impl/CsExecuteRequest.java | 2 +- .../scheduler/impl/CsExecutorExecutionManager.java | 2 +- .../cs/server/scheduler/impl/CsJobListener.java | 2 +- .../cs/server/scheduler/impl/CsSchedulerBean.java | 2 +- .../cs/server/scheduler/impl/CsSchedulerJob.java | 2 +- .../impl/JobToExecuteRequestConsumer.java | 2 +- .../linkis/cs/server/service/AbstractService.java | 2 +- .../cs/server/service/ContextHistoryService.java | 2 +- .../linkis/cs/server/service/ContextIDService.java | 2 +- .../cs/server/service/ContextListenerService.java | 2 +- .../linkis/cs/server/service/ContextService.java | 2 +- .../apache/linkis/cs/server/service/Service.java | 2 +- .../service/impl/ContextHistoryServiceImpl.java | 2 +- .../server/service/impl/ContextIDServiceImpl.java | 2 +- .../service/impl/ContextListenerServiceImpl.java | 2 +- .../cs/server/service/impl/ContextServiceImpl.java | 2 +- .../org/apache/linkis/cs/server/util/CsUtils.java | 2 +- .../test/java/org/apache/linkis/cs/AndTest.java | 2 +- .../java/org/apache/linkis/cs/ContainsTest.java | 2 +- .../org/apache/linkis/cs/ContextScopeTest.java | 2 +- .../org/apache/linkis/cs/ContextSearchTest.java | 2 +- .../java/org/apache/linkis/cs/ContextTypeTest.java | 2 +- .../test/java/org/apache/linkis/cs/RegexTest.java | 2 +- .../cs/contextcache/test/csid/TestContextID.java | 2 +- .../contextcache/test/keyword/TestContextKey.java | 2 +- .../test/keyword/TestContextKeyValue.java | 2 +- .../test/keyword/TestContextKeyValueParser.java | 2 +- .../test/keyword/TestContextValue.java | 2 +- .../test/service/TestContextCacheService.java | 2 +- .../org/apache/linkis/cs/csid/TestContextID.java | 2 +- .../LinkisCsServerErrorCodeSummaryTest.java | 2 +- .../ContextSearchFailedExceptionTest.java | 2 +- .../highavailable/test/TestContextHAManager.java | 2 +- .../cs/highavailable/test/haid/TestHAID.java | 2 +- .../test/persist/TestPersistence.java | 2 +- .../apache/linkis/cs/keyword/TestContextKey.java | 2 +- .../linkis/cs/keyword/TestContextKeyValue.java | 2 +- .../apache/linkis/cs/keyword/TestContextValue.java | 2 +- .../org/apache/linkis/cs/parser/ApiJsonTest.java | 2 +- .../linkis/cs/persistence/AContextHistory.java | 2 +- .../apache/linkis/cs/persistence/AContextID.java | 2 +- .../linkis/cs/persistence/AContextIDListener.java | 2 +- .../apache/linkis/cs/persistence/AContextKey.java | 2 +- .../linkis/cs/persistence/AContextKeyListener.java | 2 +- .../linkis/cs/persistence/AContextKeyValue.java | 2 +- .../linkis/cs/persistence/AContextValue.java | 2 +- .../linkis/cs/persistence/ContextHistoryTest.java | 2 +- .../cs/persistence/ContextIDListenerTest.java | 2 +- .../linkis/cs/persistence/ContextIDTest.java | 2 +- .../cs/persistence/ContextKeyListenerTest.java | 2 +- .../linkis/cs/persistence/ContextMapTest.java | 2 +- .../linkis/cs/persistence/ExtraFieldClassTest.java | 2 +- .../linkis/cs/persistence/MapTypeAdapter.java | 2 +- .../apache/linkis/cs/persistence/ProxyMethodA.java | 2 +- .../apache/linkis/cs/persistence/ProxyTest.java | 2 +- .../org/apache/linkis/cs/persistence/Scan.java | 2 +- .../cs/persistence/conf/PersistenceConfTest.java | 2 +- .../persistence/dao/ContextHistoryMapperTest.java | 2 +- .../dao/ContextIDListenerMapperTest.java | 2 +- .../cs/persistence/dao/ContextIDMapperTest.java | 2 +- .../dao/ContextKeyListenerMapperTest.java | 2 +- .../cs/persistence/utils/PersistenceUtilsTest.java | 2 +- .../linkis/cs/server/ContextHistoryRestfulApi.java | 2 +- .../linkis/cs/server/ContextIDRestfulApi.java | 2 +- .../cs/server/ContextListenerRestfulApi.java | 2 +- .../apache/linkis/cs/server/ContextRestfulApi.java | 2 +- .../apache/linkis/cs/server/CsRestfulParent.java | 2 +- .../java/org/apache/linkis/cs/server/Scan.java | 2 +- .../org/apache/linkis/cs/server/SchedulerTest.java | 2 +- .../cs/server/conf/ContextServerConfTest.java | 2 +- .../linkis-context-service/pom.xml | 2 +- .../linkis-datasource-client/pom.xml | 2 +- .../DatasourceClientErrorCodeSummary.java | 2 +- .../linkis-datasource-manager/common/pom.xml | 2 +- .../datasourcemanager/common/DataSources.java | 2 +- .../datasourcemanager/common/ServiceErrorCode.java | 2 +- .../datasourcemanager/common/auth/AuthContext.java | 2 +- .../common/domain/DataSource.java | 2 +- .../common/domain/DataSourceEnv.java | 2 +- .../domain/DataSourceParamKeyDefinition.java | 2 +- .../common/domain/DataSourceParameter.java | 2 +- .../common/domain/DataSourceType.java | 2 +- .../common/domain/DatasourceVersion.java | 2 +- .../LinkisDatasourceManagerErrorCodeSummary.java | 2 +- .../common/exception/JsonErrorException.java | 2 +- .../datasourcemanager/common/util/CryptoUtils.java | 2 +- .../common/util/PatternInjectUtils.java | 2 +- .../datasourcemanager/common/util/json/Json.java | 2 +- .../linkis-datasource-manager/server/pom.xml | 2 +- .../core/LinkisDataSourceManagerApplication.java | 2 +- .../datasourcemanager/core/dao/DataSourceDao.java | 10 +- .../core/dao/DataSourceEnvDao.java | 2 +- .../core/dao/DataSourceParamKeyDao.java | 2 +- .../core/dao/DataSourceTypeDao.java | 2 +- .../core/dao/DataSourceVersionDao.java | 2 +- .../core/dao/mapper/DataSouceMapper.xml | 16 + .../CustomMultiPartFormDataTransformer.java | 2 +- .../core/formdata/FormDataTransformerFactory.java | 2 +- .../core/formdata/FormStreamContent.java | 2 +- .../formdata/MultiPartFormDataTransformer.java | 2 +- .../core/restful/DataSourceAdminRestfulApi.java | 28 +- .../core/restful/DataSourceCoreRestfulApi.java | 39 +- .../core/restful/RestfulApiHelper.java | 2 +- .../exception/BeanValidationExceptionMapper.java | 2 +- .../core/service/BmlAppService.java | 2 +- .../core/service/DataSourceInfoService.java | 10 +- .../core/service/DataSourceOpService.java | 2 +- .../core/service/DataSourceRelateService.java | 2 +- .../core/service/MetadataOperateService.java | 2 +- .../core/service/hooks/DataSourceParamsHook.java | 2 +- .../service/hooks/DefaultDataSourceParamsHook.java | 2 +- .../core/service/impl/BmlAppServiceImpl.java | 2 +- .../service/impl/DataSourceInfoServiceImpl.java | 8 +- .../service/impl/DataSourceRelateServiceImpl.java | 2 +- .../service/impl/MetadataOperateServiceImpl.java | 2 +- .../validate/DataSourceParameterValidator.java | 2 +- .../core/validate/ParameterValidateException.java | 2 +- .../core/validate/ParameterValidateStrategy.java | 2 +- .../core/validate/ParameterValidator.java | 2 +- .../strategy/RegExpParameterValidateStrategy.java | 2 +- .../strategy/TypeParameterValidateStrategy.java | 2 +- .../datasourcemanager/core/vo/DataSourceEnvVo.java | 2 +- .../datasourcemanager/core/vo/DataSourceVo.java | 2 +- .../datasourcemanager/core/vo/PageViewVo.java | 2 +- .../core/dao/DataSourceDaoTest.java | 14 + .../restful/DataSourceAdminRestfulApiTest.java | 81 +++ .../core/restful/DataSourceCoreRestfulApiTest.java | 25 + .../core/service/DataSourceInfoServiceTest.java | 19 +- .../linkis-metadata-query/common/pom.xml | 2 +- .../metadata/query/common/MdmConfiguration.java | 2 +- .../query/common/cache/CacheConfiguration.java | 4 +- .../metadata/query/common/cache/CacheManager.java | 2 +- .../query/common/cache/ConnCacheManager.java | 2 +- .../query/common/domain/MetaColumnInfo.java | 2 +- .../query/common/domain/MetaPartitionInfo.java | 2 +- .../LinkisMetadataQueryErrorCodeSummary.java | 2 +- .../exception/MetaMethodInvokeException.java | 2 +- .../common/exception/MetaRuntimeException.java | 2 +- .../common/service/AbstractCacheMetaService.java | 2 +- .../common/service/AbstractDbMetaService.java | 2 +- .../common/service/AbstractFsMetaService.java | 2 +- .../query/common/service/BaseMetadataService.java | 2 +- .../query/common/service/MetadataConnection.java | 2 +- .../query/common/service/MetadataDbService.java | 2 +- .../query/common/service/MetadataFsService.java | 3 +- .../query/common/MdmConfigurationTest.java | 2 +- .../query/common/cache/CacheConfigurationTest.java | 2 +- .../query/common/cache/ConnCacheManagerTest.java | 2 +- .../exception/MetaMethodInvokeExceptionTest.java | 2 +- .../common/exception/MetaRuntimeExceptionTest.java | 2 +- .../linkis-metadata-query/server/pom.xml | 2 +- .../server/src/main/assembly/distribution.xml | 15 +- .../server/LinkisMetadataQueryApplication.java | 2 +- .../server/loader/MetaClassLoaderManager.java | 4 +- .../query/server/service/MetadataQueryService.java | 2 +- .../service/impl/MetadataQueryServiceImpl.java | 2 +- .../metadata/query/server/utils/MetadataUtils.java | 2 +- .../server/loader/MetaClassLoaderManagerTest.java | 2 +- .../service/elasticsearch/pom.xml | 2 +- .../metadata/query/service/ElasticConnection.java | 2 +- .../query/service/ElasticParamsMapper.java | 2 +- .../metadata/query/service/EsMetaService.java | 2 +- .../linkis-metadata-query/service/hdfs/pom.xml | 2 +- .../metadata/query/service/HdfsConnection.java | 2 +- .../metadata/query/service/HdfsMetaService.java | 2 +- .../metadata/query/service/HdfsParamsMapper.java | 2 +- .../query/service/conf/ConfigurationUtils.java | 2 +- .../linkis-metadata-query/service/hive/pom.xml | 2 +- .../metadata/query/service/HiveConnection.java | 2 +- .../metadata/query/service/HiveMetaService.java | 2 +- .../metadata/query/service/HiveParamsMapper.java | 2 +- .../service/{mysql => jdbc}/pom.xml | 22 +- .../src/main/assembly/distribution.xml | 0 .../query/service/ClickhouseMetaService.java} | 15 +- .../metadata/query/service/Db2MetaService.java | 2 +- .../metadata/query/service/DmMetaService.java | 2 +- .../metadata/query/service/DorisMetaService.java} | 15 +- .../query/service/GreenplumMetaService.java | 2 +- .../query/service/KingbaseMetaService.java | 2 +- .../metadata/query/service/MysqlMetaService.java | 8 +- .../metadata/query/service/OracleMetaService.java | 7 +- .../query/service/PostgresqlMetaService.java | 2 +- .../query/service/SqlserverMetaService.java | 2 +- .../query/service/clickhouse}/SqlConnection.java | 21 +- .../query/service/conf/SqlParamsMapper.java | 5 +- .../metadata/query/service/db2/SqlConnection.java | 2 +- .../metadata/query/service/dm/SqlConnection.java | 2 +- .../query/service/greenplum/SqlConnection.java | 2 +- .../query/service/kingbase/SqlConnection.java | 2 +- .../query/service/mysql/SqlConnection.java | 11 +- .../query/service/oracle/SqlConnection.java | 32 +- .../query/service/postgres/SqlConnection.java | 2 +- .../query/service/sqlserver/SqlConnection.java | 2 +- .../linkis-metadata-query/service/kafka/pom.xml | 2 +- .../metadata/query/service/KafkaConnection.java | 2 +- .../metadata/query/service/KafkaMetaService.java | 2 +- .../metadata/query/service/KafkaParamsMapper.java | 2 +- .../metadata/query/service/SqlParamsMapper.java | 38 - .../linkis-datasource/linkis-metadata/pom.xml | 2 +- .../metadata/LinkisDataSourceApplication.java | 2 +- .../metadata/condition/DataSourceCondition.java | 2 +- .../org/apache/linkis/metadata/dao/MdqDao.java | 2 +- .../linkis/metadata/domain/AbstractAuditable.java | 2 +- .../org/apache/linkis/metadata/domain/Column.java | 2 +- .../metadata/domain/mdq/DomainCoversionUtils.java | 2 +- .../apache/linkis/metadata/domain/mdq/Tunple.java | 2 +- .../metadata/domain/mdq/bo/ApplicationBO.java | 2 +- .../linkis/metadata/domain/mdq/bo/BaseBO.java | 2 +- .../linkis/metadata/domain/mdq/bo/MdqTableBO.java | 2 +- .../metadata/domain/mdq/bo/MdqTableBaseInfoBO.java | 2 +- .../domain/mdq/bo/MdqTableFieldsInfoBO.java | 2 +- .../domain/mdq/bo/MdqTableImportInfoBO.java | 2 +- .../linkis/metadata/domain/mdq/bo/ModelBO.java | 2 +- .../linkis/metadata/domain/mdq/po/MdqAccess.java | 2 +- .../linkis/metadata/domain/mdq/po/MdqField.java | 2 +- .../linkis/metadata/domain/mdq/po/MdqImport.java | 2 +- .../linkis/metadata/domain/mdq/po/MdqLineage.java | 2 +- .../linkis/metadata/domain/mdq/po/MdqTable.java | 2 +- .../metadata/domain/mdq/po/MdqTableInfo.java | 2 +- .../metadata/domain/mdq/vo/ApplicationVO.java | 2 +- .../linkis/metadata/domain/mdq/vo/BaseVO.java | 2 +- .../metadata/domain/mdq/vo/MdqImportInfoVO.java | 2 +- .../metadata/domain/mdq/vo/MdqTableBaseInfoVO.java | 2 +- .../domain/mdq/vo/MdqTableFieldsInfoVO.java | 2 +- .../mdq/vo/MdqTablePartitionStatisticInfoVO.java | 2 +- .../domain/mdq/vo/MdqTableStatisticInfoVO.java | 2 +- .../linkis/metadata/domain/mdq/vo/MdqTableVO.java | 2 +- .../linkis/metadata/domain/mdq/vo/ModelVO.java | 2 +- .../errorcode/LinkisMetadataErrorCodeSummary.java | 2 +- .../apache/linkis/metadata/hive/config/DSEnum.java | 2 +- .../linkis/metadata/hive/config/DataSource.java | 2 +- .../hive/config/DataSourceContextHolder.java | 2 +- .../metadata/hive/config/DynamicDataSource.java | 2 +- .../metadata/hive/config/LinkisMybatisConfig.java | 2 +- .../metadata/hive/config/MultiSourceExAop.java | 2 +- .../linkis/metadata/hive/dao/HiveMetaDao.java | 2 +- .../metadata/hive/dto/MetadataQueryParam.java | 2 +- .../restful/remote/DataSourceRestfulRemote.java | 2 +- .../linkis/metadata/service/DataSourceService.java | 2 +- .../service/HiveMetaWithPermissionService.java | 3 +- .../apache/linkis/metadata/service/MdqService.java | 2 +- .../service/impl/DataSourceServiceImpl.java | 2 +- .../impl/HiveMetaWithPermissionServiceImpl.java | 3 +- .../metadata/service/impl/MdqServiceImpl.java | 2 +- .../org/apache/linkis/metadata/type/Lifecycle.java | 2 +- .../apache/linkis/metadata/type/MdqImportType.java | 2 +- .../apache/linkis/metadata/type/ModelLevel.java | 2 +- .../apache/linkis/metadata/type/UseWayType.java | 2 +- .../org/apache/linkis/metadata/util/Constants.java | 2 +- .../org/apache/linkis/metadata/util/DWSConfig.java | 2 +- .../org/apache/linkis/metadata/util/HiveUtils.java | 2 +- .../condition/DataSourceConditionTest.java | 2 +- .../LinkisMetadataErrorCodeSummaryTest.java | 2 +- .../linkis/metadata/hive/dao/HiveMetaDaoTest.java | 2 +- .../apache/linkis/metadata/type/LifecycleTest.java | 2 +- .../linkis/metadata/type/ModelLevelTest.java | 2 +- .../linkis/metadata/type/UseWayTypeTest.java | 2 +- .../apache/linkis/metadata/util/ConstantsTest.java | 2 +- .../apache/linkis/metadata/util/DWSConfigTest.java | 2 +- .../apache/linkis/metadata/util/HiveUtilsTest.java | 2 +- .../linkis-datasource/pom.xml | 4 +- .../linkis-error-code-client/pom.xml | 2 +- .../errorcode/client/ClientConfiguration.java | 2 +- .../errorcode/client/ErrorCodeClientBuilder.java | 2 +- .../errorcode/client/LinkisErrorCodeClient.java | 2 +- .../errorcode/client/handler/ErrorCodeHandler.java | 2 +- .../client/handler/ExceptionErrorCodeHandler.java | 2 +- .../client/handler/LinkisErrorCodeFactory.java | 2 +- .../client/handler/LinkisErrorCodeHandler.java | 2 +- .../client/handler/LogErrorCodeHandler.java | 2 +- .../client/handler/LogFileErrorCodeHandler.java | 2 +- .../client/manager/LinkisErrorCodeManager.java | 2 +- .../synchronizer/LinkisErrorCodeSynchronizer.java | 2 +- .../apache/linkis/errorcode/client/utils/Test.java | 2 +- .../errorcode/client/ClientConfigurationTest.java | 2 +- .../client/ErrorCodeClientBuilderTest.java | 2 +- .../client/LinkisErrorCodeClientTest.java | 2 +- .../client/handler/ErrorCodeHandlerTest.java | 2 +- .../client/handler/LinkisErrorCodeHandlerTest.java | 2 +- .../client/manager/LinkisErrorCodeManagerTest.java | 2 +- .../LinkisErrorCodeSynchronizerTest.java | 2 +- .../linkis-error-code-common/pom.xml | 2 +- .../apache/linkis/errorcode/common/CommonConf.java | 2 +- .../linkis/errorcode/common/CommonConfTest.java | 2 +- .../linkis-error-code-server/pom.xml | 2 +- .../linkis/errorcode/server/ErrorCodeServer.java | 2 +- .../errorcode/server/dao/ErrorCodeMapper.java | 2 +- .../server/service/LinkisErrorCodeService.java | 2 +- .../service/impl/LinkisErrorCodeServiceImpl.java | 2 +- .../linkis-error-code/pom.xml | 2 +- .../linkis-instance-label-client/pom.xml | 2 +- .../linkis-instance-label-server/pom.xml | 2 +- .../instance/label/InsLabelAutoConfiguration.java | 2 +- .../instance/label/async/AsyncConsumerQueue.java | 2 +- .../label/async/GenericAsyncConsumerQueue.java | 2 +- .../label/cache/InsLabelCacheConfiguration.java | 2 +- .../linkis/instance/label/conf/InsLabelConf.java | 2 +- .../instance/label/dao/InsLabelRelationDao.java | 2 +- .../linkis/instance/label/dao/InstanceInfoDao.java | 2 +- .../instance/label/dao/InstanceLabelDao.java | 2 +- .../instance/label/entity/InsPersistenceLabel.java | 2 +- .../label/entity/InsPersistenceLabelValue.java | 2 +- .../linkis/instance/label/entity/InstanceInfo.java | 2 +- .../LinkisInstanceLabelErrorCodeSummary.java | 2 +- .../label/exception/InstanceErrorException.java | 2 +- .../label/service/InsLabelAccessService.java | 2 +- .../instance/label/service/InsLabelService.java | 2 +- .../label/service/InsLabelServiceAdapter.java | 2 +- .../label/service/annotation/AdapterMode.java | 2 +- .../label/service/impl/DefaultInsLabelService.java | 48 +- .../impl/DefaultInsLabelServiceAdapter.java | 2 +- .../label/service/impl/EurekaInsLabelService.java | 2 +- .../linkis/instance/label/utils/EntityParser.java | 2 +- .../label/vo/InsPersistenceLabelSearchVo.java | 2 +- .../linkis/instance/label/vo/InstanceInfoVo.java | 2 +- .../service/rpc/DefaultInsLabelRpcService.scala | 6 +- .../linkis-jobhistory/pom.xml | 2 +- .../linkis/jobhistory/LinkisJobHistoryApp.java | 2 +- .../linkis/jobhistory/cache/QueryCacheManager.java | 2 +- .../linkis/jobhistory/cache/QueryCacheService.java | 2 +- .../linkis/jobhistory/cache/domain/TaskResult.java | 2 +- .../cache/impl/DefaultQueryCacheManager.java | 2 +- .../cache/impl/QueryCacheServiceImpl.java | 2 +- .../jobhistory/cache/impl/ScheduledCleanJob.java | 2 +- .../jobhistory/cache/impl/ScheduledRefreshJob.java | 2 +- .../cache/impl/ScheduledRefreshUndoneJob.java | 2 +- .../jobhistory/cache/impl/UserTaskResultCache.java | 2 +- .../linkis/jobhistory/cache/utils/MD5Util.java | 2 +- .../linkis/jobhistory/dao/JobDetailMapper.java | 2 +- .../linkis/jobhistory/dao/JobHistoryMapper.java | 2 +- .../apache/linkis/jobhistory/entity/JobDetail.java | 2 +- .../linkis/jobhistory/entity/JobHistory.java | 2 +- .../apache/linkis/jobhistory/entity/QueryTask.java | 2 +- .../linkis/jobhistory/entity/QueryTaskVO.java | 2 +- .../linkis/jobhistory/transitional/TaskStatus.java | 2 +- .../apache/linkis/jobhistory/util/Constants.java | 2 +- .../impl/JobHistoryDetailQueryServiceImpl.scala | 4 +- .../linkis-ps-common-lock/pom.xml | 2 +- .../common/lock/CommonLockSpringConfiguration.java | 2 +- .../common/lock/dao/CommonLockMapper.java | 2 +- .../common/lock/entity/CommonLock.java | 2 +- .../common/lock/service/CommonLockService.java | 2 +- .../service/impl/DefaultCommonLockService.java | 2 +- .../linkis-storage-script-dev-client/pom.xml | 2 +- .../linkis-storage-script-dev-server/pom.xml | 2 +- .../linkis/filesystem/LinkisPublicServiceApp.java | 2 +- .../filesystem/conf/WorkSpaceConfiguration.java | 2 +- .../filesystem/constant/WorkSpaceConstants.java | 2 +- .../linkis/filesystem/entity/DirFileTree.java | 2 +- .../apache/linkis/filesystem/entity/LogLevel.java | 2 +- .../filesystem/exception/WorkSpaceException.java | 2 +- .../exception/WorkspaceExceptionManager.java | 2 +- .../linkis/filesystem/util/WorkspaceUtil.java | 2 +- .../conf/WorkSpaceConfigurationTest.java | 2 +- .../constant/WorkSpaceConstantsTest.java | 2 +- .../exception/WorkSpaceExceptionTest.java | 2 +- .../exception/WorkspaceExceptionManagerTest.java | 2 +- .../restful/api/BMLFsRestfulApiTest.java | 2 +- .../filesystem/restful/api/FsRestfulApiTest.java | 2 +- .../linkis/filesystem/util/WorkspaceUtilTest.java | 2 +- .../linkis-udf/linkis-udf-client/pom.xml | 2 +- .../linkis-udf/linkis-udf-common/pom.xml | 2 +- .../java/org/apache/linkis/udf/entity/UDFInfo.java | 2 +- .../org/apache/linkis/udf/entity/UDFManager.java | 2 +- .../java/org/apache/linkis/udf/entity/UDFTree.java | 2 +- .../org/apache/linkis/udf/entity/UDFVersion.java | 2 +- .../apache/linkis/udf/excepiton/UDFException.java | 2 +- .../org/apache/linkis/udf/utils/ConstantVar.java | 2 +- .../java/org/apache/linkis/udf/vo/DownloadVo.java | 2 +- .../java/org/apache/linkis/udf/vo/UDFAddVo.java | 2 +- .../java/org/apache/linkis/udf/vo/UDFInfoVo.java | 2 +- .../java/org/apache/linkis/udf/vo/UDFUpdateVo.java | 2 +- .../org/apache/linkis/udf/vo/UDFVersionVo.java | 2 +- .../linkis-udf/linkis-udf-service/pom.xml | 2 +- .../org/apache/linkis/udf/api/UDFRestfulApi.java | 2 +- .../java/org/apache/linkis/udf/dao/UDFDao.java | 2 +- .../java/org/apache/linkis/udf/dao/UDFTreeDao.java | 2 +- .../org/apache/linkis/udf/dao/UDFVersionDao.java | 2 +- .../org/apache/linkis/udf/service/UDFService.java | 2 +- .../apache/linkis/udf/service/UDFTreeService.java | 2 +- .../linkis/udf/service/impl/UDFServiceImpl.java | 2 +- .../udf/service/impl/UDFTreeServiceImpl.java | 2 +- linkis-public-enhancements/linkis-variable/pom.xml | 2 +- .../org/apache/linkis/variable/dao/VarMapper.java | 2 +- .../org/apache/linkis/variable/entity/VarKey.java | 2 +- .../linkis/variable/entity/VarKeyAndValue.java | 2 +- .../apache/linkis/variable/entity/VarKeyUser.java | 2 +- .../linkis/variable/entity/VarKeyValueVO.java | 2 +- .../org/apache/linkis/variable/entity/VarTree.java | 2 +- .../variable/exception/VariableException.java | 2 +- .../linkis/variable/service/VariableService.java | 2 +- .../org/apache/linkis/variable/util/Constants.java | 2 +- .../apache/linkis/variable/dao/VarMapperTest.java | 17 + .../variable/service/VariableServiceTest.java | 17 + linkis-public-enhancements/pom.xml | 2 +- .../linkis-service-discovery/linkis-eureka/pom.xml | 2 +- .../eureka/SpringCloudEurekaApplication.java | 2 +- .../linkis/eureka/conf/EurekaSecurityConfig.java | 2 +- .../linkis-gateway-authentication/pom.xml | 2 +- .../gateway/authentication/dao/TokenDao.java | 2 +- .../gateway/authentication/entity/TokenEntity.java | 2 +- .../LinkisGwAuthenticationErrorCodeSummary.java | 2 +- .../exception/TokenAuthException.java | 2 +- .../exception/TokenNotExistException.java | 2 +- .../gateway/authentication/dao/TokenDaoTest.java | 2 +- .../service/CachedTokenServiceTest.java | 3 +- .../linkis-gateway-core/pom.xml | 2 +- .../LinkisGatewayCoreErrorCodeSummary.java | 2 +- .../linkis/gateway/route/GatewayRouter.scala | 12 +- .../linkis/gateway/security/UserRestful.scala | 7 +- .../linkis-gateway-httpclient-support/pom.xml | 2 +- .../dws/annotation/DWSHttpMessageResult.java | 2 +- .../LinkisGwHttpclientSupportErrorCodeSummary.java | 2 +- .../TokenAuthenticationStrategy.scala | 7 +- .../linkis-gateway-server-support/pom.xml | 2 +- .../ujes/route/DefaultLabelGatewayRouter.scala | 11 +- .../ujes/route/label/RouteLabelParser.scala | 7 +- .../linkis-spring-cloud-gateway/pom.xml | 2 +- .../springcloud/LinkisGatewayApplication.java | 2 +- .../errorcode/GatewayErrorCodeSummary.java | 2 +- .../http/GatewayAuthorizationFilter.java | 2 +- .../springcloud/http/SpringCloudHttpUtils.java | 2 +- .../SpringCloudGatewayWebsocketFilter.java | 2 +- .../websocket/WebSocketServiceConfiguration.java | 2 +- .../websocket/WebsocketGatewaySession.scala | 2 +- .../errorcode}/GatewayErrorCodeSummaryTest.java | 4 +- .../linkis-gateway-datasource-ruler/pom.xml | 2 +- .../linkis-service-gateway/pom.xml | 2 +- linkis-spring-cloud-services/pom.xml | 2 +- linkis-web/.env | 2 +- linkis-web/package.json | 2 +- linkis-web/pom.xml | 2 +- linkis-web/release-docs/LICENSE | 2 + .../release-docs/licenses/LICENSE-ace-builds.txt | 24 + .../{LICENSE => licenses/LICENSE-v-jsoneditor.txt} | 44 -- linkis-web/src/dss/assets/images/Linkis.svg | 15 +- pom.xml | 16 +- tool/dependencies/known-dependencies.txt | 2 + 1797 files changed, 3788 insertions(+), 3124 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
