You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ja...@apache.org on 2022/08/15 15:34:55 UTC
[incubator-linkis] branch dev-1.3.1 updated (2b49e05a8 -> 09bcceb86)
This is an automated email from the ASF dual-hosted git repository.
jackxu2011 pushed a change to branch dev-1.3.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
from 2b49e05a8 Add ErrorCode module unit test configuration file entry (#2725)
new c7cdf8a7a Added k8S deployment file and Jenkins pipeline profile (#2342)
new 33feec69d 1.fix headless service (#2375)
new 6af018005 Merge remote-tracking branch 'origin/dev-1.2.0' into dev-1.3.0
new e438a4b2d Merge pull request #2403 from legendtkl/merge120
new 449478a2a Merge pull request #2426 from apache/dev-1.2.0
new 6086344e2 [Feature] Delete the previously committed k8s-related resource files, which can be generated using Helm (#2448)
new 78d98ca71 [Feature] Add scripts and documents for helm chart development and testing (#2445)
new 3dd1d4cd6 [Feature] Add Dockerfile to linkis-dist module for both linkis backends and web (#2447)
new 4af9e7fef [Feature] Add helm charts for linkis backends, web and db init (#2446)
new 92353cdd8 Add two scripts for development assistance: login-pod/remote-debug-proxy (#2465)
new dd9401148 Add install front-end dependencies
new 9fb97809b adjust apache rat check exclude configuration for module linkis-web (#2499)
new dadbe6a9f Support git action and add publish-docker.yaml (#2478)
new 3c459bd41 Merge pull request #1 from apache/dev-1.3.0
new 15f536b67 Merge pull request #2483 from utopianet/dev-1.3.0
new f7fa65a46 [Feature] init rbac role and roleRef for linkis (#2514)
new 33402e363 [Feature] introduced a new image, called LDH (Linkis's hadoop all-in-one image) (#2540)
new 413134eec [Feat] expose pod namespace via downward api (#2554)
new 0691a8b0d Merge branch 'dev-1.3.0-merge' into dev-1.2.0
new 2962ce8f0 Merge pull request #2 from casionone/dev-1.2.0
new 476a313b6 Merge pull request #2565 from casionone/dev-1.3.0-merge
new d753cd808 Merge pull request #2641 from apache/dev-1.2.0
new 261840154 Merge pull request #2700 from apache/master
new 044f9f0e0 clear expired cookie when user login (#2699)
new e3353b831 Add regular interval for Loghelper to push logs (#2709)
new ea43a6de9 Refactor exception in CS hook in spark plugin. (#2711)
new c6d61c25c Merge branch 'dev-1.3.0' into dev-1.3.1-merge-1.3.0
new 471cfda9f [Refactor] refactor linkis-web module (#2714)
new 04e18f1cf update version to 1.2.0 (#2747)
new c4b3b2994 Fix the problem that the result set is not completely written to HDFS (#2740)
new 4709efd26 Fixed the problem that some rows might be lost when reading the result set (#2756)
new 181835ed1 update flink engine version to 1.12.2 (#2689)
new 993545916 fix: fix Github repos page License display with Unknown licenses found (#2715)
new 11914fb94 [Feature] The connection cache pool key value in the ConnectionManager is adjusted to the data source name + version number. (#2742)
new 2dedfcaa3 [Bug] [JDBC-Engine] jdbc data source configuration priority definition. (#2751)
new 4479c2d81 Update README.md doc (#2752)
new 5d1959f9e update CONTRIBUTING.md (#2753)
new 3fec951f8 Merge remote-tracking branch 'origin/master' into dev-1.2.0-master
new 08fe27199 Fix links
new 123a297c7 Merge pull request #2758 from WeDataSphere/dev-1.2.0-master
new 43f750c63 Merge pull request #2760 from apache/master
new 1f914cec5 feat: add code formatter (#2761)
new 922173686 fix: Python codeparser parsing error (#2764)
new 3803b8579 [bug] fix bug: class path resource [org/springframework/web/servlet/config/annotation/WebMvcConfigurer.class] cannot be opened because it does not exist, due to jars dependency issue (#2769)
new 4cba5c0c2 Merge remote-tracking branch 'origin/dev-1.3.0' into dev-1.3.1-merge-1.3.0
new 9b85eaacb code format
new 1fad46b05 code format
new fe7ad33c4 code format
new 4068fbb6b update line separator to LF
new 6e7f14c27 code format
new 09bcceb86 Merge pull request #2778 from WeDataSphere/dev-1.3.1-merge-1.3.0
The 2828 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/auto-comment.yml | 2 +-
.github/workflows/publish-docker.yaml | 85 +
.gitignore | 3 +-
.../linkis-engineconn.properties => .scalafmt.conf | 37 +-
CONTRIBUTING.md | 10 +-
CONTRIBUTING_CN.md | 76 +-
README.md | 133 +-
README_CN.md | 207 +-
docs/index.md | 7 +
linkis-commons/linkis-common/pom.xml | 321 ++-
.../linkis/common/errorcode/ErrorCodeUtils.java | 12 +-
.../errorcode/LinkisCommonsErrorCodeSummary.java | 86 +-
...inkisComputationGovernanceErrorCodeSummary.java | 101 +-
.../LinkisEngineConnErrorCodeSummary.java | 89 +-
.../common/errorcode/LinkisErrorCodeSummary.java | 108 +-
.../errorcode/LinkisExtensionErrorCodeSummary.java | 81 +-
.../errorcode/LinkisFrameErrorCodeSummary.java | 80 +-
.../LinkisPublicEnhancementErrorCodeSummary.java | 82 +-
.../LinkisSpringCloudServiceErrorCodeSummary.java | 80 +-
.../linkis/common/exception/ErrorException.java | 22 +-
.../linkis/common/exception/ExceptionLevel.java | 66 +-
.../linkis/common/exception/ExceptionManager.java | 90 +-
.../linkis/common/exception/FatalException.java | 22 +-
.../exception/LinkisCommonErrorException.java | 14 +-
.../linkis/common/exception/LinkisException.java | 244 +-
.../common/exception/LinkisRetryException.java | 20 +-
.../common/exception/LinkisRuntimeException.java | 201 +-
.../VariableOperationFailedException.java | 14 +-
.../linkis/common/exception/WarnException.java | 22 +-
.../main/java/org/apache/linkis/common/io/Fs.java | 30 +-
.../java/org/apache/linkis/common/io/FsPath.java | 594 +++--
.../apache/linkis/common/utils/ByteTimeUtils.java | 650 +++--
.../org/apache/linkis/common/utils/DESUtil.java | 208 +-
.../common/utils/VariableOperationUtils.java | 325 ++-
.../org/apache/linkis/common/ServiceInstance.scala | 33 +-
.../linkis/common/collection/LoopArray.scala | 72 +-
.../linkis/common/conf/BDPConfiguration.scala | 76 +-
.../org/apache/linkis/common/conf/ByteType.scala | 11 +-
.../org/apache/linkis/common/conf/CommonVars.scala | 21 +-
.../apache/linkis/common/conf/Configuration.scala | 25 +-
.../linkis/common/conf/DWCArgumentsParser.scala | 56 +-
.../org/apache/linkis/common/conf/TimeType.scala | 15 +-
.../common/errorcode/CommonErrorConstants.scala | 10 +-
.../org/apache/linkis/common/io/FsReader.scala | 27 +-
.../org/apache/linkis/common/io/FsWriter.scala | 14 +-
.../org/apache/linkis/common/io/MetaData.scala | 9 +-
.../scala/org/apache/linkis/common/io/Record.scala | 9 +-
.../common/io/resultset/ResultDeserializer.scala | 12 +-
.../common/io/resultset/ResultSerializer.scala | 11 +-
.../linkis/common/io/resultset/ResultSet.scala | 73 +-
.../common/io/resultset/ResultSetReader.scala | 23 +-
.../common/io/resultset/ResultSetWriter.scala | 19 +-
.../org/apache/linkis/common/listener/Event.scala | 11 +-
.../linkis/common/listener/EventListener.scala | 11 +-
.../linkis/common/listener/ListenerEventBus.scala | 203 +-
.../common/listener/SingleThreadListenerBus.scala | 14 +-
.../org/apache/linkis/common/log/LogUtils.scala | 12 +-
.../apache/linkis/common/utils/ArrayUtils.scala | 22 +-
.../apache/linkis/common/utils/ClassUtils.scala | 32 +-
.../linkis/common/utils/CodeAndRunTypeUtils.scala | 30 +-
.../apache/linkis/common/utils/FileService.scala | 19 +-
.../org/apache/linkis/common/utils/JavaLog.scala | 33 +-
.../org/apache/linkis/common/utils/JsonUtils.scala | 12 +-
.../org/apache/linkis/common/utils/LDAPUtils.scala | 23 +-
.../org/apache/linkis/common/utils/Logging.scala | 15 +-
.../apache/linkis/common/utils/OverloadUtils.scala | 14 +-
.../org/apache/linkis/common/utils/RSAUtils.scala | 25 +-
.../apache/linkis/common/utils/RefreshUtils.scala | 46 +-
.../apache/linkis/common/utils/RetryHandler.scala | 20 +-
.../apache/linkis/common/utils/ShutdownUtils.scala | 39 +-
.../org/apache/linkis/common/utils/Utils.scala | 156 +-
.../apache/linkis/common/utils/VariableUtils.scala | 290 ++-
.../org/apache/linkis/common/utils/ZipUtils.scala | 229 +-
.../linkis/common/variable/CustomDateType.scala | 30 +-
.../linkis/common/variable/DateTypeUtils.scala | 22 +-
.../linkis/common/variable/VariableType.scala | 62 +-
.../common/errorcode/ErrorCodeUtilsTest.java | 20 +-
.../LinkisCommonsErrorCodeSummaryTest.java | 132 +-
...sComputationGovernanceErrorCodeSummaryTest.java | 128 +-
.../errorcode/LinkisErrorCodeSummaryTest.java | 110 +-
.../errorcode/LinkisFrameErrorCodeSummaryTest.java | 96 +-
.../common/exception/ErrorExceptionTest.java | 36 +-
.../common/exception/ExceptionLevelTest.java | 70 +-
.../common/exception/ExceptionManagerTest.java | 166 +-
.../common/exception/FatalExceptionTest.java | 36 +-
.../exception/LinkisCommonErrorExceptionTest.java | 14 +-
.../common/exception/LinkisExceptionTest.java | 196 +-
.../common/exception/LinkisRetryExceptionTest.java | 10 +-
.../exception/LinkisRuntimeExceptionTest.java | 196 +-
.../linkis/common/exception/WarnExceptionTest.java | 35 +-
.../common/variable/VariableOperationTest.java | 131 +-
.../linkis/common/collection/LoopArrayTest.scala | 7 +-
.../linkis/common/utils/ArrayUtilsTest.scala | 3 +-
.../linkis/common/utils/ClassUtilsTest.scala | 32 +-
.../common/utils/CodeAndRunTypeUtilsTest.scala | 21 +-
.../linkis/common/utils/OverloadUtilsTest.scala | 6 +-
.../linkis/common/utils/VariableUtilsTest.scala | 9 +-
.../linkis/common/variable/DateTypeUtilsTest.scala | 6 +-
.../linkis/common/variable/VariableTypeTest.scala | 9 +-
linkis-commons/linkis-hadoop-common/pom.xml | 149 +-
.../linkis/hadoop/common/utils/KerberosUtils.java | 159 +-
.../linkis/hadoop/common/conf/HadoopConf.scala | 24 +-
.../common/entity/HDFSFileSystemContainer.scala | 16 +-
.../linkis/hadoop/common/utils/HDFSUtils.scala | 159 +-
linkis-commons/linkis-httpclient/pom.xml | 145 +-
.../linkis/httpclient/AbstractHttpClient.scala | 340 ++-
.../org/apache/linkis/httpclient/Client.scala | 13 +-
.../linkis/httpclient/GenericHttpClient.scala | 31 +-
.../apache/linkis/httpclient/ResultListener.scala | 9 +-
.../AbstractAuthenticationStrategy.scala | 63 +-
.../httpclient/authentication/Authentication.scala | 9 +-
.../authentication/AuthenticationAction.scala | 11 +-
.../authentication/AuthenticationStrategy.scala | 11 +-
.../authentication/HttpAuthentication.scala | 11 +-
.../linkis/httpclient/config/ClientConfig.scala | 44 +-
.../httpclient/config/ClientConfigBuilder.scala | 32 +-
.../httpclient/config/HttpClientConstant.scala | 2 +-
.../httpclient/discovery/AbstractDiscovery.scala | 118 +-
.../linkis/httpclient/discovery/Discovery.scala | 11 +-
.../httpclient/discovery/DiscoveryListener.scala | 9 +-
.../httpclient/discovery/HeartbeatAction.scala | 9 +-
.../httpclient/exception/DiscoveryException.scala | 9 +-
.../exception/HttpClientResultException.scala | 11 +-
.../exception/HttpClientRetryException.scala | 2 +-
.../exception/HttpMessageParseException.scala | 11 +-
.../loadbalancer/AbstractLoadBalancer.scala | 20 +-
.../loadbalancer/DefaultLoadbalancerStrategy.scala | 11 +-
.../httpclient/loadbalancer/LoadBalancer.scala | 11 +-
.../loadbalancer/LoadBalancerStrategy.scala | 9 +-
.../apache/linkis/httpclient/request/Action.scala | 11 +-
.../linkis/httpclient/request/DownloadAction.scala | 13 +-
.../linkis/httpclient/request/GetAction.scala | 22 +-
.../linkis/httpclient/request/HttpAction.scala | 12 +-
.../linkis/httpclient/request/POSTAction.scala | 19 +-
.../linkis/httpclient/request/PutAction.scala | 11 +-
.../httpclient/request/ServerUrlAction.scala | 9 +-
.../linkis/httpclient/request/UploadAction.scala | 52 +-
.../linkis/httpclient/request/UserAction.scala | 9 +-
.../linkis/httpclient/request/UserPwdAction.scala | 11 +-
.../httpclient/response/HashMapHttpResult.scala | 23 +-
.../linkis/httpclient/response/HttpResult.scala | 11 +-
.../linkis/httpclient/response/ListResult.scala | 9 +-
.../linkis/httpclient/response/MetricResult.scala | 20 +-
.../apache/linkis/httpclient/response/Result.scala | 18 +-
.../response/impl/DefaultHttpResult.scala | 15 +-
linkis-commons/linkis-module/pom.xml | 805 ++++---
.../apache/linkis/DataWorkCloudApplication.java | 321 ++-
.../org/apache/linkis/LinkisBaseServerApp.java | 44 +-
.../org/apache/linkis/proxy/ProxyUserEntity.java | 84 +-
.../org/apache/linkis/proxy/ProxyUserService.java | 2 +-
.../apache/linkis/server/utils/AopTargetUtils.java | 74 +-
.../linkis/server/utils/ModuleUserUtils.java | 115 +-
.../linkis/server/BDPJettyServerHelper.scala | 109 +-
.../org/apache/linkis/server/Knife4jConfig.scala | 40 +-
.../scala/org/apache/linkis/server/Message.scala | 80 +-
.../conf/DataWorkCloudCustomExcludeFilter.scala | 34 +-
.../linkis/server/conf/ServerConfiguration.scala | 182 +-
.../server/exception/BDPServerException.scala | 18 +-
.../exception/FetchMapCacheFailedException.scala | 15 +-
.../exception/IllegalUserTicketException.scala | 11 +-
.../server/exception/LoginExpireException.scala | 11 +-
.../exception/NoApplicationExistsException.scala | 11 +-
.../server/exception/NonLoginException.scala | 11 +-
.../scala/org/apache/linkis/server/package.scala | 128 +-
.../server/restful/SpringRestfulCatchAOP.scala | 24 +-
.../linkis/server/security/ProxyUserSSOUtils.scala | 49 +-
.../apache/linkis/server/security/SSOUtils.scala | 162 +-
.../linkis/server/security/SecurityFilter.scala | 143 +-
.../linkis/server/socket/ControllerServer.scala | 79 +-
.../apache/linkis/server/socket/ServerSocket.scala | 55 +-
.../linkis/server/socket/SocketListener.scala | 9 +-
.../server/socket/controller/ServerEvent.scala | 26 +-
.../socket/controller/ServerEventService.scala | 21 +-
.../socket/controller/ServerListenerEventBus.scala | 55 +-
.../linkis/server/utils/LinkisMainHelper.scala | 28 +-
linkis-commons/linkis-mybatis/pom.xml | 165 +-
.../apache/linkis/mybatis/DataSourceConfig.java | 12 +-
.../org/apache/linkis/mybatis/DataSourceUtils.java | 123 +-
.../linkis/mybatis/MyBatisMapperScannerConfig.java | 20 +-
.../mybatis/MybatisConfigurationFactory.java | 183 +-
.../linkis/mybatis/conf/MybatisConfiguration.java | 93 +-
linkis-commons/linkis-protocol/pom.xml | 79 +-
.../linkis/protocol/AbstractRetryableProtocol.java | 32 +-
.../linkis/protocol/constants/TaskConstant.java | 88 +-
.../apache/linkis/protocol/engine/EngineInfo.java | 38 +-
.../apache/linkis/protocol/engine/EngineState.java | 56 +-
.../protocol/label/InsLabelAttachRequest.java | 42 +-
.../protocol/label/InsLabelQueryRequest.java | 24 +-
.../protocol/label/InsLabelQueryResponse.java | 24 +-
.../protocol/label/InsLabelRefreshRequest.java | 42 +-
.../protocol/label/InsLabelRemoveRequest.java | 22 +-
.../protocol/label/LabelInsQueryRequest.java | 22 +-
.../protocol/label/LabelInsQueryResponse.java | 24 +-
.../linkis/protocol/label/NodeLabelAddRequest.java | 38 +-
.../protocol/label/NodeLabelRemoveRequest.java | 38 +-
.../linkis/protocol/message/RequestMethod.java | 6 +-
.../protocol/query/cache/CacheTaskResult.java | 14 +-
.../protocol/query/cache/FailedToDeleteCache.java | 14 +-
.../protocol/query/cache/FailedToWriteCache.java | 14 +-
.../protocol/query/cache/RequestDeleteCache.java | 42 +-
.../protocol/query/cache/RequestReadCache.java | 56 +-
.../protocol/query/cache/RequestWriteCache.java | 76 +-
.../linkis/protocol/usercontrol/RequestLogin.java | 32 +-
.../protocol/usercontrol/RequestRegister.java | 18 +-
.../usercontrol/RequestUserListFromWorkspace.java | 20 +-
.../protocol/usercontrol/RequestUserWorkspace.java | 20 +-
.../linkis/protocol/usercontrol/ResponseLogin.java | 72 +-
.../protocol/usercontrol/ResponseRegister.java | 72 +-
.../usercontrol/ResponseUserWorkspace.java | 20 +-
.../usercontrol/ResponseWorkspaceUserList.java | 20 +-
.../apache/linkis/protocol/util/ImmutablePair.java | 64 +-
.../apache/linkis/protocol/BroadcastProtocol.scala | 11 +-
.../apache/linkis/protocol/CacheableProtocol.scala | 9 +-
.../apache/linkis/protocol/IRCommonProtocol.scala | 9 +-
.../org/apache/linkis/protocol/IRProtocol.scala | 11 +-
.../linkis/protocol/IRServiceGroupProtocol.scala | 12 +-
.../apache/linkis/protocol/InstanceProtocol.scala | 11 +-
.../org/apache/linkis/protocol/Protocol.scala | 11 +-
.../apache/linkis/protocol/RetryableProtocol.scala | 12 +-
.../linkis/protocol/SingleInstanceProtocol.scala | 11 +-
.../protocol/callback/LogCallbackProtocol.scala | 12 +-
.../linkis/protocol/engine/EngineCallback.scala | 20 +-
.../engine/EngineStateTransitionRequest.scala | 17 +-
.../linkis/protocol/engine/JobProgressInfo.scala | 10 +-
.../protocol/engine/RequestEngineStatus.scala | 12 +-
.../protocol/engine/RequestUserEngineKill.scala | 21 +-
.../apache/linkis/protocol/mdq/MDQProtocol.scala | 37 +-
.../org/apache/linkis/protocol/task/Task.scala | 11 +-
.../linkis/protocol/utils/ProtocolUtils.scala | 20 +-
.../apache/linkis/protocol/utils/TaskUtils.scala | 49 +-
.../linkis/protocol/utils/ZuulEntranceUtils.scala | 100 +-
.../variable/RequestQueryGlobalVariable.scala | 19 +-
.../protocol/variable/ResponseQueryVariable.scala | 9 +-
linkis-commons/linkis-rpc/pom.xml | 220 +-
.../linkis/rpc/message/annotation/Chain.java | 2 +-
.../linkis/rpc/message/annotation/Method.java | 2 +-
.../linkis/rpc/message/annotation/Order.java | 2 +-
.../message/exception/MessageErrorException.java | 14 +-
.../message/exception/MessageWarnException.java | 14 +-
.../linkis/rpc/message/method/MessageExecutor.java | 121 +-
.../rpc/message/method/MethodExecuteWrapper.java | 64 +-
.../rpc/message/method/ReceiverMethodSearcher.java | 97 +-
.../rpc/message/parser/DefaultServiceParser.java | 118 +-
.../linkis/rpc/message/parser/ServiceMethod.java | 126 +-
.../linkis/rpc/message/parser/ServiceParser.java | 2 +-
.../message/registry/AbstractServiceRegistry.java | 106 +-
.../rpc/message/registry/ServiceRegistry.java | 2 +-
.../message/registry/SpringServiceRegistry.java | 17 +-
.../message/utils/LoadBalancerOptionsUtils.java | 34 +-
.../linkis/rpc/message/utils/MessageUtils.java | 160 +-
.../apache/linkis/rpc/serializer/NoneDelegate.java | 55 +-
.../rpc/serializer/ProtostuffSerializeUtil.java | 147 +-
.../org/apache/linkis/rpc/AsynRPCMessageBus.scala | 46 +-
.../org/apache/linkis/rpc/BaseRPCSender.scala | 74 +-
.../org/apache/linkis/rpc/BroadcastListener.scala | 9 +-
.../org/apache/linkis/rpc/MessageReceiver.scala | 10 +-
.../apache/linkis/rpc/MessageReceiverChooser.scala | 4 +-
.../scala/org/apache/linkis/rpc/RPCMapCache.scala | 22 +-
.../org/apache/linkis/rpc/RPCReceiveRemote.scala | 12 +-
.../org/apache/linkis/rpc/RPCReceiveRestful.scala | 106 +-
.../org/apache/linkis/rpc/RPCSpringBeanCache.scala | 55 +-
.../scala/org/apache/linkis/rpc/Receiver.scala | 11 +-
.../org/apache/linkis/rpc/ReceiverChooser.scala | 26 +-
.../apache/linkis/rpc/ReceiverSenderBuilder.scala | 16 +-
.../main/scala/org/apache/linkis/rpc/Sender.scala | 99 +-
.../org/apache/linkis/rpc/SenderFactory.scala | 17 +-
.../apache/linkis/rpc/conf/RPCConfiguration.scala | 104 +-
.../linkis/rpc/conf/RPCSpringConfiguration.scala | 37 +-
.../linkis/rpc/errorcode/RPCErrorConstants.scala | 14 +-
.../rpc/exception/DWCRPCRetryException.scala | 11 +-
.../linkis/rpc/exception/DWCURIException.scala | 11 +-
.../rpc/exception/NoInstanceExistsException.scala | 12 +-
.../rpc/exception/RPCInitFailedException.scala | 12 +-
.../linkis/rpc/interceptor/RPCInterceptor.scala | 9 +-
.../rpc/interceptor/RPCInterceptorChain.scala | 45 +-
.../rpc/interceptor/RPCInterceptorExchange.scala | 14 +-
.../linkis/rpc/interceptor/RPCLoadBalancer.scala | 18 +-
.../linkis/rpc/interceptor/RPCServerLoader.scala | 85 +-
.../common/BroadcastRPCInterceptor.scala | 83 +-
.../common/BroadcastSenderBuilder.scala | 9 +-
.../common/CacheableRPCInterceptor.scala | 98 +-
.../interceptor/common/CommonRPCInterceptor.scala | 22 +-
.../common/InstanceRPCLoadBalancer.scala | 20 +-
.../common/RetryableRPCInterceptor.scala | 52 +-
.../common/SingleInstanceRPCLoadBalancer.scala | 27 +-
.../rpc/sender/FeignClientRequestInterceptor.scala | 17 +-
.../linkis/rpc/sender/LocalMessageSender.scala | 13 +-
.../SpringCloudFeignConfigurationCache.scala | 50 +-
.../linkis/rpc/sender/SpringMVCRPCSender.scala | 171 +-
.../org/apache/linkis/rpc/sender/UnionSender.scala | 39 +-
.../sender/eureka/EurekaClientRefreshUtils.scala | 27 +-
.../rpc/sender/eureka/EurekaRPCServerLoader.scala | 21 +-
.../rpc/transform/JavaCollectionSerializer.scala | 47 +-
.../apache/linkis/rpc/transform/RPCConsumer.scala | 33 +-
.../apache/linkis/rpc/transform/RPCFormats.scala | 9 +-
.../apache/linkis/rpc/transform/RPCProduct.scala | 58 +-
.../org/apache/linkis/rpc/utils/RPCUtils.scala | 64 +-
.../linkis/rpc/message/utils/MessageUtilsTest.java | 85 +
.../org/apache/linkis/rpc/RPCFormatsTest.scala | 47 +-
.../linkis/rpc/message/utils/MessageUtilsTest.java | 86 -
linkis-commons/linkis-scheduler/pom.xml | 91 +-
.../linkis/scheduler/AbstractScheduler.scala | 33 +-
.../org/apache/linkis/scheduler/Scheduler.scala | 20 +-
.../apache/linkis/scheduler/SchedulerContext.scala | 16 +-
.../scheduler/conf/SchedulerConfiguration.scala | 21 +-
.../apache/linkis/scheduler/event/LogEvent.scala | 13 +-
.../linkis/scheduler/event/ScheduleEvent.scala | 11 +-
.../scheduler/event/SchedulerEventListener.scala | 11 +-
.../exception/LinkisJobRetryException.scala | 12 +-
.../exception/SchedulerErrorException.scala | 13 +-
.../WaitForNextAskExecutorException.scala | 11 +-
.../scheduler/executer/AbstractExecutor.scala | 23 +-
.../executer/ConcurrentTaskInfoSupport.scala | 11 +-
.../executer/ConcurrentTaskOperateSupport.scala | 9 +-
.../linkis/scheduler/executer/ExecuteRequest.scala | 18 +-
.../scheduler/executer/ExecuteResponse.scala | 14 +-
.../linkis/scheduler/executer/Executor.scala | 12 +-
.../linkis/scheduler/executer/ExecutorInfo.scala | 11 +-
.../scheduler/executer/ExecutorManager.scala | 11 +-
.../scheduler/executer/SingleTaskInfoSupport.scala | 11 +-
.../executer/SingleTaskOperateSupport.scala | 11 +-
.../apache/linkis/scheduler/future/BDPFuture.scala | 11 +-
.../linkis/scheduler/future/BDPFutureTask.scala | 14 +-
.../scheduler/listener/ConsumerListener.scala | 11 +-
.../scheduler/listener/ExecutorListener.scala | 18 +-
.../linkis/scheduler/listener/JobListener.scala | 11 +-
.../linkis/scheduler/listener/LogListener.scala | 11 +-
.../scheduler/listener/ProgressListener.scala | 11 +-
.../scheduler/listener/SchedulerListener.scala | 9 +-
.../linkis/scheduler/queue/AbstractGroup.scala | 17 +-
.../linkis/scheduler/queue/ConsumeQueue.scala | 70 +-
.../apache/linkis/scheduler/queue/Consumer.scala | 18 +-
.../linkis/scheduler/queue/ConsumerManager.scala | 17 +-
.../org/apache/linkis/scheduler/queue/Group.scala | 25 +-
.../linkis/scheduler/queue/GroupFactory.scala | 9 +-
.../org/apache/linkis/scheduler/queue/Job.scala | 265 ++-
.../apache/linkis/scheduler/queue/JobInfo.scala | 34 +-
.../apache/linkis/scheduler/queue/LockJob.scala | 11 +-
.../linkis/scheduler/queue/LoopArrayQueue.scala | 114 +-
.../linkis/scheduler/queue/SchedulerEvent.scala | 32 +-
.../scheduler/queue/SchedulerEventState.scala | 16 +-
.../apache/linkis/scheduler/queue/UserJob.scala | 13 +-
.../queue/fifoqueue/FIFOConsumerManager.scala | 33 +-
.../scheduler/queue/fifoqueue/FIFOGroup.scala | 55 +-
.../queue/fifoqueue/FIFOGroupFactory.scala | 37 +-
.../scheduler/queue/fifoqueue/FIFOScheduler.scala | 12 +-
.../queue/fifoqueue/FIFOSchedulerContextImpl.scala | 32 +-
.../queue/fifoqueue/FIFOUserConsumer.scala | 136 +-
.../parallelqueue/ParallelConsumerManager.scala | 96 +-
.../queue/parallelqueue/ParallelGroup.scala | 26 +-
.../queue/parallelqueue/ParallelGroupFactory.scala | 13 +-
.../queue/parallelqueue/ParallelScheduler.scala | 13 +-
.../ParallelSchedulerContextImpl.scala | 15 +-
.../linkis/scheduler/AbstractSchedulerTest.scala | 15 +-
.../linkis/scheduler/SchedulerContextTest.scala | 5 +-
.../conf/SchedulerConfigurationTest.scala | 26 +-
.../linkis/scheduler/event/LogEventTest.scala | 7 +-
.../exception/LinkisJobRetryExceptionTest.scala | 4 +-
.../exception/SchedulerErrorExceptionTest.scala | 3 +-
.../WaitForNextAskExecutorExceptionTest.scala | 3 +-
.../scheduler/future/BDPFutureTaskTest.scala | 12 +-
.../scheduler/queue/SchedulerEventStateTest.scala | 5 +-
.../queue/fifoqueue/FIFOConsumerManagerTest.scala | 44 +-
.../queue/fifoqueue/FIFOGroupFactoryTest.scala | 5 +-
.../scheduler/queue/fifoqueue/FIFOGroupTest.scala | 9 +-
.../fifoqueue/FIFOSchedulerContextImplTest.scala | 6 +-
.../queue/fifoqueue/FIFOSchedulerTest.scala | 15 +-
.../queue/fifoqueue/FIFOUserConsumerTest.scala | 5 +-
.../ParallelConsumerManagerTest.scala | 6 +-
.../parallelqueue/ParallelGroupFactoryTest.scala | 6 +-
.../queue/parallelqueue/ParallelGroupTest.scala | 6 +-
.../ParallelSchedulerContextImplTest.scala | 6 +-
.../parallelqueue/ParallelSchedulerTest.scala | 14 +-
linkis-commons/linkis-storage/pom.xml | 144 +-
.../linkis/storage/domain/FsPathListWithError.java | 38 +-
.../linkis/storage/excel/ExcelStorageReader.java | 60 +-
.../org/apache/linkis/storage/excel/XlsUtils.java | 88 +-
.../org/apache/linkis/storage/excel/XlsxUtils.java | 90 +-
.../storage/exception/FSNotInitException.java | 12 +-
.../linkis/storage/exception/StorageErrorCode.java | 40 +-
.../storage/exception/StorageErrorException.java | 21 +-
.../storage/exception/StorageFatalException.java | 21 +-
.../storage/exception/StorageWarnException.java | 20 +-
.../linkis/storage/factory/BuildFactory.java | 6 +-
.../storage/factory/impl/BuildHDFSFileSystem.java | 67 +-
.../storage/factory/impl/BuildLocalFileSystem.java | 62 +-
.../org/apache/linkis/storage/fs/FileSystem.java | 112 +-
.../linkis/storage/fs/impl/HDFSFileSystem.java | 816 ++++---
.../linkis/storage/fs/impl/LocalFileSystem.java | 763 +++---
.../linkis/storage/pipeline/PipelineReader.java | 18 +-
.../linkis/storage/pipeline/PipelineWriter.java | 2 +-
.../org/apache/linkis/storage/FSFactory.scala | 64 +-
.../org/apache/linkis/storage/LineMetaData.scala | 12 +-
.../org/apache/linkis/storage/LineRecord.scala | 12 +-
.../linkis/storage/conf/LinkisStorageConf.scala | 18 +-
.../apache/linkis/storage/csv/CSVFsReader.scala | 12 +-
.../apache/linkis/storage/csv/CSVFsWriter.scala | 21 +-
.../linkis/storage/csv/StorageCSVReader.scala | 13 +-
.../linkis/storage/csv/StorageCSVWriter.scala | 22 +-
.../apache/linkis/storage/domain/DataType.scala | 46 +-
.../org/apache/linkis/storage/domain/Dolphin.scala | 52 +-
.../linkis/storage/domain/MethodEntity.scala | 101 +-
.../linkis/storage/excel/ExcelFsReader.scala | 12 +-
.../linkis/storage/excel/ExcelFsWriter.scala | 28 +-
.../linkis/storage/excel/StorageExcelReader.scala | 13 +-
.../linkis/storage/excel/StorageExcelWriter.scala | 33 +-
.../storage/excel/StorageMultiExcelWriter.scala | 36 +-
.../org/apache/linkis/storage/io/IOClient.scala | 53 +-
.../storage/io/IOMethodInterceptorCreator.scala | 30 +-
.../resultset/DefaultResultSetFactory.scala | 72 +-
.../linkis/storage/resultset/ResultMetaData.scala | 13 +-
.../linkis/storage/resultset/ResultRecord.scala | 13 +-
.../storage/resultset/ResultSetFactory.scala | 45 +-
.../linkis/storage/resultset/ResultSetReader.scala | 38 +-
.../linkis/storage/resultset/ResultSetWriter.scala | 44 +-
.../storage/resultset/StorageResultSet.scala | 24 +-
.../storage/resultset/StorageResultSetReader.scala | 55 +-
.../storage/resultset/StorageResultSetWriter.scala | 58 +-
.../storage/resultset/html/HtmlResultSet.scala | 19 +-
.../linkis/storage/resultset/io/IOMetaData.scala | 9 +-
.../linkis/storage/resultset/io/IORecord.scala | 11 +-
.../resultset/io/IOResultDeserializer.scala | 12 +-
.../storage/resultset/io/IOResultSerializer.scala | 15 +-
.../linkis/storage/resultset/io/IOResultSet.scala | 15 +-
.../resultset/picture/PictureResultSet.scala | 17 +-
.../storage/resultset/table/TableMetaData.scala | 12 +-
.../storage/resultset/table/TableRecord.scala | 13 +-
.../resultset/table/TableResultDeserializer.scala | 39 +-
.../resultset/table/TableResultSerializer.scala | 66 +-
.../storage/resultset/table/TableResultSet.scala | 15 +-
.../resultset/txt/TextResultDeserializer.scala | 13 +-
.../resultset/txt/TextResultSerializer.scala | 16 +-
.../storage/resultset/txt/TextResultSet.scala | 17 +-
.../linkis/storage/script/ScriptFsReader.scala | 17 +-
.../linkis/storage/script/ScriptFsWriter.scala | 51 +-
.../linkis/storage/script/VariableParser.scala | 55 +-
.../script/compaction/CommonScriptCompaction.scala | 14 +-
.../script/compaction/PYScriptCompaction.scala | 12 +-
.../script/compaction/QLScriptCompaction.scala | 17 +-
.../script/compaction/ScalaScriptCompaction.scala | 17 +-
.../script/compaction/ShellScriptCompaction.scala | 18 +-
.../storage/script/parser/CommonScriptParser.scala | 26 +-
.../storage/script/parser/PYScriptParser.scala | 11 +-
.../storage/script/parser/QLScriptParser.scala | 12 +-
.../storage/script/parser/ScalaScriptParser.scala | 14 +-
.../storage/script/parser/ShellScriptParser.scala | 6 +-
.../script/reader/StorageScriptFsReader.scala | 51 +-
.../script/writer/StorageScriptFsWriter.scala | 51 +-
.../linkis/storage/source/AbstractFileSource.scala | 26 +-
.../apache/linkis/storage/source/FileSource.scala | 41 +-
.../apache/linkis/storage/source/FileSplit.scala | 46 +-
.../storage/source/ResultsetFileSource.scala | 22 +-
.../linkis/storage/source/TextFileSource.scala | 14 +-
.../linkis/storage/utils/FileSystemUtils.scala | 41 +-
.../storage/utils/StorageConfiguration.scala | 39 +-
.../linkis/storage/utils/StorageHelper.scala | 27 +-
.../apache/linkis/storage/utils/StorageUtils.scala | 127 +-
linkis-commons/pom.xml | 45 +-
.../linkis-cli/linkis-cli-application/pom.xml | 137 +-
.../cli/application/LinkisClientApplication.java | 482 ++--
.../cli/application/constants/AppConstants.java | 27 +-
.../linkis/cli/application/constants/AppKeys.java | 248 +-
.../cli/application/constants/LinkisConstants.java | 4 +-
.../cli/application/constants/LinkisKeys.java | 52 +-
.../linkis/cli/application/data/FinishedData.java | 36 +-
.../linkis/cli/application/data/PreparedData.java | 14 +-
.../linkis/cli/application/data/ProcessedData.java | 56 +-
.../interactor/command/LinkisCmdType.java | 64 +-
.../command/template/UniversalCmdTemplate.java | 636 ++---
.../cli/application/interactor/job/LinkisJob.java | 4 +-
.../interactor/job/LinkisJobStatus.java | 192 +-
.../interactor/job/LinkisManageJob.java | 894 ++++---
.../application/interactor/job/LinkisOnceJob.java | 470 ++--
.../interactor/job/LinkisSubmitJob.java | 424 ++--
.../job/builder/LinkisManageJobBuilder.java | 181 +-
.../job/builder/LinkisOnceJobBuilder.java | 388 ++-
.../job/builder/LinkisSubmitJobBuilder.java | 383 ++-
.../interactor/job/builder/ProcessKeyUtils.java | 86 +-
.../interactor/job/data/LinkisJobData.java | 16 +-
.../interactor/job/data/LinkisJobDataImpl.java | 838 +++----
.../interactor/job/data/LinkisLogData.java | 32 +-
.../interactor/job/data/LinkisOnceJobData.java | 404 ++--
.../interactor/job/data/LinkisResultData.java | 12 +-
.../interactor/job/data/LinkisResultSet.java | 78 +-
.../interactor/job/data/SimpleOnceJobAdapter.java | 652 +++--
.../interactor/job/desc/LinkisJobManDesc.java | 42 +-
.../interactor/job/desc/LinkisOnceDesc.java | 218 +-
.../interactor/job/desc/LinkisSubmitDesc.java | 162 +-
.../interactor/job/subtype/LinkisManSubType.java | 28 +-
.../job/subtype/LinkisSubmitSubType.java | 18 +-
.../interactor/validate/LinkisManageValidator.java | 56 +-
.../validate/LinkisOnceSubmitValidator.java | 488 ++--
.../interactor/validate/LinkisSubmitValidator.java | 443 ++--
.../interactor/validate/UJESContextValidator.java | 90 +-
.../observer/event/LinkisClientEvent.java | 8 +-
.../observer/event/SingleObserverEvent.java | 34 +-
.../observer/listener/LinkisClientListener.java | 2 +-
.../observer/listener/TriggerEventListener.java | 16 +-
.../cli/application/operator/OperatorUtils.java | 86 +-
.../operator/once/LinkisNodeStatus.java | 18 +-
.../operator/once/OnceJobConstants.java | 6 +-
.../operator/ujes/LinkisJobOperator.java | 1358 ++++++-----
.../operator/ujes/LinkisOperResultAdapter.java | 56 +-
.../operator/ujes/LinkisOperatorBuilder.java | 26 +-
.../operator/ujes/UJESClientContext.java | 216 +-
.../operator/ujes/UJESClientFactory.java | 340 ++-
.../application/operator/ujes/UJESConstants.java | 32 +-
.../operator/ujes/UJESResultAdapter.java | 1070 ++++-----
.../operator/ujes/result/OpenLogResult2.java | 24 +-
.../operator/ujes/result/ResultSetResult2.java | 24 +-
.../application/present/LinkisLogPresenter.java | 58 +-
.../present/LinkisResultInfoPresenter.java | 157 +-
.../application/present/LinkisResultPresenter.java | 338 ++-
.../present/model/LinkisJobInfoModel.java | 122 +-
.../present/model/LinkisJobKillModel.java | 58 +-
.../application/present/model/LinkisLogModel.java | 38 +-
.../present/model/LinkisResultInfoModel.java | 94 +-
.../present/model/LinkisResultModel.java | 56 +-
.../present/model/LinkisSubmitResultModel.java | 48 +-
.../cli/application/suite/ExecutionSuite.java | 68 +-
.../application/suite/ExecutionSuiteFactory.java | 314 ++-
.../cli/application/utils/ExecutionUtils.java | 327 ++-
.../apache/linkis/cli/application/utils/Utils.java | 42 +-
.../application/LinkisClientApplicationTest.java | 302 +--
.../cli/application/constants/TestConstants.java | 138 +-
.../command/template/ProcessInputUtil.java | 138 +-
.../interactor/command/template/TestCmdType.java | 68 +-
.../command/template/TestParamMapper.java | 54 +-
.../command/template/TestSparkCmdTemplate.java | 408 ++--
.../interactor/execution/LinkisExecutorTest.java | 172 +-
.../interactor/job/LinkisJobBuilderTest.java | 139 +-
.../linkis-cli/linkis-cli-common/pom.xml | 31 +-
.../cli/common/entity/command/CmdOption.java | 22 +-
.../cli/common/entity/command/CmdTemplate.java | 12 +-
.../linkis/cli/common/entity/command/CmdType.java | 6 +-
.../cli/common/entity/command/ParamItem.java | 86 +-
.../linkis/cli/common/entity/command/Params.java | 112 +-
.../cli/common/entity/execution/Execution.java | 16 +-
.../apache/linkis/cli/common/entity/job/Job.java | 58 +-
.../linkis/cli/common/entity/job/JobData.java | 14 +-
.../linkis/cli/common/entity/job/JobStatus.java | 14 +-
.../linkis/cli/common/entity/job/JobSubType.java | 2 +-
.../linkis/cli/common/entity/present/Model.java | 2 +-
.../cli/common/entity/present/Presenter.java | 2 +-
.../common/entity/properties/ClientProperties.java | 30 +-
.../cli/common/entity/result/ExecutionResult.java | 17 +-
.../cli/common/entity/result/ResultHandler.java | 2 +-
.../cli/common/entity/validate/Validator.java | 2 +-
.../linkis/cli/common/entity/var/VarAccess.java | 10 +-
.../common/exception/LinkisClientException.java | 2 +-
.../exception/LinkisClientRuntimeException.java | 170 +-
.../cli/common/exception/error/ErrorLevel.java | 68 +-
.../cli/common/exception/error/ErrorMsg.java | 4 +-
.../common/exception/handler/ExceptionHandler.java | 2 +-
.../linkis-cli/linkis-cli-core/pom.xml | 68 +-
.../linkis/cli/core/builder/AbstractBuilder.java | 56 +-
.../cli/core/builder/BuildableByVarAccess.java | 48 +-
.../apache/linkis/cli/core/builder/Builder.java | 2 +-
.../linkis/cli/core/constants/CommonConstants.java | 28 +-
.../cli/core/exception/BuilderException.java | 16 +-
.../cli/core/exception/CommandException.java | 72 +-
.../exception/LinkisClientExecutionException.java | 18 +-
.../cli/core/exception/PresenterException.java | 17 +-
.../linkis/cli/core/exception/PropsException.java | 16 +-
.../cli/core/exception/TransformerException.java | 18 +-
.../cli/core/exception/UnknownException.java | 16 +-
.../cli/core/exception/ValidateException.java | 16 +-
.../cli/core/exception/VarAccessException.java | 17 +-
.../cli/core/exception/error/CommonErrMsg.java | 124 +-
.../exception/handler/CommandExceptionHandler.java | 26 +-
.../exception/handler/DefaultExceptionHandler.java | 94 +-
.../interactor/command/CmdTemplateFactory.java | 64 +-
.../cli/core/interactor/command/SpecialMap.java | 8 +-
.../interactor/command/fitter/AbstractFitter.java | 372 ++-
.../cli/core/interactor/command/fitter/Fitter.java | 2 +-
.../interactor/command/fitter/FitterResult.java | 38 +-
.../interactor/command/fitter/FitterUtils.java | 6 +-
.../interactor/command/fitter/SingleTplFitter.java | 37 +-
.../interactor/command/parser/AbstarctParser.java | 252 +-
.../cli/core/interactor/command/parser/Parser.java | 2 +-
.../interactor/command/parser/SingleCmdParser.java | 58 +-
.../command/parser/result/ParseResult.java | 54 +-
.../command/parser/transformer/ParamKeyMapper.java | 148 +-
.../command/template/AbstractCmdTemplate.java | 775 +++---
.../command/template/option/BaseOption.java | 209 +-
.../interactor/command/template/option/Flag.java | 68 +-
.../command/template/option/MapOption.java | 188 +-
.../command/template/option/Parameter.java | 122 +-
.../command/template/option/SpecialMapOption.java | 24 +-
.../command/template/option/StdOption.java | 88 +-
.../core/interactor/execution/AsyncSubmission.java | 118 +-
.../linkis/cli/core/interactor/execution/Help.java | 40 +-
.../core/interactor/execution/JobManagement.java | 104 +-
.../core/interactor/execution/SyncSubmission.java | 276 ++-
.../cli/core/interactor/job/AbstractJob.java | 80 +-
.../cli/core/interactor/job/AsyncBackendJob.java | 8 +-
.../linkis/cli/core/interactor/job/JobBuilder.java | 32 +-
.../cli/core/interactor/job/LogAccessibleJob.java | 10 +-
.../core/interactor/job/ManagableBackendJob.java | 22 +-
.../core/interactor/job/ResultAccessibleJob.java | 10 +-
.../cli/core/interactor/job/SyncBackendJob.java | 2 +-
.../cli/core/interactor/job/TerminatableJob.java | 6 +-
.../cli/core/interactor/job/TerminateToken.java | 14 +-
.../interactor/properties/PropertiesLoader.java | 12 +-
.../interactor/properties/PropsFilesScanner.java | 97 +-
.../core/interactor/properties/StdPropsLoader.java | 106 +-
.../properties/reader/PropertiesReader.java | 12 +-
.../properties/reader/PropsFileReader.java | 116 +-
.../interactor/properties/reader/SysEnvReader.java | 64 +-
.../properties/reader/SysPropsReader.java | 72 +-
.../interactor/result/DefaultResultHandler.java | 18 +-
.../interactor/result/ExecutionResultImpl.java | 66 +-
.../interactor/result/ExecutionStatusEnum.java | 18 +-
.../interactor/result/PresentResultHandler.java | 77 +-
.../core/interactor/validate/ParamValidator.java | 10 +-
.../interactor/validate/ParsedTplValidator.java | 78 +-
.../core/interactor/validate/PropsValidator.java | 10 +-
.../cli/core/interactor/var/StdVarAccess.java | 494 ++--
.../cli/core/interactor/var/SysVarAccess.java | 142 +-
.../cli/core/operator/JobOperatorBuilder.java | 16 +-
.../cli/core/operator/JobOperatorFactory.java | 109 +-
.../cli/core/present/DefaultStdOutPresenter.java | 10 +-
.../linkis/cli/core/present/HelpInfoPresenter.java | 126 +-
.../linkis/cli/core/present/PresentMode.java | 2 +-
.../linkis/cli/core/present/PresentModeImpl.java | 24 +-
.../linkis/cli/core/present/PresentWayImpl.java | 42 +-
.../core/present/display/DisplayOperFactory.java | 34 +-
.../cli/core/present/display/DisplayOperator.java | 2 +-
.../core/present/display/PlainTextFileWriter.java | 150 +-
.../cli/core/present/display/StdOutWriter.java | 24 +-
.../core/present/display/data/FileDisplayData.java | 43 +-
.../present/display/data/StdoutDisplayData.java | 14 +-
.../cli/core/present/model/HelpInfoModel.java | 32 +-
.../apache/linkis/cli/core/utils/CommonUtils.java | 98 +-
.../org/apache/linkis/cli/core/utils/LogUtils.java | 16 +-
.../linkis/cli/core/utils/SchedulerUtils.java | 110 +-
.../linkis/cli/core/utils/converter/Converter.java | 2 +-
.../converter/PredefinedStringConverters.java | 285 ++-
.../linkis/cli/core/constants/TestConstants.java | 134 +-
.../handler/CommandExceptionHandlerTest.java | 78 +-
.../cli/core/interactor/command/TestCmdType.java | 68 +-
.../command/fitter/SingleTplFitterTest.java | 173 +-
.../command/parser/SingleCmdParserTest.java | 274 +--
.../command/template/TestParamMapper.java | 18 +-
.../command/template/TestSparkCmdTemplate.java | 437 ++--
.../interactor/properties/StdPropsLoaderTest.java | 179 +-
.../cli/core/interactor/var/StdVarAccessTest.java | 495 ++--
.../apache/linkis/cli/core/utils/TestUtils.java | 64 +-
.../linkis-client/linkis-cli/pom.xml | 72 +-
.../linkis-computation-client/pom.xml | 171 +-
.../linkis/computation/client/JobListener.scala | 9 +-
.../linkis/computation/client/JobMetrics.scala | 30 +-
.../linkis/computation/client/LinkisJob.scala | 11 +-
.../computation/client/LinkisJobBuilder.scala | 70 +-
.../computation/client/LinkisJobClient.scala | 17 +-
.../computation/client/ResultSetIterator.scala | 77 +-
.../client/interactive/InteractiveJob.scala | 88 +-
.../client/interactive/InteractiveJobBuilder.scala | 29 +-
.../client/interactive/LogListener.scala | 9 +-
.../client/interactive/ProgressListener.scala | 10 +-
.../computation/client/job/AbstractLinkisJob.scala | 74 +-
.../client/job/AbstractSubmittableLinkisJob.scala | 9 +-
.../computation/client/job/StorableLinkisJob.scala | 43 +-
.../client/job/SubmittableLinkisJob.scala | 11 +-
.../client/once/LinkisManagerClient.scala | 58 +-
.../linkis/computation/client/once/OnceJob.scala | 76 +-
.../once/action/CreateEngineConnAction.scala | 17 +-
.../client/once/action/ECMOperateAction.scala | 8 +-
.../client/once/action/ECResourceInfoAction.scala | 7 +-
.../once/action/EngineConnOperateAction.scala | 2 +-
.../client/once/action/GetEngineConnAction.scala | 24 +-
.../client/once/action/KillEngineConnAction.scala | 17 +-
.../client/once/action/LinkisManagerAction.scala | 11 +-
.../once/action/ServiceInstanceBuilder.scala | 13 +-
.../once/result/CreateEngineConnResult.scala | 11 +-
.../client/once/result/ECMOperateResult.scala | 7 +-
.../client/once/result/ECResourceInfoResult.scala | 3 +-
.../once/result/EngineConnOperateResult.scala | 15 +-
.../client/once/result/GetEngineConnResult.scala | 11 +-
.../client/once/result/KillEngineConnResult.scala | 11 +-
.../client/once/result/LinkisManagerResult.scala | 9 +-
.../client/once/simple/SimpleOnceJob.scala | 71 +-
.../client/once/simple/SimpleOnceJobBuilder.scala | 59 +-
.../client/operator/OnceJobOperator.scala | 12 +-
.../computation/client/operator/Operator.scala | 11 +-
.../client/operator/OperatorFactory.scala | 27 +-
.../client/operator/StorableOperator.scala | 9 +-
.../impl/EngineConnApplicationInfoOperator.scala | 37 +-
.../operator/impl/EngineConnCommonOperator.scala | 14 +-
.../impl/EngineConnDiagnosisOperator.scala | 12 +-
.../operator/impl/EngineConnLogOperator.scala | 45 +-
.../operator/impl/EngineConnMetricsOperator.scala | 12 +-
.../operator/impl/EngineConnProgressOperator.scala | 27 +-
.../computation/client/utils/LabelKeyUtils.scala | 9 +-
.../org/apache/linkis/ujes/client/UJESClient.scala | 135 +-
.../apache/linkis/ujes/client/UJESClientImpl.scala | 20 +-
.../exception/UJESClientBuilderException.scala | 14 +-
.../ujes/client/request/GetColumnsAction.scala | 22 +-
.../linkis/ujes/client/request/GetDBSAction.scala | 21 +-
.../request/GetPartitionStatisticInfoAction.scala | 15 +-
.../client/request/GetTableBaseInfoAction.scala | 9 +-
.../request/GetTableStatisticInfoAction.scala | 11 +-
.../ujes/client/request/GetTablesAction.scala | 19 +-
.../ujes/client/request/JobExecIdAction.scala | 26 +-
.../ujes/client/request/JobExecuteAction.scala | 113 +-
.../linkis/ujes/client/request/JobInfoAction.scala | 23 +-
.../linkis/ujes/client/request/JobListAction.scala | 18 +-
.../linkis/ujes/client/request/JobLogAction.scala | 22 +-
.../ujes/client/request/JobSubmitAction.scala | 29 +-
.../linkis/ujes/client/request/OpenLogAction.scala | 12 +-
.../ujes/client/request/ResultSetAction.scala | 25 +-
.../ujes/client/request/ResultSetListAction.scala | 20 +-
.../linkis/ujes/client/request/UJESJobAction.scala | 8 +-
.../linkis/ujes/client/request/UserAction.scala | 8 +-
.../ujes/client/response/GetColumnsResult.scala | 12 +-
.../linkis/ujes/client/response/GetDBSResult.scala | 14 +-
.../response/GetPartitionStatisticInfoResult.scala | 4 +-
.../client/response/GetTableBaseInfoResult.scala | 3 +-
.../response/GetTableStatisticInfoResult.scala | 16 +-
.../ujes/client/response/GetTablesResult.scala | 12 +-
.../ujes/client/response/JobExecuteResult.scala | 8 +-
.../ujes/client/response/JobInfoResult.scala | 39 +-
.../ujes/client/response/JobKillResult.scala | 8 +-
.../ujes/client/response/JobListResult.scala | 14 +-
.../linkis/ujes/client/response/JobLogResult.scala | 12 +-
.../ujes/client/response/JobPauseResult.scala | 8 +-
.../ujes/client/response/JobProgressResult.scala | 18 +-
.../ujes/client/response/JobStatusResult.scala | 11 +-
.../ujes/client/response/JobSubmitResult.scala | 13 +-
.../ujes/client/response/OpenLogResult.scala | 14 +-
.../ujes/client/response/ResultSetListResult.scala | 17 +-
.../ujes/client/response/ResultSetResult.scala | 13 +-
.../ujes/client/response/UJESJobResult.scala | 8 +-
.../ujes/client/response/image/ShowImage.scala | 31 +-
.../linkis/ujes/client/utils/UJESClientUtils.scala | 21 +-
.../computation/client/FlinkOnceJobTest.java | 127 +-
.../computation/client/InteractiveJobTest.java | 50 +-
.../linkis/computation/client/TestLogListener.java | 12 +-
.../ujes/client/PythonImageJavaClientTest.java | 263 +--
.../linkis/ujes/client/UJESClientImplTestJ.java | 99 +-
.../linkis-computation-governance-common/pom.xml | 106 +-
.../common/entity/ExecutionNodeStatus.java | 54 +-
.../governance/common/entity/NodeExistStatus.java | 6 +-
.../governance/common/entity/job/JobRequest.java | 374 +--
.../common/entity/job/JobRequestWithDetail.java | 64 +-
.../common/entity/job/QueryException.java | 12 +-
.../governance/common/entity/job/SubJobDetail.java | 182 +-
.../governance/common/entity/job/SubJobInfo.java | 92 +-
.../common/entity/task/RequestOneTask.java | 28 +-
.../common/entity/task/RequestPersistTask.java | 744 +++---
.../common/entity/task/RequestReadAllTask.java | 30 +-
.../common/entity/task/ResponsePersist.java | 120 +-
.../common/conf/GovernaceCommonConf.scala | 34 +-
.../common/constant/job/JobRequestConstants.scala | 11 +-
.../common/constant/job/TaskInfoConstants.scala | 2 +-
.../common/entity/job/OnceExecutorContent.scala | 3 +-
.../exception/GovernanceErrorException.scala | 11 +-
.../common/exception/LinkisJobRetryException.scala | 13 +-
.../governance/common/paser/CodeParser.scala | 98 +-
.../protocol/conf/RemoveCacheConfRequest.scala | 7 +-
.../protocol/conf/RequestQueryGlobalConfig.scala | 53 +-
.../common/protocol/conf/ResponseQueryConfig.scala | 12 +-
.../protocol/engineconn/RequestEngineStatus.scala | 19 +-
.../common/protocol/job/JobDetailReqProcotol.scala | 18 +-
.../common/protocol/job/JobReqProcotol.scala | 17 +-
.../common/protocol/job/JobRespProtocol.scala | 27 +-
.../common/protocol/task/RequestTask.scala | 44 +-
.../protocol/task/ResponseEngineConnPid.scala | 21 +-
.../common/protocol/task/ResponseTaskExecute.scala | 75 +-
.../governance/common/utils/ECPathUtils.scala | 21 +-
.../common/utils/EngineConnArguments.scala | 65 +-
.../common/utils/GovernanceConstant.scala | 8 +-
.../governance/common/utils/GovernanceUtils.scala | 23 +-
.../linkis/governance/common/utils/JobUtils.scala | 2 +-
.../common/utils/OnceExecutorContentUtils.scala | 29 +-
.../common/paser/PythonCodeParseTest.scala | 57 +
.../common/paser/SQLCodeParserTest.scala | 2 +-
.../governance/common/utils/JobUtilsTest.scala | 5 +-
.../linkis-engineconn-linux-launch/pom.xml | 95 +-
.../launch/LinuxProcessEngineConnLaunch.scala | 13 +-
.../linkis-engineconn-manager-core/pom.xml | 127 +-
.../apache/linkis/ecm/core/conf/ECMErrorCode.scala | 9 +-
.../apache/linkis/ecm/core/conf/ECPCoreConf.scala | 2 +-
.../linkis/ecm/core/engineconn/EngineConn.scala | 13 +-
.../ecm/core/engineconn/EngineConnInfo.scala | 9 +-
.../ecm/core/engineconn/YarnEngineConn.scala | 10 +-
.../ecm/core/exception/ECMCoreException.scala | 15 +-
.../ecm/core/launch/DiscoveryMsgGenerator.scala | 19 +-
.../linkis/ecm/core/launch/EngineConnLaunch.scala | 10 +-
.../ecm/core/launch/EngineConnLaunchRunner.scala | 14 +-
.../ecm/core/launch/EngineConnManagerEnv.scala | 9 +-
.../core/launch/ProcessEngineCommandBuilder.scala | 24 +-
.../ecm/core/launch/ProcessEngineCommandExec.scala | 25 +-
.../ecm/core/launch/ProcessEngineConnLaunch.scala | 176 +-
.../ecm/core/listener/ECMAsyncListenerBus.scala | 22 +-
.../ecm/core/listener/ECMEventListener.scala | 10 +-
.../ecm/core/listener/ECMSyncListenerBus.scala | 13 +-
.../linkis/ecm/core/metrics/ECMMetrics.scala | 10 +-
.../linkis/ecm/core/report/ECMHealthReport.scala | 9 +-
.../linkis/ecm/core/report/NodeHealthReport.scala | 9 +-
.../apache/linkis/ecm/core/utils/PortUtils.scala | 25 +-
.../linkis/ecm/core/utils/PortUtilsTest.scala | 2 +-
.../linkis-engineconn-manager-server/pom.xml | 268 ++-
.../linkis/ecm/server/LinkisECMApplication.java | 130 +-
.../linkis/ecm/server/conf/ECMConfiguration.scala | 115 +-
.../ecm/server/context/DefaultECMContext.scala | 16 +-
.../linkis/ecm/server/context/ECMContext.scala | 13 +-
.../ecm/server/converter/ECMEngineConverter.scala | 14 +-
.../ecm/server/engineConn/DefaultEngineConn.scala | 27 +-
.../server/engineConn/DefaultYarnEngineConn.scala | 12 +-
.../ecm/server/errorcode/ECMErrorConstants.scala | 10 +-
.../ecm/server/exception/ECMErrorException.scala | 14 +-
.../apache/linkis/ecm/server/hook/ECMHook.scala | 10 +-
.../linkis/ecm/server/hook/JarUDFLoadECMHook.scala | 40 +-
.../linkis/ecm/server/listener/ECMReadyEvent.scala | 14 +-
.../ecm/server/metrics/DefaultECMMetrics.scala | 45 +-
.../server/operator/EngineConnLogOperator.scala | 133 +-
.../operator/EngineConnYarnLogOperator.scala | 66 +-
.../ecm/server/report/DefaultECMHealthReport.scala | 18 +-
.../ecm/server/service/ECMHealthService.scala | 17 +-
.../ecm/server/service/ECMMetricsService.scala | 13 +-
.../ecm/server/service/ECMRegisterService.scala | 9 +-
.../ecm/server/service/EngineConnKillService.scala | 9 +-
.../server/service/EngineConnLaunchService.scala | 29 +-
.../ecm/server/service/EngineConnListService.scala | 18 +-
.../service/EngineConnPidCallbackService.scala | 10 +-
.../service/EngineConnStatusCallbackService.scala | 9 +-
.../server/service/LocalDirsHandleService.scala | 9 +-
.../ecm/server/service/LogCallbackService.scala | 10 +-
.../linkis/ecm/server/service/OperateService.scala | 1 -
.../service/ResourceLocalizationService.scala | 14 +-
.../ecm/server/service/YarnCallbackService.scala | 9 +-
.../impl/AbstractEngineConnLaunchService.scala | 92 +-
.../impl/BmlResourceLocalizationService.scala | 106 +-
.../service/impl/DefaultECMHealthService.scala | 83 +-
.../service/impl/DefaultECMMetricsService.scala | 11 +-
.../service/impl/DefaultECMRegisterService.scala | 40 +-
.../impl/DefaultEngineConnListService.scala | 66 +-
.../impl/DefaultEngineConnPidCallbackService.scala | 20 +-
.../DefaultEngineConnStatusCallbackService.scala | 41 +-
.../impl/DefaultLocalDirsHandleService.scala | 25 +-
.../service/impl/DefaultOperateService.scala | 12 +-
.../service/impl/DefaultYarnCallbackService.scala | 20 +-
.../impl/LinuxProcessEngineConnLaunchService.scala | 26 +-
.../impl/ProcessEngineConnLaunchService.scala | 110 +-
.../ecm/server/spring/ECMSpringConfiguration.scala | 34 +-
.../apache/linkis/ecm/server/util/ECMUtils.scala | 27 +-
.../linkis/ecm/server/util/HardwareUtils.scala | 6 +-
.../impl/DefaultEngineConnKillServiceTest.java | 98 +-
.../linkis-engineconn-manager/pom.xml | 33 +-
.../linkis-once-engineconn/pom.xml | 174 +-
.../engineconn/once/executor/OnceExecutor.scala | 83 +-
.../executor/OnceExecutorExecutionContext.scala | 36 +-
.../once/executor/OperableOnceExecutor.scala | 1 -
.../executor/creation/OnceExecutorFactory.scala | 20 +-
.../executor/creation/OnceExecutorManager.scala | 38 +-
.../exception/OnceEngineConnErrorException.scala | 12 +-
.../execution/OnceEngineConnExecution.scala | 67 +-
.../once/executor/hook/OnceEngineConnHook.scala | 20 +-
.../operator/OperableOnceEngineConnOperator.scala | 26 +-
.../linkis-computation-engineconn/pom.xml | 273 ++-
.../async/AsyncConcurrentComputationExecutor.scala | 115 +-
.../executor/async/AsyncEngineConnJob.scala | 30 +-
.../executor/async/AsyncExecuteContext.scala | 27 +-
.../executor/async/AsyncExecuteExecutor.scala | 19 +-
.../executor/async/AsyncExecuteRequest.scala | 7 +-
.../executor/async/AsyncExecutorManager.scala | 10 +-
.../executor/bml/BmlEnginePreExecuteHook.scala | 46 +-
.../executor/bml/BmlHookDownloadException.scala | 2 +-
.../executor/conf/ComputationExecutorConf.scala | 45 +-
...bstractComputationSingleExecutorECFactory.scala | 7 +-
.../creation/ComputationExecutorFactory.scala | 31 +-
.../creation/ComputationExecutorManager.scala | 48 +-
...omputationSingleExecutorEngineConnFactory.scala | 48 +-
.../executor/cs/CSEnginePreExecuteHook.scala | 34 +-
.../computation/executor/cs/CSResourceParser.scala | 28 +-
.../computation/executor/cs/CSTableRegister.scala | 71 +-
.../executor/cs/CSTableResultSetWriter.scala | 17 +-
.../executor/entity/CommonEngineConnTask.scala | 17 +-
.../executor/entity/EngineConnTask.scala | 12 +-
.../computation/executor/entity/TaskStatus.scala | 14 +-
.../execute/ComputationEngineConnExecution.scala | 52 +-
.../executor/execute/ComputationExecutor.scala | 207 +-
.../execute/ConcurrentComputationExecutor.scala | 33 +-
.../executor/execute/EngineExecutionContext.scala | 121 +-
.../executor/hook/ComputationEngineConnHook.scala | 29 +-
.../executor/hook/ComputationExecutorHook.scala | 33 +-
.../executor/hook/ExecutorLabelsRestHook.scala | 19 +-
.../computation/executor/hook/InitSQLHook.scala | 43 +-
.../executor/hook/UDFLoadEngineConnHook.scala | 102 +-
.../executor/hook/UseDatabaseEngineHook.scala | 35 +-
.../executor/hook/executor/ExecuteOnceHook.scala | 25 +-
.../hook/executor/FunctionExecutorHook.scala | 19 +-
.../executor/listener/ResultSetListener.scala | 15 +-
.../executor/listener/TaskProgressListener.scala | 9 +-
.../executor/listener/TaskStatusListener.scala | 14 +-
.../computation/executor/rs/RsOutputStream.scala | 35 +-
.../executor/service/TaskExecutionService.scala | 10 +-
.../service/TaskExecutionServiceImpl.scala | 343 ++-
.../executor/upstream/ECTaskEntranceMonitor.scala | 40 +-
.../SingleThreadUpstreamConnectionMonitor.scala | 80 +-
.../upstream/UpstreamConnectionMonitor.scala | 8 +-
.../upstream/access/ConnectionInfoAccess.scala | 6 +-
.../access/ConnectionInfoAccessRequest.scala | 6 +-
.../upstream/access/ECTaskEntranceInfoAccess.scala | 60 +-
.../access/ECTaskEntranceInfoAccessRequest.scala | 8 +-
.../upstream/entity/ECTaskEntranceConnection.scala | 36 +-
.../upstream/entity/UpstreamConnection.scala | 7 +-
.../TaskStatusChangedForUpstreamMonitorEvent.scala | 11 +-
.../upstream/handler/ECTaskKillHandler.scala | 37 +-
.../handler/ECTaskKillHandlerRequest.scala | 9 +-
.../executor/upstream/handler/MonitorHandler.scala | 6 +-
.../upstream/handler/MonitorHandlerRequest.scala | 7 +-
...skStatusChangedForUpstreamMonitorListener.scala | 8 +-
.../service/ECTaskEntranceMonitorService.scala | 34 +-
.../upstream/wrapper/ConnectionInfoWrapper.scala | 2 +-
.../wrapper/ECTaskEntranceConnectionWrapper.scala | 35 +-
.../executor/utlis/ComputationEngineConstant.scala | 9 +-
.../executor/utlis/ComputationEngineUtils.scala | 11 +-
.../executor/utlis/ComputationErrorCode.scala | 11 +-
.../computation/executor/utlis/ProgressUtils.scala | 6 +-
.../access/ECTaskEntranceInfoAccessHelper.scala | 34 +-
.../linkis-engineconn-common/pom.xml | 130 +-
.../engineconn/common/conf/EngineConnConf.scala | 52 +-
.../common/conf/EngineConnConstant.scala | 9 +-
.../common/creation/EngineCreationContext.scala | 15 +-
.../engineconn/common/engineconn/EngineConn.scala | 36 +-
.../common/exception/EngineConnException.scala | 11 +-
.../common/execution/EngineConnExecution.scala | 17 +-
.../engineconn/common/hook/EngineConnHook.scala | 44 +-
.../linkis-engineconn-core/pom.xml | 116 +-
.../linkis/engineconn/core/EngineConnObject.scala | 20 +-
.../AbstractCodeLanguageLabelExecutorFactory.scala | 53 +-
.../core/creation/AbstractExecutorFactory.scala | 22 +-
.../core/engineconn/EngineConnManager.scala | 20 +-
.../core/exception/EngineConnErrorCode.scala | 9 +-
.../core/exception/EngineConnFatalException.scala | 14 +-
.../execution/AbstractEngineConnExecution.scala | 38 +-
.../core/execution/EngineConnExecution.scala | 21 +-
.../engineconn/core/executor/ExecutorManager.scala | 146 +-
.../linkis/engineconn/core/hook/ExecutorHook.scala | 15 +-
.../linkis/engineconn/core/hook/ShutdownHook.scala | 20 +-
.../engineconn/core/util/EngineConnUtils.scala | 8 +-
.../engineconn/launch/EngineConnServer.scala | 92 +-
.../accessible-executor/pom.xml | 139 +-
.../acessible/executor/log/AbstractLogCache.java | 22 +-
.../acessible/executor/log/LogCache.java | 42 +-
.../acessible/executor/log/MountLogCache.java | 160 +-
.../acessible/executor/log/SendAppender.java | 131 +-
.../acessible/executor/log/TimeLogCache.java | 28 +-
.../conf/AccessibleExecutorConfiguration.scala | 36 +-
.../AccessibleExecutorSpringConfiguration.scala | 30 +-
.../executor/entity/AccessibleExecutor.scala | 125 +-
.../executor/entity/ExecutorStatusInfo.scala | 8 +-
.../execution/AccessibleEngineConnExecution.scala | 175 +-
.../executor/info/NodeHealthyInfoManager.scala | 19 +-
.../executor/info/NodeHeartbeatMsgManager.scala | 8 +-
.../executor/info/NodeOverLoadInfoManager.scala | 11 +-
.../executor/listener/ExecutorLockListener.scala | 17 +-
.../executor/listener/ExecutorStatusListener.scala | 25 +-
.../acessible/executor/listener/LogListener.scala | 9 +-
.../executor/listener/NodeHealthyListener.scala | 15 +-
.../event/AccessibleExecutorConnAsyncEvent.scala | 31 +-
.../executor/listener/event/LogUpdateEvent.scala | 8 +-
.../executor/listener/event/TaskEvent.scala | 26 +-
.../executor/lock/EngineConnTimedLock.scala | 72 +-
.../acessible/executor/lock/TimedLock.scala | 8 +-
.../acessible/executor/log/LogHelper.scala | 81 +-
.../impl/EngineConnApplicationInfoOperator.scala | 18 +-
.../executor/service/AccessibleService.scala | 12 +-
.../service/DefaultAccessibleService.scala | 69 +-
.../service/DefaultExecutorHeartbeatService.scala | 77 +-
.../executor/service/DefaultManagerService.scala | 32 +-
.../executor/service/DefaultOperateService.scala | 29 +-
.../service/EngineConnTimedLockService.scala | 120 +-
.../service/ExecutorHeartbeatService.scala | 17 +-
.../acessible/executor/service/LockService.scala | 34 +-
.../acessible/executor/service/LogService.scala | 9 +-
.../executor/service/OperateService.scala | 13 +-
.../executor/utils/AccessableExecutorUtils.scala | 12 +-
.../callback/hook/CallbackEngineConnHook.scala | 82 +-
.../service/EngineConnAfterStartCallback.scala | 15 +-
.../callback/service/EngineConnCallback.scala | 19 +-
.../callback/service/EngineConnPidCallback.scala | 14 +-
.../callback/service/EngineConnTimedCallback.scala | 13 +-
.../executor-core/pom.xml | 127 +-
.../executor/ExecutorExecutionContext.scala | 52 +-
.../conf/EngineConnExecutorConfiguration.scala | 50 +-
.../executor/entity/ExecutableExecutor.scala | 11 +-
.../engineconn/executor/entity/Executor.scala | 14 +-
.../engineconn/executor/entity/LabelExecutor.scala | 12 +-
.../executor/entity/ResourceExecutor.scala | 9 +-
.../executor/entity/ResourceFetchExecutor.scala | 2 +-
.../executor/entity/SensibleExecutor.scala | 19 +-
.../engineconn/executor/entity/YarnExecutor.scala | 9 +-
.../listener/EngineConnAsyncListener.scala | 8 +-
.../listener/EngineConnAsyncListenerBus.scala | 37 +-
.../executor/listener/EngineConnSyncListener.scala | 8 +-
.../listener/EngineConnSyncListenerBus.scala | 26 +-
.../listener/ExecutorListenerBusContext.scala | 23 +-
.../listener/event/EngineConnAsyncEvent.scala | 13 +-
.../listener/event/EngineConnSyncEvent.scala | 12 +-
.../engineconn/executor/service/LabelService.scala | 16 +-
.../executor/service/ManagerService.scala | 20 +-
.../linkis-engineconn-plugin-core/pom.xml | 147 +-
.../engineplugin/common/EngineConnPlugin.scala | 15 +-
.../common/conf/EngineConnPluginConf.scala | 17 +-
.../common/conf/EnvConfiguration.scala | 65 +-
.../common/creation/EngineConnFactory.scala | 42 +-
.../common/creation/ExecutorFactory.scala | 17 +-
.../common/creation/LabelExecutorFactory.scala | 23 +-
.../exception/EngineConnBuildFailedException.scala | 12 +-
.../exception/EngineConnPluginErrorCode.scala | 9 +-
.../exception/EngineConnPluginErrorException.scala | 13 +-
.../exception/EngineConnPluginLoadException.scala | 6 +-
.../EngineConnPluginLoadResourceException.scala | 6 +-
.../EngineConnPluginNotFoundException.scala | 6 +-
.../common/launch/EngineConnLaunchBuilder.scala | 16 +-
.../launch/entity/EngineConnBuildRequest.scala | 29 +-
.../launch/entity/EngineConnCreationDesc.scala | 15 +-
.../launch/entity/EngineConnLaunchRequest.scala | 11 +-
.../process/EngineConnResourceGenerator.scala | 11 +-
.../common/launch/process/Environment.scala | 25 +-
.../JavaProcessEngineConnLaunchBuilder.scala | 114 +-
.../process/ProcessEngineConnLaunchBuilder.scala | 69 +-
.../process/ProcessEngineConnLaunchRequest.scala | 41 +-
.../common/loader/conf/PluginLoaderConstant.scala | 9 +-
.../loader/entity/EngineConnPluginInfo.scala | 26 +-
.../loader/entity/EngineConnPluginInstance.scala | 9 +-
.../exception/EngineConnPluginLoadException.scala | 5 +-
.../EngineConnPluginLoadResourceException.scala | 5 +-
.../EngineConnPluginNotFoundException.scala | 5 +-
.../resource/AbstractEngineResourceFactory.scala | 27 +-
.../common/resource/EngineResourceFactory.scala | 9 +-
.../common/resource/EngineResourceRequest.scala | 30 +-
.../resource/GenericEngineResourceFactory.scala | 28 +-
.../common/resource/UserNodeResource.scala | 15 +-
.../linkis-engineconn-plugin-server/pom.xml | 413 ++--
.../engineplugin/cache/EngineConnPluginCache.java | 62 +-
.../cache/GuavaEngineConnPluginCache.java | 241 +-
.../cache/config/EngineConnPluginCacheConfig.java | 13 +-
.../DefaultRefreshPluginCacheContainer.java | 365 ++-
.../cache/refresh/PluginCacheRefresher.java | 4 +-
.../cache/refresh/RefreshPluginCacheContainer.java | 60 +-
.../cache/refresh/RefreshPluginCacheOperation.java | 86 +-
.../refresh/RefreshableEngineConnPluginCache.java | 58 +-
.../classloader/EngineConnPluginClassLoader.java | 198 +-
.../loaders/CacheablesEngineConnPluginLoader.java | 128 +-
.../loaders/DefaultEngineConnPluginLoader.java | 412 ++--
.../loader/loaders/EngineConnPluginsLoader.java | 28 +-
.../loaders/EngineConnPluginsResourceLoader.java | 14 +-
.../BmlEngineConnPluginResourceLoader.java | 401 ++--
.../LocalEngineConnPluginResourceLoader.java | 56 +-
.../loader/loaders/resource/PluginResource.java | 90 +-
.../loader/utils/EngineConnPluginUtils.java | 246 +-
.../engineplugin/loader/utils/ExceptionHelper.java | 12 +-
.../server/LinkisEngineConnPluginServer.java | 6 +-
.../conf/EngineConnPluginSpringConfiguration.java | 10 +-
.../server/dao/EngineConnBmlResourceDao.java | 10 +-
.../server/entity/EngineConnBmlResource.java | 180 +-
.../loader/EngineConnPluginLoaderConf.scala | 29 +-
.../conf/EngineConnPluginConfiguration.scala | 21 +-
.../interceptor/EngineConnLaunchInterceptor.scala | 23 +-
.../server/loader/EngineConnPluginsLoader.scala | 17 +-
.../AbstractEngineConnBmlResourceGenerator.scala | 59 +-
.../DefaultEngineConnBmlResourceGenerator.scala | 75 +-
.../localize/EngineConnBmlResourceGenerator.scala | 11 +-
.../service/DefaultEngineConnLaunchService.scala | 50 +-
.../DefaultEngineConnResourceFactoryService.scala | 26 +-
.../service/DefaultEngineConnResourceService.scala | 161 +-
.../server/service/EngineConnLaunchService.scala | 19 +-
.../service/EngineConnResourceFactoryService.scala | 14 +-
.../server/service/EngineConnResourceService.scala | 20 +-
.../loader/EngineConnPluginLoaderTest.java | 20 +-
.../linkis-engineconn/pom.xml | 44 +-
.../linkis-entrance/pom.xml | 291 ++-
.../linkis/entrance/LinkisEntranceApplication.java | 6 +-
.../EntranceExecutorManagerBeanAnnotation.java | 38 +-
.../annotation/EntranceParserBeanAnnotation.java | 38 +-
.../annotation/EntranceServerBeanAnnotation.java | 38 +-
.../PersistenceEngineBeanAnnotation.java | 38 +-
.../entrance/conf/EntranceSpringConfiguration.java | 294 ++-
.../entrance/constant/ServiceNameConsts.java | 8 +-
.../entrance/context/DefaultEntranceContext.java | 142 +-
.../entrance/exception/EntranceErrorCode.java | 51 +-
.../exception/EntranceIllegalParamException.java | 12 +-
.../entrance/exception/EntranceRPCException.java | 14 +-
.../entrance/exception/QueryFailedException.java | 14 +-
.../entrance/job/EntranceExecuteRequest.java | 136 +-
.../linkis/entrance/job/EntranceExecutionJob.java | 386 ++-
.../entrance/parser/AbstractEntranceParser.java | 220 +-
.../apache/linkis/entrance/parser/ParserUtils.java | 108 +-
.../persistence/QueryPersistenceEngine.java | 287 ++-
.../persistence/QueryPersistenceManager.java | 284 +--
.../entrance/server/DefaultEntranceServer.java | 99 +-
.../entrance/vo/YarnResourceWithStatusVo.java | 166 +-
.../apache/linkis/entrance/EntranceContext.scala | 19 +-
.../apache/linkis/entrance/EntranceParser.scala | 12 +-
.../apache/linkis/entrance/EntranceServer.scala | 159 +-
.../linkis/entrance/EntranceWebSocketService.scala | 476 ++--
.../cache/GlobalConfigurationKeyValueCache.scala | 26 +-
.../cli/heartbeat/CliHeartbeatMonitor.scala | 42 +-
.../cli/heartbeat/HeartbeatLossHandler.scala | 2 +-
.../entrance/cli/heartbeat/KillHandler.scala | 13 +-
.../entrance/conf/EntranceConfiguration.scala | 178 +-
.../linkis/entrance/cs/CSEntranceHelper.scala | 118 +-
.../errorcode/EntranceErrorConstants.scala | 122 +-
.../linkis/entrance/event/EntranceEvent.scala | 24 +-
.../entrance/event/EntranceEventListener.scala | 9 +-
.../entrance/event/EntranceEventListenerBus.scala | 24 +-
.../linkis/entrance/event/EntranceLogEvent.scala | 22 +-
.../entrance/event/EntranceLogListener.scala | 9 +-
.../entrance/event/EntranceLogListenerBus.scala | 24 +-
.../exception/CacheNotReadyException.scala | 16 +-
.../exception/EntranceCastFailException.scala | 15 +-
.../exception/EntranceErrorException.scala | 10 +-
.../exception/JobHistoryFailedException.scala | 11 +-
.../exception/LogReadFailedException.scala | 14 +-
.../exception/SensitiveTablesCheckException.scala | 13 +-
.../entrance/exception/SubmitFailedException.scala | 14 +-
.../entrance/execute/DefaultEntranceExecutor.scala | 209 +-
.../entrance/execute/EngineLockListener.scala | 11 +-
.../linkis/entrance/execute/EntranceExecutor.scala | 61 +-
.../entrance/execute/EntranceExecutorManager.scala | 135 +-
.../linkis/entrance/execute/EntranceJob.scala | 192 +-
.../execute/ExecuteRequestInterceptor.scala | 118 +-
.../entrance/execute/JobLockExecuteRequest.scala | 11 +-
.../apache/linkis/entrance/execute/MarkReq.scala | 15 +-
.../execute/impl/EntranceExecutorManagerImpl.scala | 27 +-
.../execute/operation/ScriptisOperation.scala | 17 +-
.../entrance/interceptor/EntranceInterceptor.scala | 34 +-
.../entrance/interceptor/OnceJobInterceptor.scala | 77 +-
.../entrance/interceptor/RuntypeInterceptor.scala | 18 +-
.../interceptor/exception/CodeCheckException.scala | 15 +-
.../exception/LabelCheckException.scala | 15 +-
.../exception/LimitCheckException.scala | 15 +-
.../exception/LogPathCreateException.scala | 16 +-
.../exception/PythonCodeCheckException.scala | 22 +-
.../exception/VarSubstitutionException.scala | 14 +-
.../interceptor/impl/CSEntranceInterceptor.scala | 13 +-
.../interceptor/impl/CommentInterceptor.scala | 47 +-
.../interceptor/impl/CompatibleInterceptor.scala | 7 +-
.../interceptor/impl/CustomVariableUtils.scala | 34 +-
.../impl/DBInfoCompleteInterceptor.scala | 13 +-
.../linkis/entrance/interceptor/impl/Explain.scala | 274 ++-
.../interceptor/impl/LabelCheckInterceptor.scala | 50 +-
.../impl/LogPathCreateInterceptor.scala | 47 +-
.../impl/ParserVarLabelInterceptor.scala | 16 +-
.../impl/PythonCodeCheckInterceptor.scala | 41 +-
.../interceptor/impl/SQLCodeCheckInterceptor.scala | 24 +-
.../impl/SQLLimitEntranceInterceptor.scala | 30 +-
.../interceptor/impl/ScalaCodeInterceptor.scala | 25 +-
.../impl/ShellDangerousGrammerInterceptor.scala | 56 +-
.../impl/SparkCodeCheckInterceptor.scala | 23 +-
.../impl/StorePathEntranceInterceptor.scala | 29 +-
.../impl/VarSubstitutionInterceptor.scala | 34 +-
.../org/apache/linkis/entrance/log/Cache.scala | 14 +-
.../linkis/entrance/log/CacheLogManager.scala | 58 +-
.../linkis/entrance/log/CacheLogReader.scala | 35 +-
.../linkis/entrance/log/CacheLogWriter.scala | 31 +-
.../org/apache/linkis/entrance/log/ErrorCode.scala | 10 +-
.../linkis/entrance/log/ErrorCodeListener.scala | 41 +-
.../linkis/entrance/log/ErrorCodeManager.scala | 35 +-
.../linkis/entrance/log/HDFSCacheLogWriter.scala | 59 +-
.../org/apache/linkis/entrance/log/LogFilter.scala | 14 +-
.../apache/linkis/entrance/log/LogHandler.scala | 22 +-
.../apache/linkis/entrance/log/LogManager.scala | 40 +-
.../org/apache/linkis/entrance/log/LogReader.scala | 143 +-
.../org/apache/linkis/entrance/log/LogWriter.scala | 48 +-
.../org/apache/linkis/entrance/log/LoopArray.scala | 43 +-
.../entrance/log/WebSocketCacheLogReader.scala | 29 +-
.../linkis/entrance/log/WebSocketLogWriter.scala | 28 +-
.../EntranceOrchestrationFactory.scala | 14 +-
.../EntranceUserParallelOrchestratorPlugin.scala | 79 +-
.../entrance/parser/CommonEntranceParser.scala | 178 +-
.../persistence/EntranceResultSetEngine.scala | 25 +-
.../entrance/persistence/HaPersistenceTask.scala | 8 +-
.../persistence/JobCompletedListener.scala | 11 +-
.../entrance/persistence/PersistenceEngine.scala | 16 +-
.../entrance/persistence/PersistenceManager.scala | 19 +-
.../entrance/persistence/ResultSetEngine.scala | 11 +-
.../entrance/persistence/ResultSetListener.scala | 11 +-
.../entrance/restful/EntranceRestfulRemote.scala | 49 +-
.../entrance/scheduler/EntranceGroupFactory.scala | 135 +-
.../scheduler/EntranceSchedulerContext.scala | 19 +-
.../cache/CacheOutputExecuteResponse.scala | 11 +-
.../scheduler/cache/ReadCacheConsumer.scala | 69 +-
.../scheduler/cache/ReadCacheConsumerManager.scala | 20 +-
.../entrance/timeout/JobTimeoutManager.scala | 103 +-
.../linkis/entrance/utils/CommonLogPathUtils.scala | 7 +-
.../linkis/entrance/utils/JobHistoryHelper.scala | 68 +-
.../apache/linkis/entrance/utils/LogHelper.scala | 5 +-
.../apache/linkis/entrance/utils/RGBUtils.scala | 3 +-
.../linkis-application-manager/pom.xml | 329 ++-
.../manager/am/LinkisManagerApplication.java | 8 +-
.../linkis/manager/am/exception/AMErrorCode.java | 46 +-
.../manager/am/exception/AMErrorException.java | 14 +-
.../manager/am/exception/AMRetryException.java | 14 +-
.../manager/am/service/ECResourceInfoService.java | 12 +-
.../am/service/impl/ECResourceInfoServiceImpl.java | 56 +-
.../manager/am/util/ECResourceInfoUtils.java | 70 +-
.../linkis/manager/am/vo/AMEngineNodeVo.java | 364 +--
.../manager/am/vo/ECResourceInfoRecordVo.java | 372 +--
.../org/apache/linkis/manager/am/vo/EMNodeVo.java | 308 +--
.../apache/linkis/manager/am/vo/ResourceVo.java | 42 +-
.../linkis/manager/rm/conf/ResourceStatus.java | 44 +-
.../linkis/manager/rm/domain/RMLabelContainer.java | 286 ++-
.../linkis/manager/rm/exception/RMErrorCode.java | 93 +-
.../external/dao/ExternalResourceProviderDao.java | 2 +-
.../domain/ExternalResourceIdentifier.java | 2 +-
.../external/domain/ExternalResourceProvider.java | 90 +-
.../parser/ExternalResourceIdentifierParser.java | 4 +-
.../parser/YarnResourceIdentifierParser.java | 18 +-
.../request/ExternalResourceRequester.java | 12 +-
.../external/service/ExternalResourceService.java | 48 +-
.../service/impl/ExternalResourceServiceImpl.java | 330 ++-
.../rm/external/yarn/YarnResourceIdentifier.java | 22 +-
.../manager/rm/restful/vo/ApplicationListVo.java | 60 +-
.../manager/rm/restful/vo/EngineInstanceVo.java | 126 +-
.../rm/restful/vo/UserCreatorEngineType.java | 56 +-
.../manager/rm/restful/vo/UserResourceVo.java | 210 +-
.../manager/rm/utils/RequestKerberosUrlUtils.java | 205 +-
.../linkis/manager/am/conf/AMConfiguration.scala | 62 +-
.../manager/am/conf/ConfigurationMapCache.scala | 40 +-
.../am/conf/EngineConnConfigurationService.scala | 25 +-
.../manager/am/conf/ManagerMonitorConf.scala | 17 +-
.../am/converter/DefaultMetricsConverter.scala | 27 +-
.../linkis/manager/am/label/AMLabelChecker.scala | 21 +-
.../linkis/manager/am/label/AMLabelFilter.scala | 25 +-
.../am/label/DefaultManagerLabelService.scala | 17 +-
.../manager/am/label/EngineReuseLabelRester.scala | 12 +-
.../label/MultiUserEngineReuseLabelChooser.scala | 29 +-
.../am/locker/DefaultEngineNodeLocker.scala | 27 +-
.../manager/am/locker/EngineNodeLocker.scala | 12 +-
.../manager/am/manager/DefaultEMNodeManager.scala | 97 +-
.../am/manager/DefaultEngineNodeManager.scala | 189 +-
.../linkis/manager/am/manager/EMNodeManager.scala | 40 +-
.../manager/am/manager/EngineNodeManager.scala | 52 +-
.../manager/am/pointer/AbstractNodePointer.scala | 47 +-
.../manager/am/pointer/DefaultEMNodPointer.scala | 46 +-
.../pointer/DefaultEngineConnPluginPointer.scala | 29 +-
.../am/pointer/DefaultEngineNodPointer.scala | 34 +-
.../am/pointer/DefaultNodePointerBuilder.scala | 17 +-
.../am/pointer/EngineConnPluginPointer.scala | 9 +-
.../am/recycle/AssignNodeRuleExecutor.scala | 24 +-
.../manager/am/recycle/RecyclingRuleExecutor.scala | 9 +-
.../linkis/manager/am/rpc/ManagerRPCFormats.scala | 17 +-
.../manager/am/selector/DefaultNodeSelector.scala | 29 +-
.../manager/am/selector/ECAvailableRule.scala | 15 +-
.../linkis/manager/am/selector/NodeSelector.scala | 9 +-
.../am/selector/rule/AvailableNodeSelectRule.scala | 29 +-
.../selector/rule/ConcurrencyNodeSelectRule.scala | 14 +-
.../am/selector/rule/NewECMStandbyRule.scala | 45 +-
.../manager/am/selector/rule/NodeSelectRule.scala | 9 +-
.../am/selector/rule/OverLoadNodeSelectRule.scala | 33 +-
.../am/selector/rule/ResourceNodeSelectRule.scala | 57 +-
.../am/selector/rule/ScoreNodeSelectRule.scala | 22 +-
.../am/selector/rule/TaskInfoNodeSelectRule.scala | 33 +-
.../manager/am/service/EMEngineService.scala | 12 +-
.../linkis/manager/am/service/EngineService.scala | 11 +-
.../manager/am/service/HeartbeatService.scala | 9 +-
.../cache/ConfCacheRemoveBroadcastListener.scala | 65 +-
.../am/service/em/DefaultECMOperateService.scala | 3 +-
.../am/service/em/DefaultEMEngineService.scala | 55 +-
.../am/service/em/DefaultEMInfoService.scala | 42 +-
.../am/service/em/DefaultEMRegisterService.scala | 59 +-
.../am/service/em/DefaultEMUnregisterService.scala | 31 +-
.../manager/am/service/em/ECMOperateService.scala | 1 -
.../manager/am/service/em/EMInfoService.scala | 9 +-
.../manager/am/service/em/EMRegisterService.scala | 19 +-
.../am/service/em/EMUnregisterService.scala | 9 +-
.../am/service/engine/AbstractEngineService.scala | 13 +-
.../engine/DefaultEngineAskEngineService.scala | 79 +-
.../engine/DefaultEngineConnCanKillService.scala | 36 +-
.../DefaultEngineConnStatusCallbackService.scala | 33 +-
.../engine/DefaultEngineCreateService.scala | 249 +-
.../service/engine/DefaultEngineInfoService.scala | 60 +-
.../engine/DefaultEngineOperateService.scala | 24 +-
.../engine/DefaultEngineRecycleService.scala | 52 +-
.../service/engine/DefaultEngineReuseService.scala | 128 +-
.../service/engine/DefaultEngineStopService.scala | 74 +-
.../engine/DefaultEngineSwitchService.scala | 10 +-
.../am/service/engine/EngineAskEngineService.scala | 9 +-
.../service/engine/EngineConnCanKillService.scala | 3 +-
.../engine/EngineConnStatusCallbackService.scala | 13 +-
.../am/service/engine/EngineCreateService.scala | 9 +-
.../am/service/engine/EngineInfoService.scala | 20 +-
.../am/service/engine/EngineKillService.scala | 14 +-
.../am/service/engine/EngineOperateService.scala | 18 +-
.../am/service/engine/EngineRecycleService.scala | 9 +-
.../am/service/engine/EngineReuseService.scala | 9 +-
.../am/service/engine/EngineStopService.scala | 21 +-
.../am/service/engine/EngineSwitchService.scala | 9 +-
.../am/service/heartbeat/AMHeartbeatService.scala | 31 +-
.../am/service/monitor/NodeHeartbeatMonitor.scala | 234 +-
.../apache/linkis/manager/am/utils/AMUtils.scala | 245 +-
.../linkis/manager/label/LabelManagerUtils.scala | 3 +-
.../manager/label/conf/LabelManagerConf.scala | 12 +-
.../label/score/DefaultNodeLabelScorer.scala | 170 +-
.../label/score/LabelScoreServiceInstance.scala | 15 +-
.../manager/label/score/NodeLabelScorer.scala | 31 +-
.../label/service/NodeLabelAddService.scala | 9 +-
.../label/service/NodeLabelRemoveService.scala | 9 +-
.../manager/label/service/NodeLabelService.scala | 45 +-
.../label/service/ResourceLabelService.scala | 62 +-
.../manager/label/service/UserLabelService.scala | 10 +-
.../service/impl/DefaultNodeLabelAddService.scala | 14 +-
.../impl/DefaultNodeLabelRemoveService.scala | 21 +-
.../service/impl/DefaultNodeLabelService.scala | 273 ++-
.../service/impl/DefaultResourceLabelService.scala | 122 +-
.../service/impl/DefaultUserLabelService.scala | 59 +-
.../manager/rm/external/yarn/YarnAppInfo.scala | 11 +-
.../rm/external/yarn/YarnResourceRequester.scala | 216 +-
.../manager/rm/message/RMMessageService.scala | 22 +-
.../linkis/manager/rm/restful/RMMonitorRest.scala | 567 +++--
.../manager/rm/service/LabelResourceService.scala | 14 +-
.../rm/service/RequestResourceService.scala | 334 ++-
.../manager/rm/service/ResourceLockService.scala | 32 +-
.../manager/rm/service/ResourceManager.scala | 92 +-
.../service/impl/DefaultReqResourceService.scala | 6 +-
.../rm/service/impl/DefaultResourceManager.scala | 529 +++--
.../impl/DriverAndYarnReqResourceService.scala | 88 +-
.../rm/service/impl/LabelResourceServiceImpl.scala | 34 +-
.../rm/service/impl/ResourceLogService.scala | 58 +-
.../rm/service/impl/UserResourceService.scala | 39 +-
.../apache/linkis/manager/rm/utils/RMUtils.scala | 177 +-
.../manager/rm/utils/UserConfiguration.scala | 114 +-
.../service/common/label/LabelChecker.scala | 9 +-
.../manager/service/common/label/LabelFilter.scala | 9 +-
.../service/common/label/ManagerLabelService.scala | 9 +-
.../service/common/metrics/MetricsConverter.scala | 10 +-
.../service/common/pointer/EMNodPointer.scala | 9 +-
.../service/common/pointer/EngineNodePointer.scala | 15 +-
.../service/common/pointer/NodePointer.scala | 50 +-
.../common/pointer/NodePointerBuilder.scala | 9 +-
.../linkis-manager/linkis-label-common/pom.xml | 123 +-
.../label/builder/AbstractGenericLabelBuilder.java | 616 +++--
.../label/builder/CombinedLabelBuilder.java | 63 +-
.../label/builder/DefaultGlobalLabelBuilder.java | 459 ++--
.../label/builder/ExtensibleLabelBuilder.java | 78 +-
.../manager/label/builder/GenericLabelBuilder.java | 81 +-
.../linkis/manager/label/builder/LabelBuilder.java | 34 +-
.../manager/label/builder/LabelBuilderAdapter.java | 143 +-
.../label/builder/factory/LabelBuilderFactory.java | 158 +-
.../factory/LabelBuilderFactoryContext.java | 99 +-
.../builder/factory/StdLabelBuilderFactory.java | 350 ++-
.../manager/label/conf/LabelCommonConfig.java | 88 +-
.../manager/label/constant/LabelConstant.java | 4 +-
.../manager/label/constant/LabelKeyConstant.java | 44 +-
.../manager/label/entity/CloneableLabel.java | 28 +-
.../linkis/manager/label/entity/CombinedLabel.java | 10 +-
.../manager/label/entity/CombinedLabelImpl.java | 106 +-
.../linkis/manager/label/entity/Feature.java | 48 +-
.../linkis/manager/label/entity/GenericLabel.java | 40 +-
.../manager/label/entity/InheritableLabel.java | 58 +-
.../apache/linkis/manager/label/entity/Label.java | 80 +-
.../manager/label/entity/SerializableLabel.java | 233 +-
.../linkis/manager/label/entity/TenantLabel.java | 66 +-
.../manager/label/entity/UserModifiable.java | 6 +-
.../manager/label/entity/annon/ValueSerialNum.java | 2 +-
.../manager/label/entity/cache/CacheLabel.java | 58 +-
.../manager/label/entity/cluster/ClusterLabel.java | 58 +-
.../manager/label/entity/cluster/EnvLabel.java | 51 +-
.../manager/label/entity/em/EMInstanceLabel.java | 80 +-
.../label/entity/engine/CodeLanguageLabel.java | 28 +-
.../entity/engine/ConcurrentEngineConnLabel.java | 28 +-
.../label/entity/engine/EngineBaseInfoLabel.java | 66 +-
.../label/entity/engine/EngineInstanceLabel.java | 83 +-
.../label/entity/engine/EngineTypeLabel.java | 68 +-
.../label/entity/engine/ReuseExclusionLabel.java | 62 +-
.../label/entity/engine/UserCreatorLabel.java | 88 +-
.../label/entity/entrance/BindEngineLabel.java | 124 +-
.../label/entity/entrance/ExecuteOnceLabel.java | 14 +-
.../entity/entrance/JobQueuingTimeoutLabel.java | 29 +-
.../entity/entrance/JobRunningTimeoutLabel.java | 29 +-
.../label/entity/entrance/LoadBalanceLabel.java | 84 +-
.../label/entity/entrance/RetryCountLabel.java | 28 +-
.../entity/entrance/RetryWaitTimeOutLabel.java | 28 +-
.../entity/node/AliasServiceInstanceLabel.java | 60 +-
.../label/entity/node/NodeInstanceLabel.java | 4 +-
.../manager/label/entity/route/RouteLabel.java | 58 +-
.../label/entity/search/SearchableLabel.java | 16 +-
.../label/exception/LabelErrorException.java | 14 +-
.../label/exception/LabelRuntimeException.java | 21 +-
.../label/utils/EngineTypeLabelCreator.java | 144 +-
.../linkis/manager/label/utils/LabelUtils.java | 631 +++--
.../linkis/manager/label/utils/LabelUtil.scala | 27 +-
.../linkis/manager/label/TestLabelBuilder.java | 19 +-
.../linkis-manager/linkis-manager-common/pom.xml | 152 +-
.../linkis/manager/common/constant/AMConstant.java | 16 +-
.../linkis/manager/common/constant/RMConstant.java | 12 +-
.../common/entity/enumeration/MaintainType.java | 6 +-
.../common/entity/enumeration/NodeHealthy.java | 36 +-
.../common/entity/enumeration/NodeStatus.java | 164 +-
.../manager/common/entity/label/LabelKeyValue.java | 38 +-
.../common/entity/metrics/AMNodeMetrics.java | 98 +-
.../common/entity/metrics/NodeHealthyInfo.java | 28 +-
.../manager/common/entity/metrics/NodeMetrics.java | 14 +-
.../common/entity/metrics/NodeOverLoadInfo.java | 56 +-
.../common/entity/metrics/NodeTaskInfo.java | 62 +-
.../manager/common/entity/node/AMEMNode.java | 284 +--
.../manager/common/entity/node/AMEngineNode.java | 398 ++--
.../linkis/manager/common/entity/node/AMNode.java | 12 +-
.../entity/node/DefaultScoreServiceInstance.java | 36 +-
.../manager/common/entity/node/EngineNode.java | 12 +-
.../manager/common/entity/node/InfoRMNode.java | 110 +-
.../manager/common/entity/node/LabelNode.java | 4 +-
.../linkis/manager/common/entity/node/Node.java | 20 +-
.../linkis/manager/common/entity/node/RMNode.java | 4 +-
.../common/entity/node/ScoreServiceInstance.java | 8 +-
.../entity/persistence/ECResourceInfoRecord.java | 312 +--
.../entity/persistence/PersistenceLabel.java | 182 +-
.../entity/persistence/PersistenceLabelRel.java | 14 +-
.../common/entity/persistence/PersistenceLock.java | 128 +-
.../common/entity/persistence/PersistenceNode.java | 126 +-
.../entity/persistence/PersistenceNodeEntity.java | 132 +-
.../entity/persistence/PersistenceNodeMetrics.java | 164 +-
.../persistence/PersistenceNodeMetricsEntity.java | 146 +-
.../entity/persistence/PersistenceResource.java | 226 +-
.../common/entity/resource/CommonNodeResource.java | 312 +--
.../common/entity/resource/NodeResource.java | 40 +-
.../entity/resource/ResourceActionRecord.java | 154 +-
.../common/entity/resource/ResourceType.java | 18 +-
.../common/entity/resource/UserResource.java | 84 +-
.../manager/common/exception/RMErrorException.java | 20 +-
.../manager/common/exception/RMFatalException.java | 12 +-
.../manager/common/exception/RMWarnException.java | 12 +-
.../common/exception/ResourceWarnException.java | 13 +-
.../manager/common/protocol/bml/BmlResource.java | 138 +-
.../common/protocol/em/EMInfoClearRequest.java | 30 +-
.../manager/common/protocol/em/EMRequest.java | 2 +-
.../common/protocol/em/EMResourceClearRequest.java | 30 +-
.../common/protocol/em/GetEMEnginesRequest.java | 30 +-
.../common/protocol/em/GetEMInfoRequest.java | 30 +-
.../manager/common/protocol/em/PauseEMRequest.java | 30 +-
.../manager/common/protocol/em/StopEMRequest.java | 30 +-
.../common/protocol/engine/ECCanKillRequest.java | 110 +-
.../common/protocol/engine/ECCanKillResponse.java | 70 +-
.../common/protocol/engine/EngineAskRequest.java | 170 +-
.../protocol/engine/EngineConnReleaseRequest.java | 74 +-
.../protocol/engine/EngineCreateRequest.java | 188 +-
.../protocol/engine/EngineInfoClearRequest.java | 32 +-
.../common/protocol/engine/EngineLockType.java | 14 +-
.../protocol/engine/EngineRecyclingRequest.java | 30 +-
.../protocol/engine/EngineReourceClearRequest.java | 32 +-
.../common/protocol/engine/EngineRequest.java | 2 +-
.../common/protocol/engine/EngineReuseRequest.java | 106 +-
.../common/protocol/engine/EngineStopRequest.java | 68 +-
.../common/protocol/engine/EngineStopResponse.java | 38 +-
.../protocol/engine/EngineSuicideRequest.java | 76 +-
.../protocol/engine/EngineSwitchRequest.java | 8 +-
.../common/protocol/node/NodeHealthyRequest.java | 14 +-
.../common/protocol/node/NodeHeartbeatMsg.java | 109 +-
.../common/protocol/node/NodeHeartbeatRequest.java | 2 +-
.../protocol/node/NodeHeartbeatResourceMsg.java | 111 +-
.../common/protocol/node/RequestNodeStatus.java | 2 +-
.../common/protocol/node/ResponseNodeStatus.java | 14 +-
.../common/protocol/node/StopNodeRequest.java | 2 +-
.../protocol/yarn/YarnAuthorizationResponse.java | 36 +-
.../linkis/manager/common/utils/ManagerUtils.java | 34 +-
.../manager/common/conf/ManagerCommonConf.scala | 9 +-
.../manager/common/conf/RMConfiguration.scala | 49 +-
.../common/entity/recycle/RecyclingRule.scala | 15 +-
.../manager/common/entity/resource/Resource.scala | 547 +++--
.../manager/common/monitor/ManagerMonitor.scala | 13 +-
.../linkis/manager/common/operator/Operator.scala | 13 +-
.../manager/common/operator/OperatorFactory.scala | 15 +-
.../manager/common/protocol/EngineLock.scala | 20 +-
.../manager/common/protocol/OperateRequest.scala | 23 +-
.../manager/common/protocol/OperateResponse.scala | 3 +-
.../common/protocol/ServiceHealthReport.scala | 13 +-
.../manager/common/protocol/ServiceState.scala | 13 +-
.../common/protocol/em/ECMOperateRequest.scala | 14 +-
.../common/protocol/em/ECMOperateResponse.scala | 12 +-
.../protocol/em/EMResourceRegisterRequest.scala | 4 +-
.../common/protocol/em/RegisterEMRequest.scala | 9 +-
.../common/protocol/em/RegisterEMResponse.scala | 12 +-
.../protocol/engine/EngineAsyncResponse.scala | 19 +-
.../protocol/engine/EngineConnStatusCallback.scala | 30 +-
.../protocol/engine/EngineOperateRequest.scala | 15 +-
.../protocol/engine/EngineOperateResponse.scala | 10 +-
.../common/protocol/label/LabelUpdateRequest.scala | 12 +-
.../protocol/resource/ResourceProtocol.scala | 29 +-
.../protocol/resource/ResourceWithStatus.scala | 15 +-
.../common/serializer/NodeResourceSerializer.scala | 77 +-
.../serializer/RegisterEMRequestSerializer.scala | 65 +-
.../manager/common/utils/ResourceUtils.scala | 136 +-
.../linkis/manager/rm/ResourceManagerParam.scala | 18 +-
.../apache/linkis/manager/rm/ResultResource.scala | 29 +-
.../linkis-manager-persistence/pom.xml | 160 +-
.../manager/PersistenceSpringConfiguration.java | 160 +-
.../linkis/manager/dao/ECResourceRecordMapper.java | 22 +-
.../linkis/manager/dao/LabelManagerMapper.java | 346 +--
.../linkis/manager/dao/LockManagerMapper.java | 34 +-
.../linkis/manager/dao/NodeManagerMapper.java | 244 +-
.../manager/dao/NodeMetricManagerMapper.java | 131 +-
.../linkis/manager/dao/ResourceManagerMapper.java | 152 +-
.../org/apache/linkis/manager/entity/Tunple.java | 30 +-
.../exception/NodeInstanceDuplicateException.java | 6 +-
.../exception/NodeInstanceNotFoundException.java | 6 +-
.../exception/PersistenceErrorException.java | 14 +-
.../exception/PersistenceWarnException.java | 14 +-
.../persistence/LabelManagerPersistence.java | 115 +-
.../persistence/LockManagerPersistence.java | 6 +-
.../manager/persistence/ManagerPersistence.java | 10 +-
.../persistence/NodeManagerPersistence.java | 154 +-
.../persistence/NodeMetricManagerPersistence.java | 76 +-
.../persistence/ResourceLabelPersistence.java | 73 +-
.../persistence/ResourceManagerPersistence.java | 219 +-
.../impl/DefaultLabelManagerPersistence.java | 630 +++--
.../impl/DefaultLockManagerPersistence.java | 89 +-
.../impl/DefaultManagerPersistence.java | 121 +-
.../impl/DefaultNodeManagerPersistence.java | 436 ++--
.../impl/DefaultNodeMetricManagerPersistence.java | 267 +--
.../impl/DefaultResourceLabelPersistence.java | 280 ++-
.../impl/DefaultResourceManagerPersistence.java | 332 ++-
.../linkis/manager/util/PersistenceUtils.java | 99 +-
.../test/java/org/apache/linkis/manager/Scan.java | 20 +-
.../manager/persistence/PersistenceTest.java | 478 ++--
.../linkis-manager/pom.xml | 93 +-
linkis-computation-governance/pom.xml | 44 +-
linkis-dist/bin/install.sh | 2 +-
linkis-dist/docker/ldh.Dockerfile | 89 +
linkis-dist/docker/linkis.Dockerfile | 99 +
linkis-dist/docker/scripts/entry-point-ldh.sh | 53 +
linkis-dist/docker/scripts/prepare-ldh-image.sh | 76 +
linkis-dist/helm/README.md | 328 +++
.../helm/charts/linkis/.helmignore | 36 +-
linkis-dist/helm/charts/linkis/Chart.yaml | 39 +
.../helm/charts/linkis/templates/NOTES.txt | 26 +-
.../helm/charts/linkis/templates/_helpers.tpl | 393 +++
.../linkis/templates/configmap-init-sql.yaml | 1406 +++++++++++
.../linkis/templates/configmap-linkis-config.yaml | 321 +++
.../templates/configmap-linkis-web-config.yaml | 54 +
linkis-dist/helm/charts/linkis/templates/jobs.yaml | 52 +
.../templates/linkis-cg-engineconnmanager.yaml | 184 ++
.../linkis/templates/linkis-cg-engineplugin.yaml | 184 ++
.../linkis/templates/linkis-cg-entrance.yaml | 184 ++
.../linkis/templates/linkis-cg-linkismanager.yaml | 184 ++
.../charts/linkis/templates/linkis-mg-eureka.yaml | 168 ++
.../charts/linkis/templates/linkis-mg-gateway.yaml | 184 ++
.../helm/charts/linkis/templates/linkis-ps-cs.yaml | 184 ++
.../templates/linkis-ps-data-source-manager.yaml | 184 ++
.../linkis/templates/linkis-ps-metadataquery.yaml | 187 ++
.../linkis/templates/linkis-ps-publicservice.yaml | 184 ++
.../helm/charts/linkis/templates/linkis-web.yaml | 124 +
.../charts/linkis/templates/serviceaccount.yaml | 57 +
linkis-dist/helm/charts/linkis/values.yaml | 390 +++
.../helm/scripts/common.sh | 20 +-
linkis-dist/helm/scripts/create-kind-cluster.sh | 43 +
linkis-dist/helm/scripts/install-charts.sh | 46 +
.../helm/scripts/install-ldh.sh | 30 +-
.../helm/scripts/install-mysql.sh | 27 +-
.../helm/scripts/login-pod.sh | 24 +-
linkis-dist/helm/scripts/remote-debug-proxy.sh | 106 +
.../helm/scripts/resources/kind-cluster.yaml | 28 +-
.../resources/ldh/configmaps/configmap-flink.yaml | 562 +++++
.../resources/ldh/configmaps/configmap-hadoop.yaml | 659 ++++++
.../resources/ldh/configmaps/configmap-hive.yaml | 230 ++
.../resources/ldh/configmaps/configmap-spark.yaml | 208 ++
.../ldh/configmaps/configmap-zookeeper.yaml | 98 +
linkis-dist/helm/scripts/resources/ldh/ldh.yaml | 216 ++
linkis-dist/helm/scripts/resources/mysql.yaml | 57 +
linkis-dist/package/db/linkis_dml.sql | 1 +
linkis-dist/package/sbin/ext/linkis-common-start | 30 +-
linkis-dist/package/sbin/ext/linkis-mg-eureka | 33 +-
linkis-dist/package/sbin/ext/linkis-mg-gateway | 31 +-
linkis-dist/pom.xml | 522 ++--
linkis-engineconn-plugins/elasticsearch/pom.xml | 263 +--
.../ElasticSearchEngineConnPlugin.scala | 15 +-
...asticSearchProcessEngineConnLaunchBuilder.scala | 1 +
.../conf/ElasticSearchConfiguration.scala | 1 +
.../exception/EsConvertResponseException.scala | 3 +-
.../exception/EsEngineException.scala | 1 +
.../exception/EsParamsIllegalException.scala | 1 +
.../executer/ElasticSearchEngineConnExecutor.scala | 93 +-
.../executer/ElasticSearchExecutorOrder.scala | 3 +-
.../executer/client/ElasticSearchExecutor.scala | 10 +-
.../executer/client/ElasticSearchResponse.scala | 10 +-
.../elasticsearch/executer/client/EsClient.scala | 48 +-
.../executer/client/EsClientFactory.scala | 87 +-
.../executer/client/ResponseHandler.scala | 17 +-
.../client/impl/ElasticSearchExecutorImpl.scala | 81 +-
.../executer/client/impl/ResponseHandlerImpl.scala | 81 +-
.../factory/ElasticSearchEngineConnFactory.scala | 17 +-
.../factory/ElasticSearchJsonExecutorFactory.scala | 20 +-
.../factory/ElasticSearchSqlExecutorFactory.scala | 20 +-
linkis-engineconn-plugins/flink/pom.xml | 929 ++++----
.../flink/client/config/Environment.java | 518 ++--
.../flink/client/config/entries/ConfigEntry.java | 56 +-
.../client/config/entries/ExecutionEntry.java | 668 +++---
.../flink/client/context/ExecutionContext.java | 1262 +++++-----
.../deployment/ClusterDescriptorAdapter.java | 331 ++-
.../ClusterDescriptorAdapterFactory.java | 24 +-
.../YarnApplicationClusterDescriptorAdapter.java | 82 +-
.../YarnPerJobClusterDescriptorAdapter.java | 95 +-
.../factory/LinkisYarnClusterClientFactory.java | 120 +-
.../flink/client/result/AbstractResult.java | 38 +-
.../flink/client/result/BatchResult.java | 187 +-
.../flink/client/result/ChangelogResult.java | 398 ++--
.../flink/client/result/Result.java | 26 +-
.../flink/client/result/ResultUtil.java | 134 +-
.../flink/client/result/TypedResult.java | 94 +-
.../client/sql/operation/AbstractJobOperation.java | 198 +-
.../flink/client/sql/operation/JobOperation.java | 10 +-
.../flink/client/sql/operation/Operation.java | 4 +-
.../client/sql/operation/OperationFactory.java | 10 +-
.../client/sql/operation/OperationFactoryImpl.java | 190 +-
.../flink/client/sql/operation/OperationUtil.java | 78 +-
.../sql/operation/impl/CreateViewOperation.java | 62 +-
.../client/sql/operation/impl/DDLOperation.java | 108 +-
.../sql/operation/impl/DescribeTableOperation.java | 117 +-
.../sql/operation/impl/DropViewOperation.java | 78 +-
.../sql/operation/impl/ExplainOperation.java | 74 +-
.../client/sql/operation/impl/InsertOperation.java | 149 +-
.../client/sql/operation/impl/ResetOperation.java | 35 +-
.../client/sql/operation/impl/SelectOperation.java | 324 ++-
.../client/sql/operation/impl/SetOperation.java | 125 +-
.../sql/operation/impl/ShowCatalogsOperation.java | 22 +-
.../impl/ShowCurrentCatalogOperation.java | 22 +-
.../impl/ShowCurrentDatabaseOperation.java | 22 +-
.../sql/operation/impl/ShowDatabasesOperation.java | 22 +-
.../sql/operation/impl/ShowFunctionsOperation.java | 22 +-
.../sql/operation/impl/ShowModulesOperation.java | 22 +-
.../sql/operation/impl/ShowTablesOperation.java | 45 +-
.../sql/operation/impl/ShowViewsOperation.java | 48 +-
.../sql/operation/impl/UseCatalogOperation.java | 46 +-
.../sql/operation/impl/UseDatabaseOperation.java | 40 +-
.../client/sql/operation/result/ColumnInfo.java | 95 +-
.../client/sql/operation/result/ConstantNames.java | 44 +-
.../client/sql/operation/result/ResultKind.java | 8 +-
.../client/sql/operation/result/ResultSet.java | 246 +-
.../result/ResultSetJsonDeserializer.java | 254 +-
.../operation/result/ResultSetJsonSerializer.java | 128 +-
.../flink/client/sql/parser/SqlCommand.java | 112 +-
.../flink/client/sql/parser/SqlCommandCall.java | 52 +-
.../flink/client/sql/parser/SqlCommandParser.java | 32 +-
.../client/sql/parser/SqlCommandParserImpl.java | 374 ++-
.../flink/client/utils/YarnConfLoader.java | 76 +-
.../flink/exception/ExecutorInitException.java | 28 +-
.../flink/exception/FlinkInitFailedException.java | 18 +-
.../flink/exception/JobExecutionException.java | 18 +-
.../flink/exception/SqlExecutionException.java | 18 +-
.../flink/exception/SqlParseException.java | 18 +-
.../flink/FlinkEngineConnPlugin.scala | 21 +-
.../flink/config/FlinkEnvConfiguration.scala | 89 +-
.../flink/config/FlinkResourceConfiguration.scala | 22 +-
.../flink/context/EnvironmentContext.scala | 90 +-
.../flink/context/FlinkEngineConnContext.scala | 20 +-
.../flink/executor/FlinkCodeOnceExecutor.scala | 138 +-
.../flink/executor/FlinkExecutor.scala | 71 +-
.../flink/executor/FlinkJarOnceExecutor.scala | 30 +-
.../flink/executor/FlinkOnceExecutor.scala | 131 +-
.../executor/FlinkSQLComputationExecutor.scala | 231 +-
.../executormanager/FlinkExecutorManager.scala | 19 +-
.../factory/FlinkApplicationExecutorFactory.scala | 19 +-
.../flink/factory/FlinkCodeExecutorFactory.scala | 21 +-
.../flink/factory/FlinkEngineConnFactory.scala | 306 ++-
.../flink/factory/FlinkSQLExecutorFactory.scala | 34 +-
.../launch/FlinkEngineConnLaunchBuilder.scala | 62 +-
.../flink/listener/FlinkListener.scala | 22 +-
.../flink/listener/FlinkListenerGroup.scala | 29 +-
.../flink/operator/TriggerSavepointOperator.scala | 12 +-
.../linkis/engineconnplugin/flink/ql/Grammar.scala | 11 +-
.../engineconnplugin/flink/ql/GrammarFactory.scala | 11 +-
.../flink/ql/impl/CreateTableAsSelectGrammar.scala | 29 +-
.../resource/FlinkEngineConnResourceFactory.scala | 39 +-
.../flink/setting/HudiSettings.scala | 114 +-
.../engineconnplugin/flink/setting/Settings.scala | 22 +-
.../engineconnplugin/flink/util/ClassUtil.scala | 25 +-
.../flink/util/FlinkValueFormatUtil.scala | 11 +-
linkis-engineconn-plugins/hive/pom.xml | 724 +++---
.../linkis/engineplugin/hive/log/HiveProgress.java | 66 +-
.../hive/serde/CustomerDelimitedJSONSerDe.java | 615 +++--
.../engineplugin/hive/HiveEngineConnPlugin.scala | 35 +-
.../engineplugin/hive/common/HiveUtils.scala | 60 +-
.../linkis/engineplugin/hive/conf/Counters.scala | 2 +-
.../hive/conf/HiveEngineConfiguration.scala | 30 +-
.../hive/creation/HiveEngineConnFactory.scala | 80 +-
.../linkis/engineplugin/hive/cs/CSHiveHelper.scala | 18 +-
.../engineplugin/hive/entity/HiveSession.scala | 22 +-
.../exception/NotSupportedHiveTypeException.scala | 42 +-
.../hive/executor/HiveEngineConnExecutor.scala | 323 ++-
.../hive/hook/HiveAddJarsEngineHook.scala | 51 +-
.../hive/hook/HiveAddMetaTableNameHook.scala | 71 +-
.../HiveProcessEngineConnLaunchBuilder.scala | 18 +-
.../linkis/engineplugin/hive/log/LogHelper.scala | 43 +-
.../hive/progress/HiveProgressHelper.scala | 46 +-
linkis-engineconn-plugins/io_file/pom.xml | 261 +-
.../engineplugin/io/utils/ReflectionUtils.java | 12 +-
.../engineplugin/io/IoEngineConnPlugin.scala | 17 +-
.../builder/IoProcessEngineConnLaunchBuilder.scala | 11 +-
.../io/conf/IOEngineConnConfiguration.scala | 14 +-
.../manager/engineplugin/io/domain/FSInfo.scala | 17 +-
.../io/executor/IoEngineConnExecutor.scala | 309 ++-
.../io/factory/IoEngineConnFactory.scala | 27 +-
.../engineplugin/io/service/FsProxyService.scala | 23 +-
.../manager/engineplugin/io/utils/IOHelp.scala | 59 +-
linkis-engineconn-plugins/jdbc/pom.xml | 446 ++--
.../engineplugin/jdbc/ConnectionManager.java | 642 +++--
.../jdbc/JDBCDataSourceConfigurations.java | 68 +-
.../engineplugin/jdbc/JDBCPropertiesParser.java | 18 +-
.../manager/engineplugin/jdbc/JdbcAuthType.java | 38 +-
.../engineplugin/jdbc/PropertiesParser.java | 49 +-
.../jdbc/constant/JDBCEngineConnConstant.java | 104 +-
.../engineplugin/jdbc/monitor/ProgressMonitor.java | 92 +-
.../jdbc/monitor/impl/TrinoProgressMonitor.java | 98 +-
.../engineplugin/jdbc/JDBCEngineConnPlugin.scala | 17 +-
.../JDBCProcessEngineConnLaunchBuilder.scala | 8 +-
.../engineplugin/jdbc/conf/JDBCConfiguration.scala | 11 +-
.../exception/JDBCParamsIllegalException.scala | 14 +-
.../jdbc/executer/JDBCEngineConnExecutor.scala | 245 +-
.../jdbc/executer/JDBCMultiDatasourceParser.scala | 102 +-
.../jdbc/executer/JDBCSQLCodeParser.scala | 18 +-
.../jdbc/factory/JDBCEngineConnFactory.scala | 16 +-
.../engineplugin/jdbc/ConnectionManagerTest.java | 86 +-
.../engineplugin/jdbc/ProgressMonitorTest.java | 82 +-
.../executer/JDBCMultiDatasourceParserTest.scala | 28 +
.../TestJDBCEngineConnExecutor.scala | 136 +-
linkis-engineconn-plugins/openlookeng/pom.xml | 242 +-
.../builder/OpenLooKengProcessECLaunchBuilder.java | 8 +-
.../openlookeng/conf/OpenLooKengConfiguration.java | 48 +-
.../conf/OpenLooKengEngineConfCache.java | 26 +-
.../exception/OpenLooKengClientException.java | 6 +-
.../exception/OpenLooKengSourceGroupException.java | 6 +-
.../OpenLooKengStateInvalidException.java | 6 +-
.../executor/OpenLooKengEngineConnExecutor.java | 678 +++---
.../openlookeng/OpenLooKengECPlugin.scala | 17 +-
.../factory/OpenLooKengEngineConnFactory.scala | 15 +-
linkis-engineconn-plugins/pipeline/pom.xml | 263 +--
.../pipeline/PipelineEngineConnPlugin.scala | 17 +-
.../builder/PipelineEngineConnLaunchBuilder.scala | 12 +-
.../conf/PipelineEngineConfiguration.scala | 22 +-
.../pipeline/constant/PipeLineConstant.scala | 13 +-
.../pipeline/conversions/FsConvertions.scala | 15 +-
.../exception/PipeLineErrorException.scala | 12 +-
.../pipeline/executor/CSVExecutor.scala | 45 +-
.../pipeline/executor/CopyExecutor.scala | 20 +-
.../pipeline/executor/ExcelExecutor.scala | 51 +-
.../pipeline/executor/OutputStreamCache.scala | 8 +-
.../pipeline/executor/PipeLineExecutor.scala | 14 +-
.../executor/PipelineEngineConnExecutor.scala | 66 +-
.../executor/PipelineExecutorSelector.scala | 31 +-
.../factory/PipelineEngineConnFactory.scala | 18 +-
linkis-engineconn-plugins/pom.xml | 51 +-
linkis-engineconn-plugins/presto/pom.xml | 230 +-
.../presto/PrestoEngineConnPlugin.scala | 14 +-
.../PrestoProcessEngineConnLaunchBuilder.scala | 1 +
.../presto/conf/PrestoConfiguration.scala | 21 +-
.../presto/conf/PrestoEngineConf.scala | 20 +-
.../presto/exception/PrestoException.scala | 7 +-
.../presto/executer/PrestoEngineConnExecutor.scala | 207 +-
.../presto/factory/PrestoEngineConnFactory.scala | 9 +-
linkis-engineconn-plugins/python/pom.xml | 313 ++-
.../python/PythonEngineConnPlugin.scala | 25 +-
.../python/conf/PythonEngineConfiguration.scala | 23 +-
.../exception/NoSupportEngineException.scala | 13 +-
.../exception/PythonSessionNullException.scala | 23 +-
.../python/executor/PythonEngineConnExecutor.scala | 89 +-
.../python/executor/PythonSession.scala | 118 +-
.../python/factory/PythonEngineConnFactory.scala | 28 +-
.../python/hook/PythonVersionEngineHook.scala | 44 +-
.../PythonProcessEngineConnLaunchBuilder.scala | 13 +-
.../manager/engineplugin/python/utils/Kind.scala | 49 +-
.../manager/engineplugin/python/utils/State.scala | 12 +-
linkis-engineconn-plugins/shell/pom.xml | 341 ++-
.../engineplugin/shell/ShellEngineConnPlugin.scala | 18 +-
.../ShellProcessEngineConnLaunchBuilder.scala | 12 +-
.../shell/common/ShellEnginePluginConst.scala | 2 +-
.../shell/exception/NoCorrectUserException.scala | 14 +-
.../engineplugin/shell/executor/ReaderThread.scala | 22 +-
.../shell/executor/ShellEngineConnExecutor.scala | 181 +-
.../shell/executor/YarnAppIdExtractor.scala | 41 +-
.../shell/factory/ShellEngineConnFactory.scala | 18 +-
.../shell/TestShellEngineConnPlugin.scala | 7 +-
.../common/TestShellEngineConnPluginConst.scala | 10 +-
.../exception/TestNoCorrectUserException.scala | 6 +-
.../executor/TestShellEngineConnExecutor.scala | 20 +-
linkis-engineconn-plugins/spark/pom.xml | 815 ++++---
.../spark/Interpreter/Interpreter.scala | 12 +-
.../spark/Interpreter/ProcessInterpreter.scala | 53 +-
.../spark/Interpreter/PythonInterpreter.scala | 96 +-
.../engineplugin/spark/SparkEngineConnPlugin.scala | 17 +-
.../spark/args/SparkPythonArgsAppender.scala | 7 +-
.../args/SparkPythonArgsPreExecutionHook.scala | 107 +-
.../spark/args/SparkScalaPreExecutionHook.scala | 22 +-
.../linkis/engineplugin/spark/common/Kind.scala | 53 +-
.../spark/common/LineBufferedProcess.scala | 12 +-
.../spark/common/LineBufferedStream.scala | 37 +-
.../engineplugin/spark/common/LogContainer.scala | 21 +-
.../spark/common/SparkEnginePluginConst.scala | 2 +-
.../engineplugin/spark/common/SparkKind.scala | 45 +-
.../linkis/engineplugin/spark/common/State.scala | 15 +-
.../spark/config/SparkConfiguration.scala | 77 +-
.../spark/config/SparkResourceConfiguration.scala | 12 +-
.../engineplugin/spark/cs/CSSparkHelper.scala | 18 +-
.../spark/cs/CSSparkPostExecutionHook.scala | 29 +-
.../spark/cs/CSSparkPreExecutionHook.scala | 60 +-
.../engineplugin/spark/cs/CSTableParser.scala | 81 +-
.../spark/entity/SparkEngineSession.scala | 23 +-
.../ApplicationAlreadyStoppedException.scala | 16 +-
.../spark/exception/ExecuteError.scala | 14 +-
.../spark/exception/MDQErrorException.scala | 11 +-
.../spark/exception/NoSupportEngineException.scala | 17 +-
.../spark/exception/QueryFailedException.scala | 15 +-
.../spark/exception/RetryException.scala | 15 +-
.../spark/exception/SparkCreateFileException.scala | 12 +-
.../exception/SparkSessionNullException.scala | 13 +-
.../engineplugin/spark/executor/SQLSession.scala | 102 +-
.../spark/executor/SparkEngineConnExecutor.scala | 146 +-
.../spark/executor/SparkExecutorOrder.scala | 9 +-
.../spark/executor/SparkPythonExecutor.scala | 212 +-
.../spark/executor/SparkScalaExecutor.scala | 271 ++-
.../spark/executor/SparkSqlExecutor.scala | 60 +-
.../spark/extension/SparkPostExecutionHook.scala | 26 +-
.../spark/extension/SparkPreExecutionHook.scala | 18 +-
.../spark/extension/SparkSqlExtension.scala | 72 +-
.../spark/factory/SparkEngineConnFactory.scala | 113 +-
.../factory/SparkEngineConnResourceFactory.scala | 34 +-
.../spark/factory/SparkPythonExecutorFactory.scala | 23 +-
.../spark/factory/SparkScalaExecutorFactory.scala | 25 +-
.../spark/factory/SparkSqlExecutorFactory.scala | 25 +-
.../engineplugin/spark/imexport/CsvRelation.scala | 161 +-
.../engineplugin/spark/imexport/ExportData.scala | 65 +-
.../engineplugin/spark/imexport/LoadData.scala | 133 +-
.../imexport/util/BackGroundServiceUtils.scala | 30 +-
.../spark/imexport/util/ImExportUtils.scala | 19 +-
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 209 +-
.../spark/lineage/LineageSparkSqlExtension.scala | 21 +-
.../spark/lineage/SparkLineageUtils.scala | 14 +-
.../spark/mdq/MDQPostExecutionHook.scala | 36 +-
.../spark/mdq/MDQPreExecutionHook.scala | 43 +-
.../engineplugin/spark/metadata/HPOBuilder.scala | 98 +-
.../spark/metadata/MetaDataInfoTool.scala | 35 +-
.../spark/metadata/SparkHiveObject.scala | 24 +-
.../spark/metadata/SparkSQLHistoryParser.scala | 238 +-
.../engineplugin/spark/utils/EngineUtils.scala | 61 +-
.../engineplugin/spark/utils/JobProgressUtil.scala | 65 +-
.../org/apache/spark/sql/MethodInvokeHelper.scala | 12 +-
.../apache/spark/sql/SparkLogicalPlanHelper.scala | 18 +-
.../execution/datasources/csv/DolphinToSpark.scala | 47 +-
.../spark/sql/execution/datasources/csv/UDF.scala | 14 +-
.../scala/org/apache/spark/util/SparkUtils.scala | 24 +-
.../spark/extension/TestExecutionHooks.scala | 11 +-
.../spark/factory/TestSparkEngineConnFactory.scala | 7 +-
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 16 +-
linkis-engineconn-plugins/sqoop/pom.xml | 516 ++--
.../sqoop/client/LinkisSqoopClient.java | 370 ++-
.../engineconnplugin/sqoop/client/Sqoop.java | 901 ++++---
.../sqoop/client/config/ExecutionContext.java | 8 +-
.../sqoop/client/config/ParamsMapping.java | 232 +-
.../client/exception/JobClosableException.java | 18 +-
.../client/exception/JobExecutionException.java | 18 +-
.../sqoop/client/utils/JarLoader.java | 232 +-
.../java/org/apache/sqoop/mapreduce/JobBase.java | 656 ++---
.../sqoop/SqoopEngineConnPlugin.scala | 19 +-
.../sqoop/context/SqoopEngineConnContext.scala | 7 +-
.../sqoop/context/SqoopEnvConfiguration.scala | 15 +-
.../sqoop/context/SqoopParamsConfiguration.scala | 23 +-
.../sqoop/context/SqoopResourceConfiguration.scala | 10 +-
.../sqoop/executor/SqoopExecutor.scala | 20 +-
.../sqoop/executor/SqoopOnceCodeExecutor.scala | 137 +-
.../sqoop/executor/SqoopOnceExecutor.scala | 23 +-
.../sqoop/factory/SqoopEngineConnFactory.scala | 24 +-
.../sqoop/factory/SqoopExecutorFactory.scala | 15 +-
.../launch/SqoopEngineConnLaunchBuilder.scala | 68 +-
.../sqoop/params/SqoopParamsResolver.scala | 16 +-
.../resource/SqoopEngineConnResourceFactory.scala | 10 +-
.../engineconnplugin/sqoop/util/ClassUtil.scala | 19 +-
linkis-engineconn-plugins/trino/pom.xml | 211 +-
.../trino/src/main/assembly/distribution.xml | 144 +-
.../trino/interceptor/PasswordInterceptor.java | 51 +-
.../trino/password/CommandPasswordCallback.java | 75 +-
.../trino/password/StaticPasswordCallback.java | 27 +-
.../trino/socket/SocketChannelSocketFactory.java | 53 +-
.../main/resources/linkis-engineconn.properties | 1 -
.../trino/src/main/resources/log4j2.xml | 2 +-
.../engineplugin/trino/TrinoEngineConnPlugin.scala | 136 +-
.../TrinoProcessEngineConnLaunchBuilder.scala | 65 +-
.../trino/conf/TrinoConfiguration.scala | 127 +-
.../trino/conf/TrinoEngineConfig.scala | 85 +-
.../trino/exception/TrinoException.scala | 63 +-
.../trino/executor/TrinoEngineConnExecutor.scala | 936 ++++----
.../trino/factory/TrinoEngineConnFactory.scala | 84 +-
.../engineplugin/trino/utils/TrinoCode.scala | 97 +-
linkis-extensions/linkis-io-file-client/pom.xml | 95 +-
.../linkis/storage/io/client/DefaultIOClient.scala | 86 +-
.../apache/linkis/storage/io/client/IOClient.scala | 21 +-
.../linkis/storage/io/conf/IOFileClientConf.scala | 11 +-
.../io/iteraceptor/IOMethodInterceptor.scala | 194 +-
.../IOMethodInterceptorCreatorImpl.scala | 9 +-
.../IOComputationOrchestratorSessionFactory.scala | 124 +-
.../orchestrator/IOFileOrchestratorFactory.scala | 9 +-
.../io/orchestrator/IOTaskPlannerTransform.scala | 27 +-
.../IOUserParallelOrchestratorPlugin.scala | 17 +-
.../linkis/storage/io/utils/IOClientUtils.scala | 46 +-
linkis-extensions/pom.xml | 29 +-
.../linkis-code-orchestrator/pom.xml | 98 +-
.../orchestrator/code/plans/ast/CodeJob.scala | 17 +-
.../orchestrator/code/plans/ast/CodeStage.scala | 18 +-
.../plans/execution/CodeExecutionFactory.scala | 16 +-
.../execution/CodeReheaterNotifyTaskConsumer.scala | 18 +-
.../code/plans/logical/CacheTask.scala | 26 +-
.../code/plans/logical/CodeLogicalUnitTask.scala | 16 +-
.../plans/logical/CodeLogicalUnitTaskDesc.scala | 9 +-
.../linkis-computation-orchestrator/pom.xml | 122 +-
.../computation/utils/TaskTreeUtil.java | 72 +-
.../ComputationOrchestratorSessionFactory.scala | 36 +-
...ComputationOrchestratorSessionFactoryImpl.scala | 163 +-
.../converter/CodeConverterTransform.scala | 29 +-
.../converter/exception/CodeCheckException.scala | 19 +-
.../converter/exception/LimitCheckException.scala | 19 +-
.../exception/PythonCodeCheckException.scala | 26 +-
.../exception/SensitiveTablesCheckException.scala | 14 +-
.../exception/VarSubstitutionException.scala | 18 +-
.../converter/ruler/JobReqParamCheckRuler.scala | 29 +-
.../catalyst/optimizer/CacheTaskOptimizer.scala | 10 +-
.../optimizer/ConfigurationOptimizer.scala | 10 +-
.../catalyst/optimizer/PlaybackOptimizer.scala | 12 +-
.../catalyst/optimizer/SimplifyOptimizer.scala | 10 +-
.../catalyst/optimizer/YarnQueueOptimizer.scala | 12 +-
.../parser/DefaultCodeJobParserTransform.scala | 46 +-
.../parser/EnrichLabelParserTransform.scala | 27 +-
.../parser/label/CacheParserLabelFiller.scala | 10 +-
.../catalyst/parser/label/ParserLabelFiller.scala | 10 +-
.../physical/AbstractPhysicalTransform.scala | 160 +-
.../physical/ComputePhysicalTransform.scala | 53 +-
.../catalyst/planner/TaskPlannerTransform.scala | 104 +-
.../reheater/PruneTaskReheaterTransform.scala | 142 +-
.../validator/DefaultLabelRegularCheckRuler.scala | 14 +-
.../validator/LabelRegularCheckRuler.scala | 37 +-
.../validator/RouteLabelRegularCheckRuler.scala | 12 +-
.../conf/ComputationOrchestratorConf.scala | 48 +-
.../computation/entity/ComputationJobReq.scala | 40 +-
.../computation/execute/CodeExecTaskExecutor.scala | 25 +-
.../execute/CodeExecTaskExecutorManager.scala | 67 +-
.../DefaultCodeExecTaskExecutorManager.scala | 163 +-
.../computation/monitor/EngineConnMonitor.scala | 178 +-
.../computation/operation/log/LogEvent.scala | 12 +-
.../computation/operation/log/LogOperation.scala | 43 +-
.../computation/operation/log/LogProcessor.scala | 23 +-
.../progress/AbstractProgressOperation.scala | 43 +-
.../progress/DefaultProgressOperation.scala | 110 +-
.../operation/progress/ProgressInfoEvent.scala | 21 +-
.../operation/progress/ProgressProcessor.scala | 34 +-
.../operation/resource/ResourceReportEvent.scala | 8 +-
.../resource/ResourceReportOperation.scala | 35 +-
.../resource/ResourceReportProcessor.scala | 12 +-
.../computation/physical/CacheExecTask.scala | 103 +-
.../physical/CodeLogicalUnitExecTask.scala | 138 +-
.../service/ComputationTaskExecutionReceiver.scala | 201 +-
.../utils/ComputationOrchestratorUtils.scala | 8 +-
.../computation/utils/TreeNodeUtil.scala | 110 +-
.../linkis-orchestrator-core/pom.xml | 127 +-
.../apache/linkis/orchestrator/Orchestration.scala | 20 +-
.../apache/linkis/orchestrator/Orchestrator.scala | 29 +-
.../linkis/orchestrator/OrchestratorContext.scala | 15 +-
.../linkis/orchestrator/OrchestratorSession.scala | 17 +-
.../conf/OrchestratorConfiguration.scala | 65 +-
.../orchestrator/converter/ASTContextImpl.scala | 21 +-
.../orchestrator/converter/AbstractConverter.scala | 35 +-
.../linkis/orchestrator/converter/Converter.scala | 13 +-
.../orchestrator/converter/ConverterImpl.scala | 19 +-
.../orchestrator/core/AbstractOrchestration.scala | 119 +-
.../orchestrator/core/AbstractOrchestrator.scala | 26 +-
.../core/AbstractOrchestratorContext.scala | 21 +-
.../core/AbstractOrchestratorSession.scala | 19 +-
.../core/AbstractOrchestratorSessionBuilder.scala | 147 +-
.../orchestrator/core/AbstractSessionState.scala | 43 +-
.../linkis/orchestrator/core/CacheStrategy.scala | 21 +-
.../linkis/orchestrator/core/GlobalState.scala | 11 +-
.../linkis/orchestrator/core/MetricsSupport.scala | 13 +-
.../core/OrchestrationCacheManager.scala | 13 +-
.../orchestrator/core/OrchestrationFuture.scala | 13 +-
.../orchestrator/core/OrchestrationResponse.scala | 19 +-
.../orchestrator/core/OrchestratorPlugin.scala | 16 +-
.../core/OrchestratorSessionBuilder.scala | 28 +-
.../linkis/orchestrator/core/PlanBuilder.scala | 13 +-
.../linkis/orchestrator/core/SessionState.scala | 16 +-
.../orchestrator/core/impl/GlobalStateImpl.scala | 15 +-
.../orchestrator/core/impl/OrchestrationImpl.scala | 62 +-
.../core/impl/OrchestratorContextImpl.scala | 15 +-
.../orchestrator/core/impl/OrchestratorImpl.scala | 14 +-
.../core/impl/OrchestratorSessionBuilderImpl.scala | 35 +-
.../core/impl/OrchestratorSessionImpl.scala | 26 +-
.../orchestrator/core/impl/PlanBuilderImpl.scala | 21 +-
.../orchestrator/core/impl/SessionStateImpl.scala | 83 +-
.../core/impl/TableOrchestration.scala | 20 +-
.../apache/linkis/orchestrator/domain/JobReq.scala | 23 +-
.../apache/linkis/orchestrator/domain/Node.scala | 11 +-
.../linkis/orchestrator/domain/TreeNode.scala | 71 +-
.../linkis/orchestrator/domain/req/DataReq.scala | 15 +-
.../orchestrator/domain/req/DataViewReq.scala | 21 +-
.../orchestrator/domain/req/ResultSetReq.scala | 13 +-
.../exception/OrchestratorErrorCodeSummary.scala | 12 +-
.../exception/OrchestratorErrorException.scala | 29 +-
.../exception/OrchestratorRetryException.scala | 17 +-
.../orchestrator/execution/AbstractExecution.scala | 41 +-
.../orchestrator/execution/ExecTaskRunner.scala | 33 +-
.../linkis/orchestrator/execution/Execution.scala | 13 +-
.../orchestrator/execution/ExecutionFactory.scala | 35 +-
.../orchestrator/execution/ExecutionTask.scala | 13 +-
.../orchestrator/execution/TaskConsumer.scala | 13 +-
.../orchestrator/execution/TaskManager.scala | 13 +-
.../orchestrator/execution/TaskResponse.scala | 18 +-
.../orchestrator/execution/TaskScheduler.scala | 13 +-
.../execution/impl/AbstractExecutionFactory.scala | 26 +-
.../execution/impl/AbstractTaskManager.scala | 28 +-
.../execution/impl/BaseExecutionTask.scala | 47 +-
.../execution/impl/BaseTaskResponse.scala | 15 +-
.../execution/impl/BaseTaskScheduler.scala | 56 +-
.../execution/impl/DefaultFailedTaskResponse.scala | 17 +-
.../execution/impl/DefaultTaskManager.scala | 304 ++-
.../execution/impl/ExecutionImpl.scala | 61 +-
.../execution/impl/NotifyTaskConsumer.scala | 24 +-
.../execution/impl/UserRunningNumber.scala | 39 +-
.../execution/impl/UserTaskRunner.scala | 24 +-
.../execution/impl/UserTaskRunnerQueue.scala | 60 +-
.../extensions/CatalystExtensions.scala | 13 +-
.../extensions/CheckRulerExtensions.scala | 18 +-
.../orchestrator/extensions/Extensions.scala | 13 +-
.../extensions/OperationExtensions.scala | 13 +-
.../catalyst/CatalystExtensionsImpl.scala | 30 +-
.../extensions/catalyst/CheckRuler.scala | 17 +-
.../catalyst/CheckRulerExtensionsImpl.scala | 29 +-
.../extensions/catalyst/Transform.scala | 15 +-
.../extensions/catalyst/TransformFactory.scala | 81 +-
.../extensions/operation/CancelOperation.scala | 24 +-
.../extensions/operation/NotifyOperation.scala | 13 +-
.../extensions/operation/Operation.scala | 13 +-
.../operation/OperationExtensionsImpl.scala | 15 +-
.../listener/OrchestratorAsyncEvent.scala | 17 +-
.../listener/OrchestratorAsyncListener.scala | 11 +-
.../listener/OrchestratorAsyncListenerBus.scala | 37 +-
.../listener/OrchestratorListenerBusContext.scala | 24 +-
.../listener/OrchestratorSyncEvent.scala | 16 +-
.../listener/OrchestratorSyncListener.scala | 11 +-
.../listener/OrchestratorSyncListenerBus.scala | 29 +-
.../execution/ExecTaskRunnerCompletedEvent.scala | 15 +-
.../execution/ExecutionTaskCompletedListener.scala | 17 +-
.../listener/execution/ExecutionTaskEvent.scala | 23 +-
.../execution/ExecutionTaskStatusListener.scala | 14 +-
.../listener/task/OrchestrationKillListener.scala | 13 +-
.../listener/task/ResourceReportListener.scala | 6 +-
.../listener/task/RootTaskResponseListener.scala | 15 +-
.../orchestrator/listener/task/TaskInfoEvent.scala | 71 +-
.../listener/task/TaskLogListener.scala | 12 +-
.../listener/task/TaskProgressListener.scala | 8 +-
.../listener/task/TaskResultSetListener.scala | 13 +-
.../listener/task/TaskStatusListener.scala | 14 +-
.../linkis/orchestrator/log/LogManager.scala | 17 +-
.../orchestrator/optimizer/AbstractOptimizer.scala | 71 +-
.../linkis/orchestrator/optimizer/Optimizer.scala | 11 +-
.../orchestrator/optimizer/OptimizerImpl.scala | 24 +-
.../orchestrator/parser/AbstractParser.scala | 52 +-
.../apache/linkis/orchestrator/parser/Parser.scala | 11 +-
.../linkis/orchestrator/parser/ParserImpl.scala | 12 +-
.../orchestrator/planner/AbstractPlanner.scala | 52 +-
.../linkis/orchestrator/planner/Planner.scala | 11 +-
.../linkis/orchestrator/planner/PlannerImpl.scala | 12 +-
.../planner/command/ExplainCommandDesc.scala | 14 +-
.../linkis/orchestrator/plans/PlanContext.scala | 21 +-
.../linkis/orchestrator/plans/ast/ASTContext.scala | 14 +-
.../orchestrator/plans/ast/ASTOrchestration.scala | 13 +-
.../orchestrator/plans/ast/AbstractJob.scala | 13 +-
.../orchestrator/plans/ast/AbstractStage.scala | 8 +-
.../apache/linkis/orchestrator/plans/ast/Job.scala | 23 +-
.../orchestrator/plans/ast/QueryParams.scala | 25 +-
.../orchestrator/plans/ast/RuntimeParams.scala | 44 +-
.../linkis/orchestrator/plans/ast/Stage.scala | 11 +-
.../orchestrator/plans/ast/StartupParams.scala | 19 +-
.../orchestrator/plans/logical/AbstractTask.scala | 13 +-
.../orchestrator/plans/logical/CommandDesc.scala | 13 +-
.../orchestrator/plans/logical/CommandTask.scala | 17 +-
.../orchestrator/plans/logical/JobTask.scala | 32 +-
.../plans/logical/LogicalContext.scala | 11 +-
.../plans/logical/LogicalContextImpl.scala | 22 +-
.../plans/logical/LogicalOrchestration.scala | 17 +-
.../linkis/orchestrator/plans/logical/Origin.scala | 27 +-
.../orchestrator/plans/logical/StageTask.scala | 33 +-
.../linkis/orchestrator/plans/logical/Task.scala | 13 +-
.../orchestrator/plans/logical/TaskDesc.scala | 11 +-
.../plans/physical/AbstractExecTask.scala | 22 +-
.../orchestrator/plans/physical/CommandExec.scala | 16 +-
.../orchestrator/plans/physical/ExecTask.scala | 13 +-
.../orchestrator/plans/physical/JobExecTask.scala | 35 +-
.../plans/physical/PhysicalContext.scala | 19 +-
.../plans/physical/PhysicalContextImpl.scala | 52 +-
.../plans/physical/PhysicalOrchestration.scala | 15 +-
.../plans/physical/ReheatableExecTask.scala | 11 +-
.../plans/physical/RetryExecTask.scala | 58 +-
.../plans/physical/StageExecTask.scala | 23 +-
.../orchestrator/plans/unit/CodeLogicalUnit.scala | 41 +-
.../plans/unit/LambdaLogicalUnit.scala | 19 +-
.../orchestrator/plans/unit/LogicalUnit.scala | 11 +-
.../plugin/UserParallelOrchestratorPlugin.scala | 8 +-
.../orchestrator/reheater/AbstractReheater.scala | 25 +-
.../linkis/orchestrator/reheater/Reheater.scala | 11 +-
.../orchestrator/reheater/ReheaterImpl.scala | 12 +-
.../reheater/ReheaterNotifyTaskConsumer.scala | 43 +-
.../strategy/DefaultExecTaskRunnerFactory.scala | 20 +-
.../orchestrator/strategy/ExecTaskStatusInfo.scala | 12 +-
.../strategy/GatherStrategyJobExecTask.scala | 43 +-
.../strategy/GatherStrategyStageInfoExecTask.scala | 48 +-
.../orchestrator/strategy/ResultSetExecTask.scala | 54 +-
.../orchestrator/strategy/StatusInfoExecTask.scala | 71 +-
.../strategy/async/AsyncExecTask.scala | 14 +-
.../strategy/async/AsyncExecTaskRunner.scala | 16 +-
.../strategy/async/AsyncExecTaskRunnerImpl.scala | 85 +-
.../strategy/async/AsyncTaskManager.scala | 30 +-
.../orchestrator/utils/OrchestratorIDCreator.scala | 34 +-
.../linkis/orchestrator/utils/TreeOperator.scala | 22 +-
.../orchestrator/validator/AbstractValidator.scala | 13 +-
.../linkis/orchestrator/validator/Validator.scala | 11 +-
.../orchestrator/validator/ValidatorImpl.scala | 12 +-
.../linkis/orchestrator/OrchestratorSuite.scala | 15 +-
.../plugin/linkis-orchestrator-ecm-plugin/pom.xml | 122 +-
.../linkis/orchestrator/ecm/entity/Policy.java | 10 +-
.../ecm/ComputationEngineConnManager.scala | 138 +-
.../orchestrator/ecm/EngineConnManager.scala | 132 +-
.../ecm/EngineConnManagerBuilder.scala | 29 +-
.../ecm/LoadBalanceLabelEngineConnManager.scala | 99 +-
.../ecm/cache/EngineAsyncResponseCache.scala | 104 +-
.../orchestrator/ecm/conf/ECMPluginConf.scala | 22 +-
.../linkis/orchestrator/ecm/entity/Mark.scala | 19 +-
.../linkis/orchestrator/ecm/entity/MarkReq.scala | 71 +-
.../ecm/exception/ECMPluginErrorException.scala | 15 +-
.../ecm/service/EngineAsyncResponseService.scala | 12 +-
.../ecm/service/EngineConnExecutor.scala | 24 +-
.../ecm/service/TaskExecutionReceiver.scala | 16 +-
.../impl/ComputationEngineConnExecutor.scala | 80 +-
.../impl/DefaultEngineAsyncResponseService.scala | 31 +-
.../linkis/orchestrator/ecm/utils/ECMPUtils.scala | 17 +-
linkis-orchestrator/pom.xml | 35 +-
.../linkis-bml/linkis-bml-client/pom.xml | 123 +-
.../linkis/bml/client/AbstractBmlClient.java | 14 +-
.../org/apache/linkis/bml/client/BmlClient.java | 214 +-
.../apache/linkis/bml/client/BmlClientFactory.java | 24 +-
.../linkis/bml/client/impl/HttpBmlClient.scala | 630 +++--
.../bml/common/POSTActionFailException.scala | 41 +-
.../apache/linkis/bml/conf/BmlConfiguration.scala | 35 +-
.../org/apache/linkis/bml/http/HttpConf.scala | 33 +-
.../apache/linkis/bml/request/BmlPOSTAction.scala | 196 +-
.../org/apache/linkis/bml/response/BmlResult.scala | 132 +-
.../linkis-bml/linkis-bml-common/pom.xml | 76 +-
.../apache/linkis/bml/model/AbstractAuditable.java | 80 +-
.../apache/linkis/bml/protocol/BmlProtocol.scala | 95 +-
.../linkis-bml/linkis-bml-server/pom.xml | 211 +-
.../apache/linkis/bml/LinkisBMLApplication.java | 6 +-
.../org/apache/linkis/bml/common/Constant.java | 22 +-
.../apache/linkis/bml/common/ExecutorManager.java | 176 +-
.../linkis/bml/common/HdfsResourceHelper.java | 258 +-
.../linkis/bml/common/LocalResourceHelper.java | 260 +-
.../apache/linkis/bml/common/OperationEnum.java | 66 +-
.../apache/linkis/bml/common/ResourceHelper.java | 38 +-
.../linkis/bml/common/ResourceHelperFactory.java | 25 +-
.../apache/linkis/bml/common/ScheduledTask.java | 47 +-
.../org/apache/linkis/bml/dao/BmlProjectDao.java | 112 +-
.../org/apache/linkis/bml/dao/DownloadDao.java | 2 +-
.../org/apache/linkis/bml/dao/ResourceDao.java | 32 +-
.../java/org/apache/linkis/bml/dao/TaskDao.java | 76 +-
.../java/org/apache/linkis/bml/dao/VersionDao.java | 99 +-
.../org/apache/linkis/bml/entity/BmlProject.java | 144 +-
.../apache/linkis/bml/entity/DownloadModel.java | 214 +-
.../org/apache/linkis/bml/entity/Resource.java | 385 ++-
.../org/apache/linkis/bml/entity/ResourceTask.java | 666 +++---
.../apache/linkis/bml/entity/ResourceVersion.java | 340 +--
.../java/org/apache/linkis/bml/entity/Version.java | 28 +-
.../apache/linkis/bml/restful/RestfulUtils.java | 115 +-
.../linkis/bml/service/BmlProjectService.java | 30 +-
.../bml/service/BmlShareResourceService.java | 20 +-
.../apache/linkis/bml/service/DownloadService.java | 2 +-
.../apache/linkis/bml/service/ResourceService.java | 41 +-
.../org/apache/linkis/bml/service/TaskService.java | 64 +-
.../apache/linkis/bml/service/VersionService.java | 84 +-
.../bml/service/impl/BmlProjectServiceImpl.java | 247 +-
.../linkis/bml/service/impl/BmlServiceImpl.java | 2 +-
.../service/impl/BmlShareResourceServiceImpl.java | 26 +-
.../bml/service/impl/DownloadServiceImpl.java | 10 +-
.../bml/service/impl/ResourceServiceImpl.java | 270 ++-
.../linkis/bml/service/impl/TaskServiceImpl.java | 663 +++---
.../bml/service/impl/VersionServiceImpl.java | 347 ++-
.../org/apache/linkis/bml/threading/TaskState.java | 80 +-
.../apache/linkis/bml/util/HttpRequestHelper.java | 34 +-
.../java/org/apache/linkis/bml/util/MD5Utils.java | 86 +-
.../org/apache/linkis/bml/vo/ResourceBasicVO.java | 126 +-
.../java/org/apache/linkis/bml/vo/ResourceVO.java | 72 +-
.../apache/linkis/bml/vo/ResourceVersionsVO.java | 58 +-
.../linkis/bml/common/BmlAuthorityException.scala | 21 +-
.../bml/common/BmlPermissionDeniedException.scala | 13 +-
.../linkis/bml/common/BmlQueryFailException.scala | 10 +-
.../bml/common/BmlResourceExpiredException.scala | 11 +-
.../bml/common/BmlServerParaErrorException.scala | 10 +-
.../linkis/bml/conf/BmlServerConfiguration.scala | 21 +-
.../linkis/bml/protocol/BmlServerProtocol.scala | 15 +-
.../org/apache/linkis/bml/rpc/BmlReceiver.scala | 13 +-
.../apache/linkis/bml/WebApplicationServer.java | 6 +-
.../linkis/bml/common/HdfsResourceHelperTest.java | 16 +-
.../linkis/bml/common/LocalResourceHelperTest.java | 18 +-
.../linkis/bml/common/VersionServiceImplTest.java | 36 +-
.../apache/linkis/bml/dao/BmlProjectDaoTest.java | 148 +-
.../org/apache/linkis/bml/dao/DownloadDaoTest.java | 34 +-
.../org/apache/linkis/bml/dao/ResourceDaoTest.java | 142 +-
.../org/apache/linkis/bml/dao/TaskDaoTest.java | 74 +-
.../org/apache/linkis/bml/dao/VersionDaoTest.java | 330 +--
.../linkis/bml/service/BmlProjectServiceTest.java | 256 +-
.../bml/service/DownloadServiceImplTest.java | 40 +-
.../bml/service/ResourceServiceImplTest.java | 241 +-
.../linkis/bml/service/TaskServiceImplTest.java | 240 +-
.../linkis/bml/service/VersionServiceImplTest.java | 323 ++-
linkis-public-enhancements/linkis-bml/pom.xml | 36 +-
.../linkis-cs-client/pom.xml | 123 +-
.../java/org/apache/linkis/cs/client/Context.java | 120 +-
.../org/apache/linkis/cs/client/ContextClient.java | 260 +-
.../linkis/cs/client/LinkisWorkFlowContext.java | 226 +-
.../cs/client/builder/ContextClientFactory.java | 20 +-
.../cs/client/builder/HttpContextClientConfig.java | 58 +-
.../cs/client/http/ContextPostActionBuilder.java | 104 +-
.../linkis/cs/client/http/HttpContextClient.java | 1653 +++++++------
.../linkis/cs/client/http/HttpHeartBeater.java | 186 +-
.../cs/client/listener/ContextClientListener.java | 6 +-
.../client/listener/ContextClientListenerBus.java | 24 +-
.../listener/ContextClientListenerManager.java | 19 +-
.../cs/client/listener/ContextIDListener.java | 84 +-
.../cs/client/listener/ContextKeyListener.java | 80 +-
.../linkis/cs/client/listener/HeartBeater.java | 8 +-
.../cs/client/service/CSMetaDataService.java | 62 +-
.../linkis/cs/client/service/CSNodeService.java | 2 +-
.../cs/client/service/CSNodeServiceImpl.java | 44 +-
.../cs/client/service/CSResourceService.java | 107 +-
.../cs/client/service/CSResultDataService.java | 10 +-
.../cs/client/service/CSResultDataServiceImpl.java | 172 +-
.../linkis/cs/client/service/CSTableService.java | 364 ++-
.../cs/client/service/CSVariableService.java | 123 +-
.../linkis/cs/client/service/CSWorkService.java | 6 +-
.../cs/client/service/CSWorkServiceImpl.java | 122 +-
.../service/ContextHistoryClientService.java | 2 +-
.../service/ContextHistoryClientServiceImpl.java | 48 +-
.../cs/client/service/DefaultSearchService.java | 311 ++-
.../cs/client/service/LinkisJobDataService.java | 6 +-
.../client/service/LinkisJobDataServiceImpl.java | 138 +-
.../linkis/cs/client/service/MetaDataService.java | 20 +-
.../linkis/cs/client/service/ResourceService.java | 22 +-
.../linkis/cs/client/service/SearchService.java | 58 +-
.../linkis/cs/client/service/TableService.java | 65 +-
.../linkis/cs/client/service/VariableService.java | 8 +-
.../cs/client/utils/ContextServiceUtils.java | 278 ++-
.../linkis/cs/client/utils/ExceptionHelper.java | 12 +-
.../linkis/cs/client/utils/SerializeHelper.java | 71 +-
.../exception/ProtocolNotMatchException.scala | 11 +-
.../linkis/cs/client/http/ContextAction.scala | 48 +-
.../linkis/cs/client/http/ContextResult.scala | 74 +-
.../linkis/cs/client/utils/ContextClientConf.scala | 28 +-
.../cs/client/utils/ContextClientUtils.scala | 33 +-
.../cs/client/utils/ContextServerHttpConf.scala | 15 +-
.../org/apache/linkis/cs/client/test/Test.java | 162 +-
.../cs/client/test/bean/ClientTestContextKey.java | 62 +-
.../client/test/bean/ClientTestContextValue.java | 36 +-
.../cs/client/test/bean/ResourceValueBean.java | 30 +-
.../test/listener/CommonContextKeyListener.java | 26 +-
.../client/test/no_context_search/TestClear.java | 50 +-
.../linkis/cs/client/test/restful/RestfulTest.java | 224 +-
.../linkis/cs/client/test/service/TestInfo.java | 96 +-
.../linkis/cs/client/test/service/TestRemove.java | 142 +-
.../cs/client/test/service/TestSearchService.java | 139 +-
.../test/test_multiuser/TestChangeContext.java | 134 +-
.../test/test_multiuser/TestCreateContext.java | 149 +-
.../linkis-cs-common/pom.xml | 93 +-
.../linkis/cs/common/annotation/KeywordMethod.java | 4 +-
.../linkis/cs/common/entity/data/CSResultData.java | 14 +-
.../apache/linkis/cs/common/entity/data/Data.java | 4 +-
.../linkis/cs/common/entity/data/JobData.java | 4 +-
.../cs/common/entity/data/LinkisJobData.java | 18 +-
.../cs/common/entity/enumeration/ContextScope.java | 10 +-
.../cs/common/entity/enumeration/ContextType.java | 18 +-
.../cs/common/entity/enumeration/DBType.java | 12 +-
.../cs/common/entity/enumeration/ExpireType.java | 22 +-
.../cs/common/entity/enumeration/WorkType.java | 8 +-
.../apache/linkis/cs/common/entity/env/OSEnv.java | 4 +-
.../linkis/cs/common/entity/env/SoftWareEnv.java | 4 +-
.../cs/common/entity/env/SoftwareLibEnv.java | 4 +-
.../entity/history/AbstractContextHistory.java | 36 +-
.../entity/history/CommonResourceHistory.java | 20 +-
.../cs/common/entity/history/ContextHistory.java | 12 +-
.../entity/history/ContextHistoryIndexer.java | 2 +-
.../common/entity/history/EnvContextHistory.java | 4 +-
.../history/GlobalPropertyContextHistory.java | 4 +-
.../entity/history/KeywordContextHistroy.java | 4 +-
.../entity/history/ResourceContextHistory.java | 20 +-
.../history/metadata/CSTableLineageHistory.java | 28 +-
.../metadata/CSTableMetadataContextHistory.java | 28 +-
.../history/metadata/DBMetadataContextHistory.java | 4 +-
.../history/metadata/MetadataContextHistory.java | 12 +-
.../history/metadata/TableLineageHistory.java | 4 +-
.../history/metadata/TableOperationType.java | 8 +-
.../listener/CommonContextIDListenerDomain.java | 36 +-
.../listener/CommonContextKeyListenerDomain.java | 50 +-
.../entity/listener/ContextIDListenerDomain.java | 4 +-
.../entity/listener/ContextKeyListenerDomain.java | 4 +-
.../cs/common/entity/listener/ListenerDomain.java | 4 +-
.../linkis/cs/common/entity/metadata/CSColumn.java | 178 +-
.../linkis/cs/common/entity/metadata/CSDB.java | 130 +-
.../cs/common/entity/metadata/CSPartition.java | 196 +-
.../linkis/cs/common/entity/metadata/CSTable.java | 448 ++--
.../linkis/cs/common/entity/metadata/Column.java | 32 +-
.../linkis/cs/common/entity/metadata/DB.java | 20 +-
.../cs/common/entity/metadata/Partition.java | 32 +-
.../linkis/cs/common/entity/metadata/Table.java | 76 +-
.../cs/common/entity/object/CSFlowInfos.java | 18 +-
.../linkis/cs/common/entity/object/CSInfos.java | 4 +-
.../linkis/cs/common/entity/object/CSProperty.java | 8 +-
.../cs/common/entity/object/CommonProperty.java | 48 +-
.../cs/common/entity/resource/BMLResource.java | 64 +-
.../common/entity/resource/CommonFxResource.java | 292 +--
.../common/entity/resource/CommonUDFResource.java | 292 +--
.../cs/common/entity/resource/FxResource.java | 52 +-
.../common/entity/resource/LinkisBMLResource.java | 322 +--
.../cs/common/entity/resource/UDFResource.java | 52 +-
.../entity/source/CombinedNodeIDContextID.java | 70 +-
.../cs/common/entity/source/CommonContextID.java | 42 +-
.../cs/common/entity/source/CommonContextKey.java | 84 +-
.../entity/source/CommonContextKeyValue.java | 46 +-
.../common/entity/source/CommonContextValue.java | 36 +-
.../cs/common/entity/source/CommonHAContextID.java | 82 +-
.../linkis/cs/common/entity/source/ContextID.java | 12 +-
.../cs/common/entity/source/ContextIDParser.java | 2 +-
.../linkis/cs/common/entity/source/ContextKey.java | 32 +-
.../cs/common/entity/source/ContextKeyValue.java | 8 +-
.../cs/common/entity/source/ContextValue.java | 8 +-
.../cs/common/entity/source/CreatorContextKey.java | 4 +-
.../cs/common/entity/source/HAContextID.java | 10 +-
.../entity/source/LinkisHAWorkFlowContextID.java | 56 +-
.../entity/source/LinkisWorkflowContextID.java | 152 +-
.../cs/common/entity/source/OrderContextKey.java | 4 +-
.../cs/common/entity/source/UserContextID.java | 4 +-
.../linkis/cs/common/entity/source/ValueBean.java | 4 +-
.../cs/common/entity/source/VersionContextKey.java | 4 +-
.../cs/common/entity/source/WorkflowContextID.java | 20 +-
.../cs/common/entity/source/YMLContextKey.java | 6 +-
.../cs/common/exception/CSErrorException.java | 14 +-
.../cs/common/exception/CSWarnException.java | 14 +-
.../linkis/cs/common/exception/ErrorCode.java | 28 +-
.../cs/common/listener/ContextIDListener.java | 6 +-
.../cs/common/listener/ContextKeyListener.java | 6 +-
.../cs/common/protocol/ContextHTTPConstant.java | 22 +-
.../cs/common/protocol/ContextHistoryType.java | 40 +-
.../linkis/cs/common/protocol/ContextIDType.java | 72 +-
.../linkis/cs/common/protocol/ContextKeyType.java | 40 +-
.../cs/common/protocol/ContextKeyValueType.java | 40 +-
.../cs/common/protocol/ContextValueType.java | 40 +-
.../search/ContextSearchConditionMapBuilder.java | 325 ++-
.../cs/common/serialize/AbstractSerializer.java | 78 +-
.../cs/common/serialize/ContextSerializer.java | 12 +-
.../helper/AbstractSerializationHelper.java | 115 +-
.../helper/ContextSerializationHelper.java | 103 +-
.../serialize/helper/SerializationHelper.java | 10 +-
.../context/CombinedNodeIDContextIDSerializer.java | 28 +-
.../impl/context/CommonContextKeySerializer.java | 28 +-
.../impl/context/ContextKeyValueSerializer.java | 88 +-
.../impl/context/ContextValueSerializer.java | 88 +-
.../LinkisHAWorkFlowContextIDSerializer.java | 31 +-
.../impl/history/CommonHistorySerializer.java | 36 +-
.../history/CommonResourceHistorySerializer.java | 52 +-
.../history/metadata/CSTableLineageSerializer.java | 67 +-
.../metadata/CSTableMetadataHistorySerializer.java | 63 +-
.../impl/value/LinkisBMLResourceSerializer.java | 28 +-
.../impl/value/data/CSResultDataSerializer.java | 28 +-
.../impl/value/data/LinkisJobDataSerializer.java | 28 +-
.../impl/value/metadata/CSTableSerializer.java | 28 +-
.../impl/value/object/CSFlowInfosSerializer.java | 28 +-
.../value/object/LinkisVariableSerializer.java | 28 +-
.../linkis/cs/common/utils/CSCommonUtils.java | 88 +-
.../cs/common/utils/CSHighAvailableUtils.java | 230 +-
.../test/ContextSerializationHelperTest.java | 293 ++-
.../linkis-cs-listener/pom.xml | 93 +-
.../apache/linkis/cs/listener/CSIDListener.java | 6 +-
.../apache/linkis/cs/listener/CSKeyListener.java | 8 +-
.../cs/listener/ContextAsyncEventListener.java | 2 +-
.../ListenerBus/ContextAsyncListenerBus.java | 44 +-
.../listener/callback/AbstractCallbackEngine.java | 6 +-
.../cs/listener/callback/CallbackEngine.java | 8 +-
.../listener/callback/ContextIDCallbackEngine.java | 2 +-
.../callback/ContextKeyCallbackEngine.java | 2 +-
.../listener/callback/imp/ContextKeyValueBean.java | 70 +-
.../imp/DefaultContextIDCallbackEngine.java | 224 +-
.../imp/DefaultContextKeyCallbackEngine.java | 259 +-
.../cs/listener/conf/ContextListenerConf.java | 21 +-
.../linkis/cs/listener/event/ContextIDEvent.java | 2 +-
.../cs/listener/event/enumeration/OperateType.java | 16 +-
.../listener/event/impl/DefaultContextIDEvent.java | 32 +-
.../event/impl/DefaultContextKeyEvent.java | 56 +-
.../cs/listener/manager/ListenerManager.java | 6 +-
.../manager/imp/DefaultContextListenerManager.java | 62 +-
.../linkis/cs/listener/test/TestContextID.java | 18 +-
.../linkis/cs/listener/test/TestContextKey.java | 72 +-
.../cs/listener/test/TestContextKeyValue.java | 36 +-
.../linkis/cs/listener/test/TestContextValue.java | 32 +-
.../linkis-cs-server/pom.xml | 262 +-
.../java/org/apache/linkis/cs/ContextSearch.java | 16 +-
.../org/apache/linkis/cs/DefaultContextSearch.java | 101 +-
.../cs/condition/AbstractCommonCondition.java | 24 +-
.../linkis/cs/condition/BinaryLogicCondition.java | 58 +-
.../org/apache/linkis/cs/condition/Condition.java | 8 +-
.../apache/linkis/cs/condition/ConditionType.java | 8 +-
.../linkis/cs/condition/UnaryLogicCondition.java | 20 +-
.../condition/construction/AndConditionParser.java | 23 +-
.../condition/construction/ConditionBuilder.java | 16 +-
.../construction/ConditionBuilderImpl.java | 118 +-
.../cs/condition/construction/ConditionParser.java | 50 +-
.../construction/ContainsConditionParser.java | 16 +-
.../construction/ContextScopeConditionParser.java | 18 +-
.../construction/ContextTypeConditionParser.java | 17 +-
.../ContextValueTypeConditionParser.java | 34 +-
.../construction/NearestConditionParser.java | 26 +-
.../condition/construction/NotConditionParser.java | 18 +-
.../condition/construction/OrConditionParser.java | 23 +-
.../construction/RegexConditionParser.java | 16 +-
.../linkis/cs/condition/impl/AndCondition.java | 14 +-
.../cs/condition/impl/ContainsCondition.java | 28 +-
.../cs/condition/impl/ContextScopeCondition.java | 28 +-
.../cs/condition/impl/ContextTypeCondition.java | 28 +-
.../condition/impl/ContextValueTypeCondition.java | 28 +-
.../linkis/cs/condition/impl/NearestCondition.java | 64 +-
.../linkis/cs/condition/impl/NotCondition.java | 14 +-
.../linkis/cs/condition/impl/OrCondition.java | 14 +-
.../linkis/cs/condition/impl/RegexCondition.java | 28 +-
.../cs/contextcache/ContextCacheService.java | 29 +-
.../contextcache/DefaultContextCacheService.java | 452 ++--
.../linkis/cs/contextcache/cache/ContextCache.java | 16 +-
.../cache/DefaultContextAddListener.java | 71 +-
.../cs/contextcache/cache/DefaultContextCache.java | 295 ++-
.../cs/contextcache/cache/csid/ContextIDValue.java | 8 +-
.../cache/csid/ContextIDValueGenerator.java | 2 +-
.../csid/impl/ContextIDValueGeneratorImpl.java | 134 +-
.../cache/csid/impl/ContextIDValueImpl.java | 148 +-
.../cache/cskey/ContextKeyValueContext.java | 34 +-
.../cache/cskey/ContextValueMapSet.java | 24 +-
.../cache/cskey/impl/ContextValueMapSetImpl.java | 249 +-
.../cskey/impl/DefaultContextKeyValueContext.java | 350 ++-
.../cache/guava/ContextIDRemoveListener.java | 38 +-
.../cs/contextcache/cleaner/AUTOCleaner.java | 2 +-
.../cs/contextcache/conf/ContextCacheConf.java | 21 +-
.../contextcache/index/ContextInvertedIndex.java | 8 +-
.../index/ContextInvertedIndexSet.java | 14 +-
.../index/ContextInvertedIndexSetImpl.java | 84 +-
.../index/DefaultContextInvertedIndex.java | 56 +-
.../cs/contextcache/metric/ClassIntrospector.java | 363 ++-
.../cs/contextcache/metric/ContextCacheMetric.java | 12 +-
.../cs/contextcache/metric/ContextIDMetric.java | 14 +-
.../metric/DefaultContextCacheMetric.java | 66 +-
.../metric/DefaultContextIDMetric.java | 68 +-
.../linkis/cs/contextcache/metric/ObjectInfo.java | 239 +-
.../cs/contextcache/metric/SizeEstimator.java | 30 +-
.../contextcache/parser/ContextKeyValueParser.java | 2 +-
.../parser/DefaultContextKeyValueParser.java | 84 +-
.../cs/contextcache/utils/ContextCacheUtils.java | 16 +-
.../cs/exception/ContextSearchFailedException.java | 6 +-
.../cs/execution/AbstractConditionExecution.java | 106 +-
.../linkis/cs/execution/ConditionExecution.java | 14 +-
.../fetcher/AbstractContextCacheFetcher.java | 8 +-
.../cs/execution/fetcher/ContextCacheFetcher.java | 2 +-
.../fetcher/ContextTypeContextSearchFetcher.java | 34 +-
.../fetcher/IterateContextCacheFetcher.java | 32 +-
.../cs/execution/impl/AndConditionExecution.java | 16 +-
.../impl/BinaryLogicConditionExecution.java | 63 +-
.../execution/impl/ContainsConditionExecution.java | 34 +-
.../impl/ContextScopeConditionExecution.java | 36 +-
.../impl/ContextTypeConditionExecution.java | 37 +-
.../impl/ContextValueTypeConditionExecution.java | 36 +-
.../execution/impl/NearestConditionExecution.java | 22 +-
.../cs/execution/impl/NotConditionExecution.java | 16 +-
.../cs/execution/impl/OrConditionExecution.java | 16 +-
.../cs/execution/impl/RegexConditionExecution.java | 34 +-
.../impl/UnaryLogicConditionExecution.java | 26 +-
.../matcher/AbstractContextSearchMatcher.java | 8 +-
.../matcher/AndLogicContextSearchMatcher.java | 14 +-
.../matcher/BinaryLogicContextSearchMatcher.java | 14 +-
.../matcher/ConditionMatcherResolver.java | 44 +-
.../matcher/ContainsContextSearchMatcher.java | 26 +-
.../matcher/ContextScopeContextSearchMatcher.java | 18 +-
.../cs/execution/matcher/ContextSearchMatcher.java | 2 +-
.../matcher/ContextTypeContextSearchMatcher.java | 18 +-
.../ContextValueTypeContextSearchMatcher.java | 18 +-
.../matcher/NearestLogicContextSearchMatcher.java | 14 +-
.../matcher/NotLogicContextSearchMatcher.java | 14 +-
.../matcher/OrLogicContextSearchMatcher.java | 14 +-
.../matcher/RegexContextSearchMatcher.java | 29 +-
.../execution/matcher/SkipContextSearchMather.java | 14 +-
.../matcher/UnaryLogicContextSearchMatcher.java | 10 +-
.../ruler/AbstractContextSearchRuler.java | 8 +-
.../ruler/CommonListContextSearchRuler.java | 42 +-
.../cs/execution/ruler/ContextSearchRuler.java | 2 +-
.../execution/ruler/NearestContextSearchRuler.java | 262 +-
.../cs/highavailable/AbstractContextHAManager.java | 8 +-
.../linkis/cs/highavailable/ContextHAManager.java | 2 +-
.../cs/highavailable/DefaultContextHAManager.java | 158 +-
.../conf/ContextHighAvailableConf.java | 12 +-
.../cs/highavailable/exception/CSErrorCode.java | 16 +-
.../highavailable/ha/BackupInstanceGenerator.java | 4 +-
.../cs/highavailable/ha/ContextHAChecker.java | 8 +-
.../cs/highavailable/ha/ContextHAIDGenerator.java | 2 +-
.../ha/impl/BackupInstanceGeneratorImpl.java | 95 +-
.../ha/impl/ContextHACheckerImpl.java | 225 +-
.../ha/impl/ContextHAIDGeneratorImpl.java | 54 +-
.../pluggable/HAContextPersistenceManagerImpl.java | 127 +-
.../highavailable/proxy/MethodInterceptorImpl.java | 392 ++-
.../linkis/cs/optimize/ConditionOptimizer.java | 2 +-
.../linkis/cs/optimize/OptimizedCondition.java | 159 +-
.../cs/optimize/cost/ConditionCostCalculator.java | 30 +-
.../apache/linkis/cs/optimize/dfs/BinaryTree.java | 8 +-
.../linkis/cs/optimize/dfs/MinCostBinaryTree.java | 112 +-
.../org/apache/linkis/cs/optimize/dfs/Node.java | 14 +-
.../optimize/impl/CostBasedConditionOptimizer.java | 20 +-
.../cs/persistence/ContextPersistenceBeans.java | 44 +-
.../cs/persistence/ContextPersistenceManager.java | 16 +-
.../persistence/ContextPersistenceManagerImpl.java | 194 +-
.../persistence/aop/PersistenceTuningAspect.java | 119 +-
.../cs/persistence/conf/PersistenceConf.java | 28 +-
.../cs/persistence/dao/ContextHistoryMapper.java | 29 +-
.../persistence/dao/ContextIDListenerMapper.java | 8 +-
.../linkis/cs/persistence/dao/ContextIDMapper.java | 24 +-
.../persistence/dao/ContextKeyListenerMapper.java | 12 +-
.../cs/persistence/dao/ContextMapMapper.java | 68 +-
.../cs/persistence/entity/ExtraFieldClass.java | 118 +-
.../entity/PersistenceContextHistory.java | 138 +-
.../persistence/entity/PersistenceContextID.java | 170 +-
.../entity/PersistenceContextIDListener.java | 88 +-
.../persistence/entity/PersistenceContextKey.java | 84 +-
.../entity/PersistenceContextKeyListener.java | 76 +-
.../entity/PersistenceContextKeyValue.java | 120 +-
.../entity/PersistenceContextValue.java | 66 +-
.../cs/persistence/exception/ThrowingFunction.java | 2 +-
.../persistence/ContextHistoryPersistence.java | 12 +-
.../persistence/ContextIDListenerPersistence.java | 14 +-
.../persistence/ContextIDPersistence.java | 28 +-
.../persistence/ContextKeyListenerPersistence.java | 16 +-
.../persistence/ContextMapPersistence.java | 46 +-
.../KeywordContextHistoryPersistence.java | 10 +-
.../persistence/TransactionManager.java | 8 +-
.../impl/ContextHistoryPersistenceImpl.java | 119 +-
.../impl/ContextIDListenerPersistenceImpl.java | 90 +-
.../persistence/impl/ContextIDPersistenceImpl.java | 225 +-
.../impl/ContextKeyListenerPersistenceImpl.java | 159 +-
.../impl/ContextMapPersistenceImpl.java | 366 ++-
.../impl/KeywordContextHistoryPersistenceImpl.java | 54 +-
.../persistence/impl/TransactionManagerImpl.java | 46 +-
.../cs/persistence/util/PersistenceUtils.java | 242 +-
.../linkis/cs/server/LinkisCSApplication.java | 6 +-
.../linkis/cs/server/conf/ContextServerConf.java | 21 +-
.../cs/server/enumeration/ServiceMethod.java | 24 +-
.../linkis/cs/server/enumeration/ServiceType.java | 54 +-
.../cs/server/parser/DefaultKeywordParser.java | 184 +-
.../cs/server/parser/KeywordMethodEntity.java | 66 +-
.../linkis/cs/server/parser/KeywordParser.java | 2 +-
.../protocol/AbstractHttpRequestProtocol.java | 54 +-
.../cs/server/protocol/ContextHistoryProtocol.java | 8 +-
.../cs/server/protocol/ContextIDProtocol.java | 8 +-
.../server/protocol/ContextListenerProtocol.java | 8 +-
.../linkis/cs/server/protocol/ContextProtocol.java | 8 +-
.../cs/server/protocol/HttpRequestProtocol.java | 14 +-
.../cs/server/protocol/HttpResponseProtocol.java | 14 +-
.../cs/server/protocol/RestResponseProtocol.java | 116 +-
.../linkis/cs/server/restful/CsRestfulParent.java | 158 +-
.../linkis/cs/server/scheduler/CsScheduler.java | 6 +-
.../cs/server/scheduler/DefaultCsScheduler.java | 78 +-
.../linkis/cs/server/scheduler/HttpAnswerJob.java | 4 +-
.../cs/server/scheduler/HttpAnswerJobBuilder.java | 56 +-
.../apache/linkis/cs/server/scheduler/HttpJob.java | 4 +-
.../linkis/cs/server/scheduler/HttpJobBuilder.java | 16 +-
.../cs/server/scheduler/HttpPriorityJob.java | 2 +-
.../linkis/cs/server/scheduler/RestJobBuilder.java | 12 +-
.../cs/server/scheduler/impl/CsExecuteRequest.java | 58 +-
.../scheduler/impl/CsExecutorExecutionManager.java | 52 +-
.../cs/server/scheduler/impl/CsJobListener.java | 66 +-
.../cs/server/scheduler/impl/CsSchedulerBean.java | 37 +-
.../cs/server/scheduler/impl/CsSchedulerJob.java | 78 +-
.../impl/JobToExecuteRequestConsumer.java | 8 +-
.../linkis/cs/server/service/AbstractService.java | 114 +-
.../cs/server/service/ContextHistoryService.java | 18 +-
.../linkis/cs/server/service/ContextIDService.java | 30 +-
.../cs/server/service/ContextListenerService.java | 12 +-
.../linkis/cs/server/service/ContextService.java | 61 +-
.../apache/linkis/cs/server/service/Service.java | 10 +-
.../service/impl/ContextHistoryServiceImpl.java | 129 +-
.../server/service/impl/ContextIDServiceImpl.java | 202 +-
.../service/impl/ContextListenerServiceImpl.java | 96 +-
.../cs/server/service/impl/ContextServiceImpl.java | 497 ++--
.../org/apache/linkis/cs/server/util/CsUtils.java | 18 +-
.../ha/instancealias/InstanceAliasConverter.scala | 9 +-
.../ha/instancealias/InstanceAliasManager.scala | 9 +-
.../impl/DefaultInstanceAliasConverter.scala | 18 +-
.../impl/InstanceAliasManagerImpl.scala | 38 +-
.../impl/RouteLabelInstanceAliasConverter.scala | 69 +-
.../cs/server/scheduler/impl/CsExecutor.scala | 18 +-
.../java/org/apache/linkis/cs/ContainsTest.java | 160 +-
.../org/apache/linkis/cs/ContextScopeTest.java | 160 +-
.../org/apache/linkis/cs/ContextSearchTest.java | 85 +-
.../java/org/apache/linkis/cs/ContextTypeTest.java | 89 +-
.../test/java/org/apache/linkis/cs/RegexTest.java | 160 +-
.../cs/contextcache/test/csid/TestContextID.java | 18 +-
.../contextcache/test/keyword/TestContextKey.java | 76 +-
.../test/keyword/TestContextKeyValue.java | 36 +-
.../test/keyword/TestContextKeyValueParser.java | 86 +-
.../test/keyword/TestContextValue.java | 50 +-
.../test/service/TestContextCacheService.java | 248 +-
.../org/apache/linkis/cs/csid/TestContextID.java | 18 +-
.../highavailable/test/TestContextHAManager.java | 281 ++-
.../cs/highavailable/test/haid/TestHAID.java | 66 +-
.../test/persist/TestPersistence.java | 44 +-
.../apache/linkis/cs/keyword/TestContextKey.java | 114 +-
.../linkis/cs/keyword/TestContextKeyValue.java | 36 +-
.../apache/linkis/cs/keyword/TestContextValue.java | 50 +-
.../org/apache/linkis/cs/parser/ApiJsonTest.java | 128 +-
.../linkis/cs/persistence/AContextHistory.java | 110 +-
.../apache/linkis/cs/persistence/AContextID.java | 154 +-
.../linkis/cs/persistence/AContextIDListener.java | 36 +-
.../apache/linkis/cs/persistence/AContextKey.java | 140 +-
.../linkis/cs/persistence/AContextKeyListener.java | 36 +-
.../linkis/cs/persistence/AContextKeyValue.java | 64 +-
.../linkis/cs/persistence/AContextValue.java | 38 +-
.../linkis/cs/persistence/ContextHistoryTest.java | 165 +-
.../cs/persistence/ContextIDListenerTest.java | 72 +-
.../linkis/cs/persistence/ContextIDTest.java | 60 +-
.../cs/persistence/ContextKeyListenerTest.java | 78 +-
.../linkis/cs/persistence/ContextMapTest.java | 252 +-
.../linkis/cs/persistence/ExtraFieldClassTest.java | 49 +-
.../linkis/cs/persistence/MapTypeAdapter.java | 98 +-
.../apache/linkis/cs/persistence/ProxyMethodA.java | 8 +-
.../apache/linkis/cs/persistence/ProxyTest.java | 18 +-
.../org/apache/linkis/cs/persistence/Scan.java | 20 +-
.../linkis/cs/server/ContextHistoryRestfulApi.java | 159 +-
.../linkis/cs/server/ContextIDRestfulApi.java | 136 +-
.../cs/server/ContextListenerRestfulApi.java | 64 +-
.../apache/linkis/cs/server/ContextRestfulApi.java | 318 +--
.../apache/linkis/cs/server/CsRestfulParent.java | 61 +-
.../java/org/apache/linkis/cs/server/Scan.java | 10 +-
.../org/apache/linkis/cs/server/SchedulerTest.java | 30 +-
.../linkis-context-service/pom.xml | 52 +-
.../linkis-datasource-client/pom.xml | 116 +-
.../datasource/client/AbstractRemoteClient.scala | 2 +-
.../datasource/client/DataSourceRemoteClient.scala | 19 +-
.../datasource/client/MetaDataRemoteClient.scala | 2 +-
.../linkis/datasource/client/RemoteClient.scala | 6 +-
.../client/config/DatasourceClientConfig.scala | 26 +-
.../DataSourceClientBuilderException.scala | 7 +-
.../client/impl/LinkisDataSourceRemoteClient.scala | 87 +-
.../client/impl/LinkisMetaDataRemoteClient.scala | 26 +-
.../client/request/CreateDataSourceAction.scala | 21 +-
.../client/request/DataSourceAction.scala | 2 +-
.../request/DataSourceTestConnectAction.scala | 26 +-
.../client/request/DeleteDataSourceAction.scala | 22 +-
.../client/request/ExpireDataSourceAction.scala | 21 +-
.../request/GetAllDataSourceTypesAction.scala | 11 +-
.../GetConnectParamsByDataSourceIdAction.scala | 18 +-
.../GetConnectParamsByDataSourceNameAction.scala | 34 +-
.../request/GetDataSourceVersionsAction.scala | 18 +-
.../request/GetInfoByDataSourceIdAction.scala | 16 +-
.../request/GetInfoByDataSourceNameAction.scala | 14 +-
.../request/GetKeyTypeDatasourceAction.scala | 16 +-
.../client/request/MetadataGetColumnsAction.scala | 19 +-
.../request/MetadataGetDatabasesAction.scala | 13 +-
.../request/MetadataGetPartitionsAction.scala | 19 +-
.../request/MetadataGetTablePropsAction.scala | 13 +-
.../client/request/MetadataGetTablesAction.scala | 16 +-
.../request/PublishDataSourceVersionAction.scala | 30 +-
.../client/request/QueryDataSourceAction.scala | 6 +-
.../client/request/QueryDataSourceEnvAction.scala | 15 +-
.../client/request/UpdateDataSourceAction.scala | 24 +-
.../request/UpdateDataSourceParameterAction.scala | 25 +-
.../client/response/CreateDataSourceResult.scala | 4 +-
.../response/DataSourceTestConnectResult.scala | 4 +-
.../client/response/DeleteDataSourceResult.scala | 4 +-
.../client/response/ExpireDataSourceResult.scala | 6 +-
.../response/GetAllDataSourceTypesResult.scala | 14 +-
.../GetConnectParamsByDataSourceIdResult.scala | 4 +-
.../GetConnectParamsByDataSourceNameResult.scala | 5 +-
.../response/GetDataSourceVersionsResult.scala | 21 +-
.../response/GetInfoByDataSourceIdResult.scala | 5 +-
.../response/GetInfoByDataSourceNameResult.scala | 3 +-
.../response/GetKeyTypeDatasourceResult.scala | 19 +-
.../client/response/MetadataGetColumnsResult.scala | 19 +-
.../response/MetadataGetDatabasesResult.scala | 5 +-
.../response/MetadataGetPartitionsResult.scala | 12 +-
.../response/MetadataGetTablePropsResult.scala | 5 +-
.../client/response/MetadataGetTablesResult.scala | 5 +-
.../response/PublishDataSourceVersionResult.scala | 6 +-
.../client/response/QueryDataSourceEnvResult.scala | 16 +-
.../client/response/QueryDataSourceResult.scala | 16 +-
.../response/UpdateDataSourceParameterResult.scala | 4 +-
.../client/response/UpdateDataSourceResult.scala | 4 +-
.../linkis-datasource-manager/common/pom.xml | 105 +-
.../datasourcemanager/common/ServiceErrorCode.java | 20 +-
.../datasourcemanager/common/auth/AuthContext.java | 78 +-
.../common/domain/DataSource.java | 370 +--
.../common/domain/DataSourceEnv.java | 210 +-
.../domain/DataSourceParamKeyDefinition.java | 354 +--
.../common/domain/DataSourceParameter.java | 42 +-
.../common/domain/DataSourceType.java | 150 +-
.../common/domain/DatasourceVersion.java | 136 +-
.../common/exception/JsonErrorException.java | 8 +-
.../datasourcemanager/common/util/CryptoUtils.java | 139 +-
.../common/util/PatternInjectUtils.java | 306 ++-
.../datasourcemanager/common/util/json/Json.java | 176 +-
.../common/protocol/DsmQueryProtocol.scala | 20 +-
.../linkis-datasource-manager/server/pom.xml | 279 ++-
.../core/LinkisDataSourceManagerApplication.java | 10 +-
.../datasourcemanager/core/dao/DataSourceDao.java | 154 +-
.../core/dao/DataSourceEnvDao.java | 80 +-
.../core/dao/DataSourceParamKeyDao.java | 52 +-
.../core/dao/DataSourceTypeDao.java | 26 +-
.../core/dao/DataSourceVersionDao.java | 71 +-
.../CustomMultiPartFormDataTransformer.java | 402 ++--
.../core/formdata/FormDataTransformerFactory.java | 22 +-
.../core/formdata/FormStreamContent.java | 84 +-
.../formdata/MultiPartFormDataTransformer.java | 22 +-
.../core/restful/RestfulApiHelper.java | 192 +-
.../exception/BeanValidationExceptionMapper.java | 18 +-
.../core/service/BmlAppService.java | 48 +-
.../core/service/DataSourceInfoService.java | 387 ++-
.../core/service/DataSourceRelateService.java | 76 +-
.../core/service/MetadataOperateService.java | 30 +-
.../core/service/hooks/DataSourceParamsHook.java | 18 +-
.../service/hooks/DefaultDataSourceParamsHook.java | 12 +-
.../core/service/impl/BmlAppServiceImpl.java | 164 +-
.../service/impl/DataSourceInfoServiceImpl.java | 1054 ++++-----
.../service/impl/DataSourceRelateServiceImpl.java | 54 +-
.../service/impl/MetadataOperateServiceImpl.java | 170 +-
.../validate/DataSourceParameterValidator.java | 142 +-
.../core/validate/ParameterValidateException.java | 12 +-
.../core/validate/ParameterValidateStrategy.java | 32 +-
.../core/validate/ParameterValidator.java | 42 +-
.../strategy/RegExpParameterValidateStrategy.java | 82 +-
.../strategy/TypeParameterValidateStrategy.java | 87 +-
.../datasourcemanager/core/vo/DataSourceEnvVo.java | 38 +-
.../datasourcemanager/core/vo/DataSourceVo.java | 91 +-
.../datasourcemanager/core/vo/PageViewVo.java | 28 +-
.../core/receivers/DsmReceiver.scala | 95 +-
.../core/WebApplicationServer.java | 6 +-
.../core/dao/DataSourceDaoTest.java | 325 ++-
.../core/dao/DataSourceEnvDaoTest.java | 200 +-
.../core/dao/DataSourceParamKeyDaoTest.java | 48 +-
.../core/dao/DataSourceTypeDaoTest.java | 26 +-
.../core/dao/DataSourceVersionDaoTest.java | 126 +-
.../restful/DataSourceAdminRestfulApiTest.java | 286 ++-
.../core/restful/DataSourceCoreRestfulApiTest.java | 1025 ++++----
.../restful/DataSourceOperateRestfulApiTest.java | 10 +-
.../datasourcemanager/core/restful/MvcUtils.java | 140 +-
.../core/service/BmlAppServiceTest.java | 76 +-
.../core/service/DataSourceInfoServiceTest.java | 574 +++--
.../core/service/DataSourceRelateServiceTest.java | 16 +-
.../core/service/MetadataOperateServiceTest.java | 82 +-
.../linkis-metadata-query/common/pom.xml | 123 +-
.../metadata/query/common/MdmConfiguration.java | 8 +-
.../query/common/cache/CacheConfiguration.java | 22 +-
.../metadata/query/common/cache/CacheManager.java | 38 +-
.../query/common/cache/ConnCacheManager.java | 85 +-
.../query/common/domain/MetaColumnInfo.java | 112 +-
.../query/common/domain/MetaPartitionInfo.java | 90 +-
.../exception/MetaMethodInvokeException.java | 36 +-
.../common/exception/MetaRuntimeException.java | 16 +-
.../query/common/service/AbstractMetaService.java | 508 ++--
.../query/common/service/BaseMetadataService.java | 16 +-
.../query/common/service/MetadataConnection.java | 46 +-
.../query/common/service/MetadataDbService.java | 120 +-
.../common/protocol/MetadataOperateProtocol.scala | 19 +-
.../query/common/protocol/MetadataProtocol.scala | 6 +-
.../common/protocol/MetadataQueryProtocol.scala | 66 +-
.../linkis-metadata-query/server/pom.xml | 180 +-
.../server/LinkisMetadataQueryApplication.java | 10 +-
.../server/loader/MetaClassLoaderManager.java | 389 ++-
.../query/server/service/MetadataQueryService.java | 302 ++-
.../service/impl/MetadataQueryServiceImpl.java | 659 +++---
.../metadata/query/server/utils/MetadataUtils.java | 234 +-
.../query/server/receiver/BaseMetaReceiver.scala | 17 +-
.../server/restful/MetadataCoreRestfulTest.java | 409 ++--
.../server/restful/MetadataQueryRestfulTest.java | 457 ++--
.../metadata/query/server/restful/MvcUtils.java | 140 +-
.../service/elasticsearch/pom.xml | 177 +-
.../metadata/query/service/ElasticConnection.java | 191 +-
.../query/service/ElasticParamsMapper.java | 12 +-
.../metadata/query/service/EsMetaService.java | 122 +-
.../linkis-metadata-query/service/hive/pom.xml | 598 +++--
.../metadata/query/service/HiveConnection.java | 222 +-
.../metadata/query/service/HiveMetaService.java | 429 ++--
.../metadata/query/service/HiveParamsMapper.java | 16 +-
.../linkis-metadata-query/service/kafka/pom.xml | 200 +-
.../metadata/query/service/KafkaConnection.java | 44 +-
.../metadata/query/service/KafkaMetaService.java | 173 +-
.../metadata/query/service/KafkaParamsMapper.java | 12 +-
.../linkis-metadata-query/service/mysql/pom.xml | 178 +-
.../metadata/query/service/Db2MetaService.java | 108 +-
.../metadata/query/service/DmMetaService.java | 108 +-
.../query/service/GreenplumMetaService.java | 125 +-
.../query/service/KingbaseMetaService.java | 108 +-
.../metadata/query/service/MysqlMetaService.java | 105 +-
.../metadata/query/service/OracleMetaService.java | 132 +-
.../query/service/PostgresqlMetaService.java | 126 +-
.../metadata/query/service/SqlConnection.java | 386 ++-
.../metadata/query/service/SqlParamsMapper.java | 20 +-
.../query/service/SqlserverMetaService.java | 102 +-
.../query/service/conf/SqlParamsMapper.java | 24 +-
.../metadata/query/service/db2/SqlConnection.java | 380 ++-
.../metadata/query/service/dm/SqlConnection.java | 396 ++--
.../query/service/greenplum/SqlConnection.java | 380 ++-
.../query/service/kingbase/SqlConnection.java | 397 ++--
.../query/service/mysql/SqlConnection.java | 380 ++-
.../query/service/oracle/SqlConnection.java | 429 ++--
.../query/service/postgres/SqlConnection.java | 371 ++-
.../query/service/sqlserver/SqlConnection.java | 411 ++--
.../linkis-datasource/linkis-metadata/pom.xml | 276 ++-
.../metadata/LinkisDataSourceApplication.java | 6 +-
.../metadata/condition/DataSourceCondition.java | 10 +-
.../org/apache/linkis/metadata/dao/MdqDao.java | 26 +-
.../linkis/metadata/domain/AbstractAuditable.java | 86 +-
.../org/apache/linkis/metadata/domain/Column.java | 84 +-
.../metadata/domain/mdq/DomainCoversionUtils.java | 271 ++-
.../apache/linkis/metadata/domain/mdq/Tunple.java | 30 +-
.../metadata/domain/mdq/bo/ApplicationBO.java | 42 +-
.../linkis/metadata/domain/mdq/bo/BaseBO.java | 144 +-
.../linkis/metadata/domain/mdq/bo/MdqTableBO.java | 42 +-
.../metadata/domain/mdq/bo/MdqTableBaseInfoBO.java | 42 +-
.../domain/mdq/bo/MdqTableFieldsInfoBO.java | 202 +-
.../domain/mdq/bo/MdqTableImportInfoBO.java | 56 +-
.../linkis/metadata/domain/mdq/bo/ModelBO.java | 72 +-
.../linkis/metadata/domain/mdq/po/MdqAccess.java | 84 +-
.../linkis/metadata/domain/mdq/po/MdqField.java | 218 +-
.../linkis/metadata/domain/mdq/po/MdqImport.java | 72 +-
.../linkis/metadata/domain/mdq/po/MdqLineage.java | 72 +-
.../linkis/metadata/domain/mdq/po/MdqTable.java | 402 ++--
.../metadata/domain/mdq/po/MdqTableInfo.java | 162 +-
.../metadata/domain/mdq/vo/ApplicationVO.java | 42 +-
.../linkis/metadata/domain/mdq/vo/BaseVO.java | 144 +-
.../metadata/domain/mdq/vo/MdqImportInfoVO.java | 88 +-
.../metadata/domain/mdq/vo/MdqTableBaseInfoVO.java | 42 +-
.../domain/mdq/vo/MdqTableFieldsInfoVO.java | 162 +-
.../mdq/vo/MdqTablePartitionStatisticInfoVO.java | 122 +-
.../domain/mdq/vo/MdqTableStatisticInfoVO.java | 128 +-
.../linkis/metadata/domain/mdq/vo/MdqTableVO.java | 56 +-
.../linkis/metadata/domain/mdq/vo/ModelVO.java | 72 +-
.../apache/linkis/metadata/hive/config/DSEnum.java | 4 +-
.../linkis/metadata/hive/config/DataSource.java | 2 +-
.../hive/config/DataSourceContextHolder.java | 20 +-
.../metadata/hive/config/DynamicDataSource.java | 8 +-
.../metadata/hive/config/LinkisMybatisConfig.java | 78 +-
.../metadata/hive/config/MultiSourceExAop.java | 69 +-
.../linkis/metadata/hive/dao/HiveMetaDao.java | 76 +-
.../metadata/hive/dto/MetadataQueryParam.java | 178 +-
.../restful/remote/DataSourceRestfulRemote.java | 54 +-
.../linkis/metadata/service/DataSourceService.java | 16 +-
.../service/HiveMetaWithPermissionService.java | 10 +-
.../apache/linkis/metadata/service/MdqService.java | 68 +-
.../service/impl/DataSourceServiceImpl.java | 439 ++--
.../impl/HiveMetaWithPermissionServiceImpl.java | 161 +-
.../metadata/service/impl/MdqServiceImpl.java | 707 +++---
.../org/apache/linkis/metadata/type/Lifecycle.java | 26 +-
.../apache/linkis/metadata/type/MdqImportType.java | 6 +-
.../apache/linkis/metadata/type/ModelLevel.java | 22 +-
.../apache/linkis/metadata/type/UseWayType.java | 22 +-
.../org/apache/linkis/metadata/util/Constants.java | 16 +-
.../org/apache/linkis/metadata/util/DWSConfig.java | 58 +-
.../org/apache/linkis/metadata/util/HiveUtils.java | 50 +-
.../linkis/metadata/conf/MdqConfiguration.scala | 15 +-
.../apache/linkis/metadata/ddl/DDLCreator.scala | 36 +-
.../org/apache/linkis/metadata/ddl/DDLHelper.scala | 43 +-
.../linkis/metadata/ddl/ImportDDLCreator.scala | 309 ++-
.../linkis/metadata/ddl/ScalaDDLCreator.scala | 96 +-
.../exception/MdqIllegalParamException.scala | 11 +-
.../linkis/metadata/receiver/MDQReceiver.scala | 29 +-
.../linkis/metadata/utils/MdqConstants.scala | 3 +-
.../apache/linkis/metadata/utils/MdqUtils.scala | 27 +-
.../linkis-datasource/pom.xml | 47 +-
.../linkis-configuration/pom.xml | 124 +-
.../configuration/LinkisConfigurationApp.java | 6 +-
.../linkis/configuration/dao/ConfigMapper.java | 48 +-
.../linkis/configuration/dao/LabelMapper.java | 10 +-
.../linkis/configuration/entity/CategoryLabel.java | 56 +-
.../configuration/entity/CategoryLabelVo.java | 140 +-
.../linkis/configuration/entity/ConfigKey.java | 168 +-
.../configuration/entity/ConfigKeyValue.java | 238 +-
.../linkis/configuration/entity/ConfigTree.java | 42 +-
.../linkis/configuration/entity/ConfigValue.java | 84 +-
.../exception/ConfigurationException.java | 16 +-
.../configuration/service/ConfigKeyService.java | 12 +-
.../service/impl/ConfigKeyServiceImpl.java | 238 +-
.../util/ConfigurationConfiguration.java | 16 +-
.../configuration/util/LabelEntityParser.java | 106 +-
.../linkis/configuration/conf/Configuration.scala | 23 +-
.../receiver/ConfigurationReceiver.scala | 34 +-
.../receiver/ConfigurationReceiverChooser.scala | 18 +-
.../configuration/service/CategoryService.scala | 174 +-
.../service/ConfigurationService.scala | 300 ++-
.../linkis/configuration/util/JsonNodeUtil.scala | 14 +-
.../configuration/util/LabelParameterParser.scala | 42 +-
.../configuration/validate/ContainValidator.scala | 10 +-
.../configuration/validate/FloatValidator.scala | 14 +-
.../configuration/validate/JsonValidator.scala | 20 +-
.../configuration/validate/NoneValidator.scala | 10 +-
.../validate/NumericalValidator.scala | 22 +-
.../configuration/validate/OneOfValidator.scala | 12 +-
.../configuration/validate/RegexValidator.scala | 21 +-
.../linkis/configuration/validate/Validator.scala | 12 +-
.../configuration/validate/ValidatorManager.scala | 10 +-
.../validate/ValidatorManagerImpl.scala | 23 +-
.../linkis/configuration/WebApplicationServer.java | 6 +-
.../linkis/configuration/dao/ConfigMapperTest.java | 324 +--
.../linkis/configuration/dao/LabelMapperTest.java | 94 +-
.../restful/api/ConfigurationRestfulApiTest.java | 267 ++-
.../linkis/configuration/restful/api/MvcUtils.java | 159 +-
.../util/ConfigurationConfigurationTest.java | 14 +-
.../configuration/util/LabelEntityParserTest.java | 54 +-
.../linkis-error-code-client/pom.xml | 89 +-
.../errorcode/client/ClientConfiguration.java | 74 +-
.../errorcode/client/ErrorCodeClientBuilder.java | 66 +-
.../errorcode/client/LinkisErrorCodeClient.java | 59 +-
.../errorcode/client/handler/ErrorCodeHandler.java | 8 +-
.../client/handler/ExceptionErrorCodeHandler.java | 2 +-
.../client/handler/LinkisErrorCodeFactory.java | 12 +-
.../client/handler/LinkisErrorCodeHandler.java | 364 ++-
.../client/handler/LogErrorCodeHandler.java | 2 +-
.../client/handler/LogFileErrorCodeHandler.java | 32 +-
.../client/manager/LinkisErrorCodeManager.java | 28 +-
.../synchronizer/LinkisErrorCodeSynchronizer.java | 126 +-
.../apache/linkis/errorcode/client/utils/Test.java | 34 +-
.../errorcode/client/action/ErrorCodeAction.scala | 61 +-
.../errorcode/client/result/ErrorCodeResult.scala | 26 +-
.../errorcode/client/utils/ErrorCodeMatcher.scala | 42 +-
.../linkis-error-code-common/pom.xml | 69 +-
.../apache/linkis/errorcode/common/CommonConf.java | 2 +-
.../errorcode/common/AbstractErrorCode.scala | 13 +-
.../apache/linkis/errorcode/common/ErrorCode.scala | 17 +-
.../linkis/errorcode/common/LinkisErrorCode.scala | 44 +-
.../linkis-error-code-server/pom.xml | 121 +-
.../errorcode/server/dao/ErrorCodeMapper.java | 16 +-
.../server/service/LinkisErrorCodeService.java | 2 +-
.../service/impl/LinkisErrorCodeServiceImpl.java | 18 +-
.../errorcode/server/WebApplicationServer.java | 6 +-
.../linkis-publicservice/linkis-error-code/pom.xml | 33 +-
.../linkis-instance-label-client/pom.xml | 115 +-
.../label/client/EurekaInstanceLabelClient.scala | 23 +-
.../label/client/InstanceLabelClient.scala | 41 +-
.../linkis-instance-label-server/pom.xml | 152 +-
.../instance/label/InsLabelAutoConfiguration.java | 102 +-
.../instance/label/async/AsyncConsumerQueue.java | 62 +-
.../label/async/GenericAsyncConsumerQueue.java | 181 +-
.../label/cache/InsLabelCacheConfiguration.java | 91 +-
.../linkis/instance/label/conf/InsLabelConf.java | 44 +-
.../instance/label/dao/InsLabelRelationDao.java | 150 +-
.../linkis/instance/label/dao/InstanceInfoDao.java | 18 +-
.../instance/label/dao/InstanceLabelDao.java | 120 +-
.../instance/label/entity/InsPersistenceLabel.java | 138 +-
.../label/entity/InsPersistenceLabelValue.java | 54 +-
.../linkis/instance/label/entity/InstanceInfo.java | 70 +-
.../label/exception/InstanceErrorException.java | 20 +-
.../label/service/InsLabelAccessService.java | 158 +-
.../instance/label/service/InsLabelService.java | 126 +-
.../label/service/InsLabelServiceAdapter.java | 14 +-
.../label/service/annotation/AdapterMode.java | 2 +-
.../label/service/impl/DefaultInsLabelService.java | 762 +++---
.../impl/DefaultInsLabelServiceAdapter.java | 407 ++--
.../label/service/impl/EurekaInsLabelService.java | 120 +-
.../linkis/instance/label/utils/EntityParser.java | 34 +-
.../label/vo/InsPersistenceLabelSearchVo.java | 54 +-
.../linkis/instance/label/vo/InstanceInfoVo.java | 84 +-
.../label/service/InsLabelRpcService.scala | 44 +-
.../label/service/conf/InstanceConfigration.scala | 9 +-
.../service/rpc/DefaultInsLabelRpcService.scala | 67 +-
.../linkis-publicservice/linkis-jobhistory/pom.xml | 169 +-
.../linkis/jobhistory/LinkisJobHistoryApp.java | 6 +-
.../linkis/jobhistory/cache/QueryCacheManager.java | 8 +-
.../linkis/jobhistory/cache/QueryCacheService.java | 8 +-
.../linkis/jobhistory/cache/domain/TaskResult.java | 132 +-
.../cache/impl/DefaultQueryCacheManager.java | 322 ++-
.../jobhistory/cache/impl/ScheduledCleanJob.java | 28 +-
.../jobhistory/cache/impl/ScheduledRefreshJob.java | 28 +-
.../cache/impl/ScheduledRefreshUndoneJob.java | 28 +-
.../jobhistory/cache/impl/UserTaskResultCache.java | 139 +-
.../linkis/jobhistory/cache/utils/MD5Util.java | 91 +-
.../linkis/jobhistory/dao/JobDetailMapper.java | 24 +-
.../linkis/jobhistory/dao/JobHistoryMapper.java | 148 +-
.../apache/linkis/jobhistory/entity/JobDetail.java | 172 +-
.../linkis/jobhistory/entity/JobHistory.java | 350 +--
.../apache/linkis/jobhistory/entity/QueryTask.java | 384 +--
.../linkis/jobhistory/entity/QueryTaskVO.java | 428 ++--
.../linkis/jobhistory/transitional/TaskStatus.java | 40 +-
.../apache/linkis/jobhistory/util/Constants.java | 2 +-
.../jobhistory/conf/JobhistoryConfiguration.scala | 16 +-
.../jobhistory/conversions/TaskConversions.scala | 97 +-
.../linkis/jobhistory/entity/QueryJobDetail.scala | 13 +-
.../linkis/jobhistory/entity/QueryJobHistory.scala | 13 +-
.../impl/JobHistoryDetailQueryServiceImpl.scala | 144 +-
.../service/impl/JobHistoryQueryServiceImpl.scala | 305 ++-
.../linkis/jobhistory/util/QueryConfig.scala | 18 +-
.../apache/linkis/jobhistory/util/QueryUtils.scala | 59 +-
.../linkis/jobhistory/WebApplicationServer.java | 6 +-
.../linkis/jobhistory/dao/JobDetailMapperTest.java | 185 +-
.../linkis/jobhistory/entity/JobHistoryTest.java | 36 +-
.../restful/api/QueryRestfulApiTest.java | 226 +-
.../service/JobHistoryDetailQueryServiceTest.java | 234 +-
.../linkis-ps-common-lock/pom.xml | 127 +-
.../common/lock/CommonLockSpringConfiguration.java | 14 +-
.../common/lock/dao/CommonLockMapper.java | 24 +-
.../common/lock/entity/CommonLock.java | 128 +-
.../common/lock/service/CommonLockService.java | 6 +-
.../service/impl/DefaultCommonLockService.java | 78 +-
.../linkis-storage-script-dev-client/pom.xml | 91 +-
.../linkis/filesystem/WorkspaceClientFactory.scala | 13 +-
.../linkis/filesystem/WorkspaceClientImpl.scala | 49 +-
.../action/OpenScriptFromBMLAction.scala | 13 +-
.../filesystem/action/WorkspacePOSTAction.scala | 11 +-
.../filesystem/conf/WorkspaceClientConf.scala | 17 +-
.../filesystem/request/WorkspaceClient.scala | 22 +-
.../filesystem/request/WorkspaceHttpConf.scala | 9 +-
.../response/ScriptFromBMLResponse.scala | 13 +-
.../filesystem/response/WorkspaceResponse.scala | 12 +-
.../result/AbstractWorkspaceResult.scala | 12 +-
.../filesystem/result/ScriptFromBMLResult.scala | 14 +-
.../filesystem/result/ScriptToBMLResult.scala | 12 +-
.../linkis-storage-script-dev-server/pom.xml | 173 +-
.../linkis/filesystem/LinkisPublicServiceApp.java | 6 +-
.../filesystem/conf/WorkSpaceConfiguration.java | 69 +-
.../filesystem/constant/WorkSpaceConstants.java | 10 +-
.../linkis/filesystem/entity/DirFileTree.java | 108 +-
.../apache/linkis/filesystem/entity/LogLevel.java | 44 +-
.../filesystem/exception/WorkSpaceException.java | 12 +-
.../exception/WorkspaceExceptionManager.java | 100 +-
.../linkis/filesystem/util/WorkspaceUtil.java | 120 +-
.../apache/linkis/filesystem/bml/BMLHelper.scala | 58 +-
.../apache/linkis/filesystem/cache/FsCache.scala | 13 +-
.../conf/WorkspaceSpringConfiguration.scala | 31 +-
.../apache/linkis/filesystem/entity/FSInfo.scala | 18 +-
.../apache/linkis/filesystem/quartz/FSQuartz.scala | 39 +-
.../linkis/filesystem/service/FsService.scala | 58 +-
.../filesystem/validator/PathValidator.scala | 59 +-
.../linkis-udf/linkis-udf-client/pom.xml | 139 +-
.../scala/org/apache/linkis/udf/UDFClient.scala | 56 +-
.../apache/linkis/udf/UDFClientConfiguration.scala | 8 +-
.../linkis-udf/linkis-udf-common/pom.xml | 139 +-
.../java/org/apache/linkis/udf/entity/UDFInfo.java | 276 +--
.../org/apache/linkis/udf/entity/UDFManager.java | 28 +-
.../java/org/apache/linkis/udf/entity/UDFTree.java | 228 +-
.../org/apache/linkis/udf/entity/UDFVersion.java | 254 +-
.../apache/linkis/udf/excepiton/UDFException.java | 12 +-
.../org/apache/linkis/udf/utils/ConstantVar.java | 36 +-
.../java/org/apache/linkis/udf/vo/DownloadVo.java | 36 +-
.../java/org/apache/linkis/udf/vo/UDFAddVo.java | 304 +--
.../java/org/apache/linkis/udf/vo/UDFInfoVo.java | 308 +--
.../java/org/apache/linkis/udf/vo/UDFUpdateVo.java | 146 +-
.../org/apache/linkis/udf/vo/UDFVersionVo.java | 232 +-
.../apache/linkis/udf/api/rpc/RequestUdfTree.scala | 14 +-
.../linkis/udf/api/rpc/ResponseUdfTree.scala | 10 +-
.../linkis-udf/linkis-udf-service/pom.xml | 171 +-
.../org/apache/linkis/udf/api/UDFRestfulApi.java | 1607 +++++++------
.../java/org/apache/linkis/udf/dao/UDFDao.java | 124 +-
.../java/org/apache/linkis/udf/dao/UDFTreeDao.java | 26 +-
.../org/apache/linkis/udf/dao/UDFVersionDao.java | 43 +-
.../org/apache/linkis/udf/service/UDFService.java | 100 +-
.../apache/linkis/udf/service/UDFTreeService.java | 12 +-
.../linkis/udf/service/impl/UDFServiceImpl.java | 1894 ++++++++-------
.../udf/service/impl/UDFTreeServiceImpl.java | 381 ++-
.../apache/linkis/udf/api/rpc/UdfReceiver.scala | 10 +-
.../linkis/udf/api/rpc/UdfReceiverChooser.scala | 16 +-
.../apache/linkis/udf/utils/UdfConfiguration.scala | 14 +-
.../linkis-publicservice/linkis-variable/pom.xml | 113 +-
.../org/apache/linkis/variable/dao/VarMapper.java | 14 +-
.../org/apache/linkis/variable/entity/VarKey.java | 84 +-
.../linkis/variable/entity/VarKeyAndValue.java | 42 +-
.../apache/linkis/variable/entity/VarKeyUser.java | 70 +-
.../linkis/variable/entity/VarKeyValueVO.java | 86 +-
.../org/apache/linkis/variable/entity/VarTree.java | 84 +-
.../variable/exception/VariableException.java | 6 +-
.../linkis/variable/service/VariableService.java | 10 +-
.../org/apache/linkis/variable/util/Constants.java | 2 +-
.../variable/receiver/VariableReceiver.scala | 20 +-
.../receiver/VariableReceiverChooser.scala | 17 +-
.../variable/service/VariableServiceImpl.scala | 79 +-
.../linkis/variable/WebApplicationServer.java | 6 +-
.../apache/linkis/variable/dao/VarMapperTest.java | 144 +-
.../apache/linkis/variable/restful/MvcUtils.java | 140 +-
.../restful/api/VariableRestfulApiTest.java | 103 +-
.../variable/service/VariableServiceTest.java | 59 +-
.../linkis-publicservice/pom.xml | 170 +-
linkis-public-enhancements/pom.xml | 173 +-
.../linkis-service-discovery/linkis-eureka/pom.xml | 239 +-
.../eureka/SpringCloudEurekaApplication.java | 6 +-
.../linkis-gateway-authentication/pom.xml | 180 +-
.../gateway/authentication/dao/TokenDao.java | 10 +-
.../gateway/authentication/entity/TokenEntity.java | 162 +-
.../exception/TokenAuthException.java | 20 +-
.../exception/TokenNotExistException.java | 21 +-
.../linkis/gateway/authentication/bo/Token.scala | 24 +-
.../linkis/gateway/authentication/bo/User.scala | 3 +-
.../gateway/authentication/bo/impl/TokenImpl.scala | 33 +-
.../gateway/authentication/bo/impl/UserImpl.scala | 3 +-
.../authentication/conf/TokenConfiguration.scala | 22 +-
.../service/CachedTokenService.scala | 53 +-
.../authentication/service/TokenService.scala | 5 +-
.../authentication/WebApplicationServer.java | 6 +-
.../gateway/authentication/dao/TokenDaoTest.java | 30 +-
.../service/CachedTokenServiceTest.java | 72 +-
.../linkis-gateway-core/pom.xml | 223 +-
.../gateway/config/GatewayConfiguration.scala | 58 +-
.../config/GatewaySpringConfiguration.scala | 35 +-
.../gateway/exception/GatewayErrorException.scala | 14 +-
.../exception/TooManyServiceException.scala | 8 +-
.../linkis/gateway/http/GatewayContext.scala | 18 +-
.../linkis/gateway/http/GatewayHttpRequest.scala | 13 +-
.../linkis/gateway/http/GatewayHttpResponse.scala | 8 +-
.../apache/linkis/gateway/http/GatewayRoute.scala | 34 +-
.../linkis/gateway/parser/GatewayParser.scala | 76 +-
.../linkis/gateway/route/GatewayRouter.scala | 150 +-
.../linkis/gateway/security/GatewaySSOUtils.scala | 84 +-
.../linkis/gateway/security/LDAPUserRestful.scala | 14 +-
.../linkis/gateway/security/LinkisPreFilter.scala | 13 +-
.../linkis/gateway/security/ProxyUserUtils.scala | 60 +-
.../linkis/gateway/security/SecurityFilter.scala | 143 +-
.../linkis/gateway/security/SecurityHook.scala | 8 +-
.../linkis/gateway/security/UserRestful.scala | 226 +-
.../gateway/security/sso/SSOInterceptor.scala | 52 +-
.../security/token/TokenAuthentication.scala | 48 +-
.../rpc/interceptor/ServiceInstanceUtils.scala | 15 +-
.../linkis/server/security/ServerSSOUtils.scala | 11 +-
.../linkis-gateway-httpclient-support/pom.xml | 109 +-
.../dws/annotation/DWSHttpMessageResult.java | 10 +-
.../linkis/httpclient/dws/DWSHttpClient.scala | 127 +-
.../StaticAuthenticationStrategy.scala | 51 +-
.../TokenAuthenticationStrategy.scala | 61 +-
.../httpclient/dws/config/DWSClientConfig.scala | 68 +-
.../dws/config/DWSClientConfigBuilder.scala | 17 +-
.../dws/config/GatewayHttpClientConf.scala | 6 +-
.../dws/discovery/DWSGatewayDiscovery.scala | 27 +-
.../dws/discovery/DefaultConfigDiscovery.scala | 31 +-
.../exception/AuthenticationFailedException.scala | 8 +-
.../dws/exception/UnknownVersionException.scala | 14 +-
.../dws/request/AbstractAuthenticationAction.scala | 22 +-
.../dws/request/DWSHeartbeatAction.scala | 13 +-
.../httpclient/dws/request/DWSHttpAction.scala | 10 +-
.../linkis/httpclient/dws/request/RestType.scala | 8 +-
.../dws/response/DWSAuthenticationResult.scala | 31 +-
.../dws/response/DWSHeartbeatResult.scala | 19 +-
.../dws/response/DWSHttpMessageFactory.scala | 33 +-
.../linkis/httpclient/dws/response/DWSResult.scala | 45 +-
.../linkis-gateway-server-support/pom.xml | 281 ++-
.../src/main/assembly/distribution.xml | 1 -
.../parser/EntranceExecutionGatewayParser.scala | 57 +-
.../ujes/parser/EntranceRequestGatewayParser.scala | 44 +-
.../ujes/parser/ResultSetCacheGatewayParser.scala | 91 +-
.../ujes/route/AbstractLabelGatewayRouter.scala | 63 +-
.../ujes/route/DefaultLabelGatewayRouter.scala | 55 +-
.../gateway/ujes/route/EntranceGatewayRouter.scala | 64 +-
.../ujes/route/GatewayRouterConfiguration.scala | 38 +-
.../ujes/route/HaContextGatewayRouter.scala | 93 +-
.../route/contextservice/ContextIdParserImpl.scala | 26 +-
.../ujes/route/label/RouteLabelParser.scala | 25 +-
.../linkis-spring-cloud-gateway/pom.xml | 239 +-
.../springcloud/LinkisGatewayApplication.java | 6 +-
.../http/GatewayAuthorizationFilter.java | 398 ++--
.../springcloud/http/SpringCloudHttpUtils.java | 85 +-
.../SpringCloudGatewayWebsocketFilter.java | 455 ++--
.../websocket/WebSocketServiceConfiguration.java | 18 +-
.../SpringCloudGatewayConfiguration.scala | 158 +-
.../errorcode/GatewayErrorConstants.scala | 10 +-
.../http/LinkisGatewayHttpHeadersFilter.scala | 13 +-
.../http/SpringCloudGatewayHttpRequest.scala | 42 +-
.../http/SpringCloudGatewayHttpResponse.scala | 50 +-
.../SpringCloudGatewayWebSocketSecurityHook.scala | 10 +-
.../SpringCloudGatewayWebsocketUtils.scala | 183 +-
.../websocket/WebsocketGatewayHttpResponse.scala | 9 +-
.../websocket/WebsocketGatewaySession.scala | 201 +-
.../linkis-service-gateway/pom.xml | 40 +-
linkis-spring-cloud-services/pom.xml | 32 +-
linkis-web/pom.xml | 82 +
pom.xml | 2495 ++++++++++----------
scalastyle-config.xml | 731 +++---
tool/code-style-idea.xml | 79 +
tool/dependencies/known-dependencies.txt | 4 +-
license-header => tool/license-header | 1 +
tool/modify_license.sh | 8 +-
3177 files changed, 131213 insertions(+), 110873 deletions(-)
create mode 100644 .github/workflows/publish-docker.yaml
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => .scalafmt.conf (56%)
create mode 100644 docs/index.md
create mode 100644 linkis-commons/linkis-rpc/src/test/java/org/apache/linkis/rpc/message/utils/MessageUtilsTest.java
delete mode 100644 linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/message/utils/MessageUtilsTest.java
create mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/test/scala/org/apache/linkis/governance/common/paser/PythonCodeParseTest.scala
create mode 100644 linkis-dist/docker/ldh.Dockerfile
create mode 100644 linkis-dist/docker/linkis.Dockerfile
create mode 100644 linkis-dist/docker/scripts/entry-point-ldh.sh
create mode 100755 linkis-dist/docker/scripts/prepare-ldh-image.sh
create mode 100644 linkis-dist/helm/README.md
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/charts/linkis/.helmignore (65%)
create mode 100644 linkis-dist/helm/charts/linkis/Chart.yaml
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/charts/linkis/templates/NOTES.txt (55%)
create mode 100644 linkis-dist/helm/charts/linkis/templates/_helpers.tpl
create mode 100644 linkis-dist/helm/charts/linkis/templates/configmap-init-sql.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/configmap-linkis-config.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/configmap-linkis-web-config.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/jobs.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-cg-engineconnmanager.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-cg-engineplugin.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-cg-entrance.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-cg-linkismanager.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-mg-eureka.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-mg-gateway.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-ps-cs.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-ps-data-source-manager.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-ps-metadataquery.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-ps-publicservice.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/linkis-web.yaml
create mode 100644 linkis-dist/helm/charts/linkis/templates/serviceaccount.yaml
create mode 100644 linkis-dist/helm/charts/linkis/values.yaml
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/scripts/common.sh (70%)
mode change 100644 => 100755
create mode 100755 linkis-dist/helm/scripts/create-kind-cluster.sh
create mode 100755 linkis-dist/helm/scripts/install-charts.sh
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/scripts/install-ldh.sh (57%)
mode change 100644 => 100755
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/scripts/install-mysql.sh (65%)
mode change 100644 => 100755
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/scripts/login-pod.sh (62%)
mode change 100644 => 100755
create mode 100755 linkis-dist/helm/scripts/remote-debug-proxy.sh
copy linkis-engineconn-plugins/trino/src/main/resources/linkis-engineconn.properties => linkis-dist/helm/scripts/resources/kind-cluster.yaml (62%)
create mode 100644 linkis-dist/helm/scripts/resources/ldh/configmaps/configmap-flink.yaml
create mode 100644 linkis-dist/helm/scripts/resources/ldh/configmaps/configmap-hadoop.yaml
create mode 100644 linkis-dist/helm/scripts/resources/ldh/configmaps/configmap-hive.yaml
create mode 100644 linkis-dist/helm/scripts/resources/ldh/configmaps/configmap-spark.yaml
create mode 100644 linkis-dist/helm/scripts/resources/ldh/configmaps/configmap-zookeeper.yaml
create mode 100644 linkis-dist/helm/scripts/resources/ldh/ldh.yaml
create mode 100644 linkis-dist/helm/scripts/resources/mysql.yaml
create mode 100644 linkis-web/pom.xml
create mode 100644 tool/code-style-idea.xml
rename license-header => tool/license-header (99%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org