You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2022/02/11 02:02:36 UTC
[incubator-linkis] 01/01: Merge pull request #1431 from apache/dev-1.1.0-datasource
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit f27699aa6be01d7ee2ae3e544c8fefcef2830b0a
Merge: 2e6b915 c8dd527
Author: peacewong <wp...@gmail.com>
AuthorDate: Fri Feb 11 10:02:28 2022 +0800
Merge pull request #1431 from apache/dev-1.1.0-datasource
Merge the latest code from datasource to master
.github/workflows/build.yml | 8 +-
.mvn/wrapper/MavenWrapperDownloader.java | 117 ++
.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 50710 bytes
.mvn/wrapper/maven-wrapper.properties | 19 +
LICENSE | 1 +
LICENSE-binary | 58 +-
.../assembly-combined/conf/application-linkis.yml | 7 +-
.../conf/linkis-cg-entrance.properties | 2 +-
.../assembly-combined/conf/linkis.properties | 6 +-
.../assembly-combined/conf/log4j2.xml | 5 +-
.../assembly-combined/sbin/ext/linkis-common-start | 6 +-
.../assembly-combined/sbin/ext/linkis-mg-eureka | 6 +-
.../assembly-combined/sbin/ext/linkis-mg-gateway | 7 +-
assembly-combined-package/bin/install.sh | 9 +-
.../deploy-config/linkis-env.sh | 5 +-
licenses-binary/LICENSE-poi-ooxml-schemas.txt | 2 +-
licenses-binary/LICENSE-poi-ooxml.txt | 2 +-
licenses-binary/LICENSE-poi.txt | 2 +-
.../linkis/common/errorcode/ErrorCodeUtils.java | 7 +-
.../errorcode/LinkisCommonsErrorCodeSummary.java | 29 +-
...inkisComputationGovernanceErrorCodeSummary.java | 41 +-
.../LinkisEngineConnErrorCodeSummary.java | 30 +-
.../common/errorcode/LinkisErrorCodeSummary.java | 44 +-
.../errorcode/LinkisExtensionErrorCodeSummary.java | 12 +-
.../errorcode/LinkisFrameErrorCodeSummary.java | 15 +-
.../LinkisPublicEnhancementErrorCodeSummary.java | 12 +-
.../LinkisSpringCloudServiceErrorCodeSummary.java | 15 +-
.../linkis/common/exception/ErrorException.java | 14 +-
.../linkis/common/exception/ExceptionLevel.java | 20 +-
.../linkis/common/exception/ExceptionManager.java | 40 +-
.../linkis/common/exception/FatalException.java | 14 +-
.../exception/LinkisCommonErrorException.java | 12 +-
.../linkis/common/exception/LinkisException.java | 60 +-
.../common/exception/LinkisRetryException.java | 9 +-
.../common/exception/LinkisRuntimeException.java | 51 +-
.../linkis/common/exception/WarnException.java | 14 +-
.../main/java/org/apache/linkis/common/io/Fs.java | 8 +-
.../java/org/apache/linkis/common/io/FsPath.java | 112 +-
.../apache/linkis/common/utils/ByteTimeUtils.java | 592 ++++-----
.../org/apache/linkis/common/utils/DESUtil.java | 40 +-
.../linkis/hadoop/common/utils/KerberosUtils.java | 38 +-
.../apache/linkis/message/annotation/Chain.java | 7 +-
.../apache/linkis/message/annotation/Implicit.java | 10 +-
.../apache/linkis/message/annotation/Method.java | 7 +-
.../linkis/message/annotation/NotImplicit.java | 10 +-
.../apache/linkis/message/annotation/Order.java | 7 +-
.../apache/linkis/message/annotation/Receiver.java | 10 +-
.../linkis/message/builder/DefaultMessageJob.java | 35 +-
.../message/builder/DefaultMessageJobBuilder.java | 8 +-
.../builder/DefaultServiceMethodContext.java | 16 +-
.../org/apache/linkis/message/builder/Future.java | 7 +-
.../apache/linkis/message/builder/MessageJob.java | 9 +-
.../linkis/message/builder/MessageJobBuilder.java | 7 +-
.../linkis/message/builder/MessageJobListener.java | 24 +-
.../message/builder/MessageJobTimeoutPolicy.java | 8 +-
.../message/builder/ServiceMethodContext.java | 10 +-
.../linkis/message/conf/MessageSchedulerConf.java | 50 +-
.../context/AbstractMessageSchedulerContext.java | 8 +-
.../context/DefaultMessageSchedulerContext.java | 16 +-
.../linkis/message/context/MSContextInstance.java | 18 +-
.../message/context/MessageSchedulerContext.java | 8 +-
.../context/SpringMessageSchedulerContext.java | 10 +-
.../message/exception/MessageErrorException.java | 8 +-
.../message/exception/MessageWarnException.java | 8 +-
.../message/parser/DefaultImplicitParser.java | 15 +-
.../message/parser/DefaultServiceParser.java | 34 +-
.../linkis/message/parser/ImplicitMethod.java | 7 +-
.../linkis/message/parser/ImplicitParser.java | 8 +-
.../linkis/message/parser/ServiceMethod.java | 7 +-
.../linkis/message/parser/ServiceParser.java | 10 +-
.../publisher/AbstractMessagePublisher.java | 164 ++-
.../message/publisher/DefaultMessagePublisher.java | 8 +-
.../linkis/message/publisher/MessagePublisher.java | 9 +-
.../message/registry/AbstractImplicitRegistry.java | 37 +-
.../message/registry/AbstractServiceRegistry.java | 28 +-
.../linkis/message/registry/ImplicitRegistry.java | 8 +-
.../linkis/message/registry/ServiceRegistry.java | 8 +-
.../message/registry/SpringImplicitRegistry.java | 18 +-
.../message/registry/SpringServiceRegistry.java | 19 +-
.../message/scheduler/AbstractMessageExecutor.java | 175 ++-
.../message/scheduler/DefaultMessageExecutor.java | 40 +-
.../message/scheduler/DefaultMessageScheduler.java | 33 +-
.../linkis/message/scheduler/MessageExecutor.java | 9 +-
.../scheduler/MessageExecutorExecutionManager.java | 31 +-
.../linkis/message/scheduler/MessageScheduler.java | 8 +-
.../message/scheduler/MethodExecuteWrapper.java | 9 +-
.../message/tx/SpringTransactionManager.java | 9 +-
.../linkis/message/tx/TransactionManager.java | 14 +-
.../apache/linkis/message/utils/MessageUtils.java | 18 +-
.../linkis/message/DefaultRequestProtocol.java | 14 +-
.../apache/linkis/message/ImplicitInterface.java | 14 +-
.../linkis/message/ImplicitInterfaceImpl.java | 13 +-
.../org/apache/linkis/message/ImplicitObject.java | 10 +-
.../linkis/message/SchedulerMessageTest.java | 25 +-
.../org/apache/linkis/message/TestService.java | 24 +-
.../org/apache/linkis/message/TestService2.java | 13 +-
linkis-commons/linkis-module/pom.xml | 9 +
.../apache/linkis/DataWorkCloudApplication.java | 165 +--
.../org/apache/linkis/LinkisBaseServerApp.java | 18 +-
.../apache/linkis/server/utils/AopTargetUtils.java | 27 +-
.../apache/linkis/server/conf/Knife4jConfig.scala | 91 ++
.../apache/linkis/mybatis/DataSourceConfig.java | 48 +-
.../linkis/mybatis/MyBatisMapperScannerConfig.java | 17 +-
.../mybatis/MybatisConfigurationFactory.java | 77 +-
.../linkis/mybatis/conf/MybatisConfiguration.java | 85 +-
.../linkis/protocol/AbstractRetryableProtocol.java | 10 +-
.../linkis/protocol/constants/TaskConstant.java | 8 +-
.../apache/linkis/protocol/engine/EngineInfo.java | 7 +-
.../apache/linkis/protocol/engine/EngineState.java | 19 +-
.../protocol/label/InsLabelAttachRequest.java | 23 +-
.../protocol/label/InsLabelQueryRequest.java | 15 +-
.../protocol/label/InsLabelQueryResponse.java | 9 +-
.../protocol/label/InsLabelRefreshRequest.java | 15 +-
.../protocol/label/InsLabelRemoveRequest.java | 15 +-
.../protocol/label/LabelInsQueryRequest.java | 11 +-
.../protocol/label/LabelInsQueryResponse.java | 8 +-
.../apache/linkis/protocol/label/LabelRequest.java | 10 +-
.../linkis/protocol/label/NodeLabelAddRequest.java | 12 +-
.../protocol/label/NodeLabelRemoveRequest.java | 11 +-
.../linkis/protocol/message/HttpProtocol.java | 11 +-
.../linkis/protocol/message/RequestMethod.java | 8 +-
.../linkis/protocol/message/RequestProtocol.java | 11 +-
.../linkis/protocol/query/QueryProtocol.java | 10 +-
.../linkis/protocol/query/cache/CacheNotFound.java | 9 +-
.../protocol/query/cache/CacheTaskResult.java | 6 +-
.../protocol/query/cache/FailedToDeleteCache.java | 6 +-
.../protocol/query/cache/FailedToWriteCache.java | 7 +-
.../protocol/query/cache/RequestDeleteCache.java | 6 +-
.../protocol/query/cache/RequestReadCache.java | 10 +-
.../protocol/query/cache/RequestWriteCache.java | 13 +-
.../protocol/query/cache/ResponseDeleteCache.java | 9 +-
.../protocol/query/cache/ResponseReadCache.java | 9 +-
.../protocol/query/cache/ResponseWriteCache.java | 9 +-
.../protocol/query/cache/SuccessDeletedCache.java | 9 +-
.../protocol/query/cache/SuccessWriteCache.java | 9 +-
.../linkis/protocol/usercontrol/RequestLogin.java | 10 +-
.../protocol/usercontrol/RequestRegister.java | 9 +-
.../usercontrol/RequestUserListFromWorkspace.java | 9 +-
.../protocol/usercontrol/RequestUserWorkspace.java | 11 +-
.../linkis/protocol/usercontrol/ResponseLogin.java | 7 +-
.../protocol/usercontrol/ResponseRegister.java | 9 +-
.../usercontrol/ResponseUserWorkspace.java | 11 +-
.../usercontrol/ResponseWorkspaceUserList.java | 7 +-
.../usercontrol/UserControlLoginProtocol.java | 10 +-
.../usercontrol/UserControlRegtisterProtocol.java | 10 +-
.../apache/linkis/protocol/util/ImmutablePair.java | 10 +-
.../apache/linkis/rpc/serializer/NoneDelegate.java | 11 +-
.../rpc/serializer/ProtostuffSerializeUtil.java | 35 +-
linkis-commons/linkis-storage/pom.xml | 12 +-
.../linkis/storage/domain/FsPathListWithError.java | 13 +-
.../linkis/storage/excel/ExcelStorageReader.java | 23 +-
.../org/apache/linkis/storage/excel/XlsUtils.java | 31 +-
.../org/apache/linkis/storage/excel/XlsxUtils.java | 91 +-
.../storage/exception/FSNotInitException.java | 9 +-
.../linkis/storage/exception/StorageErrorCode.java | 21 +-
.../storage/exception/StorageErrorException.java | 14 +-
.../storage/exception/StorageFatalException.java | 17 +-
.../storage/exception/StorageWarnException.java | 15 +-
.../linkis/storage/factory/BuildFactory.java | 7 +-
.../storage/factory/impl/BuildHDFSFileSystem.java | 20 +-
.../storage/factory/impl/BuildLocalFileSystem.java | 18 +-
.../org/apache/linkis/storage/fs/FileSystem.java | 29 +-
.../linkis/storage/fs/impl/HDFSFileSystem.java | 70 +-
.../linkis/storage/fs/impl/LocalFileSystem.java | 186 +--
.../storage/pipeline/DefaultPipelineFactory.java | 10 +-
.../linkis/storage/pipeline/PipelineReader.java | 19 +-
.../linkis/storage/pipeline/PipelineWriter.java | 12 +-
.../cli/application/LinkisClientApplication.java | 277 +++--
.../cli/application/constants/AppConstants.java | 19 +-
.../application/constants/LinkisClientKeys.java | 86 +-
.../cli/application/constants/LinkisConstants.java | 8 +-
.../cli/application/constants/LinkisKeys.java | 12 +-
.../constants/UjesClientDriverConstants.java | 12 +-
.../linkis/cli/application/data/FinishedData.java | 8 +-
.../linkis/cli/application/data/PreparedData.java | 11 +-
.../linkis/cli/application/data/ProcessedData.java | 13 +-
.../cli/application/driver/LinkisClientDriver.java | 30 +-
.../cli/application/driver/UjesClientDriver.java | 417 +++++--
.../driver/UjesClientDriverBuilder.java | 66 +-
.../driver/context/LinkisClientDriverContext.java | 8 +-
.../driver/context/UjesClientDriverContext.java | 12 +-
.../driver/transformer/DriverTransformer.java | 21 +-
.../transformer/UjesClientDriverTransformer.java | 276 +++--
.../interactor/command/LinkisCmdType.java | 15 +-
.../command/template/UniversalCmdTemplate.java | 324 +++--
.../executor/LinkisJobManExecutorBuilder.java | 28 +-
.../executor/LinkisJobManageExecutor.java | 89 +-
.../execution/executor/LinkisSubmitExecutor.java | 142 ++-
.../executor/LinkisSubmitExecutorBuilder.java | 27 +-
.../execution/jobexec/LinkisJobInfo.java | 7 +-
.../execution/jobexec/LinkisJobKill.java | 17 +-
.../execution/jobexec/LinkisJobSubmitExec.java | 18 +-
.../cli/application/interactor/job/LinkisJob.java | 10 +-
.../interactor/job/LinkisJobBuilder.java | 165 ++-
.../application/interactor/job/LinkisJobMan.java | 7 +-
.../interactor/job/LinkisJobManBuilder.java | 18 +-
.../interactor/result/PresentResultHandler.java | 17 +-
.../interactor/validate/LinkisJobValidator.java | 120 +-
.../interactor/validate/UjesContextValidator.java | 35 +-
.../presenter/DefaultStdOutPresenter.java | 11 +-
.../presenter/LinkisJobLogPresenter.java | 171 +--
.../presenter/LinkisJobResultPresenter.java | 176 ++-
.../application/presenter/QueryBasedPresenter.java | 31 +-
.../converter/LinkisJobInfoModelConverter.java | 67 +-
.../converter/LinkisJobKillModelConverter.java | 37 +-
.../converter/LinkisLogModelConverter.java | 20 +-
.../converter/LinkisResultModelConverter.java | 18 +-
.../presenter/model/LinkisJobIncLogModel.java | 12 +-
.../presenter/model/LinkisJobInfoModel.java | 33 +-
.../presenter/model/LinkisJobKillResultModel.java | 17 +-
.../presenter/model/LinkisJobResultModel.java | 11 +-
.../cli/application/suite/ExecutionSuite.java | 21 +-
.../application/suite/ExecutionSuiteFactory.java | 7 +-
.../cli/application/suite/SuiteFactoryImpl.java | 21 +-
.../apache/linkis/cli/application/utils/Utils.java | 18 +-
.../application/LinkisClientApplicationTest.java | 267 ++---
.../cli/application/constants/TestConstants.java | 48 +-
.../command/template/ProcessInputUtil.java | 89 +-
.../interactor/command/template/TestCmdType.java | 13 +-
.../command/template/TestParamMapper.java | 41 +-
.../command/template/TestSparkCmdTemplate.java | 272 +++--
.../interactor/execution/LinkisExecutorTest.java | 110 +-
.../interactor/job/LinkisJobBuilderTest.java | 109 +-
.../cli/common/constants/CommonConstants.java | 8 +-
.../cli/common/entity/command/CmdOption.java | 7 +-
.../cli/common/entity/command/CmdTemplate.java | 17 +-
.../linkis/cli/common/entity/command/CmdType.java | 8 +-
.../cli/common/entity/command/ParamItem.java | 34 +-
.../linkis/cli/common/entity/command/Params.java | 29 +-
.../common/entity/context/LinkisClientContext.java | 40 +-
.../entity/execution/CommonSubExecutionType.java | 9 +-
.../cli/common/entity/execution/Execution.java | 13 +-
.../common/entity/execution/ExecutionResult.java | 16 +-
.../common/entity/execution/SubExecutionType.java | 8 +-
.../common/entity/execution/executor/Executor.java | 12 +-
.../entity/execution/executor/ExecutorContext.java | 11 +-
.../entity/execution/jobexec/ExecutionStatus.java | 9 +-
.../common/entity/execution/jobexec/JobExec.java | 9 +-
.../common/entity/execution/jobexec/JobStatus.java | 13 +-
.../apache/linkis/cli/common/entity/job/Job.java | 55 +-
.../linkis/cli/common/entity/job/OutputWay.java | 9 +-
.../common/entity/properties/ClientProperties.java | 19 +-
.../cli/common/entity/result/ResultHandler.java | 6 +-
.../entity/version/ClientVersionInformation.java | 12 +-
.../common/exception/LinkisClientException.java | 12 +-
.../exception/LinkisClientRuntimeException.java | 45 +-
.../cli/common/exception/error/ErrorLevel.java | 23 +-
.../cli/common/exception/error/ErrorMsg.java | 9 +-
.../common/exception/handler/ExceptionHandler.java | 9 +-
.../linkis/cli/common/utils/GenericsUtils.java | 17 +-
.../utils/converter/AbstractStringConverter.java | 13 +-
.../cli/common/utils/converter/Converter.java | 10 +-
.../linkis/cli/core/builder/AbstractBuilder.java | 14 +-
.../cli/core/builder/BuildableByVarAccess.java | 22 +-
.../apache/linkis/cli/core/builder/Builder.java | 9 +-
.../linkis/cli/core/constants/CommonKeys.java | 12 +-
.../linkis/cli/core/constants/Constants.java | 13 +-
.../apache/linkis/cli/core/data/ClientContext.java | 13 +-
.../cli/core/exception/BuilderException.java | 14 +-
.../cli/core/exception/CommandException.java | 23 +-
.../cli/core/exception/ExecutorException.java | 27 +-
.../cli/core/exception/PresenterException.java | 16 +-
.../linkis/cli/core/exception/PropsException.java | 12 +-
.../cli/core/exception/TransformerException.java | 15 +-
.../cli/core/exception/UnknownException.java | 12 +-
.../cli/core/exception/ValidateException.java | 14 +-
.../cli/core/exception/VarAccessException.java | 17 +-
.../cli/core/exception/error/CommonErrMsg.java | 63 +-
.../exception/handler/CommandExceptionHandler.java | 17 +-
.../exception/handler/DefaultExceptionHandler.java | 14 +-
.../interactor/command/fitter/AbstractFitter.java | 120 +-
.../cli/core/interactor/command/fitter/Fitter.java | 11 +-
.../interactor/command/fitter/FitterResult.java | 13 +-
.../interactor/command/fitter/FitterUtils.java | 10 +-
.../interactor/command/fitter/SingleTplFitter.java | 19 +-
.../interactor/command/parser/AbstarctParser.java | 77 +-
.../cli/core/interactor/command/parser/Parser.java | 12 +-
.../interactor/command/parser/SingleCmdParser.java | 27 +-
.../command/parser/result/ParseResult.java | 12 +-
.../command/parser/transformer/ParamKeyMapper.java | 46 +-
.../command/template/AbstractCmdTemplate.java | 337 ++++--
.../command/template/option/BaseOption.java | 29 +-
.../interactor/command/template/option/Flag.java | 40 +-
.../command/template/option/MapOption.java | 49 +-
.../command/template/option/Parameter.java | 34 +-
.../command/template/option/SpecialMapOption.java | 17 +-
.../command/template/option/StdOption.java | 35 +-
.../core/interactor/execution/AsyncSubmission.java | 13 +-
.../interactor/execution/ExecutionResultImpl.java | 12 +-
.../core/interactor/execution/HelpExecution.java | 6 +-
.../core/interactor/execution/JobManSubType.java | 10 +-
.../core/interactor/execution/JobManagement.java | 57 +-
.../core/interactor/execution/SyncSubmission.java | 108 +-
.../execution/executor/AsyncBackendExecutor.java | 12 +-
.../execution/executor/ExecutorBuilder.java | 10 +-
.../executor/JobManagableBackendExecutor.java | 6 +-
.../execution/executor/LogRetrievable.java | 11 +-
.../execution/executor/SyncBackendExecutor.java | 12 +-
.../interactor/execution/jobexec/JobManExec.java | 15 +-
.../execution/jobexec/JobSubmitExec.java | 32 +-
.../execution/observer/event/IncLogEvent.java | 23 +-
.../observer/event/LinkisClientEvent.java | 12 +-
.../observer/event/SingleObserverEvent.java | 12 +-
.../execution/observer/event/TriggerEvent.java | 11 +-
.../observer/listener/IncLogEventListener.java | 24 +-
.../observer/listener/LinkisClientObserver.java | 9 +-
.../observer/listener/TriggerObserver.java | 9 +-
.../linkis/cli/core/interactor/job/JobBuilder.java | 10 +-
.../interactor/properties/PropertiesLoader.java | 9 +-
.../interactor/properties/PropsFilesScanner.java | 40 +-
.../core/interactor/properties/StdPropsLoader.java | 15 +-
.../properties/reader/PropertiesReader.java | 9 +-
.../properties/reader/PropsFileReader.java | 27 +-
.../interactor/properties/reader/SysEnvReader.java | 16 +-
.../properties/reader/SysPropsReader.java | 20 +-
.../interactor/result/DefaultResultHandler.java | 10 +-
.../core/interactor/validate/ParamValidator.java | 12 +-
.../interactor/validate/ParsedTplValidator.java | 44 +-
.../core/interactor/validate/PropsValidator.java | 14 +-
.../cli/core/interactor/validate/Validator.java | 9 +-
.../cli/core/interactor/var/StdVarAccess.java | 134 ++-
.../cli/core/interactor/var/SysVarAccess.java | 34 +-
.../linkis/cli/core/interactor/var/VarAccess.java | 13 +-
.../cli/core/presenter/HelpInfoPresenter.java | 35 +-
.../linkis/cli/core/presenter/Presenter.java | 13 +-
.../cli/core/presenter/display/DisplayDriver.java | 13 +-
.../presenter/display/PlainTextFileDriver.java | 45 +-
.../cli/core/presenter/display/StdOutDriver.java | 13 +-
.../core/presenter/display/data/FileOutData.java | 9 +-
.../display/factory/DisplayDriverFactory.java | 14 +-
.../cli/core/presenter/model/HelpInfoModel.java | 10 +-
.../cli/core/presenter/model/JobExecModel.java | 32 +-
.../cli/core/presenter/model/ModelConverter.java | 7 +-
.../cli/core/presenter/model/PresenterModel.java | 13 +-
.../apache/linkis/cli/core/utils/CommonUtils.java | 19 +-
.../org/apache/linkis/cli/core/utils/LogUtils.java | 10 +-
.../apache/linkis/cli/core/utils/SpecialMap.java | 10 +-
.../converter/PredefinedStringConverters.java | 269 +++--
.../linkis/cli/core/constants/TestConstants.java | 34 +-
.../handler/CommandExceptionHandlerTest.java | 26 +-
.../cli/core/interactor/command/TestCmdType.java | 13 +-
.../command/fitter/SingleTplFitterTest.java | 127 +-
.../command/parser/SingleCmdParserTest.java | 151 +--
.../command/template/TestParamMapper.java | 15 +-
.../command/template/TestSparkCmdTemplate.java | 247 ++--
.../interactor/properties/StdPropsLoaderTest.java | 88 +-
.../cli/core/interactor/var/StdVarAccessTest.java | 303 +++--
.../apache/linkis/cli/core/utils/TestUtils.java | 13 +-
.../computation/client/FlinkOnceJobTest.java | 93 +-
.../computation/client/InteractiveJobTest.java | 26 +-
.../ujes/client/PythonImageJavaClientTest.java | 177 +--
.../linkis/ujes/client/UJESClientImplTestJ.java | 65 +-
.../common/entity/ExecutionNodeStatus.java | 18 +-
.../governance/common/entity/NodeExistStatus.java | 10 +-
.../governance/common/entity/job/JobRequest.java | 34 +-
.../common/entity/job/JobRequestWithDetail.java | 7 +-
.../common/entity/job/QueryException.java | 7 +-
.../governance/common/entity/job/SubJobDetail.java | 189 ++-
.../governance/common/entity/job/SubJobInfo.java | 100 +-
.../common/entity/task/RequestInsertTask.java | 10 +-
.../common/entity/task/RequestOneTask.java | 6 +-
.../common/entity/task/RequestPersistTask.java | 108 +-
.../common/entity/task/RequestQueryTask.java | 11 +-
.../common/entity/task/RequestReadAllTask.java | 12 +-
.../common/entity/task/RequestUpdateTask.java | 10 +-
.../common/entity/task/ResponsePersist.java | 27 +-
.../linkis/ecm/server/LinkisECMApplication.java | 17 +-
.../acessible/executor/log/AbstractLogCache.java | 7 +-
.../acessible/executor/log/LogCache.java | 14 +-
.../acessible/executor/log/MountLogCache.java | 10 +-
.../acessible/executor/log/SendAppender.java | 47 +-
.../acessible/executor/log/TimeLogCache.java | 14 +-
.../conf/AccessibleExecutorConfiguration.scala | 2 +-
.../linkis/entrance/LinkisEntranceApplication.java | 9 +-
.../BackGroundServiceBeanAnnotation.java | 17 +-
.../annotation/ConsumerManagerBeanAnnotation.java | 17 +-
.../annotation/EngineBuilderBeanAnnotation.java | 17 +-
.../annotation/EngineManagerBeanAnnotation.java | 17 +-
.../annotation/EngineRequesterBeanAnnotation.java | 17 +-
.../annotation/EngineSelectorBeanAnnotation.java | 17 +-
.../annotation/EntranceContextBeanAnnotation.java | 17 +-
.../EntranceExecutorManagerBeanAnnotation.java | 19 +-
.../EntranceInterceptorBeanAnnotation.java | 19 +-
.../EntranceListenerBusBeanAnnotation.java | 16 +-
.../EntranceLogListenerBusBeanAnnotation.java | 16 +-
.../annotation/EntranceParserBeanAnnotation.java | 17 +-
.../annotation/EntranceServerBeanAnnotation.java | 17 +-
.../ErrorCodeListenerBeanAnnotation.java | 17 +-
.../annotation/ErrorCodeManagerBeanAnnotation.java | 17 +-
.../annotation/GroupFactoryBeanAnnotation.java | 17 +-
.../annotation/LogManagerBeanAnnotation.java | 19 +-
.../NewEngineBroadcastListenerBeanAnnotation.java | 17 +-
.../PersistenceEngineBeanAnnotation.java | 17 +-
.../PersistenceManagerBeanAnnotation.java | 17 +-
.../annotation/ReceiverChooserBeanAnnotation.java | 17 +-
...atusChangedBroadcastListenerBeanAnnotation.java | 17 +-
.../annotation/ResultSetEngineBeanAnnotation.java | 17 +-
.../annotation/SchedulerBeanAnnotation.java | 17 +-
.../annotation/SchedulerContextBeanAnnotation.java | 17 +-
.../entrance/conf/EntranceSpringConfiguration.java | 150 ++-
.../entrance/context/DefaultEntranceContext.java | 34 +-
.../entrance/exception/EntranceErrorCode.java | 17 +-
.../exception/EntranceIllegalParamException.java | 9 +-
.../entrance/exception/EntranceRPCException.java | 16 +-
.../entrance/exception/QueryFailedException.java | 15 +-
.../entrance/job/EntranceExecuteRequest.java | 23 +-
.../linkis/entrance/job/EntranceExecutionJob.java | 178 +--
.../entrance/parser/AbstractEntranceParser.java | 79 +-
.../apache/linkis/entrance/parser/ParserUtils.java | 47 +-
.../persistence/AbstractPersistenceEngine.java | 10 +-
.../persistence/QueryPersistenceEngine.java | 150 ++-
.../persistence/QueryPersistenceManager.java | 76 +-
.../entrance/restful/EntranceRestfulApi.java | 292 +++--
.../entrance/server/DefaultEntranceServer.java | 23 +-
.../label/builder/AbstractGenericLabelBuilder.java | 242 ++--
.../label/builder/CombinedLabelBuilder.java | 21 +-
.../label/builder/DefaultGlobalLabelBuilder.java | 252 ++--
.../label/builder/ExtensibleLabelBuilder.java | 30 +-
.../manager/label/builder/GenericLabelBuilder.java | 53 +-
.../linkis/manager/label/builder/LabelBuilder.java | 15 +-
.../manager/label/builder/LabelBuilderAdapter.java | 61 +-
.../label/builder/factory/LabelBuilderFactory.java | 35 +-
.../factory/LabelBuilderFactoryContext.java | 15 +-
.../builder/factory/StdLabelBuilderFactory.java | 137 ++-
.../manager/label/conf/LabelCommonConfig.java | 67 +-
.../manager/label/constant/LabelConstant.java | 8 +-
.../manager/label/constant/LabelKeyConstant.java | 6 +-
.../manager/label/entity/CloneableLabel.java | 11 +-
.../linkis/manager/label/entity/CombinedLabel.java | 9 +-
.../manager/label/entity/CombinedLabelImpl.java | 27 +-
.../linkis/manager/label/entity/EMNodeLabel.java | 9 +-
.../manager/label/entity/EngineNodeLabel.java | 9 +-
.../linkis/manager/label/entity/Feature.java | 44 +-
.../linkis/manager/label/entity/FunctionLabel.java | 9 +-
.../linkis/manager/label/entity/GenericLabel.java | 22 +-
.../manager/label/entity/InheritableLabel.java | 16 +-
.../apache/linkis/manager/label/entity/Label.java | 23 +-
.../linkis/manager/label/entity/NodeLabel.java | 9 +-
.../linkis/manager/label/entity/ResourceLabel.java | 9 +-
.../manager/label/entity/SerializableLabel.java | 97 +-
.../linkis/manager/label/entity/TenantLabel.java | 23 +-
.../manager/label/entity/UserModifiable.java | 7 +-
.../manager/label/entity/annon/KeyMethod.java | 11 +-
.../manager/label/entity/annon/ValueSerialNum.java | 8 +-
.../manager/label/entity/cache/CacheLabel.java | 8 +-
.../manager/label/entity/cluster/ClusterLabel.java | 10 +-
.../manager/label/entity/cluster/EnvLabel.java | 17 +-
.../label/entity/config/ConfigurationLabel.java | 9 +-
.../manager/label/entity/em/EMInstanceLabel.java | 26 +-
.../label/entity/engine/CodeLanguageLabel.java | 8 +-
.../entity/engine/ConcurrentEngineConnLabel.java | 7 +-
.../label/entity/engine/EngineBaseInfoLabel.java | 7 +-
.../label/entity/engine/EngineInstanceLabel.java | 15 +-
.../label/entity/engine/EngineTypeLabel.java | 7 +-
.../label/entity/engine/ReuseExclusionLabel.java | 9 +-
.../label/entity/engine/UserCreatorLabel.java | 17 +-
.../label/entity/entrance/BindEngineLabel.java | 122 +-
.../label/entity/entrance/ExecuteOnceLabel.java | 9 +-
.../entity/entrance/JobQueuingTimeoutLabel.java | 11 +-
.../entity/entrance/JobRunningTimeoutLabel.java | 11 +-
.../label/entity/entrance/JobStrategyLabel.java | 9 +-
.../label/entity/entrance/LoadBalanceLabel.java | 13 +-
.../entity/node/AliasServiceInstanceLabel.java | 7 +-
.../label/entity/node/NodeInstanceLabel.java | 10 +-
.../manager/label/entity/route/RouteLabel.java | 23 +-
.../label/entity/search/SearchableLabel.java | 14 +-
.../label/exception/LabelErrorException.java | 10 +-
.../label/exception/LabelRuntimeException.java | 9 +-
.../label/utils/EngineTypeLabelCreator.java | 55 +-
.../linkis/manager/label/utils/LabelUtils.java | 214 ++--
.../linkis/manager/label/TestLabelBuilder.java | 14 +-
.../manager/am/LinkisManagerApplication.java | 15 +-
.../linkis/manager/am/exception/AMErrorCode.java | 21 +-
.../manager/am/exception/AMErrorException.java | 7 +-
.../manager/am/exception/AMRetryException.java | 8 +-
.../linkis/manager/am/restful/EMRestfulApi.java | 265 ++--
.../manager/am/restful/EngineRestfulApi.java | 223 ++--
.../linkis/manager/am/vo/AMEngineNodeVo.java | 11 +-
.../org/apache/linkis/manager/am/vo/EMNodeVo.java | 12 +-
.../linkis/manager/common/constant/AMConstant.java | 8 +-
.../common/entity/enumeration/NodeHealthy.java | 27 +-
.../common/entity/enumeration/NodeStatus.java | 68 +-
.../manager/common/entity/label/LabelKeyValue.java | 11 +-
.../common/entity/metrics/AMNodeMetrics.java | 9 +-
.../common/entity/metrics/NodeHealthyInfo.java | 7 +-
.../manager/common/entity/metrics/NodeMetrics.java | 8 +-
.../common/entity/metrics/NodeOverLoadInfo.java | 7 +-
.../common/entity/metrics/NodeTaskInfo.java | 7 +-
.../manager/common/entity/node/AMEMNode.java | 27 +-
.../manager/common/entity/node/AMEngineNode.java | 32 +-
.../linkis/manager/common/entity/node/AMNode.java | 10 +-
.../entity/node/DefaultScoreServiceInstance.java | 7 +-
.../linkis/manager/common/entity/node/EMNode.java | 11 +-
.../manager/common/entity/node/EngineNode.java | 10 +-
.../manager/common/entity/node/InfoRMNode.java | 7 +-
.../manager/common/entity/node/LabelNode.java | 9 +-
.../linkis/manager/common/entity/node/Node.java | 12 +-
.../linkis/manager/common/entity/node/RMNode.java | 7 +-
.../common/entity/node/ScoreServiceInstance.java | 14 +-
.../entity/persistence/PersistenceLabel.java | 11 +-
.../entity/persistence/PersistenceLabelRel.java | 1 -
.../common/entity/persistence/PersistenceLock.java | 7 +-
.../common/entity/persistence/PersistenceNode.java | 8 +-
.../entity/persistence/PersistenceNodeEntity.java | 13 +-
.../entity/persistence/PersistenceNodeMetrics.java | 16 +-
.../persistence/PersistenceNodeMetricsEntity.java | 13 +-
.../entity/persistence/PersistenceResource.java | 12 +-
.../common/entity/resource/CommonNodeResource.java | 38 +-
.../common/entity/resource/NodeResource.java | 10 +-
.../common/entity/resource/ResourceType.java | 16 +-
.../common/entity/resource/UserResource.java | 3 +-
.../common/exception/ResourceWarnException.java | 11 +-
.../manager/common/protocol/bml/BmlResource.java | 54 +-
.../protocol/conf/RemoveCacheConfRequest.java | 6 +-
.../common/protocol/em/EMInfoClearRequest.java | 9 +-
.../manager/common/protocol/em/EMRequest.java | 7 +-
.../common/protocol/em/EMResourceClearRequest.java | 3 +-
.../common/protocol/em/GetEMEnginesRequest.java | 7 +-
.../common/protocol/em/GetEMInfoRequest.java | 7 +-
.../manager/common/protocol/em/PauseEMRequest.java | 7 +-
.../manager/common/protocol/em/StopEMRequest.java | 7 +-
.../common/protocol/engine/EngineAskRequest.java | 33 +-
.../protocol/engine/EngineConnReleaseRequest.java | 16 +-
.../protocol/engine/EngineCreateRequest.java | 28 +-
.../protocol/engine/EngineInfoClearRequest.java | 12 +-
.../common/protocol/engine/EngineLockType.java | 13 +-
.../protocol/engine/EngineRecyclingRequest.java | 7 +-
.../common/protocol/engine/EngineRequest.java | 7 +-
.../common/protocol/engine/EngineReuseRequest.java | 21 +-
.../common/protocol/engine/EngineStopRequest.java | 22 +-
.../common/protocol/engine/EngineStopResponse.java | 8 +-
.../protocol/engine/EngineSuicideRequest.java | 23 +-
.../protocol/engine/EngineSwitchRequest.java | 7 +-
.../common/protocol/node/HeartbeatProtocol.java | 10 +-
.../common/protocol/node/NodeHeartbeatMsg.java | 17 +-
.../common/protocol/node/NodeHeartbeatRequest.java | 7 +-
.../common/protocol/node/NodeRequestProtocol.java | 10 +-
.../common/protocol/node/NodeStatusProtocol.java | 10 +-
.../common/protocol/node/RequestNodeStatus.java | 7 +-
.../common/protocol/node/ResponseNodeStatus.java | 7 +-
.../common/protocol/node/StopNodeRequest.java | 7 +-
.../linkis/manager/common/utils/ManagerUtils.java | 16 +-
.../exception/RMErrorException.java | 10 +-
.../exception/RMFatalException.java | 7 +-
.../resourcemanager/exception/RMWarnException.java | 7 +-
.../protocol/TimeoutEMEngineRequest.java | 6 +-
.../protocol/TimeoutEMEngineResponse.java | 6 +-
.../manager/PersistenceSpringConfiguration.java | 65 +-
.../linkis/manager/dao/LabelManagerMapper.java | 100 +-
.../linkis/manager/dao/LockManagerMapper.java | 17 +-
.../linkis/manager/dao/NodeManagerMapper.java | 137 ++-
.../manager/dao/NodeMetricManagerMapper.java | 105 +-
.../linkis/manager/dao/ResourceManagerMapper.java | 99 +-
.../org/apache/linkis/manager/entity/Tunple.java | 7 +-
.../exception/NodeInstanceDuplicateException.java | 9 +-
.../exception/NodeInstanceNotFoundException.java | 7 +-
.../exception/PersistenceErrorException.java | 14 +-
.../exception/PersistenceWarnException.java | 7 +-
.../persistence/LabelManagerPersistence.java | 38 +-
.../persistence/LockManagerPersistence.java | 11 +-
.../manager/persistence/ManagerPersistence.java | 10 +-
.../persistence/NodeManagerPersistence.java | 23 +-
.../persistence/NodeMetricManagerPersistence.java | 16 +-
.../persistence/ResourceLabelPersistence.java | 31 +-
.../persistence/ResourceManagerPersistence.java | 53 +-
.../impl/DefaultLabelManagerPersistence.java | 158 ++-
.../impl/DefaultLockManagerPersistence.java | 30 +-
.../impl/DefaultManagerPersistence.java | 16 +-
.../impl/DefaultNodeManagerPersistence.java | 86 +-
.../impl/DefaultNodeMetricManagerPersistence.java | 51 +-
.../impl/DefaultResourceLabelPersistence.java | 111 +-
.../impl/DefaultResourceManagerPersistence.java | 92 +-
.../linkis/manager/util/PersistenceUtils.java | 52 +-
.../src/test/java/PersistenceTest.java | 112 +-
.../src/test/java/Scan.java | 19 +-
.../resourcemanager/domain/RMLabelContainer.java | 70 +-
.../resourcemanager/exception/RMErrorCode.java | 34 +-
.../external/dao/ExternalResourceProviderDao.java | 7 +-
.../external/domain/ExternalAppInfo.java | 9 +-
.../domain/ExternalResourceIdentifier.java | 6 +-
.../external/domain/ExternalResourceProvider.java | 22 +-
.../parser/ExternalResourceIdentifierParser.java | 7 +-
.../parser/YarnResourceIdentifierParser.java | 6 +-
.../request/ExternalResourceRequester.java | 14 +-
.../external/service/ExternalResourceService.java | 33 +-
.../service/impl/ExternalResourceServiceImpl.java | 153 ++-
.../external/yarn/YarnResourceIdentifier.java | 8 +-
.../restful/vo/ApplicationListVo.java | 9 +-
.../restful/vo/EngineInstanceVo.java | 6 +-
.../linkis/resourcemanager/utils/AlertUtils.java | 84 +-
.../utils/RequestKerberosUrlUtils.java | 121 +-
.../engineconn-plugins/flink/pom.xml | 4 +-
.../flink/client/config/Environment.java | 601 +++++-----
.../flink/client/config/entries/ConfigEntry.java | 72 +-
.../client/config/entries/ExecutionEntry.java | 676 ++++++-----
.../flink/client/context/ExecutionContext.java | 1259 ++++++++++----------
.../deployment/ClusterDescriptorAdapter.java | 335 +++---
.../ClusterDescriptorAdapterFactory.java | 38 +-
.../YarnApplicationClusterDescriptorAdapter.java | 52 +-
.../YarnPerJobClusterDescriptorAdapter.java | 102 +-
.../factory/LinkisYarnClusterClientFactory.java | 46 +-
.../flink/client/result/AbstractResult.java | 51 +-
.../flink/client/result/BatchResult.java | 213 ++--
.../flink/client/result/ChangelogResult.java | 452 +++----
.../flink/client/result/Result.java | 43 +-
.../flink/client/result/ResultUtil.java | 154 +--
.../flink/client/result/TypedResult.java | 131 +-
.../client/sql/operation/AbstractJobOperation.java | 46 +-
.../flink/client/sql/operation/JobOperation.java | 20 +-
.../client/sql/operation/NonJobOperation.java | 10 +-
.../flink/client/sql/operation/Operation.java | 13 +-
.../client/sql/operation/OperationFactory.java | 16 +-
.../client/sql/operation/OperationFactoryImpl.java | 29 +-
.../flink/client/sql/operation/OperationUtil.java | 90 +-
.../sql/operation/impl/CreateViewOperation.java | 73 +-
.../client/sql/operation/impl/DDLOperation.java | 123 +-
.../sql/operation/impl/DescribeTableOperation.java | 135 ++-
.../sql/operation/impl/DropViewOperation.java | 85 +-
.../sql/operation/impl/ExplainOperation.java | 88 +-
.../client/sql/operation/impl/InsertOperation.java | 84 +-
.../client/sql/operation/impl/ResetOperation.java | 43 +-
.../client/sql/operation/impl/SelectOperation.java | 113 +-
.../client/sql/operation/impl/SetOperation.java | 144 +--
.../sql/operation/impl/ShowCatalogsOperation.java | 35 +-
.../impl/ShowCurrentCatalogOperation.java | 32 +-
.../impl/ShowCurrentDatabaseOperation.java | 32 +-
.../sql/operation/impl/ShowDatabasesOperation.java | 35 +-
.../sql/operation/impl/ShowFunctionsOperation.java | 35 +-
.../sql/operation/impl/ShowModulesOperation.java | 35 +-
.../sql/operation/impl/ShowTablesOperation.java | 69 +-
.../sql/operation/impl/ShowViewsOperation.java | 64 +-
.../sql/operation/impl/UseCatalogOperation.java | 60 +-
.../sql/operation/impl/UseDatabaseOperation.java | 52 +-
.../client/sql/operation/result/ColumnInfo.java | 142 ++-
.../client/sql/operation/result/ConstantNames.java | 54 +-
.../client/sql/operation/result/ResultKind.java | 18 +-
.../client/sql/operation/result/ResultSet.java | 313 +++--
.../result/ResultSetJsonDeserializer.java | 328 +++--
.../operation/result/ResultSetJsonSerializer.java | 170 ++-
.../flink/client/sql/parser/SqlCommand.java | 28 +-
.../flink/client/sql/parser/SqlCommandCall.java | 6 +-
.../flink/client/sql/parser/SqlCommandParser.java | 19 +-
.../client/sql/parser/SqlCommandParserImpl.java | 94 +-
.../flink/client/utils/YarnConfLoader.java | 92 +-
.../flink/exception/ExecutorInitException.java | 37 +-
.../flink/exception/FlinkInitFailedException.java | 25 +-
.../flink/exception/JobExecutionException.java | 25 +-
.../flink/exception/SqlExecutionException.java | 25 +-
.../flink/exception/SqlParseException.java | 25 +-
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../hive/src/main/assembly/distribution.xml | 3 +-
.../linkis/engineplugin/hive/log/HiveProgress.java | 6 +-
.../hive/serde/CustomerDelimitedJSONSerDe.java | 363 ++++--
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../io_file/src/main/assembly/distribution.xml | 3 +-
.../engineplugin/io/utils/ReflectionUtils.java | 7 +-
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../jdbc/src/main/assembly/distribution.xml | 3 +-
.../engineplugin/jdbc/ConnectionManager.java | 91 +-
.../manager/engineplugin/jdbc/JdbcAuthType.java | 7 +-
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../engineplugin/jdbc/TestConnectionManager.java | 5 +-
.../pipeline/src/main/assembly/distribution.xml | 3 +-
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../engineconn-plugins/spark/pom.xml | 4 +-
.../{log4j2-engineconn.xml => log4j2.xml} | 0
.../engineplugin/cache/EngineConnPluginCache.java | 17 +-
.../cache/GuavaEngineConnPluginCache.java | 135 ++-
.../cache/config/EngineConnPluginCacheConfig.java | 17 +-
.../DefaultRefreshPluginCacheContainer.java | 208 ++--
.../cache/refresh/PluginCacheRefresher.java | 7 +-
.../cache/refresh/RefreshPluginCacheContainer.java | 15 +-
.../cache/refresh/RefreshPluginCacheOperation.java | 37 +-
.../refresh/RefreshableEngineConnPluginCache.java | 16 +-
.../common/conf/EnvConfiguration.scala | 2 +-
.../classloader/EngineConnPluginClassLoader.java | 80 +-
.../loaders/CacheablesEngineConnPluginLoader.java | 86 +-
.../loaders/DefaultEngineConnPluginLoader.java | 199 ++--
.../manager/loaders/EngineConnPluginsLoader.java | 11 +-
.../loaders/EngineConnPluginsResourceLoader.java | 15 +-
.../BmlEngineConnPluginResourceLoader.java | 227 ++--
.../LocalEngineConnPluginResourceLoader.java | 32 +-
.../manager/loaders/resource/PluginResource.java | 23 +-
.../manager/utils/EngineConnPluginUtils.java | 93 +-
.../manager/utils/ExceptionHelper.java | 10 +-
.../src/test/java/EngineConnPluginLoaderTest.java | 16 +-
.../server/LinkisEngineConnPluginServer.java | 8 +-
.../conf/EngineConnPluginSpringConfiguration.java | 9 +-
.../server/dao/EngineConnBmlResourceDao.java | 12 +-
.../server/entity/EngineConnBmlResource.java | 7 +-
.../computation/utils/TaskTreeUtil.java | 22 +-
.../linkis/orchestrator/ecm/entity/Policy.java | 19 +-
.../linkis/bml/client/AbstractBmlClient.java | 6 +-
.../org/apache/linkis/bml/client/BmlClient.java | 91 +-
.../apache/linkis/bml/client/BmlClientFactory.java | 15 +-
.../apache/linkis/bml/model/AbstractAuditable.java | 7 +-
.../org/apache/linkis/bml/Entity/BmlProject.java | 6 +-
.../apache/linkis/bml/Entity/DownloadModel.java | 50 +-
.../org/apache/linkis/bml/Entity/Resource.java | 70 +-
.../org/apache/linkis/bml/Entity/ResourceTask.java | 244 ++--
.../apache/linkis/bml/Entity/ResourceVersion.java | 22 +-
.../java/org/apache/linkis/bml/Entity/Version.java | 6 +-
.../apache/linkis/bml/LinkisBMLApplication.java | 7 +-
.../org/apache/linkis/bml/common/Constant.java | 11 +-
.../apache/linkis/bml/common/ExecutorManager.java | 178 +--
.../linkis/bml/common/HdfsResourceHelper.java | 76 +-
.../linkis/bml/common/LocalResourceHelper.java | 62 +-
.../apache/linkis/bml/common/OperationEnum.java | 14 +-
.../apache/linkis/bml/common/ResourceHelper.java | 16 +-
.../linkis/bml/common/ResourceHelperFactory.java | 18 +-
.../apache/linkis/bml/common/ScheduledTask.java | 37 +-
.../org/apache/linkis/bml/dao/BmlProjectDao.java | 89 +-
.../org/apache/linkis/bml/dao/DownloadDao.java | 8 +-
.../org/apache/linkis/bml/dao/ResourceDao.java | 10 +-
.../java/org/apache/linkis/bml/dao/TaskDao.java | 71 +-
.../java/org/apache/linkis/bml/dao/VersionDao.java | 62 +-
.../linkis/bml/restful/BmlProjectRestful.java | 341 ++++--
.../apache/linkis/bml/restful/BmlRestfulApi.java | 693 +++++++----
.../apache/linkis/bml/restful/RestfulUtils.java | 58 +-
.../linkis/bml/service/BmlProjectService.java | 15 +-
.../org/apache/linkis/bml/service/BmlService.java | 10 +-
.../bml/service/BmlShareResourceService.java | 22 +-
.../apache/linkis/bml/service/DownloadService.java | 6 +-
.../apache/linkis/bml/service/ResourceService.java | 45 +-
.../org/apache/linkis/bml/service/TaskService.java | 57 +-
.../apache/linkis/bml/service/VersionService.java | 90 +-
.../bml/service/impl/BmlProjectServiceImpl.java | 75 +-
.../linkis/bml/service/impl/BmlServiceImpl.java | 11 +-
.../service/impl/BmlShareResourceServiceImpl.java | 26 +-
.../bml/service/impl/DownloadServiceImpl.java | 10 +-
.../bml/service/impl/ResourceServiceImpl.java | 76 +-
.../linkis/bml/service/impl/TaskServiceImpl.java | 357 +++---
.../bml/service/impl/VersionServiceImpl.java | 110 +-
.../org/apache/linkis/bml/threading/Scheduler.java | 10 +-
.../java/org/apache/linkis/bml/threading/Task.java | 10 +-
.../org/apache/linkis/bml/threading/TaskState.java | 26 +-
.../apache/linkis/bml/util/HttpRequestHelper.java | 18 +-
.../java/org/apache/linkis/bml/util/MD5Utils.java | 15 +-
.../org/apache/linkis/bml/vo/ResourceBasicVO.java | 11 +-
.../java/org/apache/linkis/bml/vo/ResourceVO.java | 6 +-
.../apache/linkis/bml/vo/ResourceVersionsVO.java | 22 +-
.../cs/contextcache/ContextCacheService.java | 35 +-
.../contextcache/DefaultContextCacheService.java | 146 ++-
.../linkis/cs/contextcache/cache/ContextCache.java | 8 +-
.../cs/contextcache/cache/DefaultContextCache.java | 89 +-
.../cs/contextcache/cache/csid/ContextIDValue.java | 8 +-
.../cache/csid/ContextIDValueGenerator.java | 8 +-
.../csid/impl/ContextIDValueGeneratorImpl.java | 57 +-
.../cache/csid/impl/ContextIDValueImpl.java | 32 +-
.../cache/cskey/ContextKeyValueContext.java | 16 +-
.../cache/cskey/ContextValueMapSet.java | 7 +-
.../cache/cskey/impl/ContextValueMapSetImpl.java | 49 +-
.../cskey/impl/DefaultContextKeyValueContext.java | 64 +-
.../cache/guava/ContextIDRemoveListener.java | 24 +-
.../cs/contextcache/cleaner/AUTOCleaner.java | 8 +-
.../cs/contextcache/conf/ContextCacheConf.java | 14 +-
.../contextcache/index/ContextInvertedIndex.java | 6 +-
.../index/ContextInvertedIndexSet.java | 7 +-
.../index/ContextInvertedIndexSetImpl.java | 21 +-
.../index/DefaultContextInvertedIndex.java | 19 +-
.../cs/contextcache/metric/ClassIntrospector.java | 105 +-
.../cs/contextcache/metric/ContextCacheMetric.java | 7 +-
.../cs/contextcache/metric/ContextIDMetric.java | 8 +-
.../metric/DefaultContextCacheMetric.java | 13 +-
.../metric/DefaultContextIDMetric.java | 6 +-
.../linkis/cs/contextcache/metric/Metrtic.java | 9 +-
.../linkis/cs/contextcache/metric/ObjectInfo.java | 118 +-
.../cs/contextcache/metric/SizeEstimator.java | 13 +-
.../contextcache/parser/ContextKeyValueParser.java | 6 +-
.../parser/DefaultContextKeyValueParser.java | 52 +-
.../cs/contextcache/utils/ContextCacheUtils.java | 9 +-
.../cs/contextcache/test/csid/TestContextID.java | 6 +-
.../contextcache/test/keyword/TestContextKey.java | 20 +-
.../test/keyword/TestContextKeyValue.java | 8 +-
.../test/keyword/TestContextKeyValueParser.java | 8 +-
.../test/keyword/TestContextValue.java | 10 +-
.../test/service/TestContextCacheService.java | 74 +-
.../linkis/cs/client/AbstractContextClient.java | 11 +-
.../java/org/apache/linkis/cs/client/Context.java | 42 +-
.../org/apache/linkis/cs/client/ContextClient.java | 88 +-
.../org/apache/linkis/cs/client/LinkisContext.java | 11 +-
.../linkis/cs/client/LinkisWorkFlowContext.java | 48 +-
.../cs/client/builder/ContextClientConfig.java | 10 +-
.../cs/client/builder/ContextClientFactory.java | 16 +-
.../cs/client/builder/HttpContextClientConfig.java | 56 +-
.../client/builder/RPCHttpContextClientConfig.java | 9 +-
.../cs/client/http/ContextPostActionBuilder.java | 9 +-
.../linkis/cs/client/http/HttpContextClient.java | 572 +++++----
.../linkis/cs/client/http/HttpHeartBeater.java | 97 +-
.../cs/client/listener/ContextClientEvent.java | 10 +-
.../cs/client/listener/ContextClientListener.java | 8 +-
.../client/listener/ContextClientListenerBus.java | 16 +-
.../listener/ContextClientListenerManager.java | 24 +-
.../cs/client/listener/ContextIDListener.java | 55 +-
.../cs/client/listener/ContextKeyListener.java | 43 +-
.../cs/client/listener/ContextUpdateEvent.java | 9 +-
.../linkis/cs/client/listener/HeartBeater.java | 12 +-
.../cs/client/service/CSMetaDataService.java | 26 +-
.../linkis/cs/client/service/CSNodeService.java | 7 +-
.../cs/client/service/CSNodeServiceImpl.java | 18 +-
.../cs/client/service/CSResourceService.java | 37 +-
.../cs/client/service/CSResultDataService.java | 14 +-
.../cs/client/service/CSResultDataServiceImpl.java | 57 +-
.../linkis/cs/client/service/CSTableService.java | 58 +-
.../cs/client/service/CSVariableService.java | 30 +-
.../linkis/cs/client/service/CSWorkService.java | 9 +-
.../cs/client/service/CSWorkServiceImpl.java | 29 +-
.../service/ContextHistoryClientService.java | 9 +-
.../service/ContextHistoryClientServiceImpl.java | 16 +-
.../cs/client/service/DefaultSearchService.java | 120 +-
.../cs/client/service/LinkisJobDataService.java | 14 +-
.../client/service/LinkisJobDataServiceImpl.java | 41 +-
.../linkis/cs/client/service/MetaDataService.java | 11 +-
.../linkis/cs/client/service/ResourceService.java | 13 +-
.../linkis/cs/client/service/SearchService.java | 28 +-
.../linkis/cs/client/service/TableService.java | 18 +-
.../linkis/cs/client/service/VariableService.java | 12 +-
.../cs/client/utils/ContextServiceUtils.java | 74 +-
.../linkis/cs/client/utils/ExceptionHelper.java | 9 +-
.../linkis/cs/client/utils/SerializeHelper.java | 47 +-
.../org/apache/linkis/cs/client/test/Test.java | 21 +-
.../cs/client/test/bean/ClientTestContextKey.java | 31 +-
.../client/test/bean/ClientTestContextValue.java | 9 +-
.../cs/client/test/bean/ResourceValueBean.java | 10 +-
.../test/listener/CommonContextKeyListener.java | 10 +-
.../cs/client/test/restful/ListenerTest.java | 9 +-
.../linkis/cs/client/test/restful/RestfulTest.java | 28 +-
.../linkis/cs/client/test/service/TestInfo.java | 28 +-
.../linkis/cs/client/test/service/TestRemove.java | 23 +-
.../cs/client/test/service/TestSearchService.java | 37 +-
.../test/test_multiuser/TestChangeContext.java | 23 +-
.../test/test_multiuser/TestCreateContext.java | 27 +-
.../linkis/cs/common/annotation/KeywordMethod.java | 7 +-
.../linkis/cs/common/entity/data/CSResultData.java | 10 +-
.../apache/linkis/cs/common/entity/data/Data.java | 6 +-
.../linkis/cs/common/entity/data/JobData.java | 6 +-
.../cs/common/entity/data/LinkisJobData.java | 8 +-
.../cs/common/entity/enumeration/ContextScope.java | 16 +-
.../cs/common/entity/enumeration/ContextType.java | 21 +-
.../cs/common/entity/enumeration/DBType.java | 17 +-
.../cs/common/entity/enumeration/ExpireType.java | 14 +-
.../cs/common/entity/enumeration/WorkType.java | 7 +-
.../apache/linkis/cs/common/entity/env/Env.java | 10 +-
.../apache/linkis/cs/common/entity/env/OSEnv.java | 8 +-
.../linkis/cs/common/entity/env/SoftWareEnv.java | 7 +-
.../cs/common/entity/env/SoftwareLibEnv.java | 7 +-
.../entity/history/AbstractContextHistory.java | 6 +-
.../entity/history/CommonResourceHistory.java | 10 +-
.../cs/common/entity/history/ContextHistory.java | 7 +-
.../entity/history/ContextHistoryIndexer.java | 6 +-
.../common/entity/history/EnvContextHistory.java | 8 +-
.../history/GlobalPropertyContextHistory.java | 15 +-
.../entity/history/KeywordContextHistroy.java | 8 +-
.../entity/history/ResourceContextHistory.java | 13 +-
.../history/metadata/CSTableLineageHistory.java | 12 +-
.../metadata/CSTableMetadataContextHistory.java | 7 +-
.../history/metadata/DBMetadataContextHistory.java | 9 +-
.../history/metadata/MetadataContextHistory.java | 14 +-
.../history/metadata/TableLineageHistory.java | 8 +-
.../history/metadata/TableOperationType.java | 13 +-
.../listener/CommonContextIDListenerDomain.java | 9 +-
.../listener/CommonContextKeyListenerDomain.java | 11 +-
.../entity/listener/ContextIDListenerDomain.java | 8 +-
.../entity/listener/ContextKeyListenerDomain.java | 8 +-
.../cs/common/entity/listener/ListenerDomain.java | 8 +-
.../linkis/cs/common/entity/metadata/CSColumn.java | 7 +-
.../linkis/cs/common/entity/metadata/CSDB.java | 10 +-
.../cs/common/entity/metadata/CSPartition.java | 7 +-
.../linkis/cs/common/entity/metadata/CSTable.java | 8 +-
.../linkis/cs/common/entity/metadata/Column.java | 7 +-
.../linkis/cs/common/entity/metadata/DB.java | 7 +-
.../cs/common/entity/metadata/Partition.java | 6 +-
.../linkis/cs/common/entity/metadata/Table.java | 6 +-
.../cs/common/entity/object/CSFlowInfos.java | 8 +-
.../linkis/cs/common/entity/object/CSInfos.java | 7 +-
.../linkis/cs/common/entity/object/CSProperty.java | 7 +-
.../entity/object/CommonGlobalConfiguration.java | 12 +-
.../cs/common/entity/object/CommonProperty.java | 8 +-
.../cs/common/entity/object/LinkisVariable.java | 10 +-
.../cs/common/entity/resource/BMLResource.java | 8 +-
.../common/entity/resource/CommonFxResource.java | 7 +-
.../common/entity/resource/CommonUDFResource.java | 7 +-
.../cs/common/entity/resource/FxResource.java | 7 +-
.../common/entity/resource/LinkisBMLResource.java | 8 +-
.../linkis/cs/common/entity/resource/Resource.java | 10 +-
.../cs/common/entity/resource/UDFResource.java | 7 +-
.../entity/source/CombinedNodeIDContextID.java | 10 +-
.../cs/common/entity/source/CommonContextID.java | 11 +-
.../cs/common/entity/source/CommonContextKey.java | 16 +-
.../entity/source/CommonContextKeyValue.java | 8 +-
.../common/entity/source/CommonContextValue.java | 14 +-
.../cs/common/entity/source/CommonHAContextID.java | 7 +-
.../linkis/cs/common/entity/source/ContextID.java | 15 +-
.../cs/common/entity/source/ContextIDParser.java | 8 +-
.../linkis/cs/common/entity/source/ContextKey.java | 11 +-
.../cs/common/entity/source/ContextKeyValue.java | 7 +-
.../cs/common/entity/source/ContextValue.java | 10 +-
.../cs/common/entity/source/CreatorContextKey.java | 7 +-
.../cs/common/entity/source/HAContextID.java | 8 +-
.../entity/source/LinkisHAWorkFlowContextID.java | 10 +-
.../entity/source/LinkisWorkflowContextID.java | 10 +-
.../cs/common/entity/source/OrderContextKey.java | 7 +-
.../linkis/cs/common/entity/source/Source.java | 10 +-
.../cs/common/entity/source/UserContextID.java | 9 +-
.../linkis/cs/common/entity/source/ValueBean.java | 7 +-
.../cs/common/entity/source/VersionContextKey.java | 7 +-
.../cs/common/entity/source/WorkflowContextID.java | 8 +-
.../cs/common/entity/source/YMLContextKey.java | 8 +-
.../cs/common/exception/CSErrorException.java | 11 +-
.../cs/common/exception/CSWarnException.java | 6 +-
.../linkis/cs/common/exception/ErrorCode.java | 9 +-
.../cs/common/listener/ContextIDListener.java | 6 +-
.../cs/common/listener/ContextKeyListener.java | 8 +-
.../cs/common/protocol/ContextHTTPConstant.java | 8 +-
.../cs/common/protocol/ContextHistoryType.java | 13 +-
.../linkis/cs/common/protocol/ContextIDType.java | 26 +-
.../linkis/cs/common/protocol/ContextKeyType.java | 17 +-
.../cs/common/protocol/ContextKeyValueType.java | 11 +-
.../cs/common/protocol/ContextValueType.java | 17 +-
.../search/ContextSearchConditionMapBuilder.java | 87 +-
.../cs/common/serialize/AbstractSerializer.java | 22 +-
.../cs/common/serialize/ContextSerializer.java | 8 +-
.../helper/AbstractSerializationHelper.java | 31 +-
.../helper/ContextSerializationHelper.java | 25 +-
.../serialize/helper/SerializationHelper.java | 9 +-
.../context/CombinedNodeIDContextIDSerializer.java | 16 +-
.../impl/context/CommonContextKeySerializer.java | 10 +-
.../impl/context/ContextKeyValueSerializer.java | 13 +-
.../impl/context/ContextValueSerializer.java | 17 +-
.../LinkisHAWorkFlowContextIDSerializer.java | 19 +-
.../impl/history/CommonHistorySerializer.java | 7 +-
.../history/CommonResourceHistorySerializer.java | 17 +-
.../history/metadata/CSTableLineageSerializer.java | 26 +-
.../metadata/CSTableMetadataHistorySerializer.java | 14 +-
.../impl/value/LinkisBMLResourceSerializer.java | 11 +-
.../impl/value/data/CSResultDataSerializer.java | 11 +-
.../impl/value/data/LinkisJobDataSerializer.java | 8 +-
.../impl/value/metadata/CSTableSerializer.java | 9 +-
.../impl/value/object/CSFlowInfosSerializer.java | 8 +-
.../value/object/LinkisVariableSerializer.java | 8 +-
.../linkis/cs/common/utils/CSCommonUtils.java | 39 +-
.../cs/common/utils/CSHighAvailableUtils.java | 65 +-
.../test/ContextSerializationHelperTest.java | 54 +-
.../cs/highavailable/AbstractContextHAManager.java | 6 +-
.../linkis/cs/highavailable/ContextHAManager.java | 12 +-
.../cs/highavailable/DefaultContextHAManager.java | 57 +-
.../conf/ContextHighAvailableConf.java | 15 +-
.../cs/highavailable/exception/CSErrorCode.java | 8 +-
.../highavailable/ha/BackupInstanceGenerator.java | 7 +-
.../cs/highavailable/ha/ContextHAChecker.java | 6 +-
.../cs/highavailable/ha/ContextHAIDGenerator.java | 7 +-
.../ha/impl/BackupInstanceGeneratorImpl.java | 31 +-
.../ha/impl/ContextHACheckerImpl.java | 49 +-
.../ha/impl/ContextHAIDGeneratorImpl.java | 35 +-
.../pluggable/HAContextPersistenceManagerImpl.java | 47 +-
.../highavailable/proxy/MethodInterceptorImpl.java | 111 +-
.../highavailable/test/TestContextHAManager.java | 144 ++-
.../cs/highavailable/test/haid/TestHAID.java | 6 +-
.../test/persist/TestPersistence.java | 17 +-
.../apache/linkis/cs/listener/CSIDListener.java | 10 +-
.../apache/linkis/cs/listener/CSKeyListener.java | 10 +-
.../cs/listener/ContextAsyncEventListener.java | 6 +-
.../ListenerBus/ContextAsyncListenerBus.java | 18 +-
.../listener/callback/AbstractCallbackEngine.java | 10 +-
.../cs/listener/callback/CallbackEngine.java | 9 +-
.../listener/callback/ContextIDCallbackEngine.java | 10 +-
.../callback/ContextKeyCallbackEngine.java | 7 +-
.../cs/listener/callback/imp/ClientSource.java | 13 +-
.../listener/callback/imp/ContextKeyValueBean.java | 10 +-
.../imp/DefaultContextIDCallbackEngine.java | 80 +-
.../imp/DefaultContextKeyCallbackEngine.java | 89 +-
.../cs/listener/conf/ContextListenerConf.java | 21 +-
.../linkis/cs/listener/event/ContextIDEvent.java | 7 +-
.../linkis/cs/listener/event/ContextKeyEvent.java | 10 +-
.../cs/listener/event/enumeration/OperateType.java | 19 +-
.../listener/event/impl/DefaultContextIDEvent.java | 9 +-
.../event/impl/DefaultContextKeyEvent.java | 9 +-
.../cs/listener/manager/ListenerManager.java | 15 +-
.../manager/imp/DefaultContextListenerManager.java | 16 +-
.../linkis/cs/listener/test/TestContextID.java | 7 +-
.../linkis/cs/listener/test/TestContextKey.java | 26 +-
.../cs/listener/test/TestContextKeyValue.java | 7 +-
.../linkis/cs/listener/test/TestContextValue.java | 18 +-
.../cs/persistence/ContextPersistenceBeans.java | 11 +-
.../cs/persistence/ContextPersistenceManager.java | 8 +-
.../persistence/ContextPersistenceManagerImpl.java | 16 +-
.../linkis/cs/persistence/annotation/Ignore.java | 10 +-
.../linkis/cs/persistence/annotation/Tuning.java | 10 +-
.../persistence/aop/PersistenceTuningAspect.java | 42 +-
.../cs/persistence/conf/PersistenceConf.java | 18 +-
.../cs/persistence/dao/ContextHistoryMapper.java | 26 +-
.../persistence/dao/ContextIDListenerMapper.java | 10 +-
.../linkis/cs/persistence/dao/ContextIDMapper.java | 7 +-
.../persistence/dao/ContextKeyListenerMapper.java | 12 +-
.../cs/persistence/dao/ContextMapMapper.java | 44 +-
.../cs/persistence/entity/ExtraFieldClass.java | 7 +-
.../entity/PersistenceContextHistory.java | 7 +-
.../persistence/entity/PersistenceContextID.java | 7 +-
.../entity/PersistenceContextIDListener.java | 7 +-
.../persistence/entity/PersistenceContextKey.java | 11 +-
.../entity/PersistenceContextKeyListener.java | 7 +-
.../entity/PersistenceContextKeyValue.java | 6 +-
.../entity/PersistenceContextValue.java | 11 +-
.../cs/persistence/exception/ThrowingFunction.java | 7 +-
.../persistence/ContextHistoryPersistence.java | 8 +-
.../persistence/ContextIDListenerPersistence.java | 14 +-
.../persistence/ContextIDPersistence.java | 8 +-
.../persistence/ContextKeyListenerPersistence.java | 18 +-
.../persistence/ContextMapPersistence.java | 16 +-
.../persistence/ContextMetricsPersistence.java | 10 +-
.../KeywordContextHistoryPersistence.java | 10 +-
.../persistence/TransactionManager.java | 8 +-
.../impl/ContextHistoryPersistenceImpl.java | 41 +-
.../impl/ContextIDListenerPersistenceImpl.java | 30 +-
.../persistence/impl/ContextIDPersistenceImpl.java | 36 +-
.../impl/ContextKeyListenerPersistenceImpl.java | 65 +-
.../impl/ContextMapPersistenceImpl.java | 68 +-
.../impl/ContextMetricsPersistenceImpl.java | 11 +-
.../impl/KeywordContextHistoryPersistenceImpl.java | 38 +-
.../persistence/impl/TransactionManagerImpl.java | 13 +-
.../cs/persistence/util/PersistenceUtils.java | 49 +-
.../linkis/cs/persistence/AContextHistory.java | 7 +-
.../apache/linkis/cs/persistence/AContextID.java | 11 +-
.../linkis/cs/persistence/AContextIDListener.java | 7 +-
.../apache/linkis/cs/persistence/AContextKey.java | 12 +-
.../linkis/cs/persistence/AContextKeyListener.java | 7 +-
.../linkis/cs/persistence/AContextKeyValue.java | 7 +-
.../linkis/cs/persistence/AContextValue.java | 11 +-
.../linkis/cs/persistence/ContextHistoryTest.java | 27 +-
.../cs/persistence/ContextIDListenerTest.java | 18 +-
.../linkis/cs/persistence/ContextIDTest.java | 15 +-
.../cs/persistence/ContextKeyListenerTest.java | 20 +-
.../linkis/cs/persistence/ContextMapTest.java | 45 +-
.../linkis/cs/persistence/ExtraFieldClassTest.java | 33 +-
.../linkis/cs/persistence/MapTypeAdapter.java | 14 +-
.../apache/linkis/cs/persistence/ProxyMethodA.java | 6 +-
.../apache/linkis/cs/persistence/ProxyTest.java | 6 +-
.../org/apache/linkis/cs/persistence/Scan.java | 18 +-
.../java/org/apache/linkis/cs/ContextSearch.java | 17 +-
.../org/apache/linkis/cs/DefaultContextSearch.java | 66 +-
.../cs/condition/AbstractCommonCondition.java | 9 +-
.../linkis/cs/condition/AtomicCondition.java | 9 +-
.../linkis/cs/condition/BinaryLogicCondition.java | 10 +-
.../org/apache/linkis/cs/condition/Condition.java | 10 +-
.../apache/linkis/cs/condition/ConditionType.java | 6 +-
.../linkis/cs/condition/UnaryLogicCondition.java | 8 +-
.../condition/construction/AndConditionParser.java | 13 +-
.../condition/construction/ConditionBuilder.java | 12 +-
.../construction/ConditionBuilderImpl.java | 25 +-
.../cs/condition/construction/ConditionParser.java | 47 +-
.../construction/ContainsConditionParser.java | 8 +-
.../construction/ContextScopeConditionParser.java | 11 +-
.../construction/ContextTypeConditionParser.java | 11 +-
.../ContextValueTypeConditionParser.java | 13 +-
.../construction/NearestConditionParser.java | 17 +-
.../condition/construction/NotConditionParser.java | 12 +-
.../condition/construction/OrConditionParser.java | 13 +-
.../construction/RegexConditionParser.java | 8 +-
.../linkis/cs/condition/impl/AndCondition.java | 6 +-
.../cs/condition/impl/ContainsCondition.java | 8 +-
.../cs/condition/impl/ContextScopeCondition.java | 6 +-
.../cs/condition/impl/ContextTypeCondition.java | 6 +-
.../condition/impl/ContextValueTypeCondition.java | 6 +-
.../linkis/cs/condition/impl/NearestCondition.java | 9 +-
.../linkis/cs/condition/impl/NotCondition.java | 6 +-
.../linkis/cs/condition/impl/OrCondition.java | 8 +-
.../linkis/cs/condition/impl/RegexCondition.java | 6 +-
.../cs/exception/ContextSearchFailedException.java | 6 +-
.../cs/execution/AbstractConditionExecution.java | 21 +-
.../linkis/cs/execution/ConditionExecution.java | 13 +-
.../fetcher/AbstractContextCacheFetcher.java | 8 +-
.../cs/execution/fetcher/ContextCacheFetcher.java | 7 +-
.../fetcher/ContextTypeContextSearchFetcher.java | 15 +-
.../fetcher/IterateContextCacheFetcher.java | 14 +-
.../cs/execution/impl/AndConditionExecution.java | 12 +-
.../impl/BinaryLogicConditionExecution.java | 27 +-
.../execution/impl/ContainsConditionExecution.java | 14 +-
.../impl/ContextScopeConditionExecution.java | 14 +-
.../impl/ContextTypeConditionExecution.java | 15 +-
.../impl/ContextValueTypeConditionExecution.java | 14 +-
.../execution/impl/NearestConditionExecution.java | 18 +-
.../cs/execution/impl/NotConditionExecution.java | 12 +-
.../cs/execution/impl/OrConditionExecution.java | 12 +-
.../cs/execution/impl/RegexConditionExecution.java | 14 +-
.../impl/UnaryLogicConditionExecution.java | 11 +-
.../matcher/AbstractContextSearchMatcher.java | 8 +-
.../matcher/AndLogicContextSearchMatcher.java | 11 +-
.../matcher/BinaryLogicContextSearchMatcher.java | 9 +-
.../matcher/ConditionMatcherResolver.java | 26 +-
.../matcher/ContainsContextSearchMatcher.java | 9 +-
.../matcher/ContextScopeContextSearchMatcher.java | 6 +-
.../cs/execution/matcher/ContextSearchMatcher.java | 7 +-
.../matcher/ContextTypeContextSearchMatcher.java | 8 +-
.../ContextValueTypeContextSearchMatcher.java | 8 +-
.../matcher/NearestLogicContextSearchMatcher.java | 8 +-
.../matcher/NotLogicContextSearchMatcher.java | 8 +-
.../matcher/OrLogicContextSearchMatcher.java | 11 +-
.../matcher/RegexContextSearchMatcher.java | 13 +-
.../execution/matcher/SkipContextSearchMather.java | 8 +-
.../matcher/UnaryLogicContextSearchMatcher.java | 8 +-
.../ruler/AbstractContextSearchRuler.java | 8 +-
.../ruler/CommonListContextSearchRuler.java | 18 +-
.../cs/execution/ruler/ContextSearchRuler.java | 7 +-
.../execution/ruler/NearestContextSearchRuler.java | 162 +--
.../linkis/cs/optimize/ConditionOptimizer.java | 7 +-
.../linkis/cs/optimize/OptimizedCondition.java | 30 +-
.../cs/optimize/cost/ConditionCostCalculator.java | 16 +-
.../apache/linkis/cs/optimize/dfs/BinaryTree.java | 9 +-
.../linkis/cs/optimize/dfs/MinCostBinaryTree.java | 24 +-
.../org/apache/linkis/cs/optimize/dfs/Node.java | 12 +-
.../optimize/impl/CostBasedConditionOptimizer.java | 7 +-
.../test/java/org/apache/linkis/cs/AndTest.java | 9 +-
.../java/org/apache/linkis/cs/ContainsTest.java | 21 +-
.../org/apache/linkis/cs/ContextScopeTest.java | 27 +-
.../org/apache/linkis/cs/ContextSearchTest.java | 19 +-
.../java/org/apache/linkis/cs/ContextTypeTest.java | 19 +-
.../test/java/org/apache/linkis/cs/RegexTest.java | 21 +-
.../org/apache/linkis/cs/csid/TestContextID.java | 7 +-
.../apache/linkis/cs/keyword/TestContextKey.java | 14 +-
.../linkis/cs/keyword/TestContextKeyValue.java | 9 +-
.../apache/linkis/cs/keyword/TestContextValue.java | 11 +-
.../org/apache/linkis/cs/parser/ApiJsonTest.java | 92 +-
.../linkis/cs/server/LinkisCSApplication.java | 7 +-
.../linkis/cs/server/conf/ContextServerConf.java | 18 +-
.../cs/server/enumeration/ServiceMethod.java | 22 +-
.../linkis/cs/server/enumeration/ServiceType.java | 11 +-
.../cs/server/parser/DefaultKeywordParser.java | 43 +-
.../cs/server/parser/KeywordMethodEntity.java | 7 +-
.../linkis/cs/server/parser/KeywordParser.java | 9 +-
.../protocol/AbstractHttpRequestProtocol.java | 7 +-
.../cs/server/protocol/ContextHistoryProtocol.java | 6 +-
.../cs/server/protocol/ContextIDProtocol.java | 7 +-
.../server/protocol/ContextListenerProtocol.java | 7 +-
.../linkis/cs/server/protocol/ContextProtocol.java | 7 +-
.../linkis/cs/server/protocol/HttpProtocol.java | 10 +-
.../cs/server/protocol/HttpRequestProtocol.java | 8 +-
.../cs/server/protocol/HttpResponseProtocol.java | 7 +-
.../cs/server/protocol/RestResponseProtocol.java | 12 +-
.../server/restful/ContextHistoryRestfulApi.java | 59 +-
.../cs/server/restful/ContextIDRestfulApi.java | 51 +-
.../server/restful/ContextListenerRestfulApi.java | 38 +-
.../cs/server/restful/ContextRestfulApi.java | 100 +-
.../linkis/cs/server/restful/CsRestfulParent.java | 39 +-
.../linkis/cs/server/scheduler/CsScheduler.java | 7 +-
.../cs/server/scheduler/DefaultCsScheduler.java | 38 +-
.../linkis/cs/server/scheduler/HttpAnswerJob.java | 8 +-
.../cs/server/scheduler/HttpAnswerJobBuilder.java | 7 +-
.../apache/linkis/cs/server/scheduler/HttpJob.java | 8 +-
.../linkis/cs/server/scheduler/HttpJobBuilder.java | 7 +-
.../cs/server/scheduler/HttpPriorityJob.java | 8 +-
.../linkis/cs/server/scheduler/RestJobBuilder.java | 8 +-
.../cs/server/scheduler/impl/CsExecuteRequest.java | 8 +-
.../scheduler/impl/CsExecutorExecutionManager.java | 20 +-
.../cs/server/scheduler/impl/CsJobListener.java | 18 +-
.../cs/server/scheduler/impl/CsSchedulerBean.java | 20 +-
.../cs/server/scheduler/impl/CsSchedulerJob.java | 11 +-
.../impl/JobToExecuteRequestConsumer.java | 6 +-
.../linkis/cs/server/service/AbstractService.java | 40 +-
.../cs/server/service/ContextHistoryService.java | 20 +-
.../linkis/cs/server/service/ContextIDService.java | 7 +-
.../cs/server/service/ContextListenerService.java | 14 +-
.../linkis/cs/server/service/ContextService.java | 36 +-
.../apache/linkis/cs/server/service/Service.java | 6 +-
.../service/impl/ContextHistoryServiceImpl.java | 53 +-
.../server/service/impl/ContextIDServiceImpl.java | 16 +-
.../service/impl/ContextListenerServiceImpl.java | 35 +-
.../cs/server/service/impl/ContextServiceImpl.java | 157 ++-
.../org/apache/linkis/cs/server/util/CsUtils.java | 11 +-
.../linkis/cs/server/ContextHistoryRestfulApi.java | 52 +-
.../linkis/cs/server/ContextIDRestfulApi.java | 44 +-
.../cs/server/ContextListenerRestfulApi.java | 30 +-
.../apache/linkis/cs/server/ContextRestfulApi.java | 101 +-
.../apache/linkis/cs/server/CsRestfulParent.java | 15 +-
.../java/org/apache/linkis/cs/server/Scan.java | 18 +-
.../org/apache/linkis/cs/server/SchedulerTest.java | 9 +-
.../linkis-datasource-client}/pom.xml | 70 +-
.../datasource/client/AbstractRemoteClient.scala | 34 +-
.../linkis/datasource/client/RemoteClient.scala} | 13 +-
.../client/config/DatasourceClientConfig.scala | 15 +-
.../DataSourceClientBuilderException.scala | 19 +-
.../linkis-datasource-manager/common}/pom.xml | 73 +-
.../common/ServiceErrorCode.java} | 28 +-
.../datasourcemanager/common/auth/AuthContext.java | 83 ++
.../common/domain/DataSource.java | 276 +++++
.../common/domain/DataSourceEnv.java | 175 +++
.../domain/DataSourceParamKeyDefinition.java | 219 ++++
.../common/domain/DataSourceParameter.java | 53 +
.../common/domain/DataSourceType.java | 103 ++
.../common/domain/DatasourceVersion.java | 124 ++
.../common/exception/JsonErrorException.java} | 14 +-
.../datasourcemanager/common/util/CryptoUtils.java | 103 ++
.../common/util/PatternInjectUtils.java | 209 ++++
.../datasourcemanager/common/util/json/Json.java | 133 +++
.../common/protocol/DsmQueryProtocol.scala | 30 +-
.../linkis-datasource-manager/server/pom.xml | 188 +++
.../server}/src/main/assembly/distribution.xml | 35 +-
.../core/LinkisDataSourceManagerApplication.java | 15 +-
.../datasourcemanager/core/dao/DataSourceDao.java | 115 ++
.../core/dao/DataSourceEnvDao.java | 73 ++
.../core/dao/DataSourceParamKeyDao.java} | 38 +-
.../core/dao/DataSourceTypeDao.java} | 27 +-
.../core/dao/DataSourceTypeEnvDao.java} | 41 +-
.../core/dao/DataSourceVersionDao.java | 68 ++
.../core/dao/mapper/DataSouceMapper.xml | 243 ++++
.../core/dao/mapper/DataSourceEnvMapper.xml | 99 ++
.../core/dao/mapper/DataSourceParamKeyMapper.xml | 50 +
.../core/dao/mapper/DataSourceTypeEnvMapper.xml | 32 +-
.../core/dao/mapper/DataSourceTypeMapper.xml | 38 +
.../core/dao/mapper/DataSourceVersionMapper.xml | 61 +
.../CustomMultiPartFormDataTransformer.java | 258 ++++
.../core/formdata/FormDataTransformerFactory.java} | 30 +-
.../core/formdata/FormStreamContent.java | 84 ++
.../formdata/MultiPartFormDataTransformer.java} | 37 +-
.../core/restful/DataSourceAdminRestfulApi.java | 231 ++++
.../core/restful/DataSourceCoreRestfulApi.java | 558 +++++++++
.../core/restful/DataSourceOperateRestfulApi.java | 121 ++
.../core/restful/RestfulApiHelper.java | 124 ++
.../exception/BeanValidationExceptionMapper.java | 38 +
.../core/service/BmlAppService.java | 53 +
.../core/service/DataSourceInfoService.java | 227 ++++
.../core/service/DataSourceOpService.java | 10 +-
.../core/service/DataSourceRelateService.java | 58 +
.../core/service/MetadataOperateService.java | 40 +-
.../core/service/impl/BmlAppServiceImpl.java | 130 ++
.../service/impl/DataSourceInfoServiceImpl.java | 610 ++++++++++
.../service/impl/DataSourceRelateServiceImpl.java | 58 +
.../service/impl/MetadataOperateServiceImpl.java | 136 +++
.../validate/DataSourceParameterValidator.java | 114 ++
.../core/validate/ParameterValidateException.java | 22 +-
.../core/validate/ParameterValidateStrategy.java | 42 +-
.../core/validate/ParameterValidator.java} | 43 +-
.../strategy/RegExpParameterValidateStrategy.java | 80 ++
.../strategy/TypeParameterValidateStrategy.java | 80 ++
.../datasourcemanager/core/vo/DataSourceEnvVo.java | 44 +-
.../datasourcemanager/core/vo/DataSourceVo.java | 92 ++
.../datasourcemanager/core/vo/PageViewVo.java | 30 +-
.../core/receivers/DsmReceiver.scala | 98 ++
.../linkis-metadata-manager/common}/pom.xml | 69 +-
.../metadatamanager/common/MdmConfiguration.java} | 16 +-
.../common/cache/CacheConfiguration.java | 21 +-
.../common/cache/CacheManager.java} | 43 +-
.../common/cache/ConnCacheManager.java | 76 ++
.../common/domain/MetaColumnInfo.java} | 44 +-
.../common/domain/MetaPartitionInfo.java | 87 ++
.../exception/MetaMethodInvokeException.java | 36 +-
.../common/exception/MetaRuntimeException.java | 21 +-
.../common/service/AbstractMetaService.java | 300 +++++
.../common/service/BaseMetadataService.java} | 23 +-
.../common/service/MetadataConnection.java} | 47 +-
.../common/service/MetadataDbService.java | 75 ++
.../common/service/MetadataService.java | 11 +-
.../common/protocol/MetadataOperateProtocol.scala | 14 +-
.../common/protocol/MetadataProtocol.scala | 9 +-
.../common/protocol/MetadataQueryProtocol.scala | 61 +
.../linkis-metadata-manager/server}/pom.xml | 49 +-
.../server}/src/main/assembly/distribution.xml | 75 +-
.../server/LinkisMetadataManagerApplication.java | 15 +-
.../server/loader/MetaClassLoaderManager.java | 265 ++++
.../server/restful/MetadataCoreRestful.java | 246 ++++
.../server/service/MetadataAppService.java | 87 ++
.../service/impl/MetadataAppServiceImpl.java | 237 ++++
.../server/utils/MetadataUtils.java | 180 +++
.../service/elasticsearch}/pom.xml | 52 +-
.../src/main/assembly/distribution.xml | 35 +-
.../metadatamanager/service/ElasticConnection.java | 147 +++
.../service/ElasticParamsMapper.java} | 21 +-
.../metadatamanager/service/EsMetaService.java | 104 ++
.../linkis-metadata-manager/service/hive/pom.xml | 326 +++++
.../hive/src/main/assembly/distribution.xml | 37 +-
.../metadatamanager/service/HiveConnection.java | 164 +++
.../metadatamanager/service/HiveMetaService.java | 257 ++++
.../metadatamanager/service/HiveParamsMapper.java | 21 +-
.../linkis-metadata-manager/service/kafka}/pom.xml | 87 +-
.../kafka}/src/main/assembly/distribution.xml | 36 +-
.../metadatamanager/service/KafkaConnection.java | 51 +
.../metadatamanager/service/KafkaMetaService.java | 136 +++
.../service/KafkaParamsMapper.java} | 20 +-
.../linkis-metadata-manager/service/mysql}/pom.xml | 55 +-
.../mysql}/src/main/assembly/distribution.xml | 35 +-
.../metadatamanager/service/MysqlMetaService.java | 95 ++
.../metadatamanager/service/SqlConnection.java | 235 ++++
.../metadatamanager/service/SqlParamsMapper.java | 24 +-
.../metadata/LinkisDataSourceApplication.java | 7 +-
.../org/apache/linkis/metadata/dao/MdqDao.java | 19 +-
.../linkis/metadata/domain/AbstractAuditable.java | 6 +-
.../org/apache/linkis/metadata/domain/Column.java | 8 +-
.../metadata/domain/mdq/DomainCoversionUtils.java | 84 +-
.../apache/linkis/metadata/domain/mdq/Tunple.java | 8 +-
.../metadata/domain/mdq/bo/ApplicationBO.java | 7 +-
.../linkis/metadata/domain/mdq/bo/BaseBO.java | 7 +-
.../linkis/metadata/domain/mdq/bo/MdqTableBO.java | 7 +-
.../metadata/domain/mdq/bo/MdqTableBaseInfoBO.java | 7 +-
.../domain/mdq/bo/MdqTableFieldsInfoBO.java | 7 +-
.../domain/mdq/bo/MdqTableImportInfoBO.java | 9 +-
.../linkis/metadata/domain/mdq/bo/ModelBO.java | 7 +-
.../linkis/metadata/domain/mdq/po/MdqAccess.java | 7 +-
.../linkis/metadata/domain/mdq/po/MdqField.java | 7 +-
.../linkis/metadata/domain/mdq/po/MdqImport.java | 7 +-
.../linkis/metadata/domain/mdq/po/MdqLineage.java | 7 +-
.../linkis/metadata/domain/mdq/po/MdqTable.java | 70 +-
.../metadata/domain/mdq/po/MdqTableInfo.java | 7 +-
.../metadata/domain/mdq/vo/ApplicationVO.java | 7 +-
.../linkis/metadata/domain/mdq/vo/BaseVO.java | 7 +-
.../metadata/domain/mdq/vo/MdqImportInfoVO.java | 31 +-
.../metadata/domain/mdq/vo/MdqTableBaseInfoVO.java | 9 +-
.../domain/mdq/vo/MdqTableFieldsInfoVO.java | 8 +-
.../mdq/vo/MdqTablePartitionStatisticInfoVO.java | 11 +-
.../domain/mdq/vo/MdqTableStatisticInfoVO.java | 9 +-
.../linkis/metadata/domain/mdq/vo/MdqTableVO.java | 7 +-
.../linkis/metadata/domain/mdq/vo/ModelVO.java | 7 +-
.../apache/linkis/metadata/hive/config/DSEnum.java | 7 +-
.../linkis/metadata/hive/config/DataSource.java | 7 +-
.../hive/config/DataSourceContextHolder.java | 7 +-
.../metadata/hive/config/DynamicDataSource.java | 7 +-
.../metadata/hive/config/LinkisMybatisConfig.java | 43 +-
.../metadata/hive/config/MultiSourceExAop.java | 21 +-
.../linkis/metadata/hive/dao/HiveMetaDao.java | 8 +-
.../metadata/restful/api/DataSourceRestfulApi.java | 54 +-
.../metadata/restful/api/MdqTableRestfulApi.java | 115 +-
.../restful/remote/DataSourceRestfulRemote.java | 26 +-
.../linkis/metadata/service/DataSourceService.java | 11 +-
.../service/HiveMetaWithPermissionService.java | 1 -
.../apache/linkis/metadata/service/MdqService.java | 30 +-
.../service/impl/DataSourceServiceImpl.java | 43 +-
.../impl/HiveMetaWithPermissionServiceImpl.java | 21 +-
.../metadata/service/impl/MdqServiceImpl.java | 191 +--
.../org/apache/linkis/metadata/type/Lifecycle.java | 13 +-
.../apache/linkis/metadata/type/MdqImportType.java | 11 +-
.../apache/linkis/metadata/type/ModelLevel.java | 15 +-
.../apache/linkis/metadata/type/UseWayType.java | 10 +-
.../org/apache/linkis/metadata/util/Constants.java | 8 +-
.../org/apache/linkis/metadata/util/DWSConfig.java | 109 +-
.../org/apache/linkis/metadata/util/HiveUtils.java | 11 +-
.../linkis-datasource/pom.xml | 43 +
.../linkis/configuration/dao/ConfigMapper.java | 15 +-
.../linkis/configuration/dao/LabelMapper.java | 12 +-
.../linkis/configuration/entity/CategoryLabel.java | 7 +-
.../configuration/entity/CategoryLabelVo.java | 6 +-
.../linkis/configuration/entity/ConfigKey.java | 7 +-
.../configuration/entity/ConfigKeyValue.java | 9 +-
.../linkis/configuration/entity/ConfigLabel.java | 10 +-
.../linkis/configuration/entity/ConfigTree.java | 6 +-
.../linkis/configuration/entity/ConfigValue.java | 8 +-
.../exception/ConfigurationException.java | 8 +-
.../restful/api/ConfigurationRestfulApi.java | 258 ++--
.../util/ConfigurationConfiguration.java | 13 +-
.../configuration/util/LabelEntityParser.java | 40 +-
.../errorcode/client/ClientConfiguration.java | 33 +-
.../errorcode/client/ErrorCodeClientBuilder.java | 36 +-
.../errorcode/client/LinkisErrorCodeClient.java | 37 +-
.../errorcode/client/handler/ErrorCodeHandler.java | 7 +-
.../client/handler/ExceptionErrorCodeHandler.java | 9 +-
.../client/handler/LinkisErrorCodeFactory.java | 14 +-
.../client/handler/LinkisErrorCodeHandler.java | 185 +--
.../client/handler/LogErrorCodeHandler.java | 11 +-
.../client/handler/LogFileErrorCodeHandler.java | 17 +-
.../client/manager/LinkisErrorCodeManager.java | 29 +-
.../synchronizer/LinkisErrorCodeSynchronizer.java | 71 +-
.../apache/linkis/errorcode/client/utils/Test.java | 15 +-
.../apache/linkis/errorcode/common/CommonConf.java | 7 +-
.../linkis/errorcode/server/ErrorCodeServer.java | 10 +-
.../errorcode/server/dao/ErrorCodeMapper.java | 18 +-
.../server/restful/LinkisErrorCodeRestful.java | 16 +-
.../server/service/LinkisErrorCodeService.java | 8 +-
.../service/impl/LinkisErrorCodeServiceImpl.java | 18 +-
.../instance/label/InsLabelAutoConfiguration.java | 50 +-
.../instance/label/async/AsyncConsumerQueue.java | 12 +-
.../label/async/GenericAsyncConsumerQueue.java | 107 +-
.../label/cache/InsLabelCacheConfiguration.java | 39 +-
.../linkis/instance/label/conf/InsLabelConf.java | 50 +-
.../instance/label/dao/InsLabelRelationDao.java | 32 +-
.../linkis/instance/label/dao/InstanceInfoDao.java | 8 +-
.../instance/label/dao/InstanceLabelDao.java | 28 +-
.../instance/label/entity/InsPersistenceLabel.java | 22 +-
.../label/entity/InsPersistenceLabelValue.java | 13 +-
.../linkis/instance/label/entity/InstanceInfo.java | 23 +-
.../instance/label/restful/InstanceRestful.java | 71 +-
.../label/service/InsLabelAccessService.java | 19 +-
.../instance/label/service/InsLabelService.java | 35 +-
.../label/service/InsLabelServiceAdapter.java | 8 +-
.../label/service/annotation/AdapterMode.java | 7 +-
.../label/service/impl/DefaultInsLabelService.java | 355 +++---
.../impl/DefaultInsLabelServiceAdapter.java | 174 ++-
.../label/service/impl/EurekaInsLabelService.java | 46 +-
.../linkis/instance/label/utils/EntityParser.java | 27 +-
.../label/vo/InsPersistenceLabelSearchVo.java | 12 +-
.../linkis/instance/label/vo/InstanceInfoVo.java | 8 +-
.../linkis/jobhistory/LinkisPublicServiceApp.java | 6 +-
.../linkis/jobhistory/cache/QueryCacheManager.java | 6 +-
.../linkis/jobhistory/cache/QueryCacheService.java | 8 +-
.../linkis/jobhistory/cache/domain/TaskResult.java | 13 +-
.../cache/impl/DefaultQueryCacheManager.java | 65 +-
.../cache/impl/QueryCacheServiceImpl.java | 110 +-
.../jobhistory/cache/impl/ScheduledCleanJob.java | 20 +-
.../jobhistory/cache/impl/ScheduledRefreshJob.java | 20 +-
.../jobhistory/cache/impl/UserTaskResultCache.java | 26 +-
.../linkis/jobhistory/cache/utils/MD5Util.java | 22 +-
.../linkis/jobhistory/dao/JobDetailMapper.java | 29 +-
.../linkis/jobhistory/dao/JobHistoryMapper.java | 26 +-
.../apache/linkis/jobhistory/entity/JobDetail.java | 63 +-
.../linkis/jobhistory/entity/JobHistory.java | 13 +-
.../apache/linkis/jobhistory/entity/QueryTask.java | 7 +-
.../linkis/jobhistory/entity/QueryTaskVO.java | 11 +-
.../jobhistory/restful/api/QueryRestfulApi.java | 88 +-
.../linkis/jobhistory/transitional/TaskStatus.java | 25 +-
.../apache/linkis/jobhistory/util/Constants.java | 7 +-
.../filesystem/conf/WorkSpaceConfiguration.java | 52 +-
.../filesystem/constant/WorkSpaceConstants.java | 9 +-
.../linkis/filesystem/entity/DirFileTree.java | 8 +-
.../apache/linkis/filesystem/entity/LogLevel.java | 11 +-
.../filesystem/exception/WorkSpaceException.java | 6 +-
.../exception/WorkspaceExceptionManager.java | 89 +-
.../filesystem/restful/api/BMLFsRestfulApi.java | 96 +-
.../filesystem/restful/api/FsRestfulApi.java | 318 +++--
.../linkis/filesystem/util/WorkspaceUtil.java | 46 +-
.../java/org/apache/linkis/udf/entity/UDFInfo.java | 28 +-
.../org/apache/linkis/udf/entity/UDFManager.java | 8 +-
.../java/org/apache/linkis/udf/entity/UDFTree.java | 22 +-
.../apache/linkis/udf/excepiton/UDFException.java | 14 +-
.../org/apache/linkis/udf/utils/ConstantVar.java | 34 +-
.../java/org/apache/linkis/udf/api/UDFApi.java | 280 +++--
.../java/org/apache/linkis/udf/dao/UDFDao.java | 35 +-
.../java/org/apache/linkis/udf/dao/UDFTreeDao.java | 9 +-
.../org/apache/linkis/udf/service/UDFService.java | 27 +-
.../apache/linkis/udf/service/UDFTreeService.java | 9 +-
.../linkis/udf/service/impl/UDFServiceImpl.java | 250 ++--
.../udf/service/impl/UDFTreeServiceImpl.java | 115 +-
.../java/org/apache/linkis/udf/TestUDFTree.java | 18 +-
.../org/apache/linkis/variable/dao/VarMapper.java | 19 +-
.../org/apache/linkis/variable/entity/VarKey.java | 7 +-
.../linkis/variable/entity/VarKeyAndValue.java | 7 +-
.../apache/linkis/variable/entity/VarKeyUser.java | 8 +-
.../linkis/variable/entity/VarKeyValueVO.java | 25 +-
.../org/apache/linkis/variable/entity/VarTree.java | 7 +-
.../variable/exception/VariableException.java | 8 +-
.../variable/restful/api/VariableRestfulApi.java | 28 +-
.../linkis/variable/service/VariableService.java | 9 +-
.../org/apache/linkis/variable/util/Constants.java | 6 +-
linkis-public-enhancements/pom.xml | 1 +
.../eureka/SpringCloudEurekaApplication.java | 7 +-
.../linkis/eureka/conf/EurekaSecurityConfig.java | 14 +-
.../dws/annotation/DWSHttpMessageResult.java | 12 +-
.../springcloud/LinkisGatewayApplication.java | 10 +-
.../http/GatewayAuthorizationFilter.java | 230 ++--
.../springcloud/http/SpringCloudHttpUtils.java | 39 +-
.../SpringCloudGatewayWebsocketFilter.java | 334 ++++--
.../websocket/WebSocketServiceConfiguration.java | 11 +-
mvnw | 310 +++++
mvnw.cmd | 182 +++
pom.xml | 38 +-
tool/dependencies/known-dependencies.txt | 65 +-
tool/dependencies/third-party-dependencies.txt | 63 +-
1454 files changed, 36687 insertions(+), 22237 deletions(-)
diff --cc pom.xml
index 85cf5b8,73656a7..2bafafa
--- a/pom.xml
+++ b/pom.xml
@@@ -121,8 -120,9 +120,9 @@@
<httpclient.version>4.5.13</httpclient.version>
<httpmime.version>4.5.4</httpmime.version>
<slf4j.version>1.7.30</slf4j.version>
+ <knife4j.version>2.0.9</knife4j.version>
<maven.version>3.3.3</maven.version>
- <xstream.core.version>1.4.18</xstream.core.version>
+ <xstream.core.version>1.4.19</xstream.core.version>
<spring.version>5.2.15.RELEASE</spring.version>
<spring.security.cryto.version>5.4.4</spring.security.cryto.version>
<reflections.version>0.9.10</reflections.version>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org