You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by al...@apache.org on 2022/02/15 03:05:46 UTC
[incubator-linkis] branch dev-udf updated (f27699a -> 2267dfc)
This is an automated email from the ASF dual-hosted git repository.
alexkun pushed a change to branch dev-udf
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git.
from f27699a Merge pull request #1431 from apache/dev-1.1.0-datasource
new 122bcea Adjust SimpleDateFormat to ThreadLocal variable close #1379
new f353582 Adjust log
new a420154 Implement the default retryHandler to facilitate java class inheritance
new 8a018e2 provide a method of forced cleanup when HDFS fs cache is enabled close #1380
new 2ac6d06 Add retry to enable httpClient to support Gateway HA close #1381
new dbfff30 Access-Control-Allow-Methods Support configuration
new abec82c Access-Control-Allow-Methods Support configuration
new 482f3e5 add method of getSessionTimeOut
new 6c57184 Adjust the default connection pool of the mybatis module to druid close #1384
new 4cdf426 Added resource related constants
new 925233c optimize code
new 2717b25 Optimize the way the RPC module supports the @receiver annotation close #1385
new 48b41ec optimize code
new d9ecaf4 Fix the memory leak bug of FS in ResultSetReader close #1386
new b87d840 HDFSFileSystem supports updating FS objects close #1387
new d51d0f9 Add a method to get the row and col number of the file close #1388
new ec6a8c7 Merge pull request #1 from apache/dev-1.1.0-datasource
new 95d1c4a Merge branch 'dev-1.1.2' of github.com:WeDataSphere/incubator-linkis into dev-1.1.2
new 849bf80 optimize code
new 9dfd2d6 for client add getTableStatisticInfo method
new 875c187 Add tool class for killing Linux process close #1399
new fca8c15 Add jsonCodeParser
new c68be0c optimize code
new f5a3839 Add the resultLocation property to the JobRequest object close #1400
new 1aea7c5 optimize code
new 973e9b2 add RetryWaitTimeOutLabel
new 07c8d48 Modify message-scheduler to the receiver of rpc
new 17030ba Solve compilation problems
new f4ac183 Solve compilation problems
new fa497a4 optimize code
new 21fedc4 Modify message-scheduler to the receiver of rpc
new 8527b44 Fix issue #1406
new 618e5f5 Support Engine working time idle Maintain feature close #1402
new 22877e8 Record task yarn queue resource usage. close #1405
new dd548f9 Fix issue #1406
new 9badbd8 merge the resource-manager-common module into the manager-common module $1420
new 46f7949 remove useless code
new 629b655 RM supports record changes of resource usage #1423
new d1eb214 Add bml copy resources restful_interface and rollback version restful_interface close #1401
new b9068a5 Merge branch 'dev-1.1.2' of github.com:WeDataSphere/incubator-linkis into dev-1.1.2
new d236151 Add datasource-cient to provide client way for datasource to access the server close #1407
new f49893c The naming method of the jobhistory field needs to be converted to camelCase. close #1413
new 85a505d The ps module adds a database-based distributed lock module. close #1416
new 7fdc91a Merge remote-tracking branch 'origin/dev-1.1.2' into dev-1.1.2
new 3340128 1.The udf module adds version management function and stores udf resources to bml-server. 2.modify ps dependency linkis-message-scheduler to linkis-rpc. close #1422
new 24740bf Solve compilation problems
new bfdf9a7 Add a Token authentication module for gateway. close #1430
new 9e4d423 optimize code
new 850b9af Modify message-scheduler to the receiver of rpc
new 4260d81 optimize code
new bd2f1e8 Merge branch 'dev-1.1.2' into dev-udf
new d44b2fa Merge pull request #2 from apache/dev-udf
new 367bb45 use spotless plugin to format java code
new 7e8e8bc fix Licenses issue
new 81c5cb1 use spotless plugin to format java code
new 2baae7e fix Licenses issue
new 4c9defe add gateway-authentication module
new 6d41ff8 add Licenses
new 550745f add gateway-authentication module
new 933ee6c add Licenses
new d793d63 add Licenses
new 05e0810 use spotless plugin to format java code
new af402f6 add OnceEngineConnHook
new 2e9851a Module optimization
new 541bbbc Cooperate with UDF to support version management optimization close #1422
new 35379c6 Module optimization
new 04df6ce Module optimization
new 7a25387 Support Engine working time idle Maintain feature close #1402
new 440dd86 computation engineConn supports asynchronous execution close #1443
new 1586acb optimize code
new 251c1da add init sql hook
new 4d8d5e4 add reset label hook
new fce36e5 add use db hook
new 75fbefe Optimization task reporting error information
new 6086228 Support reporting yarn resource information #1423
new dbd688e error code optimize
new c4d2a79 add get pid method
new 312d6ee ecm supports reporting actual resource usage to manager #1444
new 0fa55aa optimize code
new dbb40f1 Optimized to use GovernanceUtils.killProcess kill ec #1399
new f5bf083 Modify message-scheduler to the receiver of rpc
new e8f0965 Optimize ec startup directory format #1445
new 9c5c1e3 Replace message-scheduler with rpc module
new 48a6995 Module optimization
new f83aace Module optimization
new dd57b44 Fix issue #1449
new 287dc08 Modify the default engine of JDBC-Driver to presto
new 6a1e4b3 add no limit hooke
new 44947a0 use spotless plugin to format java code
new 4b22977 The locking code in FlinkEngineConnPlugin needs to be changed to double check lock. close #1442
new cb51457 optimize hive engineplugin
new f5aacaa optimize code
new 07eaaca Merge branch 'dev-1.1.2' of https://github.com/WeDataSphere/incubator-linkis into dev-1.1.2
new c9afe61 optimize io_file engineplugin
new 79aa341 optimize jdbc engineplugin
new beb56be optimize pipeline engineplugin
new 54dad0e use spotless plugin to format java code
new 38d17ad Merge branch 'dev-1.1.2' of https://github.com/WeDataSphere/incubator-linkis into dev-1.1.2
new 9d4d7f7 optimize python engineplugin
new 2267dfc Merge pull request #1462 from WeDataSphere/dev-1.1.2
The 1970 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 | 2 -
.../assembly-combined/sbin/kill-process-by-pid.sh | 81 +
.../linkis/common/conf/BDPConfiguration.scala | 10 +-
.../apache/linkis/common/conf/Configuration.scala | 2 +-
.../apache/linkis/common/utils/RetryHandler.scala | 10 +-
.../apache/linkis/common/utils/VariableUtils.scala | 20 +-
linkis-commons/linkis-hadoop-common/pom.xml | 24 +
.../linkis/hadoop/common/utils/HDFSUtils.scala | 60 +-
.../linkis/httpclient/AbstractHttpClient.scala | 230 +-
.../AbstractAuthenticationStrategy.scala | 31 +-
.../linkis/httpclient/config/ClientConfig.scala | 29 +-
.../httpclient/config/HttpClientConstant.scala | 14 +-
.../httpclient/discovery/AbstractDiscovery.scala | 110 +-
.../exception/HttpClientRetryException.scala | 19 +-
.../loadbalancer/DefaultLoadbalancerStrategy.scala | 3 +
.../linkis/httpclient/request/DownloadAction.scala | 13 +-
.../linkis/server/conf/ServerConfiguration.scala | 2 +
.../apache/linkis/server/security/SSOUtils.scala | 2 +
.../linkis/server/security/SecurityFilter.scala | 4 +-
linkis-commons/linkis-mybatis/pom.xml | 7 +
.../apache/linkis/mybatis/DataSourceConfig.java | 5 +-
.../linkis/protocol/constants/TaskConstant.java | 6 +
.../apache/linkis/rpc/serializer/NoneDelegate.java | 28 -
.../rpc/serializer/ProtostuffSerializeUtil.java | 15 +-
.../linkis/rpc/serializer/annotation/Chain.java | 13 +-
.../linkis/rpc/serializer/annotation/Method.java | 14 +-
.../linkis/rpc/serializer/annotation/Order.java | 12 +-
.../linkis/rpc/serializer/annotation/Receiver.java | 12 +-
.../exception/MessageErrorException.java | 12 +-
.../serializer/exception/MessageWarnException.java | 11 +-
.../rpc/serializer/method/MessageExecutor.java | 95 +
.../serializer/method/MethodExecuteWrapper.java | 69 +
.../serializer/method/ReceiverMethodSearcher.java | 95 +
.../serializer/parser/DefaultServiceParser.java | 102 +
.../rpc/serializer/parser/ServiceMethod.java | 113 +
.../rpc/serializer/parser/ServiceParser.java} | 15 +-
.../registry/AbstractServiceRegistry.java | 93 +
.../rpc/serializer/registry/ServiceRegistry.java | 13 +-
.../serializer/registry/SpringServiceRegistry.java | 33 +-
.../linkis/rpc/serializer/utils/MessageUtils.java | 93 +
.../org/apache/linkis/rpc/MessageReceiver.scala | 52 +
.../apache/linkis/rpc/MessageReceiverChooser.scala | 21 +-
.../org/apache/linkis/rpc/RPCReceiveRestful.scala | 4 +-
.../apache/linkis/rpc/conf/RPCConfiguration.scala | 8 +-
.../linkis/scheduler/queue/LoopArrayQueue.scala | 7 +-
.../linkis/storage/fs/impl/HDFSFileSystem.java | 37 +-
.../apache/linkis/storage/domain/DataType.scala | 31 +-
.../linkis/storage/resultset/ResultSetReader.scala | 7 +-
.../storage/resultset/StorageResultSetReader.scala | 22 +-
.../script/reader/StorageScriptFsReader.scala | 6 +-
.../linkis/storage/source/AbstractFileSource.scala | 2 +
.../apache/linkis/storage/source/FileSource.scala | 2 +
.../apache/linkis/storage/source/FileSplit.scala | 19 +
.../storage/source/ResultsetFileSource.scala | 3 +-
.../linkis/storage/utils/FileSystemUtils.scala | 63 +-
.../storage/utils/StorageConfiguration.scala | 2 +
.../linkis-computation-client/pom.xml | 14 +
.../computation/client/LinkisJobBuilder.scala | 23 +-
.../computation/client/LinkisJobClient.scala | 2 +-
.../client/interactive/InteractiveJobBuilder.scala | 7 +-
.../client/once/LinkisManagerClient.scala | 3 +-
.../once/result/EngineConnOperateResult.scala | 11 +-
.../client/once/simple/SimpleOnceJobBuilder.scala | 15 +-
.../org/apache/linkis/ujes/client/UJESClient.scala | 4 +
.../apache/linkis/ujes/client/UJESClientImpl.scala | 2 +-
.../request/GetTableStatisticInfoAction.scala | 81 +
.../ujes/client/request/JobExecuteAction.scala | 2 +-
.../response/GetTableStatisticInfoResult.scala} | 36 +-
.../ujes/client/response/JobInfoResult.scala | 11 +
.../governance/common/entity/job/JobRequest.java | 11 +
.../common/entity/job/OnceExecutorContent.scala | 6 +-
.../governance/common/paser/CodeParser.scala | 43 +
.../governance/common/utils/GovernanceUtils.scala | 50 +
.../launch/LinuxProcessEngineConnLaunch.scala | 18 +
.../apache/linkis/ecm/core/conf/ECMErrorCode.scala | 8 +-
.../ecm/core/launch/EngineConnManagerEnv.scala | 4 +-
.../ecm/core/launch/ProcessEngineConnLaunch.scala | 8 +
.../linkis-engineconn-manager-server/pom.xml | 8 +-
.../linkis/ecm/server/conf/ECMConfiguration.scala | 8 +-
.../linkis/ecm/server/hook/JarUDFLoadECMHook.scala | 69 +-
.../server/operator/EngineConnLogOperator.scala | 10 +-
.../ecm/server/service/ECMHealthService.scala | 17 +-
.../server/service/LocalDirsHandleService.scala | 6 +-
.../impl/AbstractEngineConnLaunchService.scala | 29 +-
.../impl/BmlResourceLocalizationService.scala | 55 +-
.../service/impl/DefaultECMHealthService.scala | 136 +-
.../service/impl/DefaultEngineConnKillService.java | 44 +-
.../impl/DefaultEngineConnPidCallbackService.scala | 2 +-
.../DefaultEngineConnStatusCallbackService.scala | 2 +-
.../impl/DefaultLocalDirsHandleService.scala | 19 +-
.../service/impl/DefaultOperateService.scala | 2 +-
.../service/impl/DefaultYarnCallbackService.scala | 2 +-
.../impl/LinuxProcessEngineConnLaunchService.scala | 10 +-
.../impl/ProcessEngineConnLaunchService.scala | 44 +-
.../ecm/server/spring/ECMSpringConfiguration.scala | 3 +-
.../apache/linkis/ecm/server/util/ECMUtils.scala | 17 +-
.../linkis/ecm/server/util/HardwareUtils.scala | 49 +-
.../linkis-once-engineconn/pom.xml | 2 +-
.../once/executor/hook/OnceEngineConnHook.scala | 40 +
.../linkis-computation-engineconn/pom.xml | 6 +-
.../async/AsyncConcurrentComputationExecutor.scala | 199 +-
.../executor/async/AsyncEngineConnJob.scala | 65 +
.../executor/async/AsyncExecuteContext.scala | 58 +
.../executor/async/AsyncExecuteExecutor.scala | 50 +
...ionExecutor.scala => AsyncExecuteRequest.scala} | 9 +-
.../executor/async/AsyncExecutorManager.scala | 58 +
.../executor/conf/ComputationExecutorConf.scala | 10 +
.../execute/ComputationEngineConnExecution.scala | 5 +-
.../executor/execute/ComputationExecutor.scala | 27 +-
.../execute/ConcurrentComputationExecutor.scala | 2 +-
.../executor/hook/ComputationExecutorHook.scala | 2 +-
.../executor/hook/ExecutorLabelsRestHook.scala | 58 +
.../computation/executor/hook/InitSQLHook.scala | 104 +
.../executor/hook/UDFLoadEngineConnHook.scala | 238 ++-
.../executor/hook/UseDatabaseEngineHook.scala | 79 +
.../hook/executor/FunctionExecutorHook.scala | 74 +
.../executor/listener/TaskStatusListener.scala | 4 +-
.../executor/service/TaskExecutionService.scala | 4 +-
.../service/TaskExecutionServiceImpl.scala | 116 +-
.../executor/utlis/ComputationErrorCode.scala} | 10 +-
.../engineconn/core/executor/ExecutorManager.scala | 63 +-
.../engineconn/core/hook/ExecutorHook.scala} | 45 +-
.../engineconn/launch/EngineConnServer.scala | 41 +-
.../accessible-executor/pom.xml | 10 +-
.../conf/AccessibleExecutorConfiguration.scala | 9 +-
.../execution/AccessibleEngineConnExecution.scala | 66 +-
.../executor/listener/event/TaskEvent.scala | 4 +-
.../executor/service/AccessibleService.scala | 4 +-
.../service/DefaultAccessibleService.scala | 37 +-
.../service/DefaultExecutorHeartbeatService.scala | 2 +-
.../executor/service/DefaultManagerService.scala | 9 +-
.../executor/service/DefaultOperateService.scala | 4 +-
.../service/EngineConnTimedLockService.scala | 4 +-
.../callback-service/pom.xml | 3 +-
.../callback/service/EngineConnCallback.scala | 10 +-
.../executor/entity/ResourceFetchExecutor.scala} | 12 +-
.../executor/service/ManagerService.scala | 4 +-
.../linkis-engineconn-launch/pom.xml | 73 -
.../linkis-engineconn/pom.xml | 1 -
.../linkis-entrance-client/pom.xml | 77 -
.../ClientEngineBuilderBeanAnnotation.java | 50 -
.../ClientEngineRequesterBeanAnnotation.java | 50 -
.../ClientEngineSelectorBeanAnnotation.java | 50 -
.../ClientEntranceParserBeanAnnotation.java | 50 -
.../ClientGroupFactoryBeanAnnotation.java | 50 -
.../ClientInterceptorsBeanAnnotation.java | 50 -
.../DefaultEntranceClientBeanAnnotation.java | 50 -
.../conf/ClientSpringConfiguration.java | 98 -
.../src/main/resources/META-INF/spring.factories | 20 -
.../EngineApplicationNameFactory.scala | 36 -
.../linkis/entranceclient/EntranceClient.scala | 43 -
.../linkis/entranceclient/EntranceClientImpl.scala | 132 --
.../entranceclient/conf/ClientConfiguration.scala | 33 -
.../ClientForEntranceSpringConfiguration.scala | 82 -
.../conf/MultiEntranceCondition.scala | 35 -
.../context/ClientEntranceParser.scala | 45 -
.../entranceclient/context/ClientLogManager.scala | 44 -
.../context/ClientPersistenceEngine.scala | 57 -
.../context/ClientPersistenceManager.scala | 61 -
.../linkis/entranceclient/execute/ClientJob.scala | 62 -
.../linkis-entrance/pom.xml | 2 +-
.../entrance/conf/EntranceSpringConfiguration.java | 56 +-
.../persistence/QueryPersistenceManager.java | 32 +-
.../entrance/restful/EntranceRestfulApi.java | 10 +-
.../entrance/vo/YarnResourceWithStatusVo.java | 109 +
.../entrance/conf/EntranceConfiguration.scala | 2 +-
.../linkis-jdbc-driver/pom.xml | 5 +
.../linkis/ujes/jdbc/LinkisBaseResultSet.java | 2196 ++++++++++----------
.../linkis/ujes/jdbc/LinkisMetaDataResultSet.java | 27 +-
.../org/apache/linkis/ujes/jdbc/TableType.java | 10 +-
.../org/apache/linkis/ujes/jdbc/UJESSQLDriver.java | 14 +-
.../apache/linkis/ujes/jdbc/UJESSQLErrorCode.java | 44 +-
.../apache/linkis/ujes/jdbc/entity/JdbcColumn.java | 73 +-
.../apache/linkis/ujes/jdbc/utils/JDBCUtils.java | 9 +-
.../linkis/ujes/jdbc/UJESClientFactory.scala | 13 +-
.../linkis/ujes/jdbc/UJESSQLConnection.scala | 32 +-
.../linkis/ujes/jdbc/UJESSQLDatabaseMetaData.scala | 67 +-
.../linkis/ujes/jdbc/UJESSQLDriverMain.scala | 50 +-
.../ujes/jdbc/UJESSQLPreparedStatement.scala | 101 +-
.../apache/linkis/ujes/jdbc/UJESSQLResultSet.scala | 359 ++--
.../ujes/jdbc/UJESSQLResultSetMetaData.scala | 102 +-
.../apache/linkis/ujes/jdbc/UJESSQLStatement.scala | 116 +-
.../linkis/ujes/jdbc/UJESSQLTypeParser.scala | 23 +-
.../jdbc/hook/JDBCDriverPreExecutionHook.scala | 10 +-
...cutionHook.scala => NoLimitExecutionHook.scala} | 32 +-
.../jdbc/hook/impl/TableauPreExecutionHook.scala | 14 +-
.../apache/linkis/ujes/jdbc/CreateConnection.java | 14 +-
.../org/apache/linkis/ujes/jdbc/JDBCSpiTest.java | 21 +-
.../ujes/jdbc/UJESSQLDatabaseMetaDataTest.java | 17 +-
.../ujes/jdbc/UJESSQLPreparedStatementTest.java | 44 +-
.../linkis/ujes/jdbc/UJESSQLResultSetTest.java | 26 +-
.../linkis/ujes/jdbc/UJESSQLStatementTest.java | 42 +-
.../manager/label/constant/LabelKeyConstant.java | 2 +
.../manager/label/entity/SerializableLabel.java | 3 -
.../linkis/manager/label/entity/TenantLabel.java | 3 +-
.../manager/label/entity/engine/RunType.scala | 1 +
.../label/entity/engine/UserCreatorLabel.java | 4 +-
.../entity/entrance/RetryWaitTimeOutLabel.java | 46 +
.../manager/label/entity/route/RouteLabel.java | 3 +-
.../linkis-manager/label-manager/pom.xml | 3 +-
.../label/service/ResourceLabelService.scala | 3 +
.../service/impl/DefaultNodeLabelAddService.scala | 2 +-
.../impl/DefaultNodeLabelRemoveService.scala | 6 +-
.../service/impl/DefaultNodeLabelService.scala | 6 +-
.../service/impl/DefaultResourceLabelService.scala | 21 +-
.../linkis-application-manager/pom.xml | 2 +-
.../linkis/manager/am/restful/EMRestfulApi.java | 30 +-
.../manager/am/restful/EngineRestfulApi.java | 27 +-
.../linkis/manager/am/conf/AMConfiguration.scala | 8 +-
.../linkis/manager/am/label/AMLabelChecker.scala | 7 -
.../am/locker/DefaultEngineNodeLocker.scala | 2 +-
.../manager/am/manager/DefaultEMNodeManager.scala | 8 +-
.../am/manager/DefaultEngineNodeManager.scala | 23 +-
.../manager/am/pointer/AbstractNodePointer.scala | 3 +
.../manager/am/pointer/DefaultEMNodPointer.scala | 6 +-
.../manager/am/selector/ECAvailableRule.scala | 50 +
.../am/selector/rule/AvailableNodeSelectRule.scala | 2 +-
.../linkis/manager/am/service/EngineService.scala | 2 +-
.../am/service/cache/DefaultConfCacheService.scala | 2 +-
.../am/service/em/DefaultEMEngineService.scala | 8 +-
.../am/service/em/DefaultEMInfoService.scala | 10 +-
.../am/service/em/DefaultEMRegisterService.scala | 18 +-
.../am/service/em/DefaultEMUnregisterService.scala | 9 +-
.../manager/am/service/em/EMRegisterService.scala | 4 +-
.../am/service/em/EMUnregisterService.scala | 3 +-
.../engine/DefaultEngineAskEngineService.scala | 18 +-
.../engine/DefaultEngineConnCanKillService.scala | 159 ++
.../DefaultEngineConnStatusCallbackService.scala | 6 +-
.../engine/DefaultEngineCreateService.scala | 99 +-
.../service/engine/DefaultEngineInfoService.scala | 2 +-
.../engine/DefaultEngineRecycleService.scala | 6 +-
.../service/engine/DefaultEngineReuseService.scala | 12 +-
.../service/engine/DefaultEngineStopService.scala | 22 +-
.../engine/DefaultEngineSwitchService.scala | 2 +-
.../am/service/engine/EngineAskEngineService.scala | 4 +-
...ervice.scala => EngineConnCanKillService.scala} | 13 +-
.../am/service/engine/EngineCreateService.scala | 4 +-
.../am/service/engine/EngineInfoService.scala | 3 +-
.../am/service/engine/EngineKillService.scala | 3 +-
.../am/service/engine/EngineReuseService.scala | 3 +-
.../am/service/engine/EngineStopService.scala | 9 +-
.../am/service/heartbeat/AMHeartbeatService.scala | 4 +-
.../am/service/monitor/NodeHeartbeatMonitor.scala | 18 +-
.../linkis-manager/linkis-manager-client/pom.xml | 60 -
.../annotation/resource/RMAnnotationParser.java | 82 -
.../client/resource/ResourceManagerClient.scala | 87 -
.../common/entity/enumeration/MaintainType.java} | 14 +-
.../PersistenceResourceActionRecord.java | 155 ++
.../entity/resource/ResourceActionRecord.java | 133 ++
.../common}/exception/RMErrorException.java | 2 +-
.../common}/exception/RMFatalException.java | 2 +-
.../manager/common}/exception/RMWarnException.java | 2 +-
.../common/protocol/engine/ECCanKillRequest.java | 81 +
.../common/protocol/engine/ECCanKillResponse.java} | 41 +-
.../engine/EngineReourceClearRequest.java} | 31 +-
.../common/protocol/node/NodeHealthyRequest.java} | 16 +-
.../protocol/node/NodeHeartbeatResourceMsg.java | 107 +
.../protocol/yarn/YarnAuthorizationRequest.java | 15 +-
.../protocol/yarn/YarnAuthorizationResponse.java} | 36 +-
.../manager/common/conf}/RMConfiguration.scala | 10 +-
.../protocol/resource/ResourceProtocol.scala | 2 +
.../protocol/resource/ResourceWithStatus.scala} | 13 +-
.../resourcemanager/ResourceManagerParam.scala | 0
.../linkis/resourcemanager/ResultResource.scala | 0
.../service/common/pointer/NodePointer.scala | 4 +-
.../linkis-resource-manager-common/pom.xml | 63 -
.../linkis/resourcemanager/RMRPCFormats.scala | 30 -
.../linkis-manager-persistence/pom.xml | 2 +-
.../linkis/manager/dao/ResourceManagerMapper.java | 9 +
.../manager/dao/impl/ResourceManagerMapper.xml | 50 +-
.../persistence/ResourceManagerPersistence.java | 7 +
.../impl/DefaultResourceManagerPersistence.java | 16 +
.../linkis-manager/linkis-resource-manager/pom.xml | 8 +-
.../resourcemanager/conf/ResourceStatus.java | 53 +
.../resourcemanager/domain/RMLabelContainer.java | 2 +-
.../external/service/ExternalResourceService.java | 2 +-
.../service/impl/ExternalResourceServiceImpl.java | 4 +-
.../restful/vo/UserCreatorEngineType.java} | 38 +-
.../resourcemanager/restful/vo/UserResourceVo.java | 178 ++
.../linkis/resourcemanager/utils/AlertUtils.java | 77 +-
.../external/yarn/YarnResourceRequester.scala | 4 +-
.../resourcemanager/message/RMMessageService.scala | 45 +-
.../resourcemanager/restful/RMMonitorRest.scala | 204 +-
.../service/LabelResourceService.scala | 2 +
.../service/RequestResourceService.scala | 3 +-
.../service/impl/DefaultResourceManager.scala | 163 +-
.../impl/DriverAndYarnReqResourceService.scala | 3 +-
.../service/impl/LabelResourceServiceImpl.scala | 4 +
.../service/impl/ResourceLogService.scala | 86 +-
.../service/impl/UserResourceService.scala | 100 +
.../linkis/resourcemanager/utils/RMUtils.scala | 36 +-
.../resourcemanager/utils/UserConfiguration.scala | 4 +-
.../linkis-manager/pom.xml | 1 -
linkis-computation-governance/pom.xml | 2 +-
.../engineconn-plugins/flink/pom.xml | 2 +-
.../flink/FlinkEngineConnPlugin.scala | 19 +-
.../flink/factory/FlinkSQLExecutorFactory.scala | 8 +-
.../linkis/engineconnplugin/flink/ql/Grammar.scala | 24 +-
.../engineconnplugin/flink/ql/GrammarFactory.scala | 37 +
.../flink/ql/impl/CreateTableAsSelectGrammar.scala | 59 +
.../engineconn-plugins/hive/pom.xml | 19 +-
.../main/resources/linkis-engineconn.properties | 4 +-
.../hive/src/main/resources/log4j2.xml | 23 +-
.../engineplugin/hive/HiveEngineConnPlugin.scala | 33 +-
.../linkis/engineplugin/hive/conf/Counters.scala | 20 +-
.../hive/executor/HiveEngineConnExecutor.scala | 69 +-
.../engineconn-plugins/io_file/pom.xml | 2 +-
.../io_file/src/main/assembly/distribution.xml | 3 +-
.../io_file/src/main/resources/log4j2.xml | 19 +-
.../engineplugin/io/IoEngineConnPlugin.scala | 21 +-
.../io/executor/IoEngineConnExecutor.scala | 22 +-
.../engineconn-plugins/jdbc/pom.xml | 8 +-
.../jdbc/src/main/assembly/distribution.xml | 3 +-
.../jdbc/src/main/resources/log4j2.xml | 17 +-
.../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 21 +-
.../engineconn-plugins/pipeline/pom.xml | 2 +-
.../pipeline/src/main/assembly/distribution.xml | 3 +-
.../main/resources/linkis-engineconn.properties | 3 +
.../pipeline/PipelineEngineConnPlugin.scala | 21 +-
.../conf/PipelineEngineConfiguration.scala | 2 +-
.../pipeline/constant/PipeLineConstant.scala | 8 +-
.../executor/PipelineEngineConnExecutor.scala | 19 +-
.../engineconn-plugins/python/pom.xml | 2 +-
.../main/resources/linkis-engineconn.properties | 3 +
.../python/src/main/resources/log4j2.xml | 30 +-
.../python/PythonEngineConnPlugin.scala | 33 +-
.../python/conf/PythonEngineConfiguration.scala | 4 +-
.../exception/PythonSessionNullException.scala | 10 +-
.../python/executor/PythonEngineConnExecutor.scala | 15 +-
.../python/executor/PythonSession.scala | 103 +-
.../engineconn-plugins/spark/pom.xml | 21 +
.../org/apache/linkis/bml/client/BmlClient.java | 8 +
.../linkis/bml/client/impl/HttpBmlClient.scala | 90 +-
.../org/apache/linkis/bml/http/HttpConf.scala | 4 +
.../apache/linkis/bml/request/BmlPOSTAction.scala | 31 +-
.../org/apache/linkis/bml/response/BmlResult.scala | 10 +
.../apache/linkis/bml/protocol/BmlProtocol.scala | 8 +-
.../src/main/assembly/distribution.xml | 26 +-
.../org/apache/linkis/bml/Entity/ResourceTask.java | 37 +
.../apache/linkis/bml/Entity/ResourceVersion.java | 20 +
.../linkis/bml/common/HdfsResourceHelper.java | 6 +-
.../apache/linkis/bml/common/OperationEnum.java | 5 +-
.../apache/linkis/bml/common/ScheduledTask.java | 3 -
.../org/apache/linkis/bml/dao/ResourceDao.java | 8 +
.../java/org/apache/linkis/bml/dao/VersionDao.java | 4 +
.../apache/linkis/bml/restful/BmlRestfulApi.java | 77 +
.../apache/linkis/bml/service/ResourceService.java | 4 +
.../org/apache/linkis/bml/service/TaskService.java | 7 +
.../bml/service/impl/ResourceServiceImpl.java | 8 +
.../linkis/bml/service/impl/TaskServiceImpl.java | 125 ++
.../linkis-cs-highavailable/pom.xml | 2 +-
.../linkis-cs-search/pom.xml | 2 +-
.../linkis-cs-server/pom.xml | 28 +-
.../datasource/client/DataSourceRemoteClient.scala | 38 +
...moteClient.scala => MetaDataRemoteClient.scala} | 17 +-
.../linkis/datasource/client/RemoteClient.scala | 2 +-
.../client/impl/LinkisDataSourceRemoteClient.scala | 58 +
.../client/impl/LinkisMetaDataRemoteClient.scala | 37 +
.../client/request/CreateDataSourceAction.scala | 68 +
.../client/request/DataSourceAction.scala | 12 +-
.../request/DataSourceTestConnectAction.scala | 77 +
.../client/request/DeleteDataSourceAction.scala | 60 +
.../client/request/ExpireDataSourceAction.scala | 61 +
.../request/GetAllDataSourceTypesAction.scala | 50 +
.../GetConnectParamsByDataSourceIdAction.scala | 73 +
.../GetConnectParamsByDataSourceNameAction.scala | 83 +
.../request/GetDataSourceVersionsAction.scala | 61 +
.../request/GetInfoByDataSourceIdAction.scala | 71 +
.../request/GetKeyTypeDatasourceAction.scala | 61 +
.../client/request/MetadataGetColumnsAction.scala | 91 +
.../request/MetadataGetDatabasesAction.scala | 71 +
.../request/MetadataGetPartitionsAction.scala | 89 +
.../request/MetadataGetTablePropsAction.scala | 90 +
.../client/request/MetadataGetTablesAction.scala | 79 +
.../request/PublishDataSourceVersionAction.scala | 72 +
.../client/request/QueryDataSourceAction.scala | 101 +
.../client/request/QueryDataSourceEnvAction.scala | 87 +
.../client/request/UpdateDataSourceAction.scala | 81 +
.../request/UpdateDataSourceParameterAction.scala | 80 +
.../client/response/CreateDataSourceResult.scala | 12 +-
.../response/DataSourceTestConnectResult.scala | 18 +-
.../client/response/DeleteDataSourceResult.scala | 12 +-
.../client/response/ExpireDataSourceResult.scala | 12 +-
.../response/GetAllDataSourceTypesResult.scala | 37 +-
.../GetConnectParamsByDataSourceIdResult.scala | 17 +-
.../GetConnectParamsByDataSourceNameResult.scala | 17 +-
.../response/GetDataSourceVersionsResult.scala | 35 +-
.../response/GetInfoByDataSourceIdResult.scala | 31 +-
.../response/GetKeyTypeDatasourceResult.scala | 38 +
.../client/response/MetadataGetColumnsResult.scala | 36 +-
.../response/MetadataGetDatabasesResult.scala | 13 +-
.../response/MetadataGetPartitionsResult.scala | 18 +-
.../response/MetadataGetTablePropsResult.scala | 18 +-
.../client/response/MetadataGetTablesResult.scala | 18 +-
.../response/PublishDataSourceVersionResult.scala | 10 +-
.../client/response/QueryDataSourceEnvResult.scala | 36 +-
.../client/response/QueryDataSourceResult.scala | 36 +-
.../response/UpdateDataSourceParameterResult.scala | 12 +-
.../client/response/UpdateDataSourceResult.scala | 12 +-
.../datasource/client/TestDataSourceClient.scala | 78 +
.../datasourcemanager/common/DsmConfiguration.java | 10 +-
.../common/util/PatternInjectUtils.java | 209 --
.../server/receiver/BaseMetaReceiver.scala | 67 +
.../linkis-metadata-manager/service/hive/pom.xml | 2 +-
.../linkis-datasource/linkis-metadata/pom.xml | 8 +-
.../org/apache/linkis/metadata/dao/impl/MdqDao.xml | 2 +-
.../metadata/domain/mdq/DomainCoversionUtils.java | 14 +
.../domain/mdq/bo/MdqTableFieldsInfoBO.java | 12 +
.../linkis/metadata/domain/mdq/po/MdqField.java | 10 +
.../linkis/metadata/ddl/ScalaDDLCreator.scala | 3 +
.../linkis-configuration/pom.xml | 2 +-
.../linkis-instance-label-client/pom.xml | 2 +-
.../linkis-instance-label-server/pom.xml | 2 +-
.../label/service/InsLabelRpcService.scala | 12 +-
.../service/rpc/DefaultInsLabelRpcService.scala | 14 +-
.../linkis-publicservice/linkis-jobhistory/pom.xml | 7 +-
.../linkis/jobhistory/dao/impl/JobDetailMapper.xml | 28 +-
.../jobhistory/dao/impl/JobHistoryMapper.xml | 70 +-
.../apache/linkis/jobhistory/entity/JobDetail.java | 72 +-
.../linkis/jobhistory/entity/JobHistory.java | 133 +-
.../jobhistory/conversions/TaskConversions.scala | 108 +-
.../service/JobHistoryDetailQueryService.java | 5 +
.../impl/JobHistoryDetailQueryServiceImpl.scala | 13 +-
.../service/impl/JobHistoryQueryServiceImpl.scala | 27 +-
.../apache/linkis/jobhistory/util/QueryUtils.scala | 8 +-
.../linkis-ps-common-lock}/pom.xml | 31 +-
.../common/lock/CommonLockSpringConfiguration.java | 38 +
.../common/lock/dao/CommonLockMapper.java | 42 +
.../common/lock/entity/CommonLock.java | 87 +
.../common/lock/service/CommonLockService.java | 14 +-
.../service/impl/DefaultCommonLockService.java | 79 +
.../linkis/filesystem/WorkspaceClientImpl.scala | 18 +
.../filesystem/request/WorkspaceClient.scala | 2 +
.../linkis-storage-script-dev-server/pom.xml | 2 +-
.../linkis-udf/linkis-udf-client/pom.xml | 2 +-
.../scala/org/apache/linkis/udf/UDFClient.scala | 72 +-
.../linkis-udf/linkis-udf-common/pom.xml | 8 +-
.../java/org/apache/linkis/udf/entity/UDFInfo.java | 59 +-
.../java/org/apache/linkis/udf/entity/UDFTree.java | 8 +-
.../org/apache/linkis/udf/entity/UDFVersion.java | 133 ++
.../org/apache/linkis/udf/utils/ConstantVar.java | 16 +-
.../java/org/apache/linkis/udf/vo/DownloadVo.java | 31 +-
.../udf/{entity/UDFInfo.java => vo/UDFAddVo.java} | 146 +-
.../udf/{entity/UDFInfo.java => vo/UDFInfoVo.java} | 146 +-
.../{entity/UDFInfo.java => vo/UDFUpdateVo.java} | 112 +-
.../{entity/UDFInfo.java => vo/UDFVersionVo.java} | 144 +-
.../linkis-udf/linkis-udf-service/pom.xml | 7 +-
.../java/org/apache/linkis/udf/api/UDFApi.java | 424 +++-
.../java/org/apache/linkis/udf/dao/UDFDao.java | 48 +-
.../java/org/apache/linkis/udf/dao/UDFTreeDao.java | 14 +-
.../org/apache/linkis/udf/dao/UDFVersionDao.java | 60 +
.../java/org/apache/linkis/udf/dao/impl/UDFDao.xml | 226 +-
.../org/apache/linkis/udf/dao/impl/UDFTreeDao.xml | 20 +-
.../apache/linkis/udf/dao/impl/UDFVersionDao.xml | 107 +
.../org/apache/linkis/udf/service/UDFService.java | 61 +-
.../linkis/udf/service/impl/UDFServiceImpl.java | 989 ++++++---
.../udf/service/impl/UDFTreeServiceImpl.java | 30 +-
.../linkis-publicservice/linkis-variable/pom.xml | 2 +-
.../linkis-publicservice/pom.xml | 2 +
.../src/main/assembly/distribution.xml | 26 +-
.../linkis-gateway-authentication}/pom.xml | 75 +-
.../gateway/authentication/dao/TokenDao.java | 18 +-
.../authentication/dao/impl/TokenMapper.xml | 53 +
.../gateway/authentication/entity/TokenEntity.java | 104 +
.../exception/TokenAuthException.java | 18 +-
.../exception/TokenNotExistException.java | 18 +-
.../linkis/gateway/authentication/bo/Token.scala | 70 +
.../linkis/gateway/authentication/bo/User.scala | 13 +-
.../gateway/authentication/bo/impl/TokenImpl.scala | 158 ++
.../gateway/authentication/bo/impl/UserImpl.scala | 12 +-
.../authentication/conf/TokenConfiguration.scala | 25 +-
.../service/CachedTokenService.scala | 157 ++
.../authentication/service/TokenService.scala | 49 +
.../gateway/authentication/dao/TokenDaoTest.java | 51 +
.../authentication/dao/utils/MyBatisUtil.java | 53 +
.../service/CachedTokenServiceTest.java | 110 +
.../src/test/resources/TokenMapper.xml | 53 +
.../src/test/resources/conf/mybatis-config.xml} | 48 +-
.../src/test/resources/conf/run_first_for_test.sql | 30 +-
.../linkis-gateway-core/pom.xml | 7 +
.../gateway/config/GatewayConfiguration.scala | 12 +-
.../config/GatewaySpringConfiguration.scala | 7 +
.../linkis/gateway/route/GatewayRouter.scala | 27 +-
.../linkis/gateway/security/GatewaySSOUtils.scala | 37 +-
.../linkis/gateway/security/SecurityFilter.scala | 8 +-
.../linkis/gateway/security/UserRestful.scala | 178 +-
.../security/token/TokenAuthentication.scala | 81 +-
.../linkis/httpclient/dws/DWSHttpClient.scala | 13 +-
.../StaticAuthenticationStrategy.scala | 41 +-
.../dws/config/GatewayHttpClientConf.scala | 11 +-
.../dws/discovery/DefaultConfigDiscovery.scala | 53 +
.../linkis/httpclient/dws/response/DWSResult.scala | 46 +-
.../linkis-gateway-server-support/pom.xml | 30 +
.../src/main/assembly/distribution.xml | 29 +-
.../ujes/parser/ResultSetCacheGatewayParser.scala | 110 +
.../ujes/route/AbstractLabelGatewayRouter.scala | 2 +-
.../ujes/route/GatewayRouterConfiguration.scala | 4 +-
.../ujes/route/label/RouteLabelParser.scala | 12 +-
.../linkis-service-gateway/pom.xml | 1 +
pom.xml | 1 +
500 files changed, 14388 insertions(+), 6864 deletions(-)
create mode 100644 assembly-combined-package/assembly-combined/sbin/kill-process-by-pid.sh
copy linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/TableType.java => linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/config/HttpClientConstant.scala (85%)
copy linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineReuseService.scala => linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/exception/HttpClientRetryException.scala (72%)
copy linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/java/org/apache/linkis/manager/client/annotation/resource/RegisterResource.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/annotation/Chain.java (89%)
rename linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/java/org/apache/linkis/manager/client/annotation/resource/EnableResourceManager.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/annotation/Method.java (89%)
copy linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/java/org/apache/linkis/manager/client/annotation/resource/RegisterResource.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/annotation/Order.java (89%)
rename linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/java/org/apache/linkis/manager/client/annotation/resource/RegisterResource.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/annotation/Receiver.java (90%)
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/exception/RMErrorException.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/exception/MessageErrorException.java (71%)
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/exception/RMWarnException.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/exception/MessageWarnException.java (74%)
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/method/MessageExecutor.java
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/method/MethodExecuteWrapper.java
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/method/ReceiverMethodSearcher.java
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/parser/DefaultServiceParser.java
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/parser/ServiceMethod.java
copy linkis-commons/{linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/request/DownloadAction.scala => linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/parser/ServiceParser.java} (80%)
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/registry/AbstractServiceRegistry.java
copy linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/TableType.java => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/registry/ServiceRegistry.java (86%)
copy linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineSwitchService.scala => linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/registry/SpringServiceRegistry.java (50%)
create mode 100644 linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/serializer/utils/MessageUtils.java
create mode 100644 linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/MessageReceiver.scala
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceProtocol.scala => linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/MessageReceiverChooser.scala (69%)
create mode 100644 linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/request/GetTableStatisticInfoAction.scala
copy linkis-computation-governance/{linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineRequest.java => linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/response/GetTableStatisticInfoResult.scala} (56%)
rename linkis-computation-governance/linkis-computation-governance-common/src/main/{java => scala}/org/apache/linkis/governance/common/entity/job/OnceExecutorContent.scala (99%)
create mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/GovernanceUtils.scala
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-service/src/main/java/org/apache/linkis/udf/dao/UDFTreeDao.java => linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/util/HardwareUtils.scala (52%)
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/hook/OnceEngineConnHook.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncEngineConnJob.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncExecuteContext.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncExecuteExecutor.scala
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/{AsyncConcurrentComputationExecutor.scala => AsyncExecuteRequest.scala} (73%)
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncExecutorManager.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/hook/ExecutorLabelsRestHook.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/hook/InitSQLHook.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/hook/UseDatabaseEngineHook.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/hook/executor/FunctionExecutorHook.scala
copy linkis-computation-governance/{linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/utlis/ComputationErrorCode.scala} (80%)
copy linkis-computation-governance/linkis-engineconn/{linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/hook/ComputationExecutorHook.scala => linkis-engineconn-core/src/main/scala/org/apache/linkis/engineconn/core/hook/ExecutorHook.scala} (58%)
rename linkis-computation-governance/linkis-engineconn/{linkis-engineconn-launch => linkis-engineconn-core}/src/main/scala/org/apache/linkis/engineconn/launch/EngineConnServer.scala (90%)
copy linkis-computation-governance/{linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-engineconn/linkis-engineconn-executor/executor-core/src/main/scala/org/apache/linkis/engineconn/executor/entity/ResourceFetchExecutor.scala} (77%)
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-launch/pom.xml
delete mode 100644 linkis-computation-governance/linkis-entrance-client/pom.xml
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientEngineBuilderBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientEngineRequesterBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientEngineSelectorBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientEntranceParserBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientGroupFactoryBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/ClientInterceptorsBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/annotation/DefaultEntranceClientBeanAnnotation.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/java/org/apache/linkis/entranceclient/conf/ClientSpringConfiguration.java
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/resources/META-INF/spring.factories
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/EngineApplicationNameFactory.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/EntranceClient.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/EntranceClientImpl.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/conf/ClientConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/conf/ClientForEntranceSpringConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/conf/MultiEntranceCondition.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/context/ClientEntranceParser.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/context/ClientLogManager.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/context/ClientPersistenceEngine.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/context/ClientPersistenceManager.scala
delete mode 100644 linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/execute/ClientJob.scala
create mode 100644 linkis-computation-governance/linkis-entrance/src/main/java/org/apache/linkis/entrance/vo/YarnResourceWithStatusVo.java
copy linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/hook/impl/{TableauPreExecutionHook.scala => NoLimitExecutionHook.scala} (62%)
create mode 100644 linkis-computation-governance/linkis-manager/label-common/src/main/java/org/apache/linkis/manager/label/entity/entrance/RetryWaitTimeOutLabel.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/ECAvailableRule.scala
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineConnCanKillService.scala
copy linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/{EngineAskEngineService.scala => EngineConnCanKillService.scala} (76%)
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-client/pom.xml
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/java/org/apache/linkis/manager/client/annotation/resource/RMAnnotationParser.java
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-client/src/main/scala/org/apache/linkis/manager/client/resource/ResourceManagerClient.scala
copy linkis-computation-governance/{linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/enumeration/MaintainType.java} (71%)
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/persistence/PersistenceResourceActionRecord.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/ResourceActionRecord.java
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager => linkis-manager-common/src/main/java/org/apache/linkis/manager/common}/exception/RMErrorException.java (96%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager => linkis-manager-common/src/main/java/org/apache/linkis/manager/common}/exception/RMFatalException.java (95%)
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager => linkis-manager-common/src/main/java/org/apache/linkis/manager/common}/exception/RMWarnException.java (95%)
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/ECCanKillRequest.java
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineRequest.java => linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/ECCanKillResponse.java} (56%)
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineRequest.java => linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineReourceClearRequest.java} (67%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/exception/RMWarnException.java => linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/node/NodeHealthyRequest.java} (67%)
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/node/NodeHeartbeatResourceMsg.java
copy linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/request/DownloadAction.scala => linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/yarn/YarnAuthorizationRequest.java (80%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineResponse.java => linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/yarn/YarnAuthorizationResponse.java} (53%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common/src/main/scala/org/apache/linkis/resourcemanager/utils => linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/conf}/RMConfiguration.scala (97%)
copy linkis-computation-governance/{linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-manager/linkis-manager-commons/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceWithStatus.scala} (71%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common => linkis-manager-common}/src/main/scala/org/apache/linkis/resourcemanager/ResourceManagerParam.scala (100%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/{linkis-resource-manager-common => linkis-manager-common}/src/main/scala/org/apache/linkis/resourcemanager/ResultResource.scala (100%)
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/pom.xml
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/scala/org/apache/linkis/resourcemanager/RMRPCFormats.scala
create mode 100644 linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/java/org/apache/linkis/resourcemanager/conf/ResourceStatus.java
copy linkis-computation-governance/linkis-manager/{linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineRequest.java => linkis-resource-manager/src/main/java/org/apache/linkis/resourcemanager/restful/vo/UserCreatorEngineType.java} (60%)
create mode 100644 linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/java/org/apache/linkis/resourcemanager/restful/vo/UserResourceVo.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/scala/org/apache/linkis/resourcemanager/service/impl/UserResourceService.scala
copy linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/EMRegisterService.scala => linkis-engineconn-plugins/engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/Grammar.scala (61%)
create mode 100644 linkis-engineconn-plugins/engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/GrammarFactory.scala
create mode 100644 linkis-engineconn-plugins/engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/ql/impl/CreateTableAsSelectGrammar.scala
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-service/src/main/java/org/apache/linkis/udf/dao/UDFTreeDao.java => linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/conf/Counters.scala (65%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/DataSourceRemoteClient.scala
copy linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/{RemoteClient.scala => MetaDataRemoteClient.scala} (50%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisDataSourceRemoteClient.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisMetaDataRemoteClient.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/CreateDataSourceAction.scala
rename linkis-computation-governance/linkis-entrance-client/src/main/scala/org/apache/linkis/entranceclient/exception/ClientErrorException.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceAction.scala (78%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceTestConnectAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DeleteDataSourceAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/ExpireDataSourceAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetAllDataSourceTypesAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceIdAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceNameAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetDataSourceVersionsAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceIdAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetKeyTypeDatasourceAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetColumnsAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetDatabasesAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetPartitionsAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablePropsAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablesAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/PublishDataSourceVersionAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceEnvAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceAction.scala
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceParameterAction.scala
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/CreateDataSourceResult.scala (68%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/DataSourceTestConnectResult.scala (63%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/DeleteDataSourceResult.scala (67%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/ExpireDataSourceResult.scala (67%)
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetAllDataSourceTypesResult.scala (51%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetConnectParamsByDataSourceIdResult.scala (65%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetConnectParamsByDataSourceNameResult.scala (64%)
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetDataSourceVersionsResult.scala (50%)
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetInfoByDataSourceIdResult.scala (56%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/GetKeyTypeDatasourceResult.scala
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/MetadataGetColumnsResult.scala (51%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/MetadataGetDatabasesResult.scala (66%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/MetadataGetPartitionsResult.scala (62%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/MetadataGetTablePropsResult.scala (64%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/MetadataGetTablesResult.scala (65%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/PublishDataSourceVersionResult.scala (71%)
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/QueryDataSourceEnvResult.scala (51%)
copy linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/UJESClientImpl.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/QueryDataSourceResult.scala (51%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/UpdateDataSourceParameterResult.scala (67%)
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/response/UpdateDataSourceResult.scala (67%)
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/test/scala/org/apache/linkis/datasource/client/TestDataSourceClient.scala
copy linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/async/AsyncConcurrentComputationExecutor.scala => linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/common/src/main/java/org/apache/linkis/datasourcemanager/common/DsmConfiguration.java (73%)
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/common/src/main/java/org/apache/linkis/datasourcemanager/common/util/PatternInjectUtils.java
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata-manager/server/src/main/scala/org/apache/linkis/metadatamanager/server/receiver/BaseMetaReceiver.scala
copy {linkis-computation-governance/linkis-manager/linkis-manager-persistence => linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock}/pom.xml (80%)
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock/src/main/java/org/apache/linkis/publicservice/common/lock/CommonLockSpringConfiguration.java
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock/src/main/java/org/apache/linkis/publicservice/common/lock/dao/CommonLockMapper.java
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock/src/main/java/org/apache/linkis/publicservice/common/lock/entity/CommonLock.java
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock/src/main/java/org/apache/linkis/publicservice/common/lock/service/CommonLockService.java (71%)
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-ps-common-lock/src/main/java/org/apache/linkis/publicservice/common/lock/service/impl/DefaultCommonLockService.java
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/entity/UDFVersion.java
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/protocol/TimeoutEMEngineRequest.java => linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/vo/DownloadVo.java (58%)
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/{entity/UDFInfo.java => vo/UDFAddVo.java} (76%)
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/{entity/UDFInfo.java => vo/UDFInfoVo.java} (76%)
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/{entity/UDFInfo.java => vo/UDFUpdateVo.java} (50%)
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-common/src/main/java/org/apache/linkis/udf/{entity/UDFInfo.java => vo/UDFVersionVo.java} (54%)
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-service/src/main/java/org/apache/linkis/udf/dao/UDFVersionDao.java
create mode 100644 linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-service/src/main/java/org/apache/linkis/udf/dao/impl/UDFVersionDao.xml
copy {linkis-computation-governance/linkis-manager/linkis-manager-persistence => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication}/pom.xml (68%)
copy linkis-public-enhancements/linkis-publicservice/linkis-udf/linkis-udf-service/src/main/java/org/apache/linkis/udf/dao/UDFTreeDao.java => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/java/org/apache/linkis/gateway/authentication/dao/TokenDao.java (67%)
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/java/org/apache/linkis/gateway/authentication/dao/impl/TokenMapper.xml
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/java/org/apache/linkis/gateway/authentication/entity/TokenEntity.java
copy linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/exception/RMErrorException.java => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/java/org/apache/linkis/gateway/authentication/exception/TokenAuthException.java (69%)
rename linkis-computation-governance/linkis-manager/linkis-manager-commons/linkis-resource-manager-common/src/main/java/org/apache/linkis/resourcemanager/exception/RMErrorException.java => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/java/org/apache/linkis/gateway/authentication/exception/TokenNotExistException.java (68%)
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/bo/Token.scala
copy linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/TableType.java => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/bo/User.scala (88%)
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/bo/impl/TokenImpl.scala
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/bo/impl/UserImpl.scala (79%)
copy linkis-engineconn-plugins/engineconn-plugins/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/conf/PipelineEngineConfiguration.scala => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/conf/TokenConfiguration.scala (62%)
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/service/CachedTokenService.scala
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/service/TokenService.scala
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/java/org/apache/linkis/gateway/authentication/dao/TokenDaoTest.java
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/java/org/apache/linkis/gateway/authentication/dao/utils/MyBatisUtil.java
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/java/org/apache/linkis/gateway/authentication/service/CachedTokenServiceTest.java
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/resources/TokenMapper.xml
copy linkis-spring-cloud-services/linkis-service-gateway/{pom.xml => linkis-gateway-authentication/src/test/resources/conf/mybatis-config.xml} (51%)
copy linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/resources/conf/run_first_for_test.sql (56%)
rename linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorCode.scala => linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-httpclient-support/src/main/scala/org/apache/linkis/httpclient/dws/config/GatewayHttpClientConf.scala (77%)
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-httpclient-support/src/main/scala/org/apache/linkis/httpclient/dws/discovery/DefaultConfigDiscovery.scala
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-server-support/src/main/scala/org/apache/linkis/gateway/ujes/parser/ResultSetCacheGatewayParser.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org