This is an automated email from the ASF dual-hosted git repository.
casion pushed a change to branch dev-1.3.2
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
from b30064d05 [Feature][linkis-engineplugin-spark] add a new Executor
(json ETL) (#3715)
add 07ce9d2e9 Turn off codecov checking (#3708)
add 7cde96717 fix log splice code bug (#3713)
add 06c660a2c fix: scala error alarm update (#3714)
add 487482086 Fix writer the file is emptied by calling flush after
calling the close method close #3709
add 5d49bf9e5 Merge pull request #3710 from
WeDataSphere/dev-1.3.1-storage-fix
add e73d28b38 [BUG] retain all inRegistry ServiceInstance (#3703) (#3726)
add 155e6b82c Replace background image (#3722)
add a3eb361d3 Return should not be used in anonymous functions, it will
throw ControlThrowable and cause logic processing errors (#3732)
add 15a4b398f Change linkis version from 1.3.0 to 1.3.1 (#3737)
add 001f07a95 Merge dev-1.3.1 into master
add 0b06dd681 feat(linkis-dist): add hadoop version control in install.sh
(#3729)
add 22afe4179 local rpc getResponse NPE (#3747)
add 7b2111be7 Add new interface for Qualitis (#3505)
add 4d1e717e0 fix(linkis-web): supplementary license information (#3749)
add 7c3627be4 [OnceECClient][LinkisManager]Once job client obtains
EngineConn information, it should use ticketId as the unique key (#3741)
add 7e74bb29f update README.md replace badge.svg (#3746)
add e04917a28 refactor: refact some code (#3748)
add 17e39d765 EngineConn idle exit adds the steps to request the
linkismanager service to clean up resources close #3716 (#3740)
add 3d2e31aca [Feature]Optimized the linkis script (#3697)
add 0d9b3c586 [Feature] 1.3.1 linkis metadata query add doris/clickhouse
(#3457)
add 7562e899d [ISSUE-3750]Fix ec history list query results are inaccurate
(#3752)
add deb76087b refactor: refact some code and clear some Scala code format
alarm (#3698)
add f88068387 [feat] add javaCode license check and add autoCode format
when exec mvn package (#3754)
add 4dc4247d2 Performance optimization, remove the synchronization wait
operation of mark cache close #3717 (#3720)
add c53107d33 fix: remove the use of jackson1 (#3757)
add 56b43ef4c [Optimize] replace the reference of EurekaServiceInstance
(#3773)
add 61fd1294e feat: merge linkis-orchestrator-ecm-plugin into
linkis-computation-orchestrator (#3770)
add 7a1689b31 RM resource operation optimization lock bit segment lock
(#3733)
add 28f70adf8 [Optimize] update configuration for Eureka (#3776)
add d4f57a910 fix: update code format (#3782)
add 0b5f6aa77 Merge dev-1.3.1 into master
new 4127826c5 Merge pull request #3784 from apache/master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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 +
.../release-docs/licenses/LICENSE-v-jsoneditor.txt | 0
linkis-web/src/dss/assets/images/Linkis.svg | 15 +-
pom.xml | 16 +-
tool/dependencies/known-dependencies.txt | 2 +
1797 files changed, 3788 insertions(+), 3080 deletions(-)
copy
linkis-public-enhancements/linkis-configuration/src/test/java/org/apache/linkis/configuration/exception/ConfigurationExceptionTest.java
=>
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/exception/RMLockFailedRetryException.java
(74%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/LabelResourceMap.scala
copy
linkis-public-enhancements/linkis-configuration/src/test/java/org/apache/linkis/configuration/exception/ConfigurationExceptionTest.java
=>
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/ResourceOperationType.scala
(80%)
copy
linkis-orchestrator/plugin/linkis-orchestrator-ecm-plugin/src/main/scala/org/apache/linkis/orchestrator/ecm/service/EngineAsyncResponseService.scala
=>
linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/java/org/apache/linkis/manager/util/PersistenceManagerConf.java
(62%)
create mode 100644 linkis-dist/package/sbin/linkis
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/java/org/apache/linkis/orchestrator/ecm/entity/Policy.java
(94%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/ComputationEngineConnManager.scala
(76%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/EngineConnManager.scala
(89%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/EngineConnManagerBuilder.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/LoadBalanceLabelEngineConnManager.scala
(99%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/cache/EngineAsyncResponseCache.scala
(98%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/conf/ECMPluginConf.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/entity/Mark.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/entity/MarkReq.scala
(95%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/exception/ECMPluginErrorException.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/service/EngineAsyncResponseService.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/service/EngineConnExecutor.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/service/TaskExecutionReceiver.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/service/impl/ComputationEngineConnExecutor.scala
(78%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/service/impl/DefaultEngineAsyncResponseService.scala
(100%)
rename linkis-orchestrator/{plugin/linkis-orchestrator-ecm-plugin =>
linkis-computation-orchestrator}/src/main/scala/org/apache/linkis/orchestrator/ecm/utils/ECMPUtils.scala
(100%)
delete mode 100644
linkis-orchestrator/plugin/linkis-orchestrator-ecm-plugin/pom.xml
delete mode 100644
linkis-public-enhancements/linkis-context-service/linkis-cs-listener/src/main/java/org/apache/linkis/cs/listener/callback/imp/ClientSource.java
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=> jdbc}/pom.xml (85%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=> jdbc}/src/main/assembly/distribution.xml (100%)
copy
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql/src/main/java/org/apache/linkis/metadata/query/service/Db2MetaService.java
=>
jdbc/src/main/java/org/apache/linkis/metadata/query/service/ClickhouseMetaService.java}
(88%)
copy
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/Db2MetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/DmMetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql/src/main/java/org/apache/linkis/metadata/query/service/Db2MetaService.java
=>
jdbc/src/main/java/org/apache/linkis/metadata/query/service/DorisMetaService.java}
(88%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/GreenplumMetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/KingbaseMetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/MysqlMetaService.java
(92%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/OracleMetaService.java
(95%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/PostgresqlMetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/SqlserverMetaService.java
(98%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql/src/main/java/org/apache/linkis/metadata/query/service
=>
jdbc/src/main/java/org/apache/linkis/metadata/query/service/clickhouse}/SqlConnection.java
(93%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/conf/SqlParamsMapper.java
(89%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/db2/SqlConnection.java
(99%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/dm/SqlConnection.java
(99%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/greenplum/SqlConnection.java
(99%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/kingbase/SqlConnection.java
(99%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/mysql/SqlConnection.java
(96%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/oracle/SqlConnection.java
(88%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/postgres/SqlConnection.java
(99%)
rename
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/{mysql
=>
jdbc}/src/main/java/org/apache/linkis/metadata/query/service/sqlserver/SqlConnection.java
(99%)
delete mode 100644
linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/mysql/src/main/java/org/apache/linkis/metadata/query/service/SqlParamsMapper.java
rename
linkis-spring-cloud-services/linkis-service-gateway/linkis-spring-cloud-gateway/src/test/java/{
=>
org/apache/linkis/gateway/springcloud/errorcode}/GatewayErrorCodeSummaryTest.java
(96%)
create mode 100644 linkis-web/release-docs/licenses/LICENSE-ace-builds.txt
copy linkis-dist/docker/licenses/LICENSE-flink-1.12.2.txt =>
linkis-web/release-docs/licenses/LICENSE-v-jsoneditor.txt (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
