You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2022/07/19 06:38:07 UTC
[incubator-linkis] branch dev-1.2.1 updated (526e01afe -> 1f8caace3)
This is an automated email from the ASF dual-hosted git repository.
casion pushed a change to branch dev-1.2.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
from 526e01afe [Improvement]Optimize of linkis assamble-combined-package module (#2376)
add 34a929fb0 fix(linkis-rpc): messageUtils.orderIsLast bug, and refactor some code (#2371)
add f58707431 Dev 1.2.0 LM ec history restful bug fix (#2372)
add 84a48a001 fix-bug #2273 Data source edit form supports Chinese and English (#2388)
add 31d9a1abd [feature] #2348 jdbc engine support trino (#2392)
add c755a1e2c scala version (#2405)
add 33611d926 feat(logging): scala remove the use of Logging's deprecated method (#2394)
add 8c79a4c9f refactor(linkis-engineconn): move the linkis-engineconn-plugin-framework to linkis-cg module (#2361)
add 10ee01de4 [ISSUE 2389] Fixed the bug in the linkis-ps-metadataquery module (#2398)
add b4627300e Add knife4j by a new module named linkis-knif4j (#2366)
add 2bcdf7f57 Fixed the problem that the task state could not be flipped normally when thread unsafe SimpleDateFormat was used as a global variable (#2418)
add f7c72e2be Support knif4j (#2434)
add 523d2f747 support Variable Operation (#2415)
add fc3be7dc0 refactor(spark): get scala version from util.properties.versionNumber… (#2419)
add 28fd5db84 refactor(linkis-scheduler): refactor some code (#2436)
add 64873ffc3 [Feature] [1.2.0] When linkis-gateway is debugged locally, knife4j-related class dependencies conflict. (#2455)
add 5aa4f6d60 [Feature] [1.2.0] Increase the version number of oshi-core in the pom file of the ECM. (#2453)
add d0355fdbf [Feature-2450] The new storage path is optimized when the engine material is updated. (#2451)
add 36ffb1623 feat: remove sun.misc.BASE64 (#2438)
add 4964cddb1 fix(linkis-bml): fix a test bug (#2457)
add 7bc7dd4cd upgrade spring-web 2.2.22 (#2462)
add 7ab847aa1 [ISSUE-1763] Add non empty validation to the applicationlist interface (#2440)
add 0ea0a0ad8 Fix issue that querying ECM history, permission management fails (#2417)
add b26cff72f [ISSUE-2344] Opt metadata sql (#2358)
add f6d4e3d50 [ISSUE-2475]linkis-bml-server fix package name capitalization problem (#2466)
add 9c679ce43 fix path separator bug
add b9b522a2b Modify task submission to be asynchronous
add 81d218c18 format code
add 8c7fea875 Modified to configuration parameters
add ed4f25c89 io support orchestrator wait
add 654abd483 update wait time
add 4b450868c remove while
add c031cc05d Fix file name garbled problem
add a2b975c3b update default cores value
add a82415145 add user judgment
add 0b0f55b34 add unique key
add c64bda868 linkis-storage - fix null data exception in exporting of excel with autoformat on
add fa595655b remove log
add 674d7eb9c optimize undone logic
add 00f6e66c1 Merge remote-tracking branch 'origin/dev-1.2.0' into dev-1.2.0-bug-fix
add d0a9a2508 linkis-bml-client - fix no user bug in deleteResource method in HttpBmlClient
add 8d99fb181 import org.apache.linkis.storage.domain.DataType.valueToString
add c9cb9d738 Merge pull request #2468 from WeDataSphere/dev-1.2.0-bug-fix
add 86664ec87 Opt format code (#2458)
add 461f5e3a2 Optimize build out dependence of linkis-cg-engineconnplugin (#2477)
add ecb9747b5 linkis-metadat-query-service-hive Correct package name errors
add 6cdb3f6a6 Merge pull request #2484 from binbinCheng/dev-1.2.0-fixMetadata
add 517829a63 Update checkEnv.sh (#2490)
add 4f09b3061 Fix the problem that 'CsvRelation' class cannot be serialized (#2489)
new 1f8caace3 Merge pull request #2486 from apache/dev-1.2.0
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:
.gitignore | 1 +
.../future/BDPFuture.scala => license-header | 13 +-
.../linkis/common/exception/LinkisException.java | 8 +-
.../VariableOperationFailedException.java | 11 +-
.../java/org/apache/linkis/common/io/FsPath.java | 2 +-
.../org/apache/linkis/common/utils/DESUtil.java | 11 +-
.../common/utils/VariableOperationUtils.java | 317 +++++++++++++++++++++
.../linkis/common/conf/BDPConfiguration.scala | 16 +-
.../apache/linkis/common/conf/Configuration.scala | 6 +-
.../linkis/common/listener/ListenerEventBus.scala | 66 ++---
.../apache/linkis/common/utils/RetryHandler.scala | 2 +-
.../org/apache/linkis/common/utils/Utils.scala | 8 +-
.../apache/linkis/common/utils/VariableUtils.scala | 19 +-
.../common/variable/VariableOperationTest.java | 52 ++++
.../linkis/hadoop/common/utils/HDFSUtils.scala | 6 +-
.../linkis/httpclient/AbstractHttpClient.scala | 2 +-
linkis-commons/linkis-module/pom.xml | 7 +
.../linkis/server/BDPJettyServerHelper.scala | 4 +-
.../org/apache/linkis/server/Knife4jConfig.scala | 86 ++++++
.../linkis/server/conf/ServerConfiguration.scala | 6 +-
.../linkis/server/security/ProxyUserSSOUtils.scala | 2 +-
.../apache/linkis/server/security/SSOUtils.scala | 6 +-
.../linkis/server/security/SecurityFilter.scala | 14 +-
.../linkis/server/socket/ControllerServer.scala | 8 +-
.../socket/controller/ServerEventService.scala | 4 +-
.../socket/controller/ServerListenerEventBus.scala | 2 +-
.../linkis/protocol/IRServiceGroupProtocol.scala | 4 +-
.../apache/linkis/protocol/RetryableProtocol.scala | 5 +-
.../linkis/protocol/engine/EngineState.scala | 32 ---
.../engine/EngineStateTransitionRequest.scala | 4 +-
.../apache/linkis/protocol/mdq/MDQProtocol.scala | 11 +-
.../org/apache/linkis/protocol/task/Task.scala | 4 +-
.../linkis/protocol/utils/ProtocolUtils.scala | 14 +-
.../variable/RequestQueryGlobalVariable.scala | 4 +-
.../protocol/variable/ResponseQueryVariable.scala | 4 +-
.../linkis/rpc/message/method/MessageExecutor.java | 21 +-
.../rpc/message/method/MethodExecuteWrapper.java | 2 +-
.../rpc/message/parser/DefaultServiceParser.java | 20 +-
.../linkis/rpc/message/parser/ServiceMethod.java | 2 +-
.../message/registry/AbstractServiceRegistry.java | 18 +-
.../message/utils/LoadBalancerOptionsUtils.java | 3 +-
.../linkis/rpc/message/utils/MessageUtils.java | 64 ++++-
.../rpc/serializer/ProtostuffSerializeUtil.java | 3 +-
.../org/apache/linkis/rpc/BaseRPCSender.scala | 4 +-
.../org/apache/linkis/rpc/RPCReceiveRestful.scala | 16 +-
.../org/apache/linkis/rpc/RPCSpringBeanCache.scala | 2 +-
.../main/scala/org/apache/linkis/rpc/Sender.scala | 5 +-
.../org/apache/linkis/rpc/SenderFactory.scala | 9 +-
.../apache/linkis/rpc/conf/RPCConfiguration.scala | 44 +--
.../linkis/rpc/conf/RPCSpringConfiguration.scala | 10 +-
.../linkis/rpc/interceptor/RPCServerLoader.scala | 2 +-
.../common/BroadcastRPCInterceptor.scala | 2 +-
.../common/CacheableRPCInterceptor.scala | 8 +-
.../common/SingleInstanceRPCLoadBalancer.scala | 2 +-
.../linkis/rpc/sender/SpringMVCRPCSender.scala | 2 +-
.../sender/eureka/EurekaClientRefreshUtils.scala | 4 +-
.../rpc/transform/JavaCollectionSerializer.scala | 4 +-
.../apache/linkis/rpc/transform/RPCConsumer.scala | 9 +-
.../apache/linkis/rpc/transform/RPCProduct.scala | 22 +-
.../org/apache/linkis/rpc/utils/RPCUtils.scala | 2 +-
.../linkis/rpc/message/utils/MessageUtilsTest.java | 86 ++++++
.../linkis/scheduler/AbstractScheduler.scala | 27 +-
.../org/apache/linkis/scheduler/Scheduler.scala | 7 +-
.../apache/linkis/scheduler/SchedulerContext.scala | 4 +-
.../apache/linkis/scheduler/event/LogEvent.scala | 12 +-
.../exception/SchedulerErrorException.scala | 2 +-
.../scheduler/executer/AbstractExecutor.scala | 6 +-
.../linkis/scheduler/executer/ExecuteRequest.scala | 10 +-
.../linkis/scheduler/executer/Executor.scala | 8 +-
.../apache/linkis/scheduler/future/BDPFuture.scala | 2 +-
.../linkis/scheduler/future/BDPFutureTask.scala | 14 +-
.../apache/linkis/scheduler/queue/Consumer.scala | 4 +-
.../org/apache/linkis/scheduler/queue/Job.scala | 16 +-
.../linkis/scheduler/queue/SchedulerEvent.scala | 34 +--
.../scheduler/queue/SchedulerEventState.scala | 33 +--
.../queue/fifoqueue/FIFOConsumerManager.scala | 2 +-
.../queue/fifoqueue/FIFOGroupFactory.scala | 2 +-
.../scheduler/queue/fifoqueue/FIFOScheduler.scala | 6 +-
.../queue/fifoqueue/FIFOSchedulerContextImpl.scala | 2 +-
.../queue/fifoqueue/FIFOUserConsumer.scala | 14 +-
.../parallelqueue/ParallelConsumerManager.scala | 8 +-
.../queue/parallelqueue/ParallelScheduler.scala | 6 +-
.../scheduler/queue/SchedulerEventStateTest.scala} | 46 ++-
linkis-commons/linkis-storage/pom.xml | 1 -
.../linkis/storage/excel/ExcelStorageReader.java | 8 +-
.../org/apache/linkis/storage/excel/XlsUtils.java | 4 +-
.../org/apache/linkis/storage/excel/XlsxUtils.java | 8 +-
.../linkis/storage/fs/impl/LocalFileSystem.java | 2 +-
.../org/apache/linkis/storage/FSFactory.scala | 15 +-
.../org/apache/linkis/storage/LineMetaData.scala | 4 +-
.../org/apache/linkis/storage/LineRecord.scala | 4 +-
.../linkis/storage/conf/LinkisStorageConf.scala | 4 +-
.../linkis/storage/csv/StorageCSVWriter.scala | 11 +-
.../apache/linkis/storage/domain/DataType.scala | 34 +--
.../org/apache/linkis/storage/domain/Dolphin.scala | 20 +-
.../linkis/storage/domain/MethodEntity.scala | 12 +-
.../linkis/storage/excel/ExcelXlsReader.java | 16 +-
.../linkis/storage/excel/StorageExcelWriter.scala | 62 ++--
.../storage/excel/StorageMultiExcelWriter.scala | 2 +-
.../org/apache/linkis/storage/io/IOClient.scala | 20 +-
.../resultset/DefaultResultSetFactory.scala | 24 +-
.../storage/resultset/ResultSetFactory.scala | 14 +-
.../linkis/storage/resultset/ResultSetReader.scala | 7 +-
.../storage/resultset/StorageResultSet.scala | 11 +-
.../storage/resultset/StorageResultSetReader.scala | 37 ++-
.../storage/resultset/StorageResultSetWriter.scala | 2 +-
.../linkis/storage/resultset/io/IOMetaData.scala | 2 +-
.../linkis/storage/resultset/io/IORecord.scala | 2 +-
.../storage/resultset/io/IOResultSerializer.scala | 2 +-
.../storage/resultset/table/TableRecord.scala | 6 +-
.../resultset/table/TableResultDeserializer.scala | 15 +-
.../resultset/table/TableResultSerializer.scala | 16 +-
.../resultset/txt/TextResultSerializer.scala | 4 +-
.../linkis/storage/utils/FileSystemUtils.scala | 6 +-
.../storage/utils/StorageConfiguration.scala | 3 +-
.../linkis/storage/utils/StorageHelper.scala | 22 +-
.../apache/linkis/storage/utils/StorageUtils.scala | 52 ++--
.../linkis/computation/client/JobMetrics.scala | 2 +-
.../client/interactive/InteractiveJob.scala | 2 +-
.../computation/client/job/AbstractLinkisJob.scala | 6 +-
.../computation/client/job/StorableLinkisJob.scala | 6 +-
.../client/once/simple/SimpleOnceJob.scala | 10 +-
.../client/operator/OnceJobOperator.scala | 4 +-
.../ujes/client/response/JobInfoResult.scala | 2 +-
.../governance/common/paser/CodeParser.scala | 2 +-
.../launch/LinuxProcessEngineConnLaunch.scala | 2 +-
.../ecm/core/launch/ProcessEngineCommandExec.scala | 2 +-
.../ecm/core/listener/ECMEventListener.scala | 2 +-
.../linkis-engineconn-manager-server/pom.xml | 2 +-
.../src/main/assembly/distribution.xml | 243 +++++++++++++++-
.../linkis/ecm/server/hook/JarUDFLoadECMHook.scala | 14 +-
.../server/operator/EngineConnLogOperator.scala | 4 +-
.../operator/EngineConnYarnLogOperator.scala | 12 +-
.../impl/AbstractEngineConnLaunchService.scala | 12 +-
.../impl/BmlResourceLocalizationService.scala | 13 +-
.../service/impl/DefaultECMHealthService.scala | 13 +-
.../service/impl/DefaultECMRegisterService.scala | 10 +-
.../impl/DefaultEngineConnListService.scala | 10 +-
.../DefaultEngineConnStatusCallbackService.scala | 4 +-
.../service/impl/DefaultOperateService.scala | 6 +-
.../engineconn/once/executor/OnceExecutor.scala | 19 +-
.../execution/OnceEngineConnExecution.scala | 2 +-
.../async/AsyncConcurrentComputationExecutor.scala | 12 +-
.../executor/bml/BmlEnginePreExecuteHook.scala | 2 +-
.../executor/conf/ComputationExecutorConf.scala | 4 +
.../creation/ComputationExecutorManager.scala | 4 +-
.../executor/cs/CSEnginePreExecuteHook.scala | 18 +-
.../computation/executor/cs/CSTableRegister.scala | 4 +-
.../executor/cs/CSTableResultSetWriter.scala | 6 +-
.../execute/ComputationEngineConnExecution.scala | 2 +-
.../executor/execute/ComputationExecutor.scala | 46 ++-
.../execute/ConcurrentComputationExecutor.scala | 8 +-
.../executor/execute/EngineExecutionContext.scala | 6 +-
.../executor/hook/ComputationExecutorHook.scala | 2 +-
.../computation/executor/hook/InitSQLHook.scala | 12 +-
.../executor/hook/UDFLoadEngineConnHook.scala | 16 +-
.../executor/hook/UseDatabaseEngineHook.scala | 4 +-
.../EngineResultsetPrefixExecutorHook.scala | 8 +-
.../executor/hook/executor/ExecuteOnceHook.scala | 4 +-
.../computation/executor/rs/RsOutputStream.scala | 2 +-
.../service/TaskExecutionServiceImpl.scala | 100 +++----
.../executor/upstream/ECTaskEntranceMonitor.scala | 4 +-
.../SingleThreadUpstreamConnectionMonitor.scala | 31 +-
.../upstream/access/ECTaskEntranceInfoAccess.scala | 4 +-
.../upstream/handler/ECTaskKillHandler.scala | 14 +-
.../service/ECTaskEntranceMonitorService.scala | 6 +-
.../wrapper/ECTaskEntranceConnectionWrapper.scala | 6 +-
.../access/ECTaskEntranceInfoAccessHelper.scala | 16 +-
.../linkis/engineconn/core/EngineConnObject.scala | 2 +-
.../AbstractCodeLanguageLabelExecutorFactory.scala | 4 +-
.../execution/AbstractEngineConnExecution.scala | 6 +-
.../core/execution/EngineConnExecution.scala | 2 +-
.../engineconn/core/executor/ExecutorManager.scala | 14 +-
.../linkis/engineconn/core/hook/ExecutorHook.scala | 2 +-
.../linkis/engineconn/core/hook/ShutdownHook.scala | 2 +-
.../engineconn/launch/EngineConnServer.scala | 28 +-
.../execution/AccessibleEngineConnExecution.scala | 18 +-
.../executor/lock/EngineConnTimedLock.scala | 24 +-
.../service/DefaultAccessibleService.scala | 22 +-
.../service/DefaultExecutorHeartbeatService.scala | 2 +-
.../executor/service/DefaultManagerService.scala | 6 +-
.../executor/service/DefaultOperateService.scala | 6 +-
.../service/EngineConnTimedLockService.scala | 20 +-
.../acessible/executor/service/LockService.scala | 2 +-
.../callback/hook/CallbackEngineConnHook.scala | 10 +-
.../engineconn/executor/entity/Executor.scala | 2 +-
.../executor/entity/SensibleExecutor.scala | 2 +-
.../listener/EngineConnSyncListenerBus.scala | 4 +-
.../engineconn/executor/service/LabelService.scala | 4 +-
.../linkis-engineconn-plugin-core/pom.xml | 0
.../engineplugin/common/EngineConnPlugin.scala | 0
.../common/conf/EngineConnPluginConf.scala | 2 +-
.../common/conf/EnvConfiguration.scala | 0
.../common/creation/EngineConnFactory.scala | 0
.../common/creation/ExecutorFactory.scala | 0
.../common/creation/LabelExecutorFactory.scala | 0
.../exception/EngineConnBuildFailedException.scala | 0
.../exception/EngineConnPluginErrorCode.scala | 0
.../exception/EngineConnPluginErrorException.scala | 0
.../exception/EngineConnPluginLoadException.scala | 0
.../EngineConnPluginLoadResourceException.scala | 0
.../EngineConnPluginNotFoundException.scala | 0
.../common/launch/EngineConnLaunchBuilder.scala | 0
.../launch/entity/EngineConnBuildRequest.scala | 0
.../launch/entity/EngineConnCreationDesc.scala | 0
.../launch/entity/EngineConnLaunchRequest.scala | 0
.../process/EngineConnResourceGenerator.scala | 0
.../common/launch/process/Environment.scala | 2 +-
.../JavaProcessEngineConnLaunchBuilder.scala | 2 +-
.../process/ProcessEngineConnLaunchBuilder.scala | 0
.../process/ProcessEngineConnLaunchRequest.scala | 0
.../common/loader/conf/PluginLoaderConstant.scala | 0
.../loader/entity/EngineConnPluginInfo.scala | 0
.../loader/entity/EngineConnPluginInstance.scala | 0
.../exception/EngineConnPluginLoadException.scala | 0
.../EngineConnPluginLoadResourceException.scala | 0
.../EngineConnPluginNotFoundException.scala | 0
.../resource/AbstractEngineResourceFactory.scala | 0
.../common/resource/EngineResourceFactory.scala | 0
.../common/resource/EngineResourceRequest.scala | 0
.../resource/GenericEngineResourceFactory.scala | 0
.../common/resource/UserNodeResource.scala | 0
.../linkis-engineconn-plugin-server/pom.xml | 0
.../src/main/assembly/distribution.xml | 69 ++---
.../engineplugin/cache/EngineConnPluginCache.java | 0
.../cache/GuavaEngineConnPluginCache.java | 0
.../cache/config/EngineConnPluginCacheConfig.java | 0
.../DefaultRefreshPluginCacheContainer.java | 0
.../cache/refresh/PluginCacheRefresher.java | 0
.../cache/refresh/RefreshPluginCacheContainer.java | 0
.../cache/refresh/RefreshPluginCacheOperation.java | 0
.../refresh/RefreshableEngineConnPluginCache.java | 0
.../classloader/EngineConnPluginClassLoader.java | 0
.../loaders/CacheablesEngineConnPluginLoader.java | 0
.../loaders/DefaultEngineConnPluginLoader.java | 0
.../loader/loaders/EngineConnPluginsLoader.java | 0
.../loaders/EngineConnPluginsResourceLoader.java | 0
.../BmlEngineConnPluginResourceLoader.java | 0
.../LocalEngineConnPluginResourceLoader.java | 0
.../loader/loaders/resource/PluginResource.java | 0
.../loader/utils/EngineConnPluginUtils.java | 0
.../engineplugin/loader/utils/ExceptionHelper.java | 0
.../server/LinkisEngineConnPluginServer.java | 0
.../conf/EngineConnPluginSpringConfiguration.java | 0
.../server/dao/EngineConnBmlResourceDao.java | 0
.../dao/impl/EngineConnBmlResourceMapper.xml | 0
.../server/entity/EngineConnBmlResource.java | 0
.../server/restful/EnginePluginRestful.java | 0
.../loader/EngineConnPluginLoaderConf.scala | 0
.../conf/EngineConnPluginConfiguration.scala | 0
.../interceptor/EngineConnLaunchInterceptor.scala | 0
.../server/loader/EngineConnPluginsLoader.scala | 0
.../AbstractEngineConnBmlResourceGenerator.scala | 0
.../DefaultEngineConnBmlResourceGenerator.scala | 2 +-
.../localize/EngineConnBmlResourceGenerator.scala | 0
.../service/DefaultEngineConnLaunchService.scala | 2 +-
.../DefaultEngineConnResourceFactoryService.scala | 2 +-
.../service/DefaultEngineConnResourceService.scala | 18 +-
.../server/service/EngineConnLaunchService.scala | 0
.../service/EngineConnResourceFactoryService.scala | 0
.../server/service/EngineConnResourceService.scala | 0
.../loader/EngineConnPluginLoaderTest.java | 0
.../linkis-engineconn/pom.xml | 2 +
.../entrance/restful/EntranceLabelRestfulApi.java | 6 +
.../apache/linkis/entrance/EntranceServer.scala | 16 +-
.../linkis/entrance/EntranceWebSocketService.scala | 20 +-
.../entrance/cli/heartbeat/KillHandler.scala | 4 +-
.../linkis/entrance/cs/CSEntranceHelper.scala | 16 +-
.../entrance/execute/DefaultEntranceExecutor.scala | 18 +-
.../entrance/execute/EntranceExecutorManager.scala | 5 +-
.../linkis/entrance/execute/EntranceJob.scala | 26 +-
.../entrance/interceptor/RuntypeInterceptor.scala | 2 +-
.../linkis/entrance/interceptor/impl/Explain.scala | 2 +-
.../impl/PythonCodeCheckInterceptor.scala | 2 +-
.../impl/ShellDangerousGrammerInterceptor.scala | 8 +-
.../linkis/entrance/log/CacheLogReader.scala | 2 +-
.../EntranceUserParallelOrchestratorPlugin.scala | 11 +-
.../entrance/parser/CommonEntranceParser.scala | 11 +-
.../scheduler/cache/ReadCacheConsumer.scala | 6 +-
.../scheduler/cache/ReadCacheConsumerManager.scala | 4 +-
.../entrance/timeout/JobTimeoutManager.scala | 12 +-
.../am/restful/ECResourceInfoRestfulApi.java | 43 +--
.../manager/am/service/ECResourceInfoService.java | 2 +-
.../am/service/impl/ECResourceInfoServiceImpl.java | 4 +-
.../manager/am/util/ECResourceInfoUtils.java | 42 +++
.../manager/am/vo/ECResourceInfoRecordVo.java | 36 +--
.../apache/linkis/manager/am/vo/ResourceVo.java | 31 +-
.../label/MultiUserEngineReuseLabelChooser.scala | 2 +-
.../am/locker/DefaultEngineNodeLocker.scala | 4 +-
.../manager/am/manager/DefaultEMNodeManager.scala | 8 +-
.../manager/am/pointer/DefaultEMNodPointer.scala | 6 +-
.../am/selector/rule/AvailableNodeSelectRule.scala | 2 +-
.../am/selector/rule/OverLoadNodeSelectRule.scala | 2 +-
.../am/selector/rule/ResourceNodeSelectRule.scala | 4 +-
.../am/selector/rule/ScoreNodeSelectRule.scala | 2 +-
.../am/selector/rule/TaskInfoNodeSelectRule.scala | 2 +-
.../am/service/em/DefaultEMEngineService.scala | 6 +-
.../am/service/em/DefaultEMRegisterService.scala | 14 +-
.../am/service/em/DefaultEMUnregisterService.scala | 10 +-
.../engine/DefaultEngineCreateService.scala | 10 +-
.../service/engine/DefaultEngineInfoService.scala | 2 +-
.../engine/DefaultEngineRecycleService.scala | 8 +-
.../service/engine/DefaultEngineStopService.scala | 8 +-
.../am/service/heartbeat/AMHeartbeatService.scala | 4 +-
.../am/service/monitor/NodeHeartbeatMonitor.scala | 18 +-
.../service/impl/DefaultNodeLabelAddService.scala | 8 +-
.../impl/DefaultNodeLabelRemoveService.scala | 4 +-
.../service/impl/DefaultNodeLabelService.scala | 4 +-
.../rm/external/yarn/YarnResourceRequester.scala | 20 +-
.../manager/rm/message/RMMessageService.scala | 4 +-
.../linkis/manager/rm/restful/RMMonitorRest.scala | 23 +-
.../manager/rm/service/ResourceLockService.scala | 10 +-
.../rm/service/impl/DefaultResourceManager.scala | 24 +-
.../manager/rm/utils/UserConfiguration.scala | 4 +-
.../manager/label/entity/engine/EngineType.scala | 2 +-
.../manager/common/entity/resource/Resource.scala | 2 +-
.../manager/common/operator/OperatorFactory.scala | 2 +-
.../linkis/manager/dao/ECResourceRecordMapper.java | 3 +-
.../manager/dao/impl/ECResourceRecordMapper.xml | 1 +
.../java/{ => org/apache/linkis/manager}/Scan.java | 2 +
.../manager/persistence}/PersistenceTest.java | 11 +-
linkis-dist/bin/checkEnv.sh | 4 +-
.../conf/{ => linkis-cli}/linkis-cli.properties | 0
linkis-dist/package/conf/linkis-cli/log4j2.xml | 49 ++++
.../package/conf/linkis-mg-gateway.properties | 4 +-
.../conf/linkis-ps-publicservice.properties | 2 +-
linkis-dist/package/conf/linkis.properties | 2 +-
linkis-dist/package/db/linkis_ddl.sql | 13 +-
linkis-dist/package/db/linkis_dml.sql | 22 +-
.../package/db/module/linkis_datasource.sql | 8 +-
linkis-dist/package/sbin/graceful-upgrade.sh | 4 +-
linkis-dist/src/main/assembly/distribution.xml | 43 +--
.../{engineconn-plugins => }/elasticsearch/pom.xml | 2 +-
.../src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../elasticsearch/src/main/resources/log4j2.xml | 0
.../ElasticSearchEngineConnPlugin.scala | 0
...asticSearchProcessEngineConnLaunchBuilder.scala | 0
.../conf/ElasticSearchConfiguration.scala | 0
.../exception/EsConvertResponseException.scala | 0
.../exception/EsEngineException.scala | 0
.../exception/EsParamsIllegalException.scala | 0
.../executer/ElasticSearchEngineConnExecutor.scala | 0
.../executer/ElasticSearchExecutorOrder.scala | 0
.../executer/client/ElasticSearchExecutor.scala | 0
.../executer/client/ElasticSearchResponse.scala | 0
.../elasticsearch/executer/client/EsClient.scala | 0
.../executer/client/EsClientFactory.scala | 0
.../executer/client/ResponseHandler.scala | 0
.../client/impl/ElasticSearchExecutorImpl.scala | 0
.../executer/client/impl/ResponseHandlerImpl.scala | 0
.../factory/ElasticSearchEngineConnFactory.scala | 0
.../factory/ElasticSearchJsonExecutorFactory.scala | 0
.../factory/ElasticSearchSqlExecutorFactory.scala | 0
.../{engineconn-plugins => }/flink/pom.xml | 2 +-
.../flink/src/main/assembly/distribution.xml | 0
.../flink/client/config/Environment.java | 0
.../flink/client/config/entries/ConfigEntry.java | 0
.../client/config/entries/ExecutionEntry.java | 0
.../flink/client/context/ExecutionContext.java | 0
.../deployment/ClusterDescriptorAdapter.java | 0
.../ClusterDescriptorAdapterFactory.java | 0
.../YarnApplicationClusterDescriptorAdapter.java | 0
.../YarnPerJobClusterDescriptorAdapter.java | 0
.../YarnSessionClusterDescriptorAdapter.scala | 0
.../factory/LinkisYarnClusterClientFactory.java | 0
.../flink/client/result/AbstractResult.java | 0
.../flink/client/result/BatchResult.java | 0
.../flink/client/result/ChangelogResult.java | 0
.../flink/client/result/Result.java | 0
.../flink/client/result/ResultUtil.java | 0
.../flink/client/result/TypedResult.java | 0
.../client/sql/operation/AbstractJobOperation.java | 0
.../flink/client/sql/operation/JobOperation.java | 0
.../client/sql/operation/NonJobOperation.java | 0
.../flink/client/sql/operation/Operation.java | 0
.../client/sql/operation/OperationFactory.java | 0
.../client/sql/operation/OperationFactoryImpl.java | 0
.../flink/client/sql/operation/OperationUtil.java | 0
.../sql/operation/impl/CreateViewOperation.java | 0
.../client/sql/operation/impl/DDLOperation.java | 0
.../sql/operation/impl/DescribeTableOperation.java | 0
.../sql/operation/impl/DropViewOperation.java | 0
.../sql/operation/impl/ExplainOperation.java | 0
.../client/sql/operation/impl/InsertOperation.java | 0
.../client/sql/operation/impl/ResetOperation.java | 0
.../client/sql/operation/impl/SelectOperation.java | 0
.../client/sql/operation/impl/SetOperation.java | 0
.../sql/operation/impl/ShowCatalogsOperation.java | 0
.../impl/ShowCurrentCatalogOperation.java | 0
.../impl/ShowCurrentDatabaseOperation.java | 0
.../sql/operation/impl/ShowDatabasesOperation.java | 0
.../sql/operation/impl/ShowFunctionsOperation.java | 0
.../sql/operation/impl/ShowModulesOperation.java | 0
.../sql/operation/impl/ShowTablesOperation.java | 0
.../sql/operation/impl/ShowViewsOperation.java | 0
.../sql/operation/impl/UseCatalogOperation.java | 0
.../sql/operation/impl/UseDatabaseOperation.java | 0
.../client/sql/operation/result/ColumnInfo.java | 0
.../client/sql/operation/result/ConstantNames.java | 0
.../client/sql/operation/result/ResultKind.java | 0
.../client/sql/operation/result/ResultSet.java | 0
.../result/ResultSetJsonDeserializer.java | 0
.../operation/result/ResultSetJsonSerializer.java | 0
.../flink/client/sql/parser/SqlCommand.java | 0
.../flink/client/sql/parser/SqlCommandCall.java | 0
.../flink/client/sql/parser/SqlCommandParser.java | 0
.../client/sql/parser/SqlCommandParserImpl.java | 0
.../flink/client/utils/YarnConfLoader.java | 0
.../flink/exception/ExecutorInitException.java | 0
.../flink/exception/FlinkInitFailedException.java | 0
.../flink/exception/JobExecutionException.java | 0
.../flink/exception/SqlExecutionException.java | 0
.../flink/exception/SqlParseException.java | 0
.../src/main/resources/flink-sql-defaults.yaml | 0
.../main/resources/linkis-engineconn.properties | 0
.../flink/src/main/resources/log4j2.xml | 0
.../flink/FlinkEngineConnPlugin.scala | 0
.../flink/config/FlinkEnvConfiguration.scala | 0
.../flink/config/FlinkResourceConfiguration.scala | 0
.../flink/context/EnvironmentContext.scala | 0
.../flink/context/FlinkEngineConnContext.scala | 0
.../flink/executor/FlinkCodeOnceExecutor.scala | 18 +-
.../flink/executor/FlinkExecutor.scala | 0
.../flink/executor/FlinkJarOnceExecutor.scala | 4 +-
.../flink/executor/FlinkOnceExecutor.scala | 8 +-
.../executor/FlinkSQLComputationExecutor.scala | 22 +-
.../executormanager/FlinkExecutorManager.scala | 0
.../factory/FlinkApplicationExecutorFactory.scala | 0
.../flink/factory/FlinkCodeExecutorFactory.scala | 0
.../flink/factory/FlinkEngineConnFactory.scala | 18 +-
.../flink/factory/FlinkSQLExecutorFactory.scala | 0
.../launch/FlinkEngineConnLaunchBuilder.scala | 4 +-
.../flink/listener/FlinkListener.scala | 2 +-
.../flink/listener/FlinkListenerGroup.scala | 0
.../flink/operator/TriggerSavepointOperator.scala | 3 +-
.../linkis/engineconnplugin/flink/ql/Grammar.scala | 0
.../engineconnplugin/flink/ql/GrammarFactory.scala | 0
.../flink/ql/impl/CreateTableAsSelectGrammar.scala | 2 +-
.../resource/FlinkEngineConnResourceFactory.scala | 0
.../flink/setting/HudiSettings.scala | 13 +-
.../engineconnplugin/flink/setting/Settings.scala | 0
.../engineconnplugin/flink/util/ClassUtil.scala | 0
.../flink/util/FlinkValueFormatUtil.scala | 0
.../{engineconn-plugins => }/hive/pom.xml | 2 +-
.../hive/src/main/assembly/distribution.xml | 0
.../linkis/engineplugin/hive/log/HiveProgress.java | 0
.../hive/serde/CustomerDelimitedJSONSerDe.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../hive/src/main/resources/log4j2.xml | 0
.../engineplugin/hive/HiveEngineConnPlugin.scala | 0
.../engineplugin/hive/common/HiveUtils.scala | 0
.../linkis/engineplugin/hive/conf/Counters.scala | 0
.../hive/conf/HiveEngineConfiguration.scala | 0
.../hive/creation/HiveEngineConnFactory.scala | 4 +-
.../linkis/engineplugin/hive/cs/CSHiveHelper.scala | 0
.../engineplugin/hive/entity/HiveSession.scala | 0
.../exception/NotSupportedHiveTypeException.scala | 0
.../hive/executor/HiveEngineConnExecutor.scala | 50 ++--
.../hive/hook/HiveAddJarsEngineHook.scala | 2 +-
.../hive/hook/HiveAddMetaTableNameHook.scala | 2 +-
.../HiveProcessEngineConnLaunchBuilder.scala | 0
.../linkis/engineplugin/hive/log/LogHelper.scala | 0
.../hive/progress/HiveProgressHelper.scala | 0
.../{engineconn-plugins => }/io_file/pom.xml | 2 +-
.../io_file/src/main/assembly/distribution.xml | 0
.../engineplugin/io/utils/ReflectionUtils.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../io_file/src/main/resources/log4j2.xml | 0
.../engineplugin/io/IoEngineConnPlugin.scala | 0
.../builder/IoProcessEngineConnLaunchBuilder.scala | 0
.../io/conf/IOEngineConnConfiguration.scala | 0
.../manager/engineplugin/io/domain/FSInfo.scala | 0
.../io/executor/IoEngineConnExecutor.scala | 14 +-
.../io/factory/IoEngineConnFactory.scala | 0
.../engineplugin/io/service/FsProxyService.scala | 0
.../manager/engineplugin/io/utils/IOHelp.scala | 0
.../{engineconn-plugins => }/jdbc/pom.xml | 4 +-
.../jdbc/src/main/assembly/distribution.xml | 0
.../engineplugin/jdbc/ConnectionManager.java | 0
.../jdbc/JDBCDataSourceConfigurations.java | 0
.../engineplugin/jdbc/JDBCPropertiesParser.java | 0
.../manager/engineplugin/jdbc/JdbcAuthType.java | 0
.../engineplugin/jdbc/PropertiesParser.java | 0
.../jdbc/constant/JDBCEngineConnConstant.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../jdbc/src/main/resources/log4j2.xml | 0
.../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 0
.../JDBCProcessEngineConnLaunchBuilder.scala | 0
.../engineplugin/jdbc/conf/JDBCConfiguration.scala | 0
.../exception/JDBCParamsIllegalException.scala | 0
.../jdbc/executer/JDBCEngineConnExecutor.scala | 47 +--
.../engineplugin/jdbc/executer/JDBCHelper.java | 0
.../jdbc/executer/JDBCMultiDatasourceParser.scala | 8 +-
.../jdbc/executer/JDBCSQLCodeParser.scala | 0
.../jdbc/factory/JDBCEngineConnFactory.scala | 0
.../engineplugin/jdbc/ConnectionManagerTest.java | 0
.../executer/JDBCMultiDatasourceParserTest.scala | 0
.../TestJDBCEngineConnExecutor.scala | 5 +-
.../src/main/assembly/distribution.xml | 59 ----
.../{engineconn-plugins => }/openlookeng/pom.xml | 4 +-
.../openlookeng/src/main/assembly/distribution.xml | 0
.../builder/OpenLooKengProcessECLaunchBuilder.java | 0
.../openlookeng/conf/OpenLooKengConfiguration.java | 0
.../conf/OpenLooKengEngineConfCache.java | 0
.../exception/OpenLooKengClientException.java | 0
.../exception/OpenLooKengSourceGroupException.java | 0
.../OpenLooKengStateInvalidException.java | 0
.../executor/OpenLooKengEngineConnExecutor.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../openlookeng/src/main/resources/log4j2.xml | 0
.../openlookeng/OpenLooKengECPlugin.scala | 0
.../factory/OpenLooKengEngineConnFactory.scala | 0
.../{engineconn-plugins => }/pipeline/pom.xml | 2 +-
.../pipeline/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../pipeline/src/main/resources/log4j2.xml | 0
.../pipeline/PipelineEngineConnPlugin.scala | 0
.../builder/PipelineEngineConnLaunchBuilder.scala | 0
.../conf/PipelineEngineConfiguration.scala | 0
.../pipeline/constant/PipeLineConstant.scala | 0
.../pipeline/conversions/FsConvertions.scala | 0
.../exception/PipeLineErrorException.scala | 0
.../pipeline/executor/CSVExecutor.scala | 0
.../pipeline/executor/CopyExecutor.scala | 0
.../pipeline/executor/ExcelExecutor.scala | 0
.../pipeline/executor/OutputStreamCache.scala | 0
.../pipeline/executor/PipeLineExecutor.scala | 0
.../executor/PipelineEngineConnExecutor.scala | 4 +-
.../executor/PipelineExecutorSelector.scala | 2 +-
.../factory/PipelineEngineConnFactory.scala | 0
linkis-engineconn-plugins/pom.xml | 23 +-
.../{engineconn-plugins => }/presto/pom.xml | 2 +-
.../presto/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../presto/src/main/resources/log4j2.xml | 0
.../presto/PrestoEngineConnPlugin.scala | 0
.../PrestoProcessEngineConnLaunchBuilder.scala | 0
.../presto/conf/PrestoConfiguration.scala | 0
.../presto/exception/PrestoException.scala | 0
.../presto/executer/PrestoEngineConnExecutor.scala | 0
.../presto/factory/PrestoEngineConnFactory.scala | 0
.../{engineconn-plugins => }/python/pom.xml | 2 +-
.../python/src/main/assembly/distribution.xml | 0
.../python/src/main/py4j/py4j-0.10.9.5-src.zip | Bin
.../main/resources/linkis-engineconn.properties | 0
.../python/src/main/resources/log4j2.xml | 0
.../python/src/main/resources/python/python.py | 0
.../python/PythonEngineConnPlugin.scala | 0
.../python/conf/PythonEngineConfiguration.scala | 0
.../exception/NoSupportEngineException.scala | 0
.../exception/PythonSessionNullException.scala | 0
.../python/executor/PythonEngineConnExecutor.scala | 23 +-
.../python/executor/PythonSession.scala | 36 +--
.../python/factory/PythonEngineConnFactory.scala | 0
.../python/hook/PythonVersionEngineHook.scala | 2 +-
.../PythonProcessEngineConnLaunchBuilder.scala | 0
.../manager/engineplugin/python/utils/Kind.scala | 0
.../manager/engineplugin/python/utils/State.scala | 0
.../{engineconn-plugins => }/shell/pom.xml | 0
.../shell/src/main/assembly/distribution.xml | 0
.../shell/src/main/resources/bin/kill-yarn-jobs.sh | 0
.../resources/conf/linkis-engineconn.properties | 0
.../shell/src/main/resources/conf/log4j2.xml | 0
.../engineplugin/shell/ShellEngineConnPlugin.scala | 0
.../ShellProcessEngineConnLaunchBuilder.scala | 0
.../shell/common/ShellEnginePluginConst.scala | 0
.../shell/exception/NoCorrectUserException.scala | 0
.../shell/executor/ErrorStreamReaderThread.scala | 12 +-
.../shell/executor/ShellEngineConnExecutor.scala | 48 ++--
.../shell/executor/YarnAppIdExtractor.scala | 6 +-
.../shell/factory/ShellEngineConnFactory.scala | 0
.../{engineconn-plugins => }/spark/pom.xml | 2 +-
.../spark/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../spark/src/main/resources/log4j2.xml | 0
.../spark/src/main/resources/python/mix_pyspark.py | 0
.../spark/Interpreter/Interpreter.scala | 0
.../spark/Interpreter/ProcessInterpreter.scala | 0
.../spark/Interpreter/PythonInterpreter.scala | 4 +-
.../engineplugin/spark/SparkEngineConnPlugin.scala | 0
.../spark/args/SparkPythonArgsAppender.scala | 0
.../args/SparkPythonArgsPreExecutionHook.scala | 23 +-
.../spark/args/SparkScalaPreExecutionHook.scala | 0
.../linkis/engineplugin/spark/common/Kind.scala | 0
.../spark/common/LineBufferedProcess.scala | 0
.../spark/common/LineBufferedStream.scala | 0
.../engineplugin/spark/common/LogContainer.scala | 0
.../spark/common/SparkEnginePluginConst.scala | 0
.../engineplugin/spark/common/SparkKind.scala | 0
.../linkis/engineplugin/spark/common/State.scala | 0
.../spark/config/SparkConfiguration.scala | 1 -
.../spark/config/SparkResourceConfiguration.scala | 0
.../engineplugin/spark/cs/CSSparkHelper.scala | 0
.../spark/cs/CSSparkPostExecutionHook.scala | 4 +-
.../spark/cs/CSSparkPreExecutionHook.scala | 6 +-
.../engineplugin/spark/cs/CSTableParser.scala | 0
.../spark/entity/SparkEngineSession.scala | 0
.../ApplicationAlreadyStoppedException.scala | 0
.../spark/exception/ExecuteError.scala | 0
.../spark/exception/MDQErrorException.scala | 0
.../spark/exception/NoSupportEngineException.scala | 0
.../spark/exception/QueryFailedException.scala | 0
.../spark/exception/RetryException.scala | 0
.../spark/exception/SparkCreateFileException.scala | 0
.../exception/SparkSessionNullException.scala | 0
.../engineplugin/spark/executor/SQLSession.scala | 0
.../spark/executor/SparkEngineConnExecutor.scala | 20 +-
.../spark/executor/SparkExecutorOrder.scala | 0
.../spark/executor/SparkPythonExecutor.scala | 46 +--
.../spark/executor/SparkScalaExecutor.scala | 51 ++--
.../spark/executor/SparkSqlExecutor.scala | 12 +-
.../spark/extension/SparkPostExecutionHook.scala | 2 +-
.../spark/extension/SparkPreExecutionHook.scala | 2 +-
.../spark/extension/SparkSqlExtension.scala | 2 +-
.../spark/factory/SparkEngineConnFactory.scala | 10 +-
.../factory/SparkEngineConnResourceFactory.scala | 0
.../spark/factory/SparkPythonExecutorFactory.scala | 0
.../spark/factory/SparkScalaExecutorFactory.scala | 0
.../spark/factory/SparkSqlExecutorFactory.scala | 0
.../engineplugin/spark/imexport/CsvRelation.scala | 6 +-
.../engineplugin/spark/imexport/ExportData.scala | 4 +-
.../engineplugin/spark/imexport/LoadData.scala | 0
.../imexport/util/BackGroundServiceUtils.scala | 0
.../spark/imexport/util/ImExportUtils.scala | 0
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 0
.../spark/lineage/LineageSparkSqlExtension.scala | 6 +-
.../spark/lineage/SparkLineageUtils.scala | 0
.../spark/mdq/MDQPostExecutionHook.scala | 4 +-
.../spark/mdq/MDQPreExecutionHook.scala | 2 +-
.../engineplugin/spark/metadata/HPOBuilder.scala | 0
.../spark/metadata/MetaDataInfoTool.scala | 6 +-
.../spark/metadata/SparkHiveObject.scala | 0
.../spark/metadata/SparkSQLHistoryParser.scala | 0
.../engineplugin/spark/utils/EngineUtils.scala | 2 +-
.../engineplugin/spark/utils/JobProgressUtil.scala | 2 +-
.../org/apache/spark/sql/MethodInvokeHelper.scala | 0
.../apache/spark/sql/SparkLogicalPlanHelper.scala | 0
.../execution/datasources/csv/DolphinToSpark.scala | 0
.../spark/sql/execution/datasources/csv/UDF.scala | 0
.../scala/org/apache/spark/util/SparkUtils.scala | 0
.../{engineconn-plugins => }/sqoop/pom.xml | 0
.../sqoop/src/main/assembly/distribution.xml | 0
.../sqoop/client/LinkisSqoopClient.java | 0
.../engineconnplugin/sqoop/client/Sqoop.java | 0
.../sqoop/client/config/ExecutionContext.java | 0
.../sqoop/client/config/ParamsMapping.java | 0
.../client/exception/JobClosableException.java | 0
.../client/exception/JobExecutionException.java | 0
.../sqoop/client/utils/JarLoader.java | 0
.../java/org/apache/sqoop/mapreduce/JobBase.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../sqoop/src/main/resources/log4j2.xml | 0
.../sqoop/SqoopEngineConnPlugin.scala | 0
.../sqoop/context/SqoopEngineConnContext.scala | 0
.../sqoop/context/SqoopEnvConfiguration.scala | 0
.../sqoop/context/SqoopParamsConfiguration.scala | 0
.../sqoop/context/SqoopResourceConfiguration.scala | 0
.../sqoop/executor/SqoopExecutor.scala | 0
.../sqoop/executor/SqoopOnceCodeExecutor.scala | 32 +--
.../sqoop/executor/SqoopOnceExecutor.scala | 0
.../sqoop/factory/SqoopEngineConnFactory.scala | 0
.../sqoop/factory/SqoopExecutorFactory.scala | 0
.../launch/SqoopEngineConnLaunchBuilder.scala | 2 +-
.../sqoop/params/SqoopParamsResolver.scala | 0
.../resource/SqoopEngineConnResourceFactory.scala | 0
.../engineconnplugin/sqoop/util/ClassUtil.scala | 0
.../linkis/storage/io/client/DefaultIOClient.scala | 47 +--
.../linkis/storage/io/conf/IOFileClientConf.scala | 2 +
.../io/iteraceptor/IOMethodInterceptor.scala | 12 +-
.../IOMethodInterceptorCreatorImpl.scala | 2 +-
.../io/orchestrator/IOTaskPlannerTransform.scala | 2 +-
.../execution/CodeReheaterNotifyTaskConsumer.scala | 2 +-
...ComputationOrchestratorSessionFactoryImpl.scala | 10 +-
.../physical/AbstractPhysicalTransform.scala | 6 +-
.../catalyst/planner/TaskPlannerTransform.scala | 6 +-
.../validator/LabelRegularCheckRuler.scala | 6 +-
.../DefaultCodeExecTaskExecutorManager.scala | 51 ++--
.../computation/monitor/EngineConnMonitor.scala | 28 +-
.../physical/CodeLogicalUnitExecTask.scala | 23 +-
.../service/ComputationTaskExecutionReceiver.scala | 4 +-
.../apache/linkis/orchestrator/Orchestrator.scala | 2 +-
.../orchestrator/converter/AbstractConverter.scala | 4 +-
.../orchestrator/core/AbstractOrchestration.scala | 22 +-
.../orchestrator/core/OrchestrationFuture.scala | 2 +
.../orchestrator/core/impl/SessionStateImpl.scala | 2 +-
.../exception/OrchestratorErrorCodeSummary.scala | 2 +
.../orchestrator/execution/AbstractExecution.scala | 4 +-
.../orchestrator/execution/ExecTaskRunner.scala | 2 +-
.../execution/impl/BaseExecutionTask.scala | 4 +-
.../execution/impl/BaseTaskScheduler.scala | 8 +-
.../execution/impl/DefaultTaskManager.scala | 8 +-
.../execution/impl/ExecutionImpl.scala | 4 +-
.../extensions/catalyst/TransformFactory.scala | 2 +-
.../listener/OrchestratorSyncListenerBus.scala | 4 +-
.../orchestrator/optimizer/AbstractOptimizer.scala | 8 +-
.../orchestrator/parser/AbstractParser.scala | 6 +-
.../orchestrator/planner/AbstractPlanner.scala | 4 +-
.../orchestrator/reheater/AbstractReheater.scala | 2 +-
.../strategy/GatherStrategyJobExecTask.scala | 4 +-
.../orchestrator/strategy/StatusInfoExecTask.scala | 2 +-
.../strategy/async/AsyncExecTaskRunnerImpl.scala | 6 +-
.../strategy/async/AsyncTaskManager.scala | 10 +-
.../ecm/ComputationEngineConnManager.scala | 28 +-
.../orchestrator/ecm/EngineConnManager.scala | 15 +-
.../ecm/EngineConnManagerBuilder.scala | 2 +-
.../ecm/LoadBalanceLabelEngineConnManager.scala | 28 +-
.../ecm/cache/EngineAsyncResponseCache.scala | 8 +-
.../impl/ComputationEngineConnExecutor.scala | 20 +-
.../impl/DefaultEngineAsyncResponseService.scala | 6 +-
.../linkis/bml/client/impl/HttpBmlClient.scala | 3 +-
.../org/apache/linkis/bml/http/HttpConf.scala | 3 +-
.../linkis/bml/common/HdfsResourceHelper.java | 6 +
.../linkis/bml/common/LocalResourceHelper.java | 6 +
.../apache/linkis/bml/common/ResourceHelper.java | 8 +
.../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 | 4 +-
.../apache/linkis/bml/dao/impl/DownloadMapper.xml | 4 +-
.../apache/linkis/bml/dao/impl/ResourceMapper.xml | 4 +-
.../org/apache/linkis/bml/dao/impl/TaskMapper.xml | 4 +-
.../apache/linkis/bml/dao/impl/VersionMapper.xml | 6 +-
.../linkis/bml/{Entity => entity}/BmlProject.java | 2 +-
.../bml/{Entity => entity}/DownloadModel.java | 2 +-
.../linkis/bml/{Entity => entity}/Resource.java | 2 +-
.../bml/{Entity => entity}/ResourceTask.java | 2 +-
.../bml/{Entity => entity}/ResourceVersion.java | 2 +-
.../linkis/bml/{Entity => entity}/Version.java | 2 +-
.../linkis/bml/restful/BmlProjectRestful.java | 4 +-
.../apache/linkis/bml/restful/BmlRestfulApi.java | 10 +-
.../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 | 4 +-
.../bml/service/impl/BmlProjectServiceImpl.java | 2 +-
.../bml/service/impl/DownloadServiceImpl.java | 2 +-
.../bml/service/impl/ResourceServiceImpl.java | 4 +-
.../linkis/bml/service/impl/TaskServiceImpl.java | 8 +-
.../bml/service/impl/VersionServiceImpl.java | 12 +-
.../apache/linkis/bml/vo/ResourceVersionsVO.java | 2 +-
.../linkis/bml/common/HdfsResourceHelperTest.java} | 37 +--
.../bml/common/LocalResourceHelperTest.java} | 38 +--
.../linkis/bml/common/VersionServiceImplTest.java | 50 ++++
.../impl/InstanceAliasManagerImpl.scala | 2 +-
.../impl/RouteLabelInstanceAliasConverter.scala | 16 +-
.../core/dao/DataSourceParamKeyDao.java | 8 +
.../core/dao/mapper/DataSourceParamKeyMapper.xml | 12 +-
.../core/restful/DataSourceCoreRestfulApi.java | 6 +-
.../core/service/DataSourceRelateService.java | 10 +
.../service/impl/DataSourceRelateServiceImpl.java | 10 +
.../core/receivers/DsmReceiver.scala | 6 +-
.../query/server/receiver/BaseMetaReceiver.scala | 4 +-
.../query/service/ElasticConnection.java | 2 +-
.../query/service/ElasticParamsMapper.java | 2 +-
.../query/service/EsMetaService.java | 2 +-
.../query/service/HiveConnection.java | 2 +-
.../query/service/HiveMetaService.java | 2 +-
.../query/service/HiveParamsMapper.java | 2 +-
.../query/service/KafkaConnection.java | 2 +-
.../query/service/KafkaMetaService.java | 2 +-
.../query/service/KafkaParamsMapper.java | 2 +-
.../query/service/MysqlMetaService.java | 2 +-
.../query/service/SqlConnection.java | 2 +-
.../query/service/SqlParamsMapper.java | 2 +-
.../linkis/metadata/hive/dao/HiveMetaDao.java | 54 +++-
.../linkis/metadata/hive/dao/impl/HiveMetaDao.xml | 200 ++++++-------
.../metadata/hive/dto/MetadataQueryParam.java | 144 ++++++++++
.../metadata/restful/api/DataSourceRestfulApi.java | 30 +-
.../metadata/restful/api/MdqTableRestfulApi.java | 17 +-
.../linkis/metadata/service/DataSourceService.java | 15 +-
.../service/HiveMetaWithPermissionService.java | 6 +-
.../apache/linkis/metadata/service/MdqService.java | 14 +-
.../service/impl/DataSourceServiceImpl.java | 84 +++---
.../impl/HiveMetaWithPermissionServiceImpl.java | 43 +--
.../metadata/service/impl/MdqServiceImpl.java | 80 +++---
.../org/apache/linkis/metadata/util/DWSConfig.java | 2 +-
.../org/apache/linkis/metadata/util/HiveUtils.java | 7 +-
.../linkis/metadata/utils/MdqConstants.scala | 6 -
.../apache/linkis/metadata/utils/MdqUtils.scala | 9 +-
.../configuration/service/CategoryService.scala | 14 +-
.../service/ConfigurationService.scala | 16 +-
.../configuration/validate/FloatValidator.scala | 2 +-
.../validate/NumericalValidator.scala | 2 +-
.../validate/ValidatorManagerImpl.scala | 2 +-
.../errorcode/client/utils/ErrorCodeMatcher.scala | 2 +-
.../label/client/EurekaInstanceLabelClient.scala | 8 +-
.../label/client/InstanceLabelClient.scala | 6 +-
.../service/rpc/DefaultInsLabelRpcService.scala | 16 +-
.../cache/impl/DefaultQueryCacheManager.java | 21 +-
.../linkis/jobhistory/cache/utils/MD5Util.java | 9 +-
.../jobhistory/restful/api/QueryRestfulApi.java | 5 +
.../jobhistory/conversions/TaskConversions.scala | 19 +-
.../impl/JobHistoryDetailQueryServiceImpl.scala | 25 +-
.../service/impl/JobHistoryQueryServiceImpl.scala | 18 +-
.../apache/linkis/jobhistory/util/QueryUtils.scala | 6 +-
.../exception/WorkspaceExceptionManager.java | 3 +-
.../filesystem/restful/api/FsRestfulApi.java | 3 +-
.../apache/linkis/filesystem/quartz/FSQuartz.scala | 6 +-
.../linkis/filesystem/service/FsService.scala | 25 +-
.../linkis-gateway-authentication/pom.xml | 14 +
.../linkis-gateway-core/pom.xml | 12 +
.../linkis/gateway/parser/GatewayParser.scala | 6 +-
.../linkis/gateway/route/GatewayRouter.scala | 8 +-
.../linkis/gateway/security/LDAPUserRestful.scala | 2 +-
.../linkis/gateway/security/LinkisPreFilter.scala | 2 +-
.../linkis/gateway/security/ProxyUserUtils.scala | 4 +-
.../linkis/gateway/security/SecurityFilter.scala | 10 +-
.../linkis/gateway/security/UserRestful.scala | 29 +-
.../security/token/TokenAuthentication.scala | 2 +-
.../linkis/httpclient/dws/DWSHttpClient.scala | 2 +-
.../dws/discovery/DWSGatewayDiscovery.scala | 2 +-
.../dws/response/DWSHeartbeatResult.scala | 2 +-
.../src/main/assembly/distribution.xml | 6 +
.../ujes/parser/ResultSetCacheGatewayParser.scala | 4 +-
.../ujes/route/AbstractLabelGatewayRouter.scala | 2 +-
.../gateway/ujes/route/EntranceGatewayRouter.scala | 4 +-
.../ujes/route/GatewayRouterConfiguration.scala | 7 +-
.../ujes/route/HaContextGatewayRouter.scala | 4 +-
.../route/contextservice/ContextIdParserImpl.scala | 4 +-
.../ujes/route/label/RouteLabelParser.scala | 2 +-
.../SpringCloudGatewayConfiguration.scala | 13 +-
.../SpringCloudGatewayWebsocketUtils.scala | 4 +-
.../websocket/WebsocketGatewaySession.scala | 4 +-
pom.xml | 10 +-
scalastyle-config.xml | 2 +-
tool/dependencies/known-dependencies.txt | 51 +++-
tool/modify_license.sh | 12 +-
829 files changed, 3654 insertions(+), 2556 deletions(-)
copy linkis-commons/linkis-scheduler/src/main/scala/org/apache/linkis/scheduler/future/BDPFuture.scala => license-header (83%)
copy linkis-engineconn-plugins/engineconn-plugins/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/exception/OpenLooKengStateInvalidException.java => linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/VariableOperationFailedException.java (72%)
create mode 100644 linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/utils/VariableOperationUtils.java
create mode 100644 linkis-commons/linkis-common/src/test/java/org/apache/linkis/common/variable/VariableOperationTest.java
create mode 100644 linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/Knife4jConfig.scala
delete mode 100644 linkis-commons/linkis-protocol/src/main/scala/org/apache/linkis/protocol/engine/EngineState.scala
create mode 100644 linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/message/utils/MessageUtilsTest.java
copy linkis-commons/linkis-scheduler/src/{main/scala/org/apache/linkis/scheduler/queue/Consumer.scala => test/scala/org/apache/linkis/scheduler/queue/SchedulerEventStateTest.scala} (53%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/pom.xml (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/EngineConnPlugin.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/conf/EngineConnPluginConf.scala (97%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/conf/EnvConfiguration.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/creation/EngineConnFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/creation/ExecutorFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/creation/LabelExecutorFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnBuildFailedException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginErrorCode.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginErrorException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginLoadException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginLoadResourceException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginNotFoundException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/EngineConnLaunchBuilder.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/entity/EngineConnBuildRequest.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/entity/EngineConnCreationDesc.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/entity/EngineConnLaunchRequest.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/process/EngineConnResourceGenerator.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/process/Environment.scala (98%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/process/JavaProcessEngineConnLaunchBuilder.scala (99%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/process/ProcessEngineConnLaunchBuilder.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/launch/process/ProcessEngineConnLaunchRequest.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/conf/PluginLoaderConstant.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/entity/EngineConnPluginInfo.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/entity/EngineConnPluginInstance.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/exception/EngineConnPluginLoadException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/exception/EngineConnPluginLoadResourceException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/loader/exception/EngineConnPluginNotFoundException.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/resource/AbstractEngineResourceFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/resource/EngineResourceFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/resource/EngineResourceRequest.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/resource/GenericEngineResourceFactory.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/resource/UserNodeResource.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/pom.xml (100%)
copy {linkis-engineconn-plugins/engineconn-plugins/sqoop => linkis-computation-governance/linkis-engineconn/linkis-engineconn-plugin-server}/src/main/assembly/distribution.xml (91%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/EngineConnPluginCache.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/GuavaEngineConnPluginCache.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/config/EngineConnPluginCacheConfig.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/refresh/DefaultRefreshPluginCacheContainer.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/refresh/PluginCacheRefresher.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/refresh/RefreshPluginCacheContainer.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/refresh/RefreshPluginCacheOperation.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/cache/refresh/RefreshableEngineConnPluginCache.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/classloader/EngineConnPluginClassLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/CacheablesEngineConnPluginLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/DefaultEngineConnPluginLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/EngineConnPluginsLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/EngineConnPluginsResourceLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/resource/BmlEngineConnPluginResourceLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/resource/LocalEngineConnPluginResourceLoader.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/loaders/resource/PluginResource.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/utils/EngineConnPluginUtils.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/loader/utils/ExceptionHelper.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/LinkisEngineConnPluginServer.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/conf/EngineConnPluginSpringConfiguration.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/dao/EngineConnBmlResourceDao.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/dao/impl/EngineConnBmlResourceMapper.xml (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/entity/EngineConnBmlResource.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/java/org/apache/linkis/engineplugin/server/restful/EnginePluginRestful.java (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderConf.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/conf/EngineConnPluginConfiguration.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/interceptor/EngineConnLaunchInterceptor.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoader.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/localize/AbstractEngineConnBmlResourceGenerator.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/localize/DefaultEngineConnBmlResourceGenerator.scala (97%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/localize/EngineConnBmlResourceGenerator.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnLaunchService.scala (96%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceFactoryService.scala (96%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceService.scala (91%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceFactoryService.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceService.scala (100%)
rename {linkis-engineconn-plugins/linkis-engineconn-plugin-framework => linkis-computation-governance/linkis-engineconn}/linkis-engineconn-plugin-server/src/test/java/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderTest.java (100%)
copy linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/Entity/Version.java => linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/vo/ResourceVo.java (61%)
rename linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/test/java/{ => org/apache/linkis/manager}/Scan.java (97%)
rename linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/test/java/{ => org/apache/linkis/manager/persistence}/PersistenceTest.java (98%)
rename linkis-dist/package/conf/{ => linkis-cli}/linkis-cli.properties (100%)
create mode 100644 linkis-dist/package/conf/linkis-cli/log4j2.xml
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/ElasticSearchEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/builder/ElasticSearchProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/conf/ElasticSearchConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsConvertResponseException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsEngineException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsParamsIllegalException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/ElasticSearchEngineConnExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/ElasticSearchExecutorOrder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/ElasticSearchExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/ElasticSearchResponse.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/EsClient.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/EsClientFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/ResponseHandler.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/impl/ElasticSearchExecutorImpl.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executer/client/impl/ResponseHandlerImpl.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/factory/ElasticSearchEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/factory/ElasticSearchJsonExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/factory/ElasticSearchSqlExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/pom.xml (99%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/config/Environment.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/config/entries/ConfigEntry.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/config/entries/ExecutionEntry.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/deployment/ClusterDescriptorAdapter.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/deployment/ClusterDescriptorAdapterFactory.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/deployment/YarnApplicationClusterDescriptorAdapter.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/deployment/YarnPerJobClusterDescriptorAdapter.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/deployment/YarnSessionClusterDescriptorAdapter.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/factory/LinkisYarnClusterClientFactory.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/AbstractResult.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/BatchResult.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/ChangelogResult.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/Result.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/ResultUtil.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/TypedResult.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/AbstractJobOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/JobOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/NonJobOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/Operation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/OperationFactory.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/OperationFactoryImpl.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/OperationUtil.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/CreateViewOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/DDLOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/DescribeTableOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/DropViewOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ExplainOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/InsertOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ResetOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/SelectOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/SetOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowCatalogsOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowCurrentCatalogOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowCurrentDatabaseOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowDatabasesOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowFunctionsOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowModulesOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowTablesOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/ShowViewsOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/UseCatalogOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/UseDatabaseOperation.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ColumnInfo.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ConstantNames.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ResultKind.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ResultSet.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ResultSetJsonDeserializer.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/result/ResultSetJsonSerializer.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/parser/SqlCommand.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/parser/SqlCommandCall.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/parser/SqlCommandParser.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/parser/SqlCommandParserImpl.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/utils/YarnConfLoader.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/exception/ExecutorInitException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/exception/FlinkInitFailedException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/exception/JobExecutionException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/exception/SqlExecutionException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/exception/SqlParseException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/resources/flink-sql-defaults.yaml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/FlinkEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkResourceConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/context/EnvironmentContext.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/context/FlinkEngineConnContext.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkCodeOnceExecutor.scala (92%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkJarOnceExecutor.scala (91%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkOnceExecutor.scala (91%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkSQLComputationExecutor.scala (91%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executormanager/FlinkExecutorManager.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkApplicationExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkCodeExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala (94%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkSQLExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala (92%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/listener/FlinkListener.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/listener/FlinkListenerGroup.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.scala (92%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/Grammar.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/GrammarFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/impl/CreateTableAsSelectGrammar.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/resource/FlinkEngineConnResourceFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/setting/HudiSettings.scala (94%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/setting/Settings.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/ClassUtil.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/pom.xml (99%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/java/org/apache/linkis/engineplugin/hive/log/HiveProgress.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/java/org/apache/linkis/engineplugin/hive/serde/CustomerDelimitedJSONSerDe.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/HiveEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/common/HiveUtils.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/conf/Counters.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/conf/HiveEngineConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/creation/HiveEngineConnFactory.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/cs/CSHiveHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/entity/HiveSession.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/exception/NotSupportedHiveTypeException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/hook/HiveAddJarsEngineHook.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/hook/HiveAddMetaTableNameHook.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/launch/HiveProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/log/LogHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/hive/src/main/scala/org/apache/linkis/engineplugin/hive/progress/HiveProgressHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/java/org/apache/linkis/manager/engineplugin/io/utils/ReflectionUtils.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/IoEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/builder/IoProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/conf/IOEngineConnConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/domain/FSInfo.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/executor/IoEngineConnExecutor.scala (95%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/factory/IoEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/service/FsProxyService.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/io_file/src/main/scala/org/apache/linkis/manager/engineplugin/io/utils/IOHelp.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/ConnectionManager.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/JDBCDataSourceConfigurations.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/JDBCPropertiesParser.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/JdbcAuthType.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/PropertiesParser.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/java/org/apache/linkis/manager/engineplugin/jdbc/constant/JDBCEngineConnConstant.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/JDBCEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/builder/JDBCProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/conf/JDBCConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/exception/JDBCParamsIllegalException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executer/JDBCEngineConnExecutor.scala (89%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executer/JDBCHelper.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executer/JDBCMultiDatasourceParser.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executer/JDBCSQLCodeParser.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/factory/JDBCEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/test/java/org/apache/linkis/manager/engineplugin/jdbc/ConnectionManagerTest.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/test/java/org/apache/linkis/manager/engineplugin/jdbc/executer/JDBCMultiDatasourceParserTest.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/jdbc/src/test/scala/org.apache.linkis.manager.engineplugin.jdbc.executer/TestJDBCEngineConnExecutor.scala (96%)
delete mode 100644 linkis-engineconn-plugins/linkis-engineconn-plugin-framework/linkis-engineconn-plugin-server/src/main/assembly/distribution.xml
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/pom.xml (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/builder/OpenLooKengProcessECLaunchBuilder.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/conf/OpenLooKengConfiguration.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/conf/OpenLooKengEngineConfCache.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/exception/OpenLooKengClientException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/exception/OpenLooKengSourceGroupException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/exception/OpenLooKengStateInvalidException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/executor/OpenLooKengEngineConnExecutor.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/scala/org/apache/linkis/engineplugin/openlookeng/OpenLooKengECPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/openlookeng/src/main/scala/org/apache/linkis/engineplugin/openlookeng/factory/OpenLooKengEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/PipelineEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/builder/PipelineEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/conf/PipelineEngineConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/constant/PipeLineConstant.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/conversions/FsConvertions.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/exception/PipeLineErrorException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/CSVExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/CopyExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/ExcelExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/OutputStreamCache.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/PipeLineExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/PipelineEngineConnExecutor.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/PipelineExecutorSelector.scala (93%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/factory/PipelineEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/PrestoEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/builder/PrestoProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/conf/PrestoConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/exception/PrestoException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executer/PrestoEngineConnExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/presto/src/main/scala/org/apache/linkis/engineplugin/presto/factory/PrestoEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/pom.xml (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/py4j/py4j-0.10.9.5-src.zip (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/resources/python/python.py (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/PythonEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/conf/PythonEngineConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/exception/NoSupportEngineException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/exception/PythonSessionNullException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/executor/PythonEngineConnExecutor.scala (90%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/executor/PythonSession.scala (91%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/factory/PythonEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/hook/PythonVersionEngineHook.scala (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/launch/PythonProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/utils/Kind.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/utils/State.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/pom.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/resources/bin/kill-yarn-jobs.sh (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/resources/conf/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/resources/conf/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/ShellEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/builder/ShellProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/common/ShellEnginePluginConst.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/exception/NoCorrectUserException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ErrorStreamReaderThread.scala (84%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ShellEngineConnExecutor.scala (87%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/YarnAppIdExtractor.scala (93%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/factory/ShellEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/pom.xml (99%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/resources/python/mix_pyspark.py (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/Interpreter/Interpreter.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/Interpreter/ProcessInterpreter.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/Interpreter/PythonInterpreter.scala (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/SparkEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/args/SparkPythonArgsAppender.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/args/SparkPythonArgsPreExecutionHook.scala (85%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/args/SparkScalaPreExecutionHook.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/Kind.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/LineBufferedProcess.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/LineBufferedStream.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/LogContainer.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/SparkEnginePluginConst.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/SparkKind.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/common/State.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/config/SparkConfiguration.scala (99%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/config/SparkResourceConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/cs/CSSparkHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/cs/CSSparkPostExecutionHook.scala (89%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/cs/CSSparkPreExecutionHook.scala (87%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/cs/CSTableParser.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/entity/SparkEngineSession.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/ApplicationAlreadyStoppedException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/ExecuteError.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/MDQErrorException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/NoSupportEngineException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/QueryFailedException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/RetryException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/SparkCreateFileException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/exception/SparkSessionNullException.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SQLSession.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkEngineConnExecutor.scala (92%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkExecutorOrder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkPythonExecutor.scala (90%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkScalaExecutor.scala (90%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkSqlExecutor.scala (92%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/extension/SparkPostExecutionHook.scala (94%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/extension/SparkPreExecutionHook.scala (94%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/extension/SparkSqlExtension.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/factory/SparkEngineConnFactory.scala (95%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/factory/SparkEngineConnResourceFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/factory/SparkPythonExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/factory/SparkScalaExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/factory/SparkSqlExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/imexport/CsvRelation.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/imexport/ExportData.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/imexport/LoadData.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/imexport/util/BackGroundServiceUtils.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/imexport/util/ImExportUtils.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/launch/SparkSubmitProcessEngineConnLaunchBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/lineage/LineageSparkSqlExtension.scala (88%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/lineage/SparkLineageUtils.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/mdq/MDQPostExecutionHook.scala (93%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/mdq/MDQPreExecutionHook.scala (97%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/metadata/HPOBuilder.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/metadata/MetaDataInfoTool.scala (86%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/metadata/SparkHiveObject.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/metadata/SparkSQLHistoryParser.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/utils/EngineUtils.scala (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/linkis/engineplugin/spark/utils/JobProgressUtil.scala (96%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/spark/sql/MethodInvokeHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/spark/sql/SparkLogicalPlanHelper.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/spark/sql/execution/datasources/csv/DolphinToSpark.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/spark/sql/execution/datasources/csv/UDF.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/spark/src/main/scala/org/apache/spark/util/SparkUtils.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/pom.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/assembly/distribution.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/LinkisSqoopClient.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/Sqoop.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/config/ExecutionContext.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/config/ParamsMapping.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/exception/JobClosableException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/exception/JobExecutionException.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/linkis/engineconnplugin/sqoop/client/utils/JarLoader.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/java/org/apache/sqoop/mapreduce/JobBase.java (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/resources/linkis-engineconn.properties (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/resources/log4j2.xml (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/SqoopEngineConnPlugin.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/context/SqoopEngineConnContext.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/context/SqoopEnvConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/context/SqoopParamsConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/context/SqoopResourceConfiguration.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala (88%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceExecutor.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/factory/SqoopEngineConnFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/factory/SqoopExecutorFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/launch/SqoopEngineConnLaunchBuilder.scala (98%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/params/SqoopParamsResolver.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/resource/SqoopEngineConnResourceFactory.scala (100%)
rename linkis-engineconn-plugins/{engineconn-plugins => }/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/util/ClassUtil.scala (100%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/BmlProject.java (98%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/DownloadModel.java (98%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/Resource.java (99%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/ResourceTask.java (99%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/ResourceVersion.java (99%)
rename linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/java/org/apache/linkis/bml/{Entity => entity}/Version.java (96%)
copy linkis-public-enhancements/linkis-bml/linkis-bml-server/src/{main/java/org/apache/linkis/bml/common/ResourceHelper.java => test/java/org/apache/linkis/bml/common/HdfsResourceHelperTest.java} (56%)
copy linkis-public-enhancements/linkis-bml/linkis-bml-server/src/{main/java/org/apache/linkis/bml/common/ResourceHelper.java => test/java/org/apache/linkis/bml/common/LocalResourceHelperTest.java} (56%)
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/test/java/org/apache/linkis/bml/common/VersionServiceImplTest.java
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/elasticsearch/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/ElasticConnection.java (99%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/elasticsearch/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/ElasticParamsMapper.java (96%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/elasticsearch/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/EsMetaService.java (98%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/hive/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/HiveConnection.java (99%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/hive/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/HiveMetaService.java (99%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/hive/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/HiveParamsMapper.java (96%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/kafka/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/KafkaConnection.java (97%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/kafka/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/KafkaMetaService.java (99%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/kafka/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/KafkaParamsMapper.java (96%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/mysql/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/MysqlMetaService.java (98%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/mysql/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/SqlConnection.java (99%)
rename linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/mysql/src/main/java/org/apache/linkis/{metadat => metadata}/query/service/SqlParamsMapper.java (97%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/java/org/apache/linkis/metadata/hive/dto/MetadataQueryParam.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org
[incubator-linkis] 01/01: Merge pull request #2486 from apache/dev-1.2.0
Posted by ca...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.2.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 1f8caace3ab4ebad759b4018540832b711ded2a7
Merge: 526e01afe 4f09b3061
Author: Casion <ca...@gmail.com>
AuthorDate: Tue Jul 19 14:38:02 2022 +0800
Merge pull request #2486 from apache/dev-1.2.0
Merge branch dev-1.2.0 to dev-1.2.1
.gitignore | 1 +
.../future/BDPFuture.scala => license-header | 13 +-
.../linkis/common/exception/LinkisException.java | 8 +-
.../VariableOperationFailedException.java | 11 +-
.../java/org/apache/linkis/common/io/FsPath.java | 2 +-
.../org/apache/linkis/common/utils/DESUtil.java | 11 +-
.../common/utils/VariableOperationUtils.java | 317 +++++++++++++++++++++
.../linkis/common/conf/BDPConfiguration.scala | 16 +-
.../apache/linkis/common/conf/Configuration.scala | 6 +-
.../linkis/common/listener/ListenerEventBus.scala | 66 ++---
.../apache/linkis/common/utils/RetryHandler.scala | 2 +-
.../org/apache/linkis/common/utils/Utils.scala | 8 +-
.../apache/linkis/common/utils/VariableUtils.scala | 19 +-
.../common/variable/VariableOperationTest.java | 52 ++++
.../linkis/hadoop/common/utils/HDFSUtils.scala | 6 +-
.../linkis/httpclient/AbstractHttpClient.scala | 2 +-
linkis-commons/linkis-module/pom.xml | 7 +
.../linkis/server/BDPJettyServerHelper.scala | 4 +-
.../org/apache/linkis/server/Knife4jConfig.scala | 86 ++++++
.../linkis/server/conf/ServerConfiguration.scala | 6 +-
.../linkis/server/security/ProxyUserSSOUtils.scala | 2 +-
.../apache/linkis/server/security/SSOUtils.scala | 6 +-
.../linkis/server/security/SecurityFilter.scala | 14 +-
.../linkis/server/socket/ControllerServer.scala | 8 +-
.../socket/controller/ServerEventService.scala | 4 +-
.../socket/controller/ServerListenerEventBus.scala | 2 +-
.../linkis/protocol/IRServiceGroupProtocol.scala | 4 +-
.../apache/linkis/protocol/RetryableProtocol.scala | 5 +-
.../linkis/protocol/engine/EngineState.scala | 32 ---
.../engine/EngineStateTransitionRequest.scala | 4 +-
.../apache/linkis/protocol/mdq/MDQProtocol.scala | 11 +-
.../org/apache/linkis/protocol/task/Task.scala | 4 +-
.../linkis/protocol/utils/ProtocolUtils.scala | 14 +-
.../variable/RequestQueryGlobalVariable.scala | 4 +-
.../protocol/variable/ResponseQueryVariable.scala | 4 +-
.../linkis/rpc/message/method/MessageExecutor.java | 21 +-
.../rpc/message/method/MethodExecuteWrapper.java | 2 +-
.../rpc/message/parser/DefaultServiceParser.java | 20 +-
.../linkis/rpc/message/parser/ServiceMethod.java | 2 +-
.../message/registry/AbstractServiceRegistry.java | 18 +-
.../message/utils/LoadBalancerOptionsUtils.java | 3 +-
.../linkis/rpc/message/utils/MessageUtils.java | 64 ++++-
.../rpc/serializer/ProtostuffSerializeUtil.java | 3 +-
.../org/apache/linkis/rpc/BaseRPCSender.scala | 4 +-
.../org/apache/linkis/rpc/RPCReceiveRestful.scala | 16 +-
.../org/apache/linkis/rpc/RPCSpringBeanCache.scala | 2 +-
.../main/scala/org/apache/linkis/rpc/Sender.scala | 5 +-
.../org/apache/linkis/rpc/SenderFactory.scala | 9 +-
.../apache/linkis/rpc/conf/RPCConfiguration.scala | 44 +--
.../linkis/rpc/conf/RPCSpringConfiguration.scala | 10 +-
.../linkis/rpc/interceptor/RPCServerLoader.scala | 2 +-
.../common/BroadcastRPCInterceptor.scala | 2 +-
.../common/CacheableRPCInterceptor.scala | 8 +-
.../common/SingleInstanceRPCLoadBalancer.scala | 2 +-
.../linkis/rpc/sender/SpringMVCRPCSender.scala | 2 +-
.../sender/eureka/EurekaClientRefreshUtils.scala | 4 +-
.../rpc/transform/JavaCollectionSerializer.scala | 4 +-
.../apache/linkis/rpc/transform/RPCConsumer.scala | 9 +-
.../apache/linkis/rpc/transform/RPCProduct.scala | 22 +-
.../org/apache/linkis/rpc/utils/RPCUtils.scala | 2 +-
.../linkis/rpc/message/utils/MessageUtilsTest.java | 86 ++++++
.../linkis/scheduler/AbstractScheduler.scala | 27 +-
.../org/apache/linkis/scheduler/Scheduler.scala | 7 +-
.../apache/linkis/scheduler/SchedulerContext.scala | 4 +-
.../apache/linkis/scheduler/event/LogEvent.scala | 12 +-
.../exception/SchedulerErrorException.scala | 2 +-
.../scheduler/executer/AbstractExecutor.scala | 6 +-
.../linkis/scheduler/executer/ExecuteRequest.scala | 10 +-
.../linkis/scheduler/executer/Executor.scala | 8 +-
.../apache/linkis/scheduler/future/BDPFuture.scala | 2 +-
.../linkis/scheduler/future/BDPFutureTask.scala | 14 +-
.../apache/linkis/scheduler/queue/Consumer.scala | 4 +-
.../org/apache/linkis/scheduler/queue/Job.scala | 16 +-
.../linkis/scheduler/queue/SchedulerEvent.scala | 34 +--
.../scheduler/queue/SchedulerEventState.scala | 33 +--
.../queue/fifoqueue/FIFOConsumerManager.scala | 2 +-
.../queue/fifoqueue/FIFOGroupFactory.scala | 2 +-
.../scheduler/queue/fifoqueue/FIFOScheduler.scala | 6 +-
.../queue/fifoqueue/FIFOSchedulerContextImpl.scala | 2 +-
.../queue/fifoqueue/FIFOUserConsumer.scala | 14 +-
.../parallelqueue/ParallelConsumerManager.scala | 8 +-
.../queue/parallelqueue/ParallelScheduler.scala | 6 +-
.../scheduler/queue/SchedulerEventStateTest.scala} | 46 ++-
linkis-commons/linkis-storage/pom.xml | 1 -
.../linkis/storage/excel/ExcelStorageReader.java | 8 +-
.../org/apache/linkis/storage/excel/XlsUtils.java | 4 +-
.../org/apache/linkis/storage/excel/XlsxUtils.java | 8 +-
.../linkis/storage/fs/impl/LocalFileSystem.java | 2 +-
.../org/apache/linkis/storage/FSFactory.scala | 15 +-
.../org/apache/linkis/storage/LineMetaData.scala | 4 +-
.../org/apache/linkis/storage/LineRecord.scala | 4 +-
.../linkis/storage/conf/LinkisStorageConf.scala | 4 +-
.../linkis/storage/csv/StorageCSVWriter.scala | 11 +-
.../apache/linkis/storage/domain/DataType.scala | 34 +--
.../org/apache/linkis/storage/domain/Dolphin.scala | 20 +-
.../linkis/storage/domain/MethodEntity.scala | 12 +-
.../linkis/storage/excel/ExcelXlsReader.java | 16 +-
.../linkis/storage/excel/StorageExcelWriter.scala | 62 ++--
.../storage/excel/StorageMultiExcelWriter.scala | 2 +-
.../org/apache/linkis/storage/io/IOClient.scala | 20 +-
.../resultset/DefaultResultSetFactory.scala | 24 +-
.../storage/resultset/ResultSetFactory.scala | 14 +-
.../linkis/storage/resultset/ResultSetReader.scala | 7 +-
.../storage/resultset/StorageResultSet.scala | 11 +-
.../storage/resultset/StorageResultSetReader.scala | 37 ++-
.../storage/resultset/StorageResultSetWriter.scala | 2 +-
.../linkis/storage/resultset/io/IOMetaData.scala | 2 +-
.../linkis/storage/resultset/io/IORecord.scala | 2 +-
.../storage/resultset/io/IOResultSerializer.scala | 2 +-
.../storage/resultset/table/TableRecord.scala | 6 +-
.../resultset/table/TableResultDeserializer.scala | 15 +-
.../resultset/table/TableResultSerializer.scala | 16 +-
.../resultset/txt/TextResultSerializer.scala | 4 +-
.../linkis/storage/utils/FileSystemUtils.scala | 6 +-
.../storage/utils/StorageConfiguration.scala | 3 +-
.../linkis/storage/utils/StorageHelper.scala | 22 +-
.../apache/linkis/storage/utils/StorageUtils.scala | 52 ++--
.../linkis/computation/client/JobMetrics.scala | 2 +-
.../client/interactive/InteractiveJob.scala | 2 +-
.../computation/client/job/AbstractLinkisJob.scala | 6 +-
.../computation/client/job/StorableLinkisJob.scala | 6 +-
.../client/once/simple/SimpleOnceJob.scala | 10 +-
.../client/operator/OnceJobOperator.scala | 4 +-
.../ujes/client/response/JobInfoResult.scala | 2 +-
.../governance/common/paser/CodeParser.scala | 2 +-
.../launch/LinuxProcessEngineConnLaunch.scala | 2 +-
.../ecm/core/launch/ProcessEngineCommandExec.scala | 2 +-
.../ecm/core/listener/ECMEventListener.scala | 2 +-
.../linkis-engineconn-manager-server/pom.xml | 2 +-
.../src/main/assembly/distribution.xml | 243 +++++++++++++++-
.../linkis/ecm/server/hook/JarUDFLoadECMHook.scala | 14 +-
.../server/operator/EngineConnLogOperator.scala | 4 +-
.../operator/EngineConnYarnLogOperator.scala | 12 +-
.../impl/AbstractEngineConnLaunchService.scala | 12 +-
.../impl/BmlResourceLocalizationService.scala | 13 +-
.../service/impl/DefaultECMHealthService.scala | 13 +-
.../service/impl/DefaultECMRegisterService.scala | 10 +-
.../impl/DefaultEngineConnListService.scala | 10 +-
.../DefaultEngineConnStatusCallbackService.scala | 4 +-
.../service/impl/DefaultOperateService.scala | 6 +-
.../engineconn/once/executor/OnceExecutor.scala | 19 +-
.../execution/OnceEngineConnExecution.scala | 2 +-
.../async/AsyncConcurrentComputationExecutor.scala | 12 +-
.../executor/bml/BmlEnginePreExecuteHook.scala | 2 +-
.../executor/conf/ComputationExecutorConf.scala | 4 +
.../creation/ComputationExecutorManager.scala | 4 +-
.../executor/cs/CSEnginePreExecuteHook.scala | 18 +-
.../computation/executor/cs/CSTableRegister.scala | 4 +-
.../executor/cs/CSTableResultSetWriter.scala | 6 +-
.../execute/ComputationEngineConnExecution.scala | 2 +-
.../executor/execute/ComputationExecutor.scala | 46 ++-
.../execute/ConcurrentComputationExecutor.scala | 8 +-
.../executor/execute/EngineExecutionContext.scala | 6 +-
.../executor/hook/ComputationExecutorHook.scala | 2 +-
.../computation/executor/hook/InitSQLHook.scala | 12 +-
.../executor/hook/UDFLoadEngineConnHook.scala | 16 +-
.../executor/hook/UseDatabaseEngineHook.scala | 4 +-
.../EngineResultsetPrefixExecutorHook.scala | 8 +-
.../executor/hook/executor/ExecuteOnceHook.scala | 4 +-
.../computation/executor/rs/RsOutputStream.scala | 2 +-
.../service/TaskExecutionServiceImpl.scala | 100 +++----
.../executor/upstream/ECTaskEntranceMonitor.scala | 4 +-
.../SingleThreadUpstreamConnectionMonitor.scala | 31 +-
.../upstream/access/ECTaskEntranceInfoAccess.scala | 4 +-
.../upstream/handler/ECTaskKillHandler.scala | 14 +-
.../service/ECTaskEntranceMonitorService.scala | 6 +-
.../wrapper/ECTaskEntranceConnectionWrapper.scala | 6 +-
.../access/ECTaskEntranceInfoAccessHelper.scala | 16 +-
.../linkis/engineconn/core/EngineConnObject.scala | 2 +-
.../AbstractCodeLanguageLabelExecutorFactory.scala | 4 +-
.../execution/AbstractEngineConnExecution.scala | 6 +-
.../core/execution/EngineConnExecution.scala | 2 +-
.../engineconn/core/executor/ExecutorManager.scala | 14 +-
.../linkis/engineconn/core/hook/ExecutorHook.scala | 2 +-
.../linkis/engineconn/core/hook/ShutdownHook.scala | 2 +-
.../engineconn/launch/EngineConnServer.scala | 28 +-
.../execution/AccessibleEngineConnExecution.scala | 18 +-
.../executor/lock/EngineConnTimedLock.scala | 24 +-
.../service/DefaultAccessibleService.scala | 22 +-
.../service/DefaultExecutorHeartbeatService.scala | 2 +-
.../executor/service/DefaultManagerService.scala | 6 +-
.../executor/service/DefaultOperateService.scala | 6 +-
.../service/EngineConnTimedLockService.scala | 20 +-
.../acessible/executor/service/LockService.scala | 2 +-
.../callback/hook/CallbackEngineConnHook.scala | 10 +-
.../engineconn/executor/entity/Executor.scala | 2 +-
.../executor/entity/SensibleExecutor.scala | 2 +-
.../listener/EngineConnSyncListenerBus.scala | 4 +-
.../engineconn/executor/service/LabelService.scala | 4 +-
.../linkis-engineconn-plugin-core/pom.xml | 0
.../engineplugin/common/EngineConnPlugin.scala | 0
.../common/conf/EngineConnPluginConf.scala | 2 +-
.../common/conf/EnvConfiguration.scala | 0
.../common/creation/EngineConnFactory.scala | 0
.../common/creation/ExecutorFactory.scala | 0
.../common/creation/LabelExecutorFactory.scala | 0
.../exception/EngineConnBuildFailedException.scala | 0
.../exception/EngineConnPluginErrorCode.scala | 0
.../exception/EngineConnPluginErrorException.scala | 0
.../exception/EngineConnPluginLoadException.scala | 0
.../EngineConnPluginLoadResourceException.scala | 0
.../EngineConnPluginNotFoundException.scala | 0
.../common/launch/EngineConnLaunchBuilder.scala | 0
.../launch/entity/EngineConnBuildRequest.scala | 0
.../launch/entity/EngineConnCreationDesc.scala | 0
.../launch/entity/EngineConnLaunchRequest.scala | 0
.../process/EngineConnResourceGenerator.scala | 0
.../common/launch/process/Environment.scala | 2 +-
.../JavaProcessEngineConnLaunchBuilder.scala | 2 +-
.../process/ProcessEngineConnLaunchBuilder.scala | 0
.../process/ProcessEngineConnLaunchRequest.scala | 0
.../common/loader/conf/PluginLoaderConstant.scala | 0
.../loader/entity/EngineConnPluginInfo.scala | 0
.../loader/entity/EngineConnPluginInstance.scala | 0
.../exception/EngineConnPluginLoadException.scala | 0
.../EngineConnPluginLoadResourceException.scala | 0
.../EngineConnPluginNotFoundException.scala | 0
.../resource/AbstractEngineResourceFactory.scala | 0
.../common/resource/EngineResourceFactory.scala | 0
.../common/resource/EngineResourceRequest.scala | 0
.../resource/GenericEngineResourceFactory.scala | 0
.../common/resource/UserNodeResource.scala | 0
.../linkis-engineconn-plugin-server/pom.xml | 0
.../src/main/assembly/distribution.xml | 69 ++---
.../engineplugin/cache/EngineConnPluginCache.java | 0
.../cache/GuavaEngineConnPluginCache.java | 0
.../cache/config/EngineConnPluginCacheConfig.java | 0
.../DefaultRefreshPluginCacheContainer.java | 0
.../cache/refresh/PluginCacheRefresher.java | 0
.../cache/refresh/RefreshPluginCacheContainer.java | 0
.../cache/refresh/RefreshPluginCacheOperation.java | 0
.../refresh/RefreshableEngineConnPluginCache.java | 0
.../classloader/EngineConnPluginClassLoader.java | 0
.../loaders/CacheablesEngineConnPluginLoader.java | 0
.../loaders/DefaultEngineConnPluginLoader.java | 0
.../loader/loaders/EngineConnPluginsLoader.java | 0
.../loaders/EngineConnPluginsResourceLoader.java | 0
.../BmlEngineConnPluginResourceLoader.java | 0
.../LocalEngineConnPluginResourceLoader.java | 0
.../loader/loaders/resource/PluginResource.java | 0
.../loader/utils/EngineConnPluginUtils.java | 0
.../engineplugin/loader/utils/ExceptionHelper.java | 0
.../server/LinkisEngineConnPluginServer.java | 0
.../conf/EngineConnPluginSpringConfiguration.java | 0
.../server/dao/EngineConnBmlResourceDao.java | 0
.../dao/impl/EngineConnBmlResourceMapper.xml | 0
.../server/entity/EngineConnBmlResource.java | 0
.../server/restful/EnginePluginRestful.java | 0
.../loader/EngineConnPluginLoaderConf.scala | 0
.../conf/EngineConnPluginConfiguration.scala | 0
.../interceptor/EngineConnLaunchInterceptor.scala | 0
.../server/loader/EngineConnPluginsLoader.scala | 0
.../AbstractEngineConnBmlResourceGenerator.scala | 0
.../DefaultEngineConnBmlResourceGenerator.scala | 2 +-
.../localize/EngineConnBmlResourceGenerator.scala | 0
.../service/DefaultEngineConnLaunchService.scala | 2 +-
.../DefaultEngineConnResourceFactoryService.scala | 2 +-
.../service/DefaultEngineConnResourceService.scala | 18 +-
.../server/service/EngineConnLaunchService.scala | 0
.../service/EngineConnResourceFactoryService.scala | 0
.../server/service/EngineConnResourceService.scala | 0
.../loader/EngineConnPluginLoaderTest.java | 0
.../linkis-engineconn/pom.xml | 2 +
.../entrance/restful/EntranceLabelRestfulApi.java | 6 +
.../apache/linkis/entrance/EntranceServer.scala | 16 +-
.../linkis/entrance/EntranceWebSocketService.scala | 20 +-
.../entrance/cli/heartbeat/KillHandler.scala | 4 +-
.../linkis/entrance/cs/CSEntranceHelper.scala | 16 +-
.../entrance/execute/DefaultEntranceExecutor.scala | 18 +-
.../entrance/execute/EntranceExecutorManager.scala | 5 +-
.../linkis/entrance/execute/EntranceJob.scala | 26 +-
.../entrance/interceptor/RuntypeInterceptor.scala | 2 +-
.../linkis/entrance/interceptor/impl/Explain.scala | 2 +-
.../impl/PythonCodeCheckInterceptor.scala | 2 +-
.../impl/ShellDangerousGrammerInterceptor.scala | 8 +-
.../linkis/entrance/log/CacheLogReader.scala | 2 +-
.../EntranceUserParallelOrchestratorPlugin.scala | 11 +-
.../entrance/parser/CommonEntranceParser.scala | 11 +-
.../scheduler/cache/ReadCacheConsumer.scala | 6 +-
.../scheduler/cache/ReadCacheConsumerManager.scala | 4 +-
.../entrance/timeout/JobTimeoutManager.scala | 12 +-
.../am/restful/ECResourceInfoRestfulApi.java | 43 +--
.../manager/am/service/ECResourceInfoService.java | 2 +-
.../am/service/impl/ECResourceInfoServiceImpl.java | 4 +-
.../manager/am/util/ECResourceInfoUtils.java | 42 +++
.../manager/am/vo/ECResourceInfoRecordVo.java | 36 +--
.../apache/linkis/manager/am/vo/ResourceVo.java | 31 +-
.../label/MultiUserEngineReuseLabelChooser.scala | 2 +-
.../am/locker/DefaultEngineNodeLocker.scala | 4 +-
.../manager/am/manager/DefaultEMNodeManager.scala | 8 +-
.../manager/am/pointer/DefaultEMNodPointer.scala | 6 +-
.../am/selector/rule/AvailableNodeSelectRule.scala | 2 +-
.../am/selector/rule/OverLoadNodeSelectRule.scala | 2 +-
.../am/selector/rule/ResourceNodeSelectRule.scala | 4 +-
.../am/selector/rule/ScoreNodeSelectRule.scala | 2 +-
.../am/selector/rule/TaskInfoNodeSelectRule.scala | 2 +-
.../am/service/em/DefaultEMEngineService.scala | 6 +-
.../am/service/em/DefaultEMRegisterService.scala | 14 +-
.../am/service/em/DefaultEMUnregisterService.scala | 10 +-
.../engine/DefaultEngineCreateService.scala | 10 +-
.../service/engine/DefaultEngineInfoService.scala | 2 +-
.../engine/DefaultEngineRecycleService.scala | 8 +-
.../service/engine/DefaultEngineStopService.scala | 8 +-
.../am/service/heartbeat/AMHeartbeatService.scala | 4 +-
.../am/service/monitor/NodeHeartbeatMonitor.scala | 18 +-
.../service/impl/DefaultNodeLabelAddService.scala | 8 +-
.../impl/DefaultNodeLabelRemoveService.scala | 4 +-
.../service/impl/DefaultNodeLabelService.scala | 4 +-
.../rm/external/yarn/YarnResourceRequester.scala | 20 +-
.../manager/rm/message/RMMessageService.scala | 4 +-
.../linkis/manager/rm/restful/RMMonitorRest.scala | 23 +-
.../manager/rm/service/ResourceLockService.scala | 10 +-
.../rm/service/impl/DefaultResourceManager.scala | 24 +-
.../manager/rm/utils/UserConfiguration.scala | 4 +-
.../manager/label/entity/engine/EngineType.scala | 2 +-
.../manager/common/entity/resource/Resource.scala | 2 +-
.../manager/common/operator/OperatorFactory.scala | 2 +-
.../linkis/manager/dao/ECResourceRecordMapper.java | 3 +-
.../manager/dao/impl/ECResourceRecordMapper.xml | 1 +
.../java/{ => org/apache/linkis/manager}/Scan.java | 2 +
.../manager/persistence}/PersistenceTest.java | 11 +-
linkis-dist/bin/checkEnv.sh | 4 +-
.../conf/{ => linkis-cli}/linkis-cli.properties | 0
linkis-dist/package/conf/linkis-cli/log4j2.xml | 49 ++++
.../package/conf/linkis-mg-gateway.properties | 4 +-
.../conf/linkis-ps-publicservice.properties | 2 +-
linkis-dist/package/conf/linkis.properties | 2 +-
linkis-dist/package/db/linkis_ddl.sql | 13 +-
linkis-dist/package/db/linkis_dml.sql | 22 +-
.../package/db/module/linkis_datasource.sql | 8 +-
linkis-dist/package/sbin/graceful-upgrade.sh | 4 +-
linkis-dist/src/main/assembly/distribution.xml | 43 +--
.../{engineconn-plugins => }/elasticsearch/pom.xml | 2 +-
.../src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../elasticsearch/src/main/resources/log4j2.xml | 0
.../ElasticSearchEngineConnPlugin.scala | 0
...asticSearchProcessEngineConnLaunchBuilder.scala | 0
.../conf/ElasticSearchConfiguration.scala | 0
.../exception/EsConvertResponseException.scala | 0
.../exception/EsEngineException.scala | 0
.../exception/EsParamsIllegalException.scala | 0
.../executer/ElasticSearchEngineConnExecutor.scala | 0
.../executer/ElasticSearchExecutorOrder.scala | 0
.../executer/client/ElasticSearchExecutor.scala | 0
.../executer/client/ElasticSearchResponse.scala | 0
.../elasticsearch/executer/client/EsClient.scala | 0
.../executer/client/EsClientFactory.scala | 0
.../executer/client/ResponseHandler.scala | 0
.../client/impl/ElasticSearchExecutorImpl.scala | 0
.../executer/client/impl/ResponseHandlerImpl.scala | 0
.../factory/ElasticSearchEngineConnFactory.scala | 0
.../factory/ElasticSearchJsonExecutorFactory.scala | 0
.../factory/ElasticSearchSqlExecutorFactory.scala | 0
.../{engineconn-plugins => }/flink/pom.xml | 2 +-
.../flink/src/main/assembly/distribution.xml | 0
.../flink/client/config/Environment.java | 0
.../flink/client/config/entries/ConfigEntry.java | 0
.../client/config/entries/ExecutionEntry.java | 0
.../flink/client/context/ExecutionContext.java | 0
.../deployment/ClusterDescriptorAdapter.java | 0
.../ClusterDescriptorAdapterFactory.java | 0
.../YarnApplicationClusterDescriptorAdapter.java | 0
.../YarnPerJobClusterDescriptorAdapter.java | 0
.../YarnSessionClusterDescriptorAdapter.scala | 0
.../factory/LinkisYarnClusterClientFactory.java | 0
.../flink/client/result/AbstractResult.java | 0
.../flink/client/result/BatchResult.java | 0
.../flink/client/result/ChangelogResult.java | 0
.../flink/client/result/Result.java | 0
.../flink/client/result/ResultUtil.java | 0
.../flink/client/result/TypedResult.java | 0
.../client/sql/operation/AbstractJobOperation.java | 0
.../flink/client/sql/operation/JobOperation.java | 0
.../client/sql/operation/NonJobOperation.java | 0
.../flink/client/sql/operation/Operation.java | 0
.../client/sql/operation/OperationFactory.java | 0
.../client/sql/operation/OperationFactoryImpl.java | 0
.../flink/client/sql/operation/OperationUtil.java | 0
.../sql/operation/impl/CreateViewOperation.java | 0
.../client/sql/operation/impl/DDLOperation.java | 0
.../sql/operation/impl/DescribeTableOperation.java | 0
.../sql/operation/impl/DropViewOperation.java | 0
.../sql/operation/impl/ExplainOperation.java | 0
.../client/sql/operation/impl/InsertOperation.java | 0
.../client/sql/operation/impl/ResetOperation.java | 0
.../client/sql/operation/impl/SelectOperation.java | 0
.../client/sql/operation/impl/SetOperation.java | 0
.../sql/operation/impl/ShowCatalogsOperation.java | 0
.../impl/ShowCurrentCatalogOperation.java | 0
.../impl/ShowCurrentDatabaseOperation.java | 0
.../sql/operation/impl/ShowDatabasesOperation.java | 0
.../sql/operation/impl/ShowFunctionsOperation.java | 0
.../sql/operation/impl/ShowModulesOperation.java | 0
.../sql/operation/impl/ShowTablesOperation.java | 0
.../sql/operation/impl/ShowViewsOperation.java | 0
.../sql/operation/impl/UseCatalogOperation.java | 0
.../sql/operation/impl/UseDatabaseOperation.java | 0
.../client/sql/operation/result/ColumnInfo.java | 0
.../client/sql/operation/result/ConstantNames.java | 0
.../client/sql/operation/result/ResultKind.java | 0
.../client/sql/operation/result/ResultSet.java | 0
.../result/ResultSetJsonDeserializer.java | 0
.../operation/result/ResultSetJsonSerializer.java | 0
.../flink/client/sql/parser/SqlCommand.java | 0
.../flink/client/sql/parser/SqlCommandCall.java | 0
.../flink/client/sql/parser/SqlCommandParser.java | 0
.../client/sql/parser/SqlCommandParserImpl.java | 0
.../flink/client/utils/YarnConfLoader.java | 0
.../flink/exception/ExecutorInitException.java | 0
.../flink/exception/FlinkInitFailedException.java | 0
.../flink/exception/JobExecutionException.java | 0
.../flink/exception/SqlExecutionException.java | 0
.../flink/exception/SqlParseException.java | 0
.../src/main/resources/flink-sql-defaults.yaml | 0
.../main/resources/linkis-engineconn.properties | 0
.../flink/src/main/resources/log4j2.xml | 0
.../flink/FlinkEngineConnPlugin.scala | 0
.../flink/config/FlinkEnvConfiguration.scala | 0
.../flink/config/FlinkResourceConfiguration.scala | 0
.../flink/context/EnvironmentContext.scala | 0
.../flink/context/FlinkEngineConnContext.scala | 0
.../flink/executor/FlinkCodeOnceExecutor.scala | 18 +-
.../flink/executor/FlinkExecutor.scala | 0
.../flink/executor/FlinkJarOnceExecutor.scala | 4 +-
.../flink/executor/FlinkOnceExecutor.scala | 8 +-
.../executor/FlinkSQLComputationExecutor.scala | 22 +-
.../executormanager/FlinkExecutorManager.scala | 0
.../factory/FlinkApplicationExecutorFactory.scala | 0
.../flink/factory/FlinkCodeExecutorFactory.scala | 0
.../flink/factory/FlinkEngineConnFactory.scala | 18 +-
.../flink/factory/FlinkSQLExecutorFactory.scala | 0
.../launch/FlinkEngineConnLaunchBuilder.scala | 4 +-
.../flink/listener/FlinkListener.scala | 2 +-
.../flink/listener/FlinkListenerGroup.scala | 0
.../flink/operator/TriggerSavepointOperator.scala | 3 +-
.../linkis/engineconnplugin/flink/ql/Grammar.scala | 0
.../engineconnplugin/flink/ql/GrammarFactory.scala | 0
.../flink/ql/impl/CreateTableAsSelectGrammar.scala | 2 +-
.../resource/FlinkEngineConnResourceFactory.scala | 0
.../flink/setting/HudiSettings.scala | 13 +-
.../engineconnplugin/flink/setting/Settings.scala | 0
.../engineconnplugin/flink/util/ClassUtil.scala | 0
.../flink/util/FlinkValueFormatUtil.scala | 0
.../{engineconn-plugins => }/hive/pom.xml | 2 +-
.../hive/src/main/assembly/distribution.xml | 0
.../linkis/engineplugin/hive/log/HiveProgress.java | 0
.../hive/serde/CustomerDelimitedJSONSerDe.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../hive/src/main/resources/log4j2.xml | 0
.../engineplugin/hive/HiveEngineConnPlugin.scala | 0
.../engineplugin/hive/common/HiveUtils.scala | 0
.../linkis/engineplugin/hive/conf/Counters.scala | 0
.../hive/conf/HiveEngineConfiguration.scala | 0
.../hive/creation/HiveEngineConnFactory.scala | 4 +-
.../linkis/engineplugin/hive/cs/CSHiveHelper.scala | 0
.../engineplugin/hive/entity/HiveSession.scala | 0
.../exception/NotSupportedHiveTypeException.scala | 0
.../hive/executor/HiveEngineConnExecutor.scala | 50 ++--
.../hive/hook/HiveAddJarsEngineHook.scala | 2 +-
.../hive/hook/HiveAddMetaTableNameHook.scala | 2 +-
.../HiveProcessEngineConnLaunchBuilder.scala | 0
.../linkis/engineplugin/hive/log/LogHelper.scala | 0
.../hive/progress/HiveProgressHelper.scala | 0
.../{engineconn-plugins => }/io_file/pom.xml | 2 +-
.../io_file/src/main/assembly/distribution.xml | 0
.../engineplugin/io/utils/ReflectionUtils.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../io_file/src/main/resources/log4j2.xml | 0
.../engineplugin/io/IoEngineConnPlugin.scala | 0
.../builder/IoProcessEngineConnLaunchBuilder.scala | 0
.../io/conf/IOEngineConnConfiguration.scala | 0
.../manager/engineplugin/io/domain/FSInfo.scala | 0
.../io/executor/IoEngineConnExecutor.scala | 14 +-
.../io/factory/IoEngineConnFactory.scala | 0
.../engineplugin/io/service/FsProxyService.scala | 0
.../manager/engineplugin/io/utils/IOHelp.scala | 0
.../{engineconn-plugins => }/jdbc/pom.xml | 4 +-
.../jdbc/src/main/assembly/distribution.xml | 0
.../engineplugin/jdbc/ConnectionManager.java | 0
.../jdbc/JDBCDataSourceConfigurations.java | 0
.../engineplugin/jdbc/JDBCPropertiesParser.java | 0
.../manager/engineplugin/jdbc/JdbcAuthType.java | 0
.../engineplugin/jdbc/PropertiesParser.java | 0
.../jdbc/constant/JDBCEngineConnConstant.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../jdbc/src/main/resources/log4j2.xml | 0
.../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 0
.../JDBCProcessEngineConnLaunchBuilder.scala | 0
.../engineplugin/jdbc/conf/JDBCConfiguration.scala | 0
.../exception/JDBCParamsIllegalException.scala | 0
.../jdbc/executer/JDBCEngineConnExecutor.scala | 47 +--
.../engineplugin/jdbc/executer/JDBCHelper.java | 0
.../jdbc/executer/JDBCMultiDatasourceParser.scala | 8 +-
.../jdbc/executer/JDBCSQLCodeParser.scala | 0
.../jdbc/factory/JDBCEngineConnFactory.scala | 0
.../engineplugin/jdbc/ConnectionManagerTest.java | 0
.../executer/JDBCMultiDatasourceParserTest.scala | 0
.../TestJDBCEngineConnExecutor.scala | 5 +-
.../src/main/assembly/distribution.xml | 59 ----
.../{engineconn-plugins => }/openlookeng/pom.xml | 4 +-
.../openlookeng/src/main/assembly/distribution.xml | 0
.../builder/OpenLooKengProcessECLaunchBuilder.java | 0
.../openlookeng/conf/OpenLooKengConfiguration.java | 0
.../conf/OpenLooKengEngineConfCache.java | 0
.../exception/OpenLooKengClientException.java | 0
.../exception/OpenLooKengSourceGroupException.java | 0
.../OpenLooKengStateInvalidException.java | 0
.../executor/OpenLooKengEngineConnExecutor.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../openlookeng/src/main/resources/log4j2.xml | 0
.../openlookeng/OpenLooKengECPlugin.scala | 0
.../factory/OpenLooKengEngineConnFactory.scala | 0
.../{engineconn-plugins => }/pipeline/pom.xml | 2 +-
.../pipeline/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../pipeline/src/main/resources/log4j2.xml | 0
.../pipeline/PipelineEngineConnPlugin.scala | 0
.../builder/PipelineEngineConnLaunchBuilder.scala | 0
.../conf/PipelineEngineConfiguration.scala | 0
.../pipeline/constant/PipeLineConstant.scala | 0
.../pipeline/conversions/FsConvertions.scala | 0
.../exception/PipeLineErrorException.scala | 0
.../pipeline/executor/CSVExecutor.scala | 0
.../pipeline/executor/CopyExecutor.scala | 0
.../pipeline/executor/ExcelExecutor.scala | 0
.../pipeline/executor/OutputStreamCache.scala | 0
.../pipeline/executor/PipeLineExecutor.scala | 0
.../executor/PipelineEngineConnExecutor.scala | 4 +-
.../executor/PipelineExecutorSelector.scala | 2 +-
.../factory/PipelineEngineConnFactory.scala | 0
linkis-engineconn-plugins/pom.xml | 23 +-
.../{engineconn-plugins => }/presto/pom.xml | 2 +-
.../presto/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../presto/src/main/resources/log4j2.xml | 0
.../presto/PrestoEngineConnPlugin.scala | 0
.../PrestoProcessEngineConnLaunchBuilder.scala | 0
.../presto/conf/PrestoConfiguration.scala | 0
.../presto/exception/PrestoException.scala | 0
.../presto/executer/PrestoEngineConnExecutor.scala | 0
.../presto/factory/PrestoEngineConnFactory.scala | 0
.../{engineconn-plugins => }/python/pom.xml | 2 +-
.../python/src/main/assembly/distribution.xml | 0
.../python/src/main/py4j/py4j-0.10.9.5-src.zip | Bin
.../main/resources/linkis-engineconn.properties | 0
.../python/src/main/resources/log4j2.xml | 0
.../python/src/main/resources/python/python.py | 0
.../python/PythonEngineConnPlugin.scala | 0
.../python/conf/PythonEngineConfiguration.scala | 0
.../exception/NoSupportEngineException.scala | 0
.../exception/PythonSessionNullException.scala | 0
.../python/executor/PythonEngineConnExecutor.scala | 23 +-
.../python/executor/PythonSession.scala | 36 +--
.../python/factory/PythonEngineConnFactory.scala | 0
.../python/hook/PythonVersionEngineHook.scala | 2 +-
.../PythonProcessEngineConnLaunchBuilder.scala | 0
.../manager/engineplugin/python/utils/Kind.scala | 0
.../manager/engineplugin/python/utils/State.scala | 0
.../{engineconn-plugins => }/shell/pom.xml | 0
.../shell/src/main/assembly/distribution.xml | 0
.../shell/src/main/resources/bin/kill-yarn-jobs.sh | 0
.../resources/conf/linkis-engineconn.properties | 0
.../shell/src/main/resources/conf/log4j2.xml | 0
.../engineplugin/shell/ShellEngineConnPlugin.scala | 0
.../ShellProcessEngineConnLaunchBuilder.scala | 0
.../shell/common/ShellEnginePluginConst.scala | 0
.../shell/exception/NoCorrectUserException.scala | 0
.../shell/executor/ErrorStreamReaderThread.scala | 12 +-
.../shell/executor/ShellEngineConnExecutor.scala | 48 ++--
.../shell/executor/YarnAppIdExtractor.scala | 6 +-
.../shell/factory/ShellEngineConnFactory.scala | 0
.../{engineconn-plugins => }/spark/pom.xml | 2 +-
.../spark/src/main/assembly/distribution.xml | 0
.../main/resources/linkis-engineconn.properties | 0
.../spark/src/main/resources/log4j2.xml | 0
.../spark/src/main/resources/python/mix_pyspark.py | 0
.../spark/Interpreter/Interpreter.scala | 0
.../spark/Interpreter/ProcessInterpreter.scala | 0
.../spark/Interpreter/PythonInterpreter.scala | 4 +-
.../engineplugin/spark/SparkEngineConnPlugin.scala | 0
.../spark/args/SparkPythonArgsAppender.scala | 0
.../args/SparkPythonArgsPreExecutionHook.scala | 23 +-
.../spark/args/SparkScalaPreExecutionHook.scala | 0
.../linkis/engineplugin/spark/common/Kind.scala | 0
.../spark/common/LineBufferedProcess.scala | 0
.../spark/common/LineBufferedStream.scala | 0
.../engineplugin/spark/common/LogContainer.scala | 0
.../spark/common/SparkEnginePluginConst.scala | 0
.../engineplugin/spark/common/SparkKind.scala | 0
.../linkis/engineplugin/spark/common/State.scala | 0
.../spark/config/SparkConfiguration.scala | 1 -
.../spark/config/SparkResourceConfiguration.scala | 0
.../engineplugin/spark/cs/CSSparkHelper.scala | 0
.../spark/cs/CSSparkPostExecutionHook.scala | 4 +-
.../spark/cs/CSSparkPreExecutionHook.scala | 6 +-
.../engineplugin/spark/cs/CSTableParser.scala | 0
.../spark/entity/SparkEngineSession.scala | 0
.../ApplicationAlreadyStoppedException.scala | 0
.../spark/exception/ExecuteError.scala | 0
.../spark/exception/MDQErrorException.scala | 0
.../spark/exception/NoSupportEngineException.scala | 0
.../spark/exception/QueryFailedException.scala | 0
.../spark/exception/RetryException.scala | 0
.../spark/exception/SparkCreateFileException.scala | 0
.../exception/SparkSessionNullException.scala | 0
.../engineplugin/spark/executor/SQLSession.scala | 0
.../spark/executor/SparkEngineConnExecutor.scala | 20 +-
.../spark/executor/SparkExecutorOrder.scala | 0
.../spark/executor/SparkPythonExecutor.scala | 46 +--
.../spark/executor/SparkScalaExecutor.scala | 51 ++--
.../spark/executor/SparkSqlExecutor.scala | 12 +-
.../spark/extension/SparkPostExecutionHook.scala | 2 +-
.../spark/extension/SparkPreExecutionHook.scala | 2 +-
.../spark/extension/SparkSqlExtension.scala | 2 +-
.../spark/factory/SparkEngineConnFactory.scala | 10 +-
.../factory/SparkEngineConnResourceFactory.scala | 0
.../spark/factory/SparkPythonExecutorFactory.scala | 0
.../spark/factory/SparkScalaExecutorFactory.scala | 0
.../spark/factory/SparkSqlExecutorFactory.scala | 0
.../engineplugin/spark/imexport/CsvRelation.scala | 6 +-
.../engineplugin/spark/imexport/ExportData.scala | 4 +-
.../engineplugin/spark/imexport/LoadData.scala | 0
.../imexport/util/BackGroundServiceUtils.scala | 0
.../spark/imexport/util/ImExportUtils.scala | 0
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 0
.../spark/lineage/LineageSparkSqlExtension.scala | 6 +-
.../spark/lineage/SparkLineageUtils.scala | 0
.../spark/mdq/MDQPostExecutionHook.scala | 4 +-
.../spark/mdq/MDQPreExecutionHook.scala | 2 +-
.../engineplugin/spark/metadata/HPOBuilder.scala | 0
.../spark/metadata/MetaDataInfoTool.scala | 6 +-
.../spark/metadata/SparkHiveObject.scala | 0
.../spark/metadata/SparkSQLHistoryParser.scala | 0
.../engineplugin/spark/utils/EngineUtils.scala | 2 +-
.../engineplugin/spark/utils/JobProgressUtil.scala | 2 +-
.../org/apache/spark/sql/MethodInvokeHelper.scala | 0
.../apache/spark/sql/SparkLogicalPlanHelper.scala | 0
.../execution/datasources/csv/DolphinToSpark.scala | 0
.../spark/sql/execution/datasources/csv/UDF.scala | 0
.../scala/org/apache/spark/util/SparkUtils.scala | 0
.../{engineconn-plugins => }/sqoop/pom.xml | 0
.../sqoop/src/main/assembly/distribution.xml | 0
.../sqoop/client/LinkisSqoopClient.java | 0
.../engineconnplugin/sqoop/client/Sqoop.java | 0
.../sqoop/client/config/ExecutionContext.java | 0
.../sqoop/client/config/ParamsMapping.java | 0
.../client/exception/JobClosableException.java | 0
.../client/exception/JobExecutionException.java | 0
.../sqoop/client/utils/JarLoader.java | 0
.../java/org/apache/sqoop/mapreduce/JobBase.java | 0
.../main/resources/linkis-engineconn.properties | 0
.../sqoop/src/main/resources/log4j2.xml | 0
.../sqoop/SqoopEngineConnPlugin.scala | 0
.../sqoop/context/SqoopEngineConnContext.scala | 0
.../sqoop/context/SqoopEnvConfiguration.scala | 0
.../sqoop/context/SqoopParamsConfiguration.scala | 0
.../sqoop/context/SqoopResourceConfiguration.scala | 0
.../sqoop/executor/SqoopExecutor.scala | 0
.../sqoop/executor/SqoopOnceCodeExecutor.scala | 32 +--
.../sqoop/executor/SqoopOnceExecutor.scala | 0
.../sqoop/factory/SqoopEngineConnFactory.scala | 0
.../sqoop/factory/SqoopExecutorFactory.scala | 0
.../launch/SqoopEngineConnLaunchBuilder.scala | 2 +-
.../sqoop/params/SqoopParamsResolver.scala | 0
.../resource/SqoopEngineConnResourceFactory.scala | 0
.../engineconnplugin/sqoop/util/ClassUtil.scala | 0
.../linkis/storage/io/client/DefaultIOClient.scala | 47 +--
.../linkis/storage/io/conf/IOFileClientConf.scala | 2 +
.../io/iteraceptor/IOMethodInterceptor.scala | 12 +-
.../IOMethodInterceptorCreatorImpl.scala | 2 +-
.../io/orchestrator/IOTaskPlannerTransform.scala | 2 +-
.../execution/CodeReheaterNotifyTaskConsumer.scala | 2 +-
...ComputationOrchestratorSessionFactoryImpl.scala | 10 +-
.../physical/AbstractPhysicalTransform.scala | 6 +-
.../catalyst/planner/TaskPlannerTransform.scala | 6 +-
.../validator/LabelRegularCheckRuler.scala | 6 +-
.../DefaultCodeExecTaskExecutorManager.scala | 51 ++--
.../computation/monitor/EngineConnMonitor.scala | 28 +-
.../physical/CodeLogicalUnitExecTask.scala | 23 +-
.../service/ComputationTaskExecutionReceiver.scala | 4 +-
.../apache/linkis/orchestrator/Orchestrator.scala | 2 +-
.../orchestrator/converter/AbstractConverter.scala | 4 +-
.../orchestrator/core/AbstractOrchestration.scala | 22 +-
.../orchestrator/core/OrchestrationFuture.scala | 2 +
.../orchestrator/core/impl/SessionStateImpl.scala | 2 +-
.../exception/OrchestratorErrorCodeSummary.scala | 2 +
.../orchestrator/execution/AbstractExecution.scala | 4 +-
.../orchestrator/execution/ExecTaskRunner.scala | 2 +-
.../execution/impl/BaseExecutionTask.scala | 4 +-
.../execution/impl/BaseTaskScheduler.scala | 8 +-
.../execution/impl/DefaultTaskManager.scala | 8 +-
.../execution/impl/ExecutionImpl.scala | 4 +-
.../extensions/catalyst/TransformFactory.scala | 2 +-
.../listener/OrchestratorSyncListenerBus.scala | 4 +-
.../orchestrator/optimizer/AbstractOptimizer.scala | 8 +-
.../orchestrator/parser/AbstractParser.scala | 6 +-
.../orchestrator/planner/AbstractPlanner.scala | 4 +-
.../orchestrator/reheater/AbstractReheater.scala | 2 +-
.../strategy/GatherStrategyJobExecTask.scala | 4 +-
.../orchestrator/strategy/StatusInfoExecTask.scala | 2 +-
.../strategy/async/AsyncExecTaskRunnerImpl.scala | 6 +-
.../strategy/async/AsyncTaskManager.scala | 10 +-
.../ecm/ComputationEngineConnManager.scala | 28 +-
.../orchestrator/ecm/EngineConnManager.scala | 15 +-
.../ecm/EngineConnManagerBuilder.scala | 2 +-
.../ecm/LoadBalanceLabelEngineConnManager.scala | 28 +-
.../ecm/cache/EngineAsyncResponseCache.scala | 8 +-
.../impl/ComputationEngineConnExecutor.scala | 20 +-
.../impl/DefaultEngineAsyncResponseService.scala | 6 +-
.../linkis/bml/client/impl/HttpBmlClient.scala | 3 +-
.../org/apache/linkis/bml/http/HttpConf.scala | 3 +-
.../linkis/bml/common/HdfsResourceHelper.java | 6 +
.../linkis/bml/common/LocalResourceHelper.java | 6 +
.../apache/linkis/bml/common/ResourceHelper.java | 8 +
.../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 | 4 +-
.../apache/linkis/bml/dao/impl/DownloadMapper.xml | 4 +-
.../apache/linkis/bml/dao/impl/ResourceMapper.xml | 4 +-
.../org/apache/linkis/bml/dao/impl/TaskMapper.xml | 4 +-
.../apache/linkis/bml/dao/impl/VersionMapper.xml | 6 +-
.../linkis/bml/{Entity => entity}/BmlProject.java | 2 +-
.../bml/{Entity => entity}/DownloadModel.java | 2 +-
.../linkis/bml/{Entity => entity}/Resource.java | 2 +-
.../bml/{Entity => entity}/ResourceTask.java | 2 +-
.../bml/{Entity => entity}/ResourceVersion.java | 2 +-
.../linkis/bml/{Entity => entity}/Version.java | 2 +-
.../linkis/bml/restful/BmlProjectRestful.java | 4 +-
.../apache/linkis/bml/restful/BmlRestfulApi.java | 10 +-
.../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 | 4 +-
.../bml/service/impl/BmlProjectServiceImpl.java | 2 +-
.../bml/service/impl/DownloadServiceImpl.java | 2 +-
.../bml/service/impl/ResourceServiceImpl.java | 4 +-
.../linkis/bml/service/impl/TaskServiceImpl.java | 8 +-
.../bml/service/impl/VersionServiceImpl.java | 12 +-
.../apache/linkis/bml/vo/ResourceVersionsVO.java | 2 +-
.../linkis/bml/common/HdfsResourceHelperTest.java} | 37 +--
.../bml/common/LocalResourceHelperTest.java} | 38 +--
.../linkis/bml/common/VersionServiceImplTest.java | 50 ++++
.../impl/InstanceAliasManagerImpl.scala | 2 +-
.../impl/RouteLabelInstanceAliasConverter.scala | 16 +-
.../core/dao/DataSourceParamKeyDao.java | 8 +
.../core/dao/mapper/DataSourceParamKeyMapper.xml | 12 +-
.../core/restful/DataSourceCoreRestfulApi.java | 6 +-
.../core/service/DataSourceRelateService.java | 10 +
.../service/impl/DataSourceRelateServiceImpl.java | 10 +
.../core/receivers/DsmReceiver.scala | 6 +-
.../query/server/receiver/BaseMetaReceiver.scala | 4 +-
.../query/service/ElasticConnection.java | 2 +-
.../query/service/ElasticParamsMapper.java | 2 +-
.../query/service/EsMetaService.java | 2 +-
.../query/service/HiveConnection.java | 2 +-
.../query/service/HiveMetaService.java | 2 +-
.../query/service/HiveParamsMapper.java | 2 +-
.../query/service/KafkaConnection.java | 2 +-
.../query/service/KafkaMetaService.java | 2 +-
.../query/service/KafkaParamsMapper.java | 2 +-
.../query/service/MysqlMetaService.java | 2 +-
.../query/service/SqlConnection.java | 2 +-
.../query/service/SqlParamsMapper.java | 2 +-
.../linkis/metadata/hive/dao/HiveMetaDao.java | 54 +++-
.../linkis/metadata/hive/dao/impl/HiveMetaDao.xml | 200 ++++++-------
.../metadata/hive/dto/MetadataQueryParam.java | 144 ++++++++++
.../metadata/restful/api/DataSourceRestfulApi.java | 30 +-
.../metadata/restful/api/MdqTableRestfulApi.java | 17 +-
.../linkis/metadata/service/DataSourceService.java | 15 +-
.../service/HiveMetaWithPermissionService.java | 6 +-
.../apache/linkis/metadata/service/MdqService.java | 14 +-
.../service/impl/DataSourceServiceImpl.java | 84 +++---
.../impl/HiveMetaWithPermissionServiceImpl.java | 43 +--
.../metadata/service/impl/MdqServiceImpl.java | 80 +++---
.../org/apache/linkis/metadata/util/DWSConfig.java | 2 +-
.../org/apache/linkis/metadata/util/HiveUtils.java | 7 +-
.../linkis/metadata/utils/MdqConstants.scala | 6 -
.../apache/linkis/metadata/utils/MdqUtils.scala | 9 +-
.../configuration/service/CategoryService.scala | 14 +-
.../service/ConfigurationService.scala | 16 +-
.../configuration/validate/FloatValidator.scala | 2 +-
.../validate/NumericalValidator.scala | 2 +-
.../validate/ValidatorManagerImpl.scala | 2 +-
.../errorcode/client/utils/ErrorCodeMatcher.scala | 2 +-
.../label/client/EurekaInstanceLabelClient.scala | 8 +-
.../label/client/InstanceLabelClient.scala | 6 +-
.../service/rpc/DefaultInsLabelRpcService.scala | 16 +-
.../cache/impl/DefaultQueryCacheManager.java | 21 +-
.../linkis/jobhistory/cache/utils/MD5Util.java | 9 +-
.../jobhistory/restful/api/QueryRestfulApi.java | 5 +
.../jobhistory/conversions/TaskConversions.scala | 19 +-
.../impl/JobHistoryDetailQueryServiceImpl.scala | 25 +-
.../service/impl/JobHistoryQueryServiceImpl.scala | 18 +-
.../apache/linkis/jobhistory/util/QueryUtils.scala | 6 +-
.../exception/WorkspaceExceptionManager.java | 3 +-
.../filesystem/restful/api/FsRestfulApi.java | 3 +-
.../apache/linkis/filesystem/quartz/FSQuartz.scala | 6 +-
.../linkis/filesystem/service/FsService.scala | 25 +-
.../linkis-gateway-authentication/pom.xml | 14 +
.../linkis-gateway-core/pom.xml | 12 +
.../linkis/gateway/parser/GatewayParser.scala | 6 +-
.../linkis/gateway/route/GatewayRouter.scala | 8 +-
.../linkis/gateway/security/LDAPUserRestful.scala | 2 +-
.../linkis/gateway/security/LinkisPreFilter.scala | 2 +-
.../linkis/gateway/security/ProxyUserUtils.scala | 4 +-
.../linkis/gateway/security/SecurityFilter.scala | 10 +-
.../linkis/gateway/security/UserRestful.scala | 29 +-
.../security/token/TokenAuthentication.scala | 2 +-
.../linkis/httpclient/dws/DWSHttpClient.scala | 2 +-
.../dws/discovery/DWSGatewayDiscovery.scala | 2 +-
.../dws/response/DWSHeartbeatResult.scala | 2 +-
.../src/main/assembly/distribution.xml | 6 +
.../ujes/parser/ResultSetCacheGatewayParser.scala | 4 +-
.../ujes/route/AbstractLabelGatewayRouter.scala | 2 +-
.../gateway/ujes/route/EntranceGatewayRouter.scala | 4 +-
.../ujes/route/GatewayRouterConfiguration.scala | 7 +-
.../ujes/route/HaContextGatewayRouter.scala | 4 +-
.../route/contextservice/ContextIdParserImpl.scala | 4 +-
.../ujes/route/label/RouteLabelParser.scala | 2 +-
.../SpringCloudGatewayConfiguration.scala | 13 +-
.../SpringCloudGatewayWebsocketUtils.scala | 4 +-
.../websocket/WebsocketGatewaySession.scala | 4 +-
pom.xml | 10 +-
scalastyle-config.xml | 2 +-
tool/dependencies/known-dependencies.txt | 51 +++-
tool/modify_license.sh | 12 +-
829 files changed, 3654 insertions(+), 2556 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org