You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by gi...@apache.org on 2023/06/20 11:42:04 UTC
[linkis] branch dependabot/maven/com.google.guava-guava-32.0.0-jre updated (fec5c411d -> ba118d390)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/com.google.guava-guava-32.0.0-jre
in repository https://gitbox.apache.org/repos/asf/linkis.git
discard fec5c411d Bump guava from 30.0-jre to 32.0.0-jre
add 436f90d7a [Bugfix] engine version support hyphen (#4246)
add ee29de943 [feat] support different hive version (#4255)
add 2826602d2 mapper formatting
add 617dcf8dc Beautify the sql style, clear and clear
add 557f4fe57 update LabelMapper.xml
add 9990b9c9a Beautify the sql style, clear and clear
add f1deacaef The abnormal class description information in the checkEngineConnDistHome method supplements the path information (#4283)
add eb5541238 [feat] upgrade hadoop\spark\hive default vertion to 3.x (#4263)
add 9563457f8 [feat] EngineConn no longer imports the dependencies of the underlying engine (#4278)
add 72d84048a give more exception in CustomerDelimitedJSONSerDe.java (#4341)
add 2c5abd7a0 [feat]Support spark3.3+ and spark2.2- compile (#4301)
add 1d9c9a301 Optimization of upload file interface in FsRestfulApi.java (#4357)
add 581ce1e67 [fix bug] The s3a file cannot be written because FileSystem is closed prematurely (#4375)
add e24da00b3 Improve exception information and add path information (#4351)
add 1e25954be support map string value (#4409)
add 6d1eed14c feat: HiveEngineConn supports concurrency.(#4175) (#4359)
add 65381be50 Merge remote-tracking branch 'upstream/dev-1.3.2' into dev-1.3.2-mergeto1.4.0
add b900b7137 update build to support spark and hadoop multi-version compilation
add 67e4c0c71 Merge pull request #4428 from WeDataSphere/dev-1.3.2-mergeto1.4.0
add a6e32ad2a Datasource code optimization (#4419)
add 1b78c4191 Merge branch 'dev-1.4.0' into dev-1.3.3-mapper-finishing
add f18c0dccb Merge pull request #4293 from binbinCheng/dev-1.3.3-mapper-finishing
add 5b321e055 [Feature] Change KIND to an optional way on kubernetes deployment (#4427)
add 0786e9b39 Fixed nohup startup bug (#4438)
add f545197a4 feat : linkis-storage support OSS filesystem support write/read launch log and resultSet in OSS(#4185) (#4424)
add 9d1ae92ab Delete useless files (#4425)
add 9ee4a46a1 Cpu load Average Usage bug (#4429)
add f33f51ac6 feat：commons_fileupload Upgrade to 1.5
add 63118b584 Merge pull request #4432 from WeDataSphere/dev-1.4.0-upgrade-dependencies
add 241894879 fix(common util)：fix getStringToMap function bug about ECResourceInfoUtils
add 6366265df Merge pull request #4430 from WeDataSphere/fix/fix-ECResourceInfoUtils
add 6a4817a14 sync master to dev-1.4.0
add 9407924c0 Revert "sync master to dev-1.4.0"
add 341c632d4 Merge pull request #4450 from apache/revert-4448-master
add aa5ae1d68 Revert "Revert "sync master to dev-1.4.0""
add c81108bae Merge pull request #4451 from apache/revert-4450-revert-4448-master
add d77162e06 Change FileUtils readFileToString Deprecated (#4443)
add 784f1510d Port range 65534 alter 65535 (#4447)
add 7155aef37 LogCache code optimization and delete useless files (#4445)
add f0f665751 feat : linkis-storage support s3 filesystem support write/read launch log and resultSet in s3(#4185) (#4435)
add 168180047 Bump snakeyaml from 1.33 to 2.0 (#4440)
add 78b7f79a9 fix: make property name consistent #4461 (#4462)
add 3702d91e9 [WIP] remove json4s from linkis (#4368)
add a4662f1bb Revert "Bump snakeyaml from 1.33 to 2.0 (#4440)" (#4469)
add 8d0584348 update task cancel msg (#4454)
add 0f1005c43 optimize engine log (#4455)
add a92146f02 update log (#4456)
add 35ff59b88 fix config cache bug (#4457)
add 899bb15e7 push tenant config code (#4453)
add fb4aad356 [issue-4467] update linkis version to 1.4.0 for docker and snapshot (#4468)
add af40a99a8 Fix test failed and remove some jars (#4471)
add c8d151250 ECM code optimization (#4449)
add 415d5cd19 Executor code optimization and Remove useless code (#4472)
add 91e648b71 Translate engineconn-plugins-openlookeng service classes from Scala to Java (#4474)
add d67e6d1e0 Updatethe volatile key for singleton (#4477)
add 8dc272520 feat: use up-to-date mysql ddl for k8s deployment #4426 (#4475)
add 63ea330cc [Bug]: fix the bug that guice:4.1.0 dependency conflict during linkis-engineconn-plugins compilation #4478 (#4479)
add 265d5d3fe add impala engineconn-plugin (#4458)
add 1ec76dee2 EngineConnsHome Filters hidden files (#4481)
add d12a32624 feat: do not kill ec when ecm restart part-1 (#4184) (#4452)
add 734932a05 Support tidb dataSources (#4486)
add 3e17fd804 hive adaptive ranger (#4485)
add db37eed39 Translate engineconn-plugins-shell service classes from Scala to Java (#4473)
add 179abedf8 improve yarn resource requester (#4492)
add dca07627d Remove the default compilation of impala
add 41798ead4 Fix front-end compilation exceptions (#4503)
add 806d37ae7 fixed the front-end startup exception (#4505)
add ba581c60c [Bugfix] update refresh time of providerCache is 30m (#4498)
add 6f4dad9ac Upgrade node to version 16.0.0 (#4495)
add b3c105d81 Support starrocks dataSources (#4496)
add bfde76c6f Release refresh button (#4507)
add a7e6ecec8 Engineplugin shell Code optimization (#4499)
add 4b787a438 fix: do not clean ec resource and service info when handler ecm close event(#4184) (#4510)
add 5e267df71 optimize code (#4512)
add 5137d3c3c Datasource client bug fix (#4500)
add 7cab75646 Support Gaussdb dataSources and Fixed pg bug (#4513)
add a549dab9c fix: FsPathTest should skip windows (#4517)
add 46c2bb24f Fixed the linkis-metadata-query-service-jdbc bug (#4508)
add ec9b2c61e Translate engineconn-plugins-python service classes from Scala to Java (#4482)
add 29cf010d2 feat: Reduce scala modules and publish jar packages with scala versions at the same time(#4192) (#4459)
add 632191aee Translate engineconn-plugins-trino service classes from Scala to Java (#4526)
add 0fb148a8e Translate engineconn-plugins-presto service classes from Scala to Java (#4514)
add 04791effe metadata-query code optimization (#4523)
add a3aec9e09 feat(pom): fix build with jdk17 for default profiles (#4480)
add be9d230f0 feat: Reduce scala module: linkis-mange#4192
add 252a00d17 feat: Reduce scala module: linkis-mange#4192
add 7c9870631 feat: Reduce scala module: linkis-mange#4192
add 4a1a41356 feat: Reduce scala module: linkis-mange#4192
add 5c2269e92 feat: Reduce scala module: linkis-mange#4192
add ab40b5df8 feat: Reduce scala module: linkis-mange#4192
add ffe42eee6 feat: Reduce scala module: linkis-mange#4192
add f1e7d8ad0 feat: Reduce scala module: linkis-manage modify exception #4192
add 0f69de9d0 feat: Reduce scala module: linkis-manage modify exception #4192
add f4921b45e feat: Reduce scala module: linkis-manage modify exception #4192
add 5665641eb feat: Reduce scala module: linkis-manage modify exception #4192
add 7fa9be049 feat: Reduce scala module: linkis-manage modify exception #4192
add ca2fe91db feat: Reduce scala module: linkis-manage modify exception #4192
add 40fca226d feat: Reduce scala module: linkis-manage modify exception #4192
add 634fd03c8 feat: Reduce scala module: linkis-manage modify exception #4192
add cbff5fa69 feat: Reduce scala module: linkis-manage modify exception #4192
add 02b2dab74 feat: Reduce scala module: linkis-manage modify exception #4192
add a99d3d715 feat: Reduce scala module: linkis-manage modify exception #4192
add 5b7fd7bd8 Reduce mixed language module linkismange #4463
add 00a2975a6 ResponseTaskRunningInfo bug fix and remove useless code (#4533)
add 5a59e5b43 properties values support the Chinese (#4521)
add e3e203596 fix init logger with wrong class #4537 (#4540)
add f1ed1dd6f feat: support multiple cluster PART-1 #4179 (#4460)
add 3989b4dcf Translate engineconn-plugins-elasticsearch service classes from Scala to Java (#4531)
add 4767c5e4e spark etl support excel and transformations can be null (#4539)
add 7bf9c4465 spark etl support redis and jedis2.9.2 upgrade 3.9.0 (#4534)
add 33463921f [Fix Bug]If the input script is json, the loop cannot be completed(#4557) (#4558)
add af0b6e312 fix(pom): fix the spark miss jetty-client, and remove the older jesery (#4562)
add a5e6991bc [Feature][Flink] Add task interceptor for FLink EC (#4556)
add e09e89706 spark etl support datalake and add scala-2.12 module (#4538)
add e4de7c992 [Gateway]All backend caches should be cleared when the user logs out (#4548)
add 9ad3d7620 [JDBC]Linkis JDBC-Driver optimization (#4545)
add 7544426a3 [Feature]Add MDC log format to Linkis for tracking JobID #4553 (#4554)
add 3b41d3445 avoid unnecessary json exception (#4567)
add 3544d3958 spark jdbc etl support dm and kingbase (#4568)
add 786751f4e spark etl support RocketMQ (#4564)
add 42d070df6 spark etl support mongo and es (#4560)
add 3db237ead [feate] Added support for postgresql based on dev-1.4.0 (#4524)
add bb1459248 fix s3 cant read logs and results (#4573)
add aa9e12498 spark etl support solr (#4569)
add 7a8c2a602 Fix serialization of number type parameters to double (#4571)
add 6b2c4ee3d web optimize for 1.4.0 (#4444)
add b0173ec65 Security Work Order Upgrade (#4561)
add 42c52b2cc spark etl support kafka (#4563)
add aee1e1795 optimization for web
add 42e3f1f0e update workflows (#4579)
add 16d7e5e33 Support oceanbase dataSources (#4581)
add 427b2ff65 [Feature][linkis-computation-client] Provide a method which can get CreateEngineResult when submit a [once] job (#4583)
add b5053afb9 Generate spark sql based on the jdbc datasource and optimized code (#4570)
add 0e7a0f9de [Feature] Add pg check script (#4587)
add 281e1b5f3 Generate jdbc sql (#4589)
add f40bf6f3a Generate spark sql from kafka es mongo (#4588)
add 470159f69 support to initialize postgresql in install.sh (#4593)
add d55437474 Generate sql code optimization (#4594)
add 2f69900d0 add jersey-apache-client4 dependency (#4599)
add ffd386a2b Fix usage docs for Impala & Trino (#4597)
add 9bb6cd8b5 Support integtation test git action (#4601)
add 288a09223 remove v prefix for impala and add default compile mode (#4609)
add b4b294f8e modify the scala packaging version (#4612)
add a97a04835 fix: remove engine version pattern check #4610 (#4611)
add 1d1abfc1b Fix ENGINE_TASK_EXPIRE_TIME ClassCastException bug (#4614)
add ef3e2b991 ECM stateless feature optimization (#4608)
add ec1eca064 update check and install scripts (#4619)
add bc93a5ebc Fix NPE bug #4621 (#4622)
add f7d81b502 [Fix Bug]Fix elasticsearch task execution failed (#4625)
add c2319d520 return id in udf_Tree_List in UDFTreeDao.xml (#4649)
add 19c30752a remove queue info, for there maybe too many logs (#4647)
add 0bdb5c3c1 Fix create ec NPE Exception #4651 (#4652)
add 8ab0bd547 [Fix Bug]Fix spark mongo etl task execution failed (#4638)
add 66a74f728 [Fix Bug]Fix spark es etl task execution failed (#4630)
add 4e7527601 fix: queresource search failed 4660 (#4661)
add 466f39814 remove node scorer service invoke (#4659)
add 7b1419d4b [fix-4653]fix jdbc connection cache error (#4654)
add c3cfc90de Spark etl support starrocks (#4650)
add 7a0ac0806 fix Collectors.toList method occur duplicate key problem#4645 (#4646)
add 114937484 fix: reuseEngine may throw NullPointerException exception #4662 (#4663)
add cd59dbadb Modify the flink error code (#4666)
add d8c018f12 Flink removes useless code (#4677)
add 4985e0b81 [ISSUE-4674][feat] update jdbc and trino ec properties (#4676)
add e9ccfe035 Use database hook should default set false #4664 (#4665)
add 3ef1758d8 Upgrade seatunnel to 2.3.1 (#4673)
add b229925ef Modify the database type supported by the JDBC engine
add 410139aec update protected_branches
add ba7e6f603 Modify the database type supported by the JDBC engine
add 3cd9d3618 Merge remote-tracking branch 'upstream/master' into dev-1.4.0-to-master
add 632497850 Merge 1.4.0 to Master
add ba118d390 Bump guava from 30.0-jre to 32.0.0-jre
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (fec5c411d)
\
N -- N -- N refs/heads/dependabot/maven/com.google.guava-guava-32.0.0-jre (ba118d390)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 6 -
.github/actions/chart-testing-action | 1 +
.github/actions/kind-action | 1 +
.github/workflows/build-backend.yml | 24 +-
.github/workflows/check-sql-pg-script.yml | 47 +
.github/workflows/integration-test.yml | 188 ++++
.github/workflows/publish-docker.yaml | 10 +-
.gitmodules | 6 +
README.md | 10 +-
README_CN.md | 27 +-
docs/configuration/impala.md | 28 +
.../configuration/linkis-computation-engineconn.md | 2 +-
.../linkis-computation-governance-common.md | 4 +-
docs/configuration/linkis-manager-common.md | 2 +-
docs/configuration/linkis-metadata-query.md | 10 +
docs/configuration/linkis-udf.md | 2 +-
docs/configuration/spark.md | 9 +
docs/errorcode/linkis-configuration-errorcode.md | 2 +-
docs/impala-usage.md | 155 +++
docs/info-1.4.0.md | 5 +
docs/trino-usage.md | 4 +-
.../linkis/common/exception/ErrorException.java | 2 +-
.../linkis/common/exception/FatalException.java | 2 +-
.../common/exception/LinkisRetryException.java | 4 +-
.../java/org/apache/linkis/common/io/FsPath.java | 20 +-
.../apache/linkis/common/utils/SecurityUtils.java | 7 +-
.../common/utils/VariableOperationUtils.java | 1 +
.../linkis/common/conf/BDPConfiguration.scala | 11 +-
.../apache/linkis/common/conf/Configuration.scala | 2 +
.../linkis/common/conf/BDPConfigurationTest.java | 41 +
.../org/apache/linkis/common/io/FsPathTest.java | 66 ++
.../linkis/common/utils/ByteTimeUtilsTest.java | 47 +
.../linkis/common/utils/SecurityUtilsTest.java | 13 -
.../common/variable/VariableOperationTest.java | 8 +
.../src/test/resources/linkis.properties | 16 +
.../linkis/hadoop/common/conf/HadoopConf.scala | 12 +
.../common/entity/HDFSFileSystemContainer.scala | 4 +-
.../linkis/hadoop/common/utils/HDFSUtils.scala | 160 ++-
.../linkis/hadoop/common/conf/HDFSUtilsTest.scala | 55 +
linkis-commons/linkis-httpclient/pom.xml | 25 -
linkis-commons/linkis-module/pom.xml | 154 ---
.../org/apache/linkis/proxy/ProxyUserService.java | 23 -
.../apache/linkis/server/ticket/RedisClient.scala | 4 +-
.../linkis/server/utils/LinkisMainHelper.scala | 2 +-
linkis-commons/linkis-mybatis/pom.xml | 28 +-
.../mybatis/MybatisConfigurationFactory.java | 4 +-
.../linkis/mybatis/conf/MybatisConfiguration.java | 2 +
.../protocol/callback/LogCallbackProtocol.scala | 3 -
linkis-commons/linkis-rpc/pom.xml | 18 +-
.../rpc/transform/JavaCollectionSerializer.scala | 50 -
.../apache/linkis/rpc/transform/RPCFormats.scala | 26 -
.../apache/linkis/rpc/transform/RPCProduct.scala | 55 -
.../org/apache/linkis/rpc/RPCFormatsTest.scala | 93 --
linkis-commons/linkis-storage/pom.xml | 34 +-
.../java/org/apache/linkis/storage/FSFactory.java | 96 ++
.../org/apache/linkis/storage/LineMetaData.java | 44 +
.../java/org/apache/linkis/storage/LineRecord.java | 47 +
.../linkis/storage/conf/LinkisStorageConf.java | 65 ++
.../org/apache/linkis/storage/csv/CSVFsWriter.java | 35 +
.../linkis/storage/csv/StorageCSVWriter.java | 128 +++
.../org/apache/linkis/storage/domain/Column.java | 51 +
.../org/apache/linkis/storage/domain/DataType.java | 226 ++++
.../org/apache/linkis/storage/domain/Dolphin.java | 130 +++
.../apache/linkis/storage/domain/MethodEntity.java | 132 +++
.../storage/domain/MethodEntitySerializer.java | 84 ++
.../storage/excel/ExcelAnalysisException.java | 34 +
.../apache/linkis/storage/excel/ExcelFsWriter.java | 41 +
.../linkis/storage/excel/ExcelXlsReader.java | 278 +++++
.../apache/linkis/storage/excel/FirstRowDeal.java | 55 +
.../apache/linkis/storage/excel/IExcelRowDeal.java | 26 +
.../apache/linkis/storage/excel/RowToCsvDeal.java | 66 ++
.../linkis/storage/excel/StorageExcelWriter.java | 310 ++++++
.../storage/excel/StorageMultiExcelWriter.java | 58 +
.../org/apache/linkis/storage/excel/XlsUtils.java | 1 +
.../storage/factory/impl/BuildHDFSFileSystem.java | 6 +-
.../storage/factory/impl/BuildLocalFileSystem.java | 8 +-
.../storage/factory/impl/BuildOSSSystem.java | 70 ++
.../storage/factory/impl/BuildS3FileSystem.java | 62 ++
.../org/apache/linkis/storage/fs/FileSystem.java | 6 +
.../linkis/storage/fs/impl/HDFSFileSystem.java | 42 +-
.../linkis/storage/fs/impl/LocalFileSystem.java | 27 +-
.../linkis/storage/fs/impl/OSSFileSystem.java | 394 +++++++
.../linkis/storage/fs/impl/S3FileSystem.java | 367 +++++++
.../org/apache/linkis/storage/io/IOClient.java | 29 +
.../apache/linkis/storage/io/IOClientFactory.java | 57 +
.../storage/io/IOMethodInterceptorCreator.java | 25 +
.../storage/io/IOMethodInterceptorFactory.java | 49 +
.../storage/resultset/DefaultResultSetFactory.java | 188 ++++
.../linkis/storage/resultset/ResultMetaData.java | 22 +
.../linkis/storage/resultset/ResultRecord.java | 22 +
.../linkis/storage/resultset/ResultSetFactory.java | 74 ++
.../storage/resultset/ResultSetReaderFactory.java | 115 ++
.../storage/resultset/ResultSetWriterFactory.java | 88 ++
.../linkis/storage/resultset/StorageResultSet.java | 79 ++
.../storage/resultset/StorageResultSetReader.java | 180 ++++
.../storage/resultset/StorageResultSetWriter.java | 260 +++++
.../storage/resultset/html/HtmlResultSet.java | 48 +
.../linkis/storage/resultset/io/IOMetaData.java | 37 +
.../linkis/storage/resultset/io/IORecord.java | 35 +
.../storage/resultset/io/IOResultDeserializer.java | 37 +
.../storage/resultset/io/IOResultSerializer.java | 47 +
.../linkis/storage/resultset/io/IOResultSet.java | 43 +
.../resultset/picture/PictureResultSet.java | 48 +
.../storage/resultset/table/TableMetaData.java | 44 +
.../storage/resultset/table/TableRecord.java | 44 +
.../resultset/table/TableResultDeserializer.java | 100 ++
.../resultset/table/TableResultSerializer.java | 111 ++
.../storage/resultset/table/TableResultSet.java | 44 +
.../resultset/txt/TextResultDeserializer.java | 36 +
.../resultset/txt/TextResultSerializer.java | 50 +
.../storage/resultset/txt/TextResultSet.java | 46 +
.../apache/linkis/storage/script/Compaction.java | 44 +
.../org/apache/linkis/storage/script/Parser.java | 30 +
.../linkis/storage/script/ParserFactory.java | 31 +
.../linkis/storage/script/ScriptFsReader.java | 40 +
.../linkis/storage/script/ScriptFsWriter.java | 37 +
.../linkis/storage/script/ScriptMetaData.java | 41 +
.../apache/linkis/storage/script/ScriptRecord.java | 26 +
.../org/apache/linkis/storage/script/Variable.java | 48 +
.../linkis/storage/script/VariableParser.java | 131 +++
.../script/compaction/CommonScriptCompaction.java | 47 +
.../script/compaction/PYScriptCompaction.java | 45 +
.../script/compaction/QLScriptCompaction.java | 45 +
.../script/compaction/ScalaScriptCompaction.java | 45 +
.../script/compaction/ShellScriptCompaction.java | 45 +
.../storage/script/parser/CommonScriptParser.java | 75 ++
.../storage/script/parser/PYScriptParser.java | 45 +
.../storage/script/parser/QLScriptParser.java | 45 +
.../storage/script/parser/ScalaScriptParser.java | 45 +
.../storage/script/parser/ShellScriptParser.java | 45 +
.../script/reader/StorageScriptFsReader.java | 161 +++
.../script/writer/StorageScriptFsWriter.java | 124 +++
.../linkis/storage/source/AbstractFileSource.java | 109 ++
.../apache/linkis/storage/source/FileSource.java | 172 +++
.../apache/linkis/storage/source/FileSplit.java | 281 +++++
.../linkis/storage/source/ResultsetFileSource.java | 54 +
.../linkis/storage/source/TextFileSource.java | 71 ++
.../linkis/storage/utils/FileSystemUtils.java | 136 +++
.../linkis/storage/utils/StorageConfiguration.java | 161 +++
.../apache/linkis/storage/utils/StorageHelper.java | 156 +++
.../apache/linkis/storage/utils/StorageUtils.java | 270 +++++
.../org/apache/linkis/storage/FSFactory.scala | 98 --
.../org/apache/linkis/storage/LineMetaData.scala | 32 -
.../org/apache/linkis/storage/LineRecord.scala | 34 -
.../linkis/storage/conf/LinkisStorageConf.scala | 63 --
.../apache/linkis/storage/csv/CSVFsReader.scala | 22 -
.../apache/linkis/storage/csv/CSVFsWriter.scala | 39 -
.../linkis/storage/csv/StorageCSVReader.scala | 20 -
.../linkis/storage/csv/StorageCSVWriter.scala | 93 --
.../apache/linkis/storage/domain/DataType.scala | 148 ---
.../org/apache/linkis/storage/domain/Dolphin.scala | 104 --
.../linkis/storage/domain/MethodEntity.scala | 101 --
.../linkis/storage/excel/ExcelFsReader.scala | 22 -
.../linkis/storage/excel/ExcelFsWriter.scala | 47 -
.../linkis/storage/excel/ExcelXlsReader.java | 378 -------
.../linkis/storage/excel/StorageExcelReader.scala | 20 -
.../linkis/storage/excel/StorageExcelWriter.scala | 236 -----
.../storage/excel/StorageMultiExcelWriter.scala | 53 -
.../org/apache/linkis/storage/io/IOClient.scala | 75 --
.../storage/io/IOMethodInterceptorCreator.scala | 53 -
.../resultset/DefaultResultSetFactory.scala | 130 ---
.../linkis/storage/resultset/ResultMetaData.scala | 22 -
.../linkis/storage/resultset/ResultRecord.scala | 22 -
.../storage/resultset/ResultSetFactory.scala | 69 --
.../linkis/storage/resultset/ResultSetReader.scala | 91 --
.../linkis/storage/resultset/ResultSetWriter.scala | 74 --
.../storage/resultset/StorageResultSet.scala | 50 -
.../storage/resultset/StorageResultSetReader.scala | 154 ---
.../storage/resultset/StorageResultSetWriter.scala | 221 ----
.../storage/resultset/html/HtmlResultSet.scala | 34 -
.../linkis/storage/resultset/io/IOMetaData.scala | 25 -
.../linkis/storage/resultset/io/IORecord.scala | 25 -
.../resultset/io/IOResultDeserializer.scala | 36 -
.../storage/resultset/io/IOResultSerializer.scala | 43 -
.../linkis/storage/resultset/io/IOResultSet.scala | 32 -
.../resultset/picture/PictureResultSet.scala | 34 -
.../storage/resultset/table/TableMetaData.scala | 30 -
.../storage/resultset/table/TableRecord.scala | 36 -
.../resultset/table/TableResultDeserializer.scala | 90 --
.../resultset/table/TableResultSerializer.scala | 92 --
.../storage/resultset/table/TableResultSet.scala | 32 -
.../resultset/txt/TextResultDeserializer.scala | 34 -
.../resultset/txt/TextResultSerializer.scala | 46 -
.../storage/resultset/txt/TextResultSet.scala | 33 -
.../linkis/storage/script/ScriptFsReader.scala | 37 -
.../linkis/storage/script/ScriptFsWriter.scala | 115 --
.../linkis/storage/script/VariableParser.scala | 117 ---
.../script/compaction/CommonScriptCompaction.scala | 34 -
.../script/compaction/PYScriptCompaction.scala | 39 -
.../script/compaction/QLScriptCompaction.scala | 38 -
.../script/compaction/ScalaScriptCompaction.scala | 38 -
.../script/compaction/ShellScriptCompaction.scala | 39 -
.../storage/script/parser/CommonScriptParser.scala | 63 --
.../storage/script/parser/PYScriptParser.scala | 39 -
.../storage/script/parser/QLScriptParser.scala | 38 -
.../storage/script/parser/ScalaScriptParser.scala | 39 -
.../storage/script/parser/ShellScriptParser.scala | 39 -
.../script/reader/StorageScriptFsReader.scala | 126 ---
.../script/writer/StorageScriptFsWriter.scala | 120 ---
.../linkis/storage/source/AbstractFileSource.scala | 71 --
.../apache/linkis/storage/source/FileSource.scala | 154 ---
.../apache/linkis/storage/source/FileSplit.scala | 162 ---
.../storage/source/ResultsetFileSource.scala | 36 -
.../linkis/storage/source/TextFileSource.scala | 52 -
.../linkis/storage/utils/FileSystemUtils.scala | 116 --
.../storage/utils/StorageConfiguration.scala | 86 --
.../linkis/storage/utils/StorageHelper.scala | 107 --
.../apache/linkis/storage/utils/StorageUtils.scala | 229 ----
.../apache/linkis/storage/LineMetaDataTest.java | 36 +
.../StorageResultSetWriterFactoryTest.java | 53 +
.../script/writer/StorageScriptFsWriterTest.java | 8 +-
.../storage/source/ResultsetFileSourceTest.java | 50 +
.../src/test/resources/result-read-test.dolphin | 1 +
.../src/test/resources/storage-read-test.dolphin | 1 +
.../storage/utils/StorageConfigurationTest.scala | 3 +-
.../linkis/cli/application/constants/AppKeys.java | 2 +
.../cli/application/constants/LinkisKeys.java | 1 +
.../command/template/UniversalCmdTemplate.java | 9 +
.../application/operator/ujes/UJESConstants.java | 5 +-
.../application/LinkisClientApplicationTest.java | 8 +-
.../linkis/cli/core/constants/CommonKeys.java | 20 -
.../linkis-computation-client/pom.xml | 4 -
.../client/once/simple/SimpleOnceJob.scala | 7 +-
.../ujes/client/response/JobProgressResult.scala | 17 +-
.../ujes/client/response/OpenLogResult.scala | 2 +-
.../computation/client/InteractiveJobTest.java | 3 +-
.../governance/common/utils/ECPathUtils.java | 53 +
.../governance/common/utils/LoggerUtils.java | 43 +
.../common/conf/GovernaceCommonConf.scala | 73 --
.../common/conf/GovernanceCommonConf.scala | 87 ++
.../exception/GovernanceErrorException.scala | 5 +-
.../governance/common/utils/ECPathUtils.scala | 48 -
.../common/utils/GovernanceConstant.scala | 1 -
.../governance/common/utils/GovernanceUtils.scala | 49 +
.../linkis/governance/common/utils/JobUtils.scala | 10 +-
.../common/conf/GovernanceCommonConfTest.scala | 4 +-
.../common/utils/GovernanceConstantTest.scala | 2 -
.../ecm/core/launch/ProcessEngineConnLaunch.scala | 9 +-
.../linkis/ecm/core/report/NodeHealthReport.scala | 4 +-
.../apache/linkis/ecm/core/utils/PortUtils.scala | 2 +-
.../linkis-engineconn-manager-server/pom.xml | 7 -
.../ecm/server/operator/EngineConnLogOperator.java | 219 ++++
.../server/operator/EngineConnYarnLogOperator.java | 147 +++
.../service/impl/DefaultEngineConnKillService.java | 285 +++++
.../linkis/ecm/server/conf/ECMConfiguration.scala | 13 +
.../ecm/server/exception/ECMErrorException.scala | 11 +-
.../linkis/ecm/server/hook/JarUDFLoadECMHook.scala | 1 -
.../linkis/ecm/server/listener/ECMReadyEvent.scala | 17 +-
.../server/operator/EngineConnLogOperator.scala | 241 -----
.../operator/EngineConnYarnLogOperator.scala | 124 ---
.../ecm/server/report/DefaultECMHealthReport.scala | 4 +-
.../ecm/server/service/ECMMetricsService.scala | 20 -
.../ecm/server/service/EngineConnListService.scala | 47 -
.../service/EngineConnPidCallbackService.scala | 26 -
.../service/EngineConnStatusCallbackService.scala | 26 -
.../ecm/server/service/LogCallbackService.scala | 26 -
.../ecm/server/service/YarnCallbackService.scala | 28 -
.../impl/AbstractEngineConnLaunchService.scala | 99 +-
.../impl/BmlResourceLocalizationService.scala | 2 -
.../service/impl/DefaultECMHealthService.scala | 9 +-
.../service/impl/DefaultECMMetricsService.scala | 25 -
.../service/impl/DefaultECMRegisterService.scala | 34 +-
.../service/impl/DefaultEngineConnKillService.java | 242 -----
.../impl/DefaultEngineConnListService.scala | 192 ----
.../impl/DefaultEngineConnPidCallbackService.scala | 39 -
.../DefaultEngineConnStatusCallbackService.scala | 67 --
.../service/impl/DefaultOperateService.scala | 24 +-
.../service/impl/DefaultYarnCallbackService.scala | 40 -
.../server/service/impl/ECMListenerService.scala | 55 +
.../impl/ProcessEngineConnLaunchService.scala | 166 ++-
.../ecm/server/spring/ECMSpringConfiguration.scala | 57 +-
.../impl/DefaultECMRegisterServiceTest.java | 55 +
.../operator/OperableOnceEngineConnOperator.java | 92 ++
.../executor/OnceExecutorExecutionContext.scala | 8 +-
.../once/executor/hook/OnceEngineConnHook.scala | 5 -
.../operator/OperableOnceEngineConnOperator.scala | 72 --
.../concurrent/monitor/HardwareMonitorService.java | 2 +-
.../executor/async/AsyncEngineConnJob.scala | 10 +
.../executor/async/AsyncExecuteExecutor.scala | 16 +-
.../computation/executor/cs/CSTableRegister.scala | 2 +-
.../executor/cs/CSTableResultSetWriter.scala | 2 +-
.../executor/execute/ComputationExecutor.scala | 14 +-
.../executor/execute/EngineExecutionContext.scala | 21 +-
.../executor/hook/ComputationEngineConnHook.scala | 5 -
.../computation/executor/hook/InitSQLHook.scala | 3 +-
.../executor/hook/UDFLoadEngineConnHook.scala | 3 +-
.../executor/hook/UseDatabaseEngineHook.scala | 2 +-
.../service/TaskExecutionServiceImpl.scala | 311 +++---
.../access/ECTaskEntranceInfoAccessHelper.scala | 96 --
.../common/password/CommandPasswordCallback.java | 75 ++
.../common/password/StaticPasswordCallback.java | 40 +
.../engineconn/common/conf/EngineConnConf.scala | 2 +-
.../common/conf/EngineConnConstant.scala | 4 -
.../engineconn/core/util/EngineConnUtils.scala | 8 +-
.../engineconn/launch/EngineConnServer.scala | 1 +
.../acessible/executor/log/AbstractLogCache.java | 38 -
.../acessible/executor/log/MountLogCache.java | 2 +-
.../acessible/executor/log/SendAppender.java | 6 +-
.../acessible/executor/log/TimeLogCache.java | 41 -
.../impl/EngineConnApplicationInfoOperator.java | 56 +
.../conf/AccessibleExecutorConfiguration.scala | 12 +
.../execution/AccessibleEngineConnExecution.scala | 2 +-
.../executor/lock/EngineConnTimedLock.scala | 16 +-
.../acessible/executor/log/LogHelper.scala | 3 -
.../impl/EngineConnApplicationInfoOperator.scala | 50 -
.../service/DefaultAccessibleService.scala | 41 +-
.../executor/service/DefaultManagerService.scala | 3 +-
.../executor/service/DefaultOperateService.scala | 24 +-
.../service/EngineConnTimedLockService.scala | 12 +-
.../acessible/executor/service/LockService.scala | 7 +-
.../executor/utils/AccessableExecutorUtils.scala | 20 -
.../callback/hook/CallbackEngineConnHook.scala | 36 +-
.../service/EngineConnAfterStartCallback.scala | 5 +-
.../callback/service/EngineConnCallback.scala | 22 +-
.../callback/service/EngineConnPidCallback.scala | 4 +-
.../callback/service/EngineConnTimedCallback.scala | 20 -
.../errorcode/EngineconnCoreErrorCodeSummary.java | 6 +-
.../exception/EngineConnPluginErrorCode.scala | 26 -
.../exception/EngineConnPluginErrorException.scala | 7 +-
.../JavaProcessEngineConnLaunchBuilder.scala | 2 +-
.../apache/linkis/entrance/parser/ParserUtils.java | 2 +-
.../persistence/QueryPersistenceManager.java | 6 +
.../entrance/restful/EntranceRestfulApi.java | 2 +-
.../entrance/server/DefaultEntranceServer.java | 3 +-
.../apache/linkis/entrance/EntranceServer.scala | 6 +
.../entrance/execute/DefaultEntranceExecutor.scala | 5 +
.../linkis/entrance/execute/EntranceExecutor.scala | 14 +-
.../entrance/execute/EntranceExecutorManager.scala | 2 +-
.../interceptor/impl/TenantLabelSetUtils.scala | 5 +
.../entrance/parser/CommonEntranceParser.scala | 25 +-
.../persistence/EntranceResultSetEngine.scala | 2 +-
.../linkis-jdbc-driver/pom.xml | 9 +
.../linkis/ujes/jdbc/LinkisSQLErrorCode.java | 62 ++
.../org/apache/linkis/ujes/jdbc/UJESSQLDriver.java | 2 +-
.../apache/linkis/ujes/jdbc/UJESSQLErrorCode.java | 57 -
.../apache/linkis/ujes/jdbc/utils/JDBCUtils.java | 2 -
.../linkis/ujes/jdbc/LinkisSQLConnection.scala | 465 ++++++++
.../linkis/ujes/jdbc/LinkisSQLException.scala | 37 +
.../ujes/jdbc/LinkisSQLPreparedStatement.scala | 351 +++++++
.../linkis/ujes/jdbc/LinkisSQLStatement.scala | 331 ++++++
.../linkis/ujes/jdbc/UJESClientFactory.scala | 22 +-
.../linkis/ujes/jdbc/UJESSQLConnection.scala | 340 ------
.../linkis/ujes/jdbc/UJESSQLDatabaseMetaData.scala | 202 ++--
.../linkis/ujes/jdbc/UJESSQLDriverMain.scala | 17 +-
.../apache/linkis/ujes/jdbc/UJESSQLException.scala | 42 -
.../ujes/jdbc/UJESSQLPreparedStatement.scala | 351 -------
.../apache/linkis/ujes/jdbc/UJESSQLResultSet.scala | 370 +++----
.../ujes/jdbc/UJESSQLResultSetMetaData.scala | 26 +-
.../apache/linkis/ujes/jdbc/UJESSQLStatement.scala | 302 ------
.../linkis/ujes/jdbc/UJESSQLTypeParser.scala | 17 +-
.../jdbc/hook/JDBCDriverPreExecutionHook.scala | 4 +-
.../ujes/jdbc/hook/impl/NoLimitExecutionHook.scala | 6 +-
.../jdbc/hook/impl/TableauPreExecutionHook.scala | 5 +-
.../apache/linkis/ujes/jdbc/CreateConnection.java | 6 +-
.../org/apache/linkis/ujes/jdbc/JDBCSpiTest.java | 12 +-
.../linkis/ujes/jdbc/LinkisSQLStatementTest.java | 155 +++
.../ujes/jdbc/UJESSQLDatabaseMetaDataTest.java | 31 +-
.../ujes/jdbc/UJESSQLPreparedStatementTest.java | 4 +-
.../linkis/ujes/jdbc/UJESSQLResultSetTest.java | 4 +-
.../linkis/ujes/jdbc/UJESSQLStatementTest.java | 155 ---
.../linkis-application-manager/pom.xml | 12 +-
.../loader/EngineConnPluginLoaderConf.java | 44 +
.../loaders/CacheablesEngineConnPluginLoader.java | 3 +-
.../loaders/DefaultEngineConnPluginLoader.java | 27 +-
.../BmlEngineConnPluginResourceLoader.java | 4 +-
.../loader/utils/EngineConnPluginUtils.java | 2 +-
.../server/conf/EngineConnPluginConfiguration.java | 42 +
.../interceptor/EngineConnLaunchInterceptor.java | 30 +
.../loader/EngineConnPluginsLoaderFactory.java | 31 +
.../AbstractEngineConnBmlResourceGenerator.java | 134 +++
.../DefaultEngineConnBmlResourceGenerator.java | 103 ++
.../localize/EngineConnBmlResourceGenerator.java | 30 +
.../localize/EngineConnLocalizeResource.java | 30 +
.../localize/EngineConnLocalizeResourceImpl.java | 69 ++
.../service/DefaultEngineConnLaunchService.java | 106 ++
.../DefaultEngineConnResourceFactoryService.java | 80 ++
.../service/DefaultEngineConnResourceService.java | 351 +++++++
.../server/service/EngineConnLaunchService.java | 26 +
.../service/EngineConnResourceFactoryService.java | 30 +
.../server/service/EngineConnResourceRequest.java | 53 +
.../server/service/EngineConnResourceService.java | 43 +
.../service/GetEngineConnResourceRequest.java | 25 +
.../RefreshAllEngineConnResourceRequest.java | 28 +
.../service/RefreshEngineConnResourceRequest.java | 25 +
.../service/impl/EnginePluginAdminServiceImpl.java | 7 +-
.../linkis/manager/LinkisManagerApplication.java | 29 +
.../manager/am/LinkisManagerApplication.java | 29 -
.../linkis/manager/am/conf/AMConfiguration.java | 125 +++
.../ApplicationManagerSpringConfiguration.java | 32 +
.../manager/am/conf/ConfigurationMapCache.java | 69 ++
.../DefaultEngineConnConfigurationService.java | 72 ++
.../am/conf/EngineConnConfigurationService.java | 28 +
.../linkis/manager/am/conf/ManagerMonitorConf.java | 45 +
.../am/converter/DefaultMetricsConverter.java | 140 +++
.../event/message/EngineConnPidCallbackEvent.java | 36 +
.../manager/am/exception/AMErrorException.java | 10 +-
.../linkis/manager/am/label/AMLabelChecker.java | 56 +
.../linkis/manager/am/label/AMLabelFilter.java | 59 ++
.../am/label/DefaultManagerLabelService.java | 63 ++
.../manager/am/label/EngineReuseLabelChooser.java | 27 +
.../am/label/MultiUserEngineReuseLabelChooser.java | 104 ++
.../manager/am/locker/DefaultEngineNodeLocker.java | 73 ++
.../linkis/manager/am/locker/EngineNodeLocker.java | 29 +
.../manager/am/manager/DefaultEMNodeManager.java | 218 ++++
.../am/manager/DefaultEngineNodeManager.java | 352 +++++++
.../linkis/manager/am/manager/EMNodeManager.java | 73 ++
.../manager/am/manager/EngineNodeManager.java | 67 ++
.../manager/am/pointer/AbstractNodePointer.java | 98 ++
.../manager/am/pointer/DefaultEMNodPointer.java | 111 ++
.../am/pointer/DefaultEngineNodPointer.java | 82 ++
.../am/pointer/DefaultNodePointerBuilder.java | 39 +
.../manager/am/recycle/AssignNodeRuleExecutor.java | 42 +
.../manager/am/recycle/RecyclingRuleExecutor.java | 28 +
.../am/restful/ECResourceInfoRestfulApi.java | 2 +-
.../linkis/manager/am/restful/EMRestfulApi.java | 57 +-
.../manager/am/restful/EngineRestfulApi.java | 4 +-
.../am/selector/DefaultECAvailableRule.java | 43 +
.../manager/am/selector/DefaultNodeSelector.java | 75 ++
.../manager/am/selector/ECAvailableRule.java | 33 +
.../linkis/manager/am/selector/NodeSelector.java | 32 +
.../am/selector/rule/AvailableNodeSelectRule.java | 68 ++
.../selector/rule/ConcurrencyNodeSelectRule.java | 37 +
.../am/selector/rule/HotspotExclusionRule.java | 62 ++
.../am/selector/rule/NewECMStandbyRule.java | 82 ++
.../manager/am/selector/rule/NodeSelectRule.java | 25 +
.../am/selector/rule/ResourceNodeSelectRule.java | 120 +++
.../am/selector/rule/ScoreNodeSelectRule.java | 70 ++
.../am/selector/rule/TaskInfoNodeSelectRule.java | 73 ++
.../linkis/manager/am/service/EMEngineService.java | 40 +
.../am/service/EngineConnPidCallbackService.java | 25 +
.../service/EngineConnStatusCallbackService.java | 25 +
.../linkis/manager/am/service/EngineService.java | 27 +
.../manager/am/service/HeartbeatService.java | 25 +
.../cache/ConfCacheRemoveBroadcastListener.java | 75 ++
.../am/service/em/DefaultECMOperateService.java | 37 +
.../am/service/em/DefaultEMEngineService.java | 231 ++++
.../am/service/em/DefaultEMInfoService.java | 142 +++
.../am/service/em/DefaultEMRegisterService.java | 124 +++
.../am/service/em/DefaultEMUnregisterService.java | 79 ++
.../manager/am/service/em/ECMOperateService.java | 27 +
.../manager/am/service/em/EMInfoService.java | 34 +
.../manager/am/service/em/EMRegisterService.java | 26 +
.../manager/am/service/em/EMUnregisterService.java | 28 +
.../am/service/engine/AbstractEngineService.java | 41 +
.../engine/DefaultEngineAskEngineService.java | 202 ++++
.../engine/DefaultEngineConnCanKillService.java | 196 ++++
.../service/engine/DefaultEngineCreateService.java | 431 ++++++++
.../service/engine/DefaultEngineInfoService.java | 145 +++
.../engine/DefaultEngineOperateService.java | 39 +
.../engine/DefaultEngineRecycleService.java | 92 ++
.../service/engine/DefaultEngineReuseService.java | 265 +++++
.../service/engine/DefaultEngineStopService.java | 316 ++++++
.../service/engine/DefaultEngineSwitchService.java | 34 +
.../am/service/engine/EngineAskEngineService.java | 26 +
.../service/engine/EngineConnCanKillService.java | 26 +
.../engine/EngineConnStatusCallbackService.java | 25 +
.../am/service/engine/EngineCreateService.java | 29 +
.../am/service/engine/EngineInfoService.java | 52 +
.../am/service/engine/EngineOperateService.java | 28 +
.../am/service/engine/EngineRecycleService.java | 28 +
.../am/service/engine/EngineReuseService.java | 29 +
.../am/service/engine/EngineStopService.java | 61 ++
.../am/service/engine/EngineSwitchService.java | 27 +
.../am/service/heartbeat/AMHeartbeatService.java | 86 ++
.../impl/DefaultEngineConnPidCallbackService.java | 61 ++
.../DefaultEngineConnStatusCallbackService.java | 129 +++
.../am/service/impl/ECResourceInfoServiceImpl.java | 8 +-
.../am/service/monitor/NodeHeartbeatMonitor.java | 372 +++++++
.../manager/am/util/ECResourceInfoUtils.java | 2 +-
.../apache/linkis/manager/am/util/LinkisUtils.java | 248 +++++
.../apache/linkis/manager/am/utils/AMUtils.java | 338 ++++++
.../manager/am/utils/DefaultRetryHandler.java | 122 +++
.../linkis/manager/am/utils/RetryHandler.java | 45 +
.../linkis/manager/am/vo/AMEngineNodeVo.java | 6 +-
.../org/apache/linkis/manager/am/vo/EMNodeVo.java | 6 +-
.../linkis/manager/label/LabelManagerUtils.java | 37 +
.../manager/label/conf/LabelManagerConf.java | 26 +
.../label/score/DefaultNodeLabelScorer.java | 203 ++++
.../label/score/LabelScoreServiceInstance.java | 51 +
.../manager/label/score/NodeLabelScorer.java | 41 +
.../manager/label/service/NodeLabelAddService.java | 28 +
.../label/service/NodeLabelRemoveService.java | 25 +
.../manager/label/service/NodeLabelService.java | 83 ++
.../label/service/ResourceLabelService.java | 62 ++
.../manager/label/service/UserLabelService.java | 37 +
.../service/impl/DefaultNodeLabelAddService.java | 69 ++
.../impl/DefaultNodeLabelRemoveService.java | 82 ++
.../service/impl/DefaultNodeLabelService.java | 459 ++++++++
.../service/impl/DefaultResourceLabelService.java | 161 +++
.../service/impl/DefaultUserLabelService.java | 167 +++
.../linkis/manager/rm/conf/ResourceStatus.java | 4 +-
.../linkis/manager/rm/domain/RMLabelContainer.java | 11 +-
.../manager/rm/entity/LabelResourceMapping.java | 68 ++
.../manager/rm/entity/ResourceOperationType.java | 25 +
.../service/impl/ExternalResourceServiceImpl.java | 10 +-
.../manager/rm/external/yarn/YarnAppInfo.java | 78 ++
.../rm/external/yarn/YarnResourceRequester.java | 454 ++++++++
.../manager/rm/message/RMMessageService.java | 75 ++
.../linkis/manager/rm/restful/RMMonitorRest.java | 880 ++++++++++++++++
.../manager/rm/service/LabelResourceService.java | 51 +
.../manager/rm/service/RequestResourceService.java | 422 ++++++++
.../manager/rm/service/ResourceLockService.java | 95 ++
.../linkis/manager/rm/service/ResourceManager.java | 96 ++
.../linkis/manager/rm/service/impl/ChangeType.java | 40 +
.../rm/service/impl/DefaultReqResourceService.java | 37 +
.../rm/service/impl/DefaultResourceManager.java | 894 ++++++++++++++++
.../impl/DriverAndYarnReqResourceService.java | 151 +++
.../rm/service/impl/LabelResourceServiceImpl.java | 102 ++
.../rm/service/impl/ResourceLogService.java | 222 ++++
.../rm/service/impl/UserResourceService.java | 128 +++
.../apache/linkis/manager/rm/utils/RMUtils.java | 288 +++++
.../manager/rm/utils/RequestKerberosUrlUtils.java | 6 -
.../linkis/manager/rm/utils/UserConfiguration.java | 210 ++++
.../manager/service/common/label/LabelChecker.java | 31 +
.../manager/service/common/label/LabelFilter.java | 29 +
.../service/common/label/ManagerLabelService.java | 32 +
.../service/common/metrics/MetricsConverter.java | 55 +
.../service/common/pointer/EMNodPointer.java | 33 +
.../service/common/pointer/EngineNodePointer.java | 34 +
.../service/common/pointer/NodePointer.java | 64 ++
.../service/common/pointer/NodePointerBuilder.java | 28 +
.../mapper/common/EngineConnBmlResourceMapper.xml | 44 +-
.../common/ExternalResourceProviderDaoImpl.xml | 4 +-
.../loader/EngineConnPluginLoaderConf.scala | 50 -
.../conf/EngineConnPluginConfiguration.scala | 42 -
.../interceptor/EngineConnLaunchInterceptor.scala | 34 -
.../server/loader/EngineConnPluginsLoader.scala | 32 -
.../AbstractEngineConnBmlResourceGenerator.scala | 122 ---
.../DefaultEngineConnBmlResourceGenerator.scala | 109 --
.../localize/EngineConnBmlResourceGenerator.scala | 44 -
.../service/DefaultEngineConnLaunchService.scala | 90 --
.../DefaultEngineConnResourceFactoryService.scala | 64 --
.../service/DefaultEngineConnResourceService.scala | 294 ------
.../server/service/EngineConnLaunchService.scala | 31 -
.../service/EngineConnResourceFactoryService.scala | 33 -
.../server/service/EngineConnResourceService.scala | 78 --
.../linkis/manager/am/conf/AMConfiguration.scala | 118 ---
.../manager/am/conf/ConfigurationMapCache.scala | 64 --
.../am/conf/EngineConnConfigurationService.scala | 70 --
.../manager/am/conf/ManagerMonitorConf.scala | 43 -
.../am/converter/DefaultMetricsConverter.scala | 102 --
.../linkis/manager/am/label/AMLabelChecker.scala | 50 -
.../linkis/manager/am/label/AMLabelFilter.scala | 56 -
.../am/label/DefaultManagerLabelService.scala | 72 --
.../manager/am/label/EngineReuseLabelRester.scala | 28 -
.../label/MultiUserEngineReuseLabelChooser.scala | 83 --
.../am/locker/DefaultEngineNodeLocker.scala | 61 --
.../manager/am/locker/EngineNodeLocker.scala | 28 -
.../manager/am/manager/DefaultEMNodeManager.scala | 193 ----
.../am/manager/DefaultEngineNodeManager.scala | 311 ------
.../linkis/manager/am/manager/EMNodeManager.scala | 71 --
.../manager/am/manager/EngineNodeManager.scala | 82 --
.../manager/am/pointer/AbstractNodePointer.scala | 83 --
.../manager/am/pointer/DefaultEMNodPointer.scala | 83 --
.../am/pointer/DefaultEngineNodPointer.scala | 68 --
.../am/pointer/DefaultNodePointerBuilder.scala | 40 -
.../am/recycle/AssignNodeRuleExecutor.scala | 38 -
.../manager/am/recycle/RecyclingRuleExecutor.scala | 29 -
.../linkis/manager/am/rpc/ManagerRPCFormats.scala | 35 -
.../manager/am/selector/DefaultNodeSelector.scala | 75 --
.../manager/am/selector/ECAvailableRule.scala | 55 -
.../linkis/manager/am/selector/NodeSelector.scala | 31 -
.../am/selector/rule/AvailableNodeSelectRule.scala | 60 --
.../selector/rule/ConcurrencyNodeSelectRule.scala | 35 -
.../am/selector/rule/HotspotExclusionRule.scala | 70 --
.../am/selector/rule/NewECMStandbyRule.scala | 83 --
.../manager/am/selector/rule/NodeSelectRule.scala | 26 -
.../am/selector/rule/OverLoadNodeSelectRule.scala | 66 --
.../am/selector/rule/ResourceNodeSelectRule.scala | 101 --
.../am/selector/rule/ScoreNodeSelectRule.scala | 55 -
.../am/selector/rule/TaskInfoNodeSelectRule.scala | 63 --
.../manager/am/service/EMEngineService.scala | 39 -
.../linkis/manager/am/service/EngineService.scala | 28 -
.../manager/am/service/HeartbeatService.scala | 26 -
.../cache/ConfCacheRemoveBroadcastListener.scala | 70 --
.../am/service/em/DefaultECMOperateService.scala | 36 -
.../am/service/em/DefaultEMEngineService.scala | 146 ---
.../am/service/em/DefaultEMInfoService.scala | 124 ---
.../am/service/em/DefaultEMRegisterService.scala | 121 ---
.../am/service/em/DefaultEMUnregisterService.scala | 89 --
.../manager/am/service/em/ECMOperateService.scala | 27 -
.../manager/am/service/em/EMInfoService.scala | 36 -
.../manager/am/service/em/EMRegisterService.scala | 33 -
.../am/service/em/EMUnregisterService.scala | 29 -
.../am/service/engine/AbstractEngineService.scala | 41 -
.../engine/DefaultEngineAskEngineService.scala | 170 ---
.../engine/DefaultEngineConnCanKillService.scala | 173 ---
.../DefaultEngineConnStatusCallbackService.scala | 104 --
.../engine/DefaultEngineCreateService.scala | 405 -------
.../service/engine/DefaultEngineInfoService.scala | 145 ---
.../engine/DefaultEngineOperateService.scala | 42 -
.../engine/DefaultEngineRecycleService.scala | 82 --
.../service/engine/DefaultEngineReuseService.scala | 219 ----
.../service/engine/DefaultEngineStopService.scala | 288 -----
.../engine/DefaultEngineSwitchService.scala | 32 -
.../am/service/engine/EngineAskEngineService.scala | 27 -
.../service/engine/EngineConnCanKillService.scala | 26 -
.../engine/EngineConnStatusCallbackService.scala | 26 -
.../am/service/engine/EngineCreateService.scala | 31 -
.../am/service/engine/EngineInfoService.scala | 50 -
.../am/service/engine/EngineKillService.scala | 31 -
.../am/service/engine/EngineOperateService.scala | 33 -
.../am/service/engine/EngineRecycleService.scala | 29 -
.../am/service/engine/EngineReuseService.scala | 30 -
.../am/service/engine/EngineStopService.scala | 74 --
.../am/service/engine/EngineSwitchService.scala | 29 -
.../am/service/heartbeat/AMHeartbeatService.scala | 83 --
.../am/service/monitor/NodeHeartbeatMonitor.scala | 493 ---------
.../apache/linkis/manager/am/utils/AMUtils.scala | 303 ------
.../linkis/manager/label/LabelManagerUtils.scala | 37 -
.../manager/label/conf/LabelManagerConf.scala | 27 -
.../label/score/DefaultNodeLabelScorer.scala | 182 ----
.../label/score/LabelScoreServiceInstance.scala | 35 -
.../manager/label/score/NodeLabelScorer.scala | 46 -
.../label/service/NodeLabelAddService.scala | 28 -
.../label/service/NodeLabelRemoveService.scala | 26 -
.../manager/label/service/NodeLabelService.scala | 93 --
.../label/service/ResourceLabelService.scala | 68 --
.../manager/label/service/UserLabelService.scala | 38 -
.../service/impl/DefaultNodeLabelAddService.scala | 56 -
.../impl/DefaultNodeLabelRemoveService.scala | 75 --
.../service/impl/DefaultNodeLabelService.scala | 411 --------
.../service/impl/DefaultResourceLabelService.scala | 162 ---
.../service/impl/DefaultUserLabelService.scala | 122 ---
.../manager/rm/entity/LabelResourceMap.scala | 52 -
.../manager/rm/entity/ResourceOperationType.scala | 26 -
.../manager/rm/external/yarn/YarnAppInfo.scala | 29 -
.../rm/external/yarn/YarnResourceRequester.scala | 405 -------
.../manager/rm/message/RMMessageService.scala | 68 --
.../linkis/manager/rm/restful/RMMonitorRest.scala | 783 --------------
.../manager/rm/service/LabelResourceService.scala | 50 -
.../rm/service/RequestResourceService.scala | 399 -------
.../manager/rm/service/ResourceLockService.scala | 80 --
.../manager/rm/service/ResourceManager.scala | 99 --
.../service/impl/DefaultReqResourceService.scala | 32 -
.../rm/service/impl/DefaultResourceManager.scala | 889 ----------------
.../impl/DriverAndYarnReqResourceService.scala | 125 ---
.../rm/service/impl/LabelResourceServiceImpl.scala | 100 --
.../rm/service/impl/ResourceLogService.scala | 240 -----
.../rm/service/impl/UserResourceService.scala | 114 --
.../apache/linkis/manager/rm/utils/RMUtils.scala | 247 -----
.../manager/rm/utils/UserConfiguration.scala | 174 ---
.../service/common/label/LabelChecker.scala | 31 -
.../manager/service/common/label/LabelFilter.scala | 30 -
.../service/common/label/ManagerLabelService.scala | 33 -
.../service/common/metrics/MetricsConverter.scala | 57 -
.../service/common/pointer/EMNodPointer.scala | 33 -
.../service/common/pointer/EngineNodePointer.scala | 34 -
.../service/common/pointer/NodePointer.scala | 70 --
.../common/pointer/NodePointerBuilder.scala | 28 -
.../src/test/java/org/apache/linkis/Scan.java | 26 +
.../org/apache/linkis/WebApplicationServer.java | 34 +
.../engineplugin/server/dao/BaseDaoTest.java | 31 +
.../server/dao/EngineConnBmlResourceDaoTest.java | 111 ++
.../am/util/ECResourceInfoLinkisUtilsTest.java | 52 +
.../dao/ExternalResourceProviderDaoTest.java | 40 +
.../src/test/resources/application.properties | 36 +
.../src/test/resources/create.sql | 47 +
.../src/test/resources/create_pg.sql | 48 +
.../src/test/resources/linkis.properties | 0
.../manager/label/conf/LabelCommonConfig.java | 4 +-
.../manager/label/entity/cluster/ClusterLabel.java | 17 +-
.../manager/label/entity/engine/EngineType.scala | 2 +
.../label/entity/engine/EngineTypeLabel.java | 30 +
.../manager/label/entity/engine/RunType.scala | 3 +-
.../label/exception/LabelErrorException.java | 10 +-
.../linkis/manager/label/utils/LabelUtils.java | 3 +-
.../linkis/manager/label/TestLabelBuilder.java | 5 +-
.../label/entity/engine/EngineTypeLabelTest.java | 46 +-
.../linkis-manager/linkis-manager-common/pom.xml | 14 -
.../manager/common/conf/ManagerCommonConf.java | 35 +
.../manager/common/conf/RMConfiguration.java | 114 ++
.../manager/common/entity/node/AMEMNode.java | 29 +-
.../manager/common/entity/node/AMEngineNode.java | 19 +-
.../manager/common/entity/node/EngineNode.java | 4 -
.../manager/common/entity/node/InfoRMNode.java | 23 +
.../manager/common/entity/node/LabelNode.java | 4 +-
.../linkis/manager/common/entity/node/Node.java | 8 +
.../entity/persistence/ECResourceInfoRecord.java | 16 +
.../common/entity/persistence/PersistenceNode.java | 20 +
.../entity/persistence/PersistenceNodeEntity.java | 23 +
.../entity/persistence/PersistenceNodeMetrics.java | 5 +-
.../common/entity/recycle/AssignEMNodeRule.java | 41 +
.../common/entity/recycle/AssignNodeRule.java | 41 +
.../common/entity/recycle/AssignUserRule.java | 32 +
.../common/entity/recycle/RecyclingRule.java | 23 +
.../common/entity/resource/CPUResource.java | 132 +++
.../entity/resource/DriverAndYarnResource.java | 222 ++++
.../common/entity/resource/InstanceResource.java | 54 +
.../entity/resource/LoadInstanceResource.java | 161 +++
.../common/entity/resource/LoadResource.java | 129 +++
.../common/entity/resource/MemoryResource.java | 120 +++
.../manager/common/entity/resource/Resource.java | 134 +++
.../common/entity/resource/SpecialResource.java | 355 +++++++
.../entity/resource/UserAvailableResource.java | 36 +
.../common/entity/resource/YarnResource.java | 176 ++++
.../manager/common/exception/RMErrorException.java | 10 +-
.../manager/common/monitor/ManagerMonitor.java | 20 +
.../linkis/manager/common/operator/Operator.java | 56 +
.../manager/common/operator/OperatorFactory.java | 33 +
.../common/operator/OperatorFactoryImpl.java | 72 ++
.../linkis/manager/common/protocol/EngineLock.java | 22 +
.../manager/common/protocol/OperateRequest.java | 39 +
.../manager/common/protocol/OperateResponse.java | 28 +
.../manager/common/protocol/RequestEngineLock.java | 48 +
.../common/protocol/RequestEngineUnlock.java | 36 +
.../common/protocol/RequestManagerUnlock.java | 59 ++
.../common/protocol/ResponseEngineLock.java | 56 +
.../common/protocol/ResponseEngineUnlock.java | 36 +
.../manager/common/protocol/bml/BmlResource.java | 9 -
.../common/protocol/em/ECMOperateRequest.java | 51 +
.../common/protocol/em/ECMOperateResponse.java | 52 +
.../protocol/em/EMResourceRegisterRequest.java | 79 ++
.../common/protocol/em/RegisterEMRequest.java | 79 ++
.../common/protocol/em/RegisterEMResponse.java | 50 +
.../protocol/engine/EngineAskAsyncResponse.java | 48 +
.../protocol/engine/EngineAsyncResponse.java | 24 +
.../protocol/engine/EngineConnStatusCallback.java | 55 +
.../engine/EngineConnStatusCallbackToAM.java | 69 ++
.../common/protocol/engine/EngineCreateError.java | 61 ++
.../protocol/engine/EngineCreateSuccess.java | 48 +
.../protocol/engine/EngineOperateRequest.java | 42 +
.../protocol/engine/EngineOperateResponse.java | 53 +
.../common/protocol/engine/EngineStopRequest.java | 51 +-
.../common/protocol/label/LabelReportRequest.java | 43 +
.../common/protocol/label/LabelUpdateRequest.java | 36 +
.../common/protocol/resource/ResourceProtocol.java | 22 +
.../protocol/resource/ResourceUsedProtocol.java | 51 +
.../protocol/resource/ResourceWithStatus.java | 103 ++
.../protocol/resource/ResponseTaskRunningInfo.java | 74 ++
.../resource/ResponseTaskYarnResource.java | 41 +
.../linkis/manager/common/utils/ManagerUtils.java | 7 +-
.../linkis/manager/common/utils/ResourceUtils.java | 312 ++++++
.../linkis/manager/rm/AvailableResource.java | 34 +
.../linkis/manager/rm/NotEnoughResource.java | 36 +
.../linkis/manager/rm/RequestResourceAndWait.java | 47 +
.../org/apache/linkis/manager/rm/ResourceInfo.java | 34 +
.../apache/linkis/manager/rm/ResultResource.java | 20 +
.../manager/common/conf/ManagerCommonConf.scala | 30 -
.../manager/common/conf/RMConfiguration.scala | 91 --
.../common/entity/recycle/RecyclingRule.scala | 32 -
.../manager/common/entity/resource/Resource.scala | 848 ---------------
.../manager/common/monitor/ManagerMonitor.scala | 20 -
.../linkis/manager/common/operator/Operator.scala | 44 -
.../manager/common/operator/OperatorFactory.scala | 64 --
.../manager/common/protocol/EngineLock.scala | 39 -
.../manager/common/protocol/OperateRequest.scala | 45 -
.../manager/common/protocol/OperateResponse.scala | 25 -
.../common/protocol/ServiceHealthReport.scala | 27 -
.../manager/common/protocol/ServiceState.scala | 20 -
.../common/protocol/em/ECMOperateRequest.scala | 37 -
.../common/protocol/em/ECMOperateResponse.scala | 32 -
.../protocol/em/EMResourceRegisterRequest.scala | 67 --
.../common/protocol/em/RegisterEMRequest.scala | 67 --
.../common/protocol/em/RegisterEMResponse.scala | 24 -
.../protocol/engine/EngineAsyncResponse.scala | 35 -
.../protocol/engine/EngineConnStatusCallback.scala | 55 -
.../protocol/engine/EngineOperateRequest.scala | 31 -
.../protocol/engine/EngineOperateResponse.scala | 32 -
.../common/protocol/label/LabelUpdateRequest.scala | 27 -
.../protocol/resource/ResourceProtocol.scala | 48 -
.../protocol/resource/ResourceWithStatus.scala | 33 -
.../common/serializer/NodeResourceSerializer.scala | 62 --
.../serializer/RegisterEMRequestSerializer.scala | 58 -
.../manager/common/utils/ResourceUtils.scala | 218 ----
.../linkis/manager/rm/ResourceManagerParam.scala | 51 -
.../apache/linkis/manager/rm/ResultResource.scala | 46 -
.../linkis/manager/dao/NodeManagerMapper.java | 4 +-
.../exception/PersistenceErrorException.java | 10 +-
.../persistence/NodeManagerPersistence.java | 20 +-
.../persistence/NodeMetricManagerPersistence.java | 12 +-
.../persistence/ResourceManagerPersistence.java | 6 +-
.../impl/DefaultNodeManagerPersistence.java | 61 +-
.../impl/DefaultNodeMetricManagerPersistence.java | 27 +-
.../impl/DefaultResourceLabelPersistence.java | 6 +-
.../impl/DefaultResourceManagerPersistence.java | 5 +-
.../mapper/common/ECResourceRecordMapper.xml | 107 --
.../resources/mapper/common/LabelManagerMapper.xml | 541 ----------
.../resources/mapper/common/LockManagerMapper.xml | 16 +-
.../resources/mapper/common/NodeManagerMapper.xml | 147 ++-
.../mapper/common/NodeMetricManagerMapper.xml | 51 +-
.../mapper/common/ResourceManagerMapper.xml | 101 --
.../mapper/mysql/ECResourceRecordMapper.xml | 129 +++
.../resources/mapper/mysql/LabelManagerMapper.xml | 585 +++++++++++
.../mapper/mysql/ResourceManagerMapper.xml | 148 +++
.../mapper/postgresql/ECResourceRecordMapper.xml | 127 +++
.../mapper/postgresql/LabelManagerMapper.xml | 540 ++++++++++
.../mapper/postgresql/ResourceManagerMapper.xml | 104 ++
.../manager/dao/ECResourceRecordMapperTest.java | 134 +++
.../linkis/manager/dao/LabelManagerMapperTest.java | 293 ++++++
.../linkis/manager/dao/NodeManagerMapperTest.java | 3 +-
.../manager/dao/ResourceManagerMapperTest.java | 45 +-
.../src/test/resources/application.properties | 4 +
.../src/test/resources/create.sql | 53 +-
.../src/test/resources/create_pg.sql | 189 ++++
linkis-dist/bin/checkEnv.sh | 4 +-
linkis-dist/bin/install-linkis-to-kubernetes.sh | 81 +-
linkis-dist/bin/install.sh | 220 ++--
linkis-dist/deploy-config/db.sh | 7 +
linkis-dist/deploy-config/linkis-env.sh | 10 +-
linkis-dist/docker/ldh.Dockerfile | 8 +-
.../licenses/LICENSE-spark-2.4.3-bin-hadoop2.7.txt | 4 -
linkis-dist/docker/scripts/entry-point-ldh.sh | 5 +-
linkis-dist/docker/scripts/prepare-ldh-image.sh | 8 +-
linkis-dist/helm/README.md | 20 +-
linkis-dist/helm/README_CN.md | 20 +-
.../linkis/templates/configmap-init-sql.yaml | 5 +-
.../linkis/templates/configmap-linkis-config.yaml | 49 +-
linkis-dist/helm/charts/linkis/templates/jobs.yaml | 24 +-
.../templates/linkis-cg-engineconnmanager.yaml | 2 +-
.../linkis/templates/linkis-cg-entrance.yaml | 2 +-
.../linkis/templates/linkis-cg-linkismanager.yaml | 2 +-
.../charts/linkis/templates/linkis-mg-eureka.yaml | 6 +-
.../charts/linkis/templates/linkis-mg-gateway.yaml | 2 +-
.../linkis/templates/linkis-ps-publicservice.yaml | 2 +-
linkis-dist/helm/charts/linkis/values.yaml | 6 +-
linkis-dist/helm/scripts/common.sh | 2 +-
.../helm/scripts/install-charts-with-ldh.sh | 5 +-
linkis-dist/helm/scripts/install-charts.sh | 3 +-
linkis-dist/helm/scripts/install-ldh.sh | 5 +-
linkis-dist/helm/scripts/install-linkis.sh | 9 +-
linkis-dist/helm/scripts/install-mysql.sh | 3 +-
linkis-dist/helm/scripts/prepare-for-spark.sh | 8 +-
linkis-dist/package/bin/linkis-cli-hive | 2 +-
linkis-dist/package/bin/linkis-cli-spark-submit | 6 +-
.../conf/linkis-cg-engineconnmanager.properties | 2 +
.../conf/linkis-cg-linkismanager.properties | 5 +-
.../package/conf/linkis-cli/linkis-cli.properties | 4 +-
.../package/conf/linkis-mg-gateway.properties | 1 -
.../conf/linkis-ps-publicservice.properties | 1 -
linkis-dist/package/conf/linkis.properties | 19 +-
linkis-dist/package/conf/log4j2.xml | 2 +-
linkis-dist/package/db/linkis_ddl.sql | 2 +
linkis-dist/package/db/linkis_ddl_pg.sql | 1109 ++++++++++++++++++++
linkis-dist/package/db/linkis_dml.sql | 76 +-
linkis-dist/package/db/linkis_dml_pg.sql | 715 +++++++++++++
.../package/db/module/linkis_configuration_dml.sql | 14 +-
linkis-dist/package/db/module/linkis_manager.sql | 1 +
.../db/upgrade/1.4.0_schema/mysql/linkis_ddl.sql | 19 +
.../db/upgrade/1.4.0_schema/mysql/linkis_dml.sql | 72 ++
.../package/sbin/ext/linkis-cg-linkismanager | 2 +-
linkis-dist/package/sbin/ext/linkis-common-start | 4 +-
linkis-dist/package/sbin/ext/linkis-mg-eureka | 4 +-
linkis-dist/package/sbin/ext/linkis-mg-gateway | 4 +-
.../package/sbin/kill-ec-process-by-port.sh | 28 +
linkis-dist/package/sbin/linkis-daemon.sh | 0
linkis-dist/pom.xml | 8 +-
linkis-dist/release-docs/LICENSE | 6 +-
.../licenses/LICENSE-aliyun-java-sdk-core.txt | 13 +
.../licenses/LICENSE-aliyun-java-sdk-kms.txt | 13 +
.../licenses/LICENSE-aliyun-java-sdk-ram.txt | 13 +
.../licenses/LICENSE-aliyun-sdk-oss.txt | 201 ++++
.../licenses/LICENSE-aws-java-sdk-core.txt | 53 +
.../licenses/LICENSE-aws-java-sdk-kms.txt | 53 +
.../licenses/LICENSE-aws-java-sdk-s3.txt | 53 +
.../licenses/LICENSE-hadoop-aliyun.txt | 270 +++++
.../licenses/LICENSE-hazelcast.txt} | 0
.../{LICENSE-bval.txt => LICENSE-ion-java.txt} | 0
.../licenses/LICENSE-jmespath-java.txt | 53 +
.../licenses/LICENSE-opentracing-api.txt | 201 ++++
.../licenses/LICENSE-opentracing-noop.txt | 201 ++++
.../licenses/LICENSE-opentracing-util.txt | 201 ++++
.../release-docs/licenses/LICENSE-postgresql.txt | 33 +
linkis-engineconn-plugins/elasticsearch/pom.xml | 4 -
.../ElasticSearchEngineConnPlugin.java | 89 ++
...lasticSearchProcessEngineConnLaunchBuilder.java | 31 +
.../conf/ElasticSearchConfiguration.java | 63 ++
.../conf/ElasticSearchEngineConsoleConf.java | 64 ++
.../exception/EsConvertResponseException.java | 27 +
.../exception/EsParamsIllegalException.java | 27 +
.../executor/ElasticSearchEngineConnExecutor.java | 285 +++++
.../executor/client/ElasticSearchExecutor.java | 27 +
.../elasticsearch/executor/client/EsClient.java | 66 ++
.../executor/client/EsClientFactory.java | 220 ++++
.../executor/client/EsClientImpl.java | 106 ++
.../executor/client/EsClientOperate.java | 30 +
.../client/impl/ElasticSearchExecutorImpl.java | 130 +++
.../elasticsearch/src/main/resources/log4j2.xml | 8 +-
.../ElasticSearchEngineConnPlugin.scala | 74 --
...asticSearchProcessEngineConnLaunchBuilder.scala | 30 -
.../conf/ElasticSearchConfiguration.scala | 49 -
.../conf/ElasticSearchEngineConsoleConf.scala | 49 -
.../exception/EsConvertResponseException.scala | 24 -
.../exception/EsEngineException.scala | 22 -
.../exception/EsParamsIllegalException.scala | 24 -
.../executor/ElasticSearchEngineConnExecutor.scala | 232 ----
.../executor/ElasticSearchExecutorOrder.scala | 25 -
.../executor/client/ElasticSearchExecutor.scala | 46 -
.../executor/client/ElasticSearchResponse.scala | 0
.../elasticsearch/executor/client/EsClient.scala | 131 ---
.../executor/client/EsClientFactory.scala | 185 ----
.../executor/client/ResponseHandler.scala | 10 +
.../client/impl/ElasticSearchExecutorImpl.scala | 112 --
.../executor/client/impl/ResponseHandlerImpl.scala | 22 +-
linkis-engineconn-plugins/flink/pom.xml | 41 +-
.../flink/errorcode/FlinkErrorCodeSummary.java | 4 +-
.../flink/operator/TriggerSavepointOperator.java | 92 ++
.../flink/src/main/resources/log4j2.xml | 6 +-
.../flink/config/FlinkEnvConfiguration.scala | 7 +-
.../flink/executor/FlinkExecutor.scala | 6 +-
.../flink/executor/FlinkOnceExecutor.scala | 16 +-
.../interceptor/FlinkJobResCleanInterceptor.scala | 93 ++
.../interceptor/FlinkJobSubmitInterceptor.scala | 50 +
.../factory/FlinkApplicationExecutorFactory.scala | 12 +-
.../flink/factory/FlinkEngineConnFactory.scala | 1 -
.../flink/operator/TriggerSavepointOperator.scala | 49 -
.../resource/FlinkJobLocalResourceCleaner.scala | 69 ++
.../flink/resource/FlinkJobResourceCleaner.scala | 38 +
linkis-engineconn-plugins/hive/pom.xml | 21 +-
.../hive/serde/CustomerDelimitedJSONSerDe.java | 12 -
.../main/resources/linkis-engineconn.properties | 5 +-
.../hive/src/main/resources/log4j2.xml | 12 +-
.../hive/conf/HiveEngineConfiguration.scala | 9 +
.../hive/creation/HiveEngineConnFactory.scala | 119 ++-
.../engineplugin/hive/entity/HiveSession.scala | 11 +-
.../HiveEngineConcurrentConnExecutor.scala | 540 ++++++++++
.../hive/executor/HiveEngineConnExecutor.scala | 8 +-
linkis-engineconn-plugins/impala/pom.xml | 143 +++
.../impala/src/main/assembly/distribution.xml | 70 ++
.../impala/client/ExecutionListener.java | 35 +
.../engineplugin/impala/client/ImpalaClient.java | 77 ++
.../impala/client/ImpalaResultSet.java | 55 +
.../client/exception/ImpalaEngineException.java | 52 +
.../client/exception/ImpalaErrorCodeSummary.java | 51 +
.../impala/client/protocol/ExecHandler.java | 72 ++
.../impala/client/protocol/ExecProgress.java | 47 +
.../impala/client/protocol/ExecStatus.java | 72 ++
.../impala/client/protocol/ExecSummary.java | 45 +
.../impala/client/protocol/QueryColumn.java | 39 +
.../impala/client/thrift/ImpalaThriftClient.java | 278 +++++
.../client/thrift/ImpalaThriftExecution.java | 186 ++++
.../client/thrift/ImpalaThriftResultSetV7.java | 361 +++++++
.../impala/client/thrift/ImpalaThriftSession.java | 104 ++
.../client/thrift/ImpalaThriftSessionFactory.java | 196 ++++
.../impala/client/util/ThriftUtil.java | 65 ++
.../main/resources/linkis-engineconn.properties | 23 +
.../impala/src/main/resources/log4j2.xml | 89 ++
.../impala/ImpalaEngineConnPlugin.scala | 66 ++
.../ImpalaProcessEngineConnLaunchBuilder.scala | 35 +
.../impala/conf/ImpalaConfiguration.scala | 68 ++
.../impala/conf/ImpalaEngineConfig.scala | 48 +
.../impala/executor/ImpalaEngineConnExecutor.scala | 510 +++++++++
.../impala/factory/ImpalaEngineConnFactory.scala | 44 +
.../executer/TestImpalaEngineConnExecutor.scala | 144 +++
linkis-engineconn-plugins/io_file/pom.xml | 10 -
.../io_file/src/main/resources/log4j2.xml | 8 +-
.../io/executor/IoEngineConnExecutor.scala | 93 +-
.../engineplugin/io/service/FsProxyService.scala | 18 +-
.../manager/engineplugin/io/utils/IOHelp.scala | 34 +-
.../src/test/resources/testIoResult.dolphin | 0
.../io/executor/IoEngineConnExecutorTest.java | 73 ++
linkis-engineconn-plugins/jdbc/pom.xml | 15 +-
.../main/resources/linkis-engineconn.properties | 3 +-
.../jdbc/src/main/resources/log4j2.xml | 6 +-
.../jdbc/executor/JDBCEngineConnExecutor.scala | 14 +-
.../engineplugin/jdbc/executor/JDBCHelper.java | 44 +-
linkis-engineconn-plugins/openlookeng/pom.xml | 4 -
.../openlookeng/OpenLooKengECPlugin.java | 85 ++
.../builder/OpenLooKengProcessECLaunchBuilder.java | 2 +-
.../executor/OpenLooKengEngineConnExecutor.java | 4 +-
.../openlookeng/src/main/resources/log4j2.xml | 6 +-
.../openlookeng/OpenLooKengECPlugin.scala | 80 --
linkis-engineconn-plugins/pipeline/pom.xml | 10 -
.../pipeline/src/main/resources/log4j2.xml | 6 +-
linkis-engineconn-plugins/pom.xml | 8 +
linkis-engineconn-plugins/presto/pom.xml | 4 -
.../presto/PrestoEngineConnPlugin.java | 72 ++
.../PrestoProcessEngineConnLaunchBuilder.java | 30 +
.../presto/conf/PrestoConfiguration.java | 63 ++
.../engineplugin/presto/conf/PrestoEngineConf.java | 53 +
.../presto/exception/PrestoClientException.java | 27 +
.../exception/PrestoStateInvalidException.java | 27 +
.../presto/executor/PrestoEngineConnExecutor.java | 468 +++++++++
.../engineplugin/presto/utils/PrestoSQLHook.java | 34 +
.../presto/src/main/resources/log4j2.xml | 8 +-
.../presto/PrestoEngineConnPlugin.scala | 71 --
.../PrestoProcessEngineConnLaunchBuilder.scala | 30 -
.../presto/conf/PrestoConfiguration.scala | 49 -
.../presto/conf/PrestoEngineConf.scala | 46 -
.../presto/exception/PrestoException.scala | 26 -
.../presto/executor/PrestoEngineConnExecutor.scala | 453 --------
.../engineplugin/presto/utils/PrestoSQLHook.scala | 36 -
.../presto/TestPrestoEngineConnPlugin.java | 30 +
.../TestPrestoProcessEngineConnLaunchBuilder.java | 35 +
.../presto/conf/TestPrestoConfiguration.java | 40 +
.../presto/exception/TestPrestoException.java | 42 +
.../factory/TestPrestoEngineConnFactory.java | 43 +
.../presto/utils/TestPrestoSQLHook.java | 31 +
.../presto/TestPrestoEngineConnPlugin.scala | 30 -
.../TestPrestoProcessEngineConnLaunchBuilder.scala | 34 -
.../presto/conf/TestPrestoConfiguration.scala | 42 -
.../presto/exception/TestPrestoException.scala | 36 -
.../factory/TestPrestoEngineConnFactory.scala | 42 -
.../presto/utils/testPrestoSQLHook.scala | 32 -
linkis-engineconn-plugins/python/pom.xml | 10 -
.../python/PythonEngineConnPlugin.java | 80 ++
.../python/conf/PythonEngineConfiguration.java | 51 +
.../python/exception/ExecuteException.java | 26 +
.../python/exception/PythonExecuteError.java | 26 +
.../PythonSessionStartFailedExeception.java | 27 +
.../python/executor/PythonEngineConnExecutor.java | 189 ++++
.../python/hook/PythonVersionEngineHook.java | 78 ++
.../PythonProcessEngineConnLaunchBuilder.java | 22 +
.../manager/engineplugin/python/utils/Kind.java | 92 ++
.../python/src/main/resources/log4j2.xml | 6 +-
.../python/PythonEngineConnPlugin.scala | 75 --
.../python/conf/PythonEngineConfiguration.scala | 49 -
.../exception/NoSupportEngineException.scala | 26 -
.../exception/PythonSessionNullException.scala | 35 -
.../python/executor/PythonEngineConnExecutor.scala | 172 ---
.../python/executor/PythonSession.scala | 22 +-
.../python/factory/PythonEngineConnFactory.scala | 2 +-
.../python/hook/PythonVersionEngineHook.scala | 67 --
.../PythonProcessEngineConnLaunchBuilder.scala | 22 -
.../manager/engineplugin/python/utils/Kind.scala | 104 --
.../manager/engineplugin/python/utils/State.scala | 74 --
.../python/TestPythonEngineConnPlugin.java | 30 +
.../python/conf/TestPythonEngineConfiguration.java | 41 +
.../exception/TestNoSupportEngineException.java | 47 +
.../executor/TestPythonEngineConnExecutor.java | 82 ++
.../factory/TestPythonEngineConnFactory.java | 44 +
.../engineplugin/python/utils/TestKind.java | 42 +
.../python/TestPythonEngineConnPlugin.scala | 30 -
.../conf/TestPythonEngineConfiguration.scala | 43 -
.../exception/TestNoSupportEngineException.scala | 95 --
.../executor/TestPythonEngineConnExecutor.scala | 82 --
.../factory/TestPythonEngineConnFactory.scala | 42 -
.../engineplugin/python/utils/TestKind.scala | 43 -
.../engineplugin/python/utils/TestState.scala | 37 -
linkis-engineconn-plugins/seatunnel/pom.xml | 20 +-
.../seatunnel/client/LinkSeatunnelZetaClient.java | 74 ++
.../client/LinkisSeatunnelFlinkClient.java | 67 --
.../client/LinkisSeatunnelFlinkSQLClient.java | 67 --
.../client/LinkisSeatunnelFlinkV2Client.java | 72 ++
.../client/LinkisSeatunnelSparkClient.java | 74 --
.../client/LinkisSeatunnelSparkV2Client.java | 74 ++
.../errorcode/SeatunnelErrorCodeSummary.java | 2 +-
.../org/apache/seatunnel/common/config/Common.java | 130 ++-
.../seatunnel/core/base/config/ConfigBuilder.java | 26 +-
.../seatunnel/core/base/config/PluginFactory.java | 237 -----
.../apache/seatunnel/core/flink/FlinkStarter.java | 74 --
.../seatunnel/core/flink/FlinkV2Starter.java | 99 ++
.../apache/seatunnel/core/spark/SparkStarter.java | 350 ------
.../seatunnel/core/spark/SparkV2Starter.java | 410 ++++++++
.../apache/seatunnel/core/sql/FlinkSqlStarter.java | 69 --
.../apache/seatunnel/core/zeta/ZetaStarter.java | 90 ++
.../seatunnel/src/main/resources/log4j2.xml | 6 +-
.../config/SeatunnelFlinkEnvConfiguration.scala | 9 +-
.../config/SeatunnelZetaEnvConfiguration.scala | 41 +
.../executor/SeatunnelFlinkOnceCodeExecutor.scala | 21 +-
.../SeatunnelFlinkSQLOnceCodeExecutor.scala | 184 ----
.../executor/SeatunnelSparkOnceCodeExecutor.scala | 4 +-
.../executor/SeatunnelZetaOnceCodeExecutor.scala | 169 +++
.../factory/SeatunnelEngineConnFactory.scala | 11 +-
.../factory/SeatunnelFlinkSQLExecutorFactory.scala | 46 -
.../factory/SeatunnelZetaExecutorFactory.scala | 45 +
.../seatunnel/util/SeatunnelUtils.scala | 15 +-
linkis-engineconn-plugins/shell/pom.xml | 10 -
.../engineplugin/shell/ShellEngineConnPlugin.java | 81 ++
.../ShellProcessEngineConnLaunchBuilder.java | 22 +
.../shell/common/ShellEngineConnPluginConst.java | 24 +
.../shell/conf/ShellEngineConnConf.java | 30 +
.../shell/exception/NoCorrectUserException.java | 28 +
.../shell/exception/ShellCodeErrorException.java | 28 +
.../engineplugin/shell/executor/ReaderThread.java | 97 ++
.../shell/executor/ShellECTaskInfo.java | 54 +
.../ShellEngineConnConcurrentExecutor.java | 151 +++
.../shell/executor/ShellEngineConnExecutor.java | 339 ++++++
.../shell/executor/YarnAppIdExtractor.java | 53 +
.../resources/conf/linkis-engineconn.properties | 3 +-
.../shell/src/main/resources/conf/log4j2.xml | 10 +-
.../engineplugin/shell/ShellEngineConnPlugin.scala | 76 --
.../ShellProcessEngineConnLaunchBuilder.scala | 22 -
.../shell/common/ShellEnginePluginConst.scala | 23 -
.../shell/conf/ShellEngineConnConf.scala | 30 -
.../shell/exception/NoCorrectUserException.scala | 27 -
.../engineplugin/shell/executor/ReaderThread.scala | 96 --
.../shell/executor/ShellECTaskInfo.scala | 20 -
.../ShellEngineConnConcurrentExecutor.scala | 348 ------
.../shell/executor/ShellEngineConnExecutor.scala | 319 ------
.../shell/executor/YarnAppIdExtractor.scala | 81 --
.../shell/factory/ShellEngineConnFactory.scala | 0
.../shell/TestShellEngineConnPlugin.java | 33 +
.../common/TestShellEngineConnPluginConst.java | 32 +
.../exception/TestNoCorrectUserException.java | 34 +
.../executor/TestShellEngineConnExecutor.java | 62 ++
.../shell/TestShellEngineConnPlugin.scala | 33 -
.../common/TestShellEngineConnPluginConst.scala | 33 -
.../exception/TestNoCorrectUserException.scala | 38 -
.../executor/TestShellEngineConnExecutor.scala | 62 --
linkis-engineconn-plugins/spark/pom.xml | 228 +---
linkis-engineconn-plugins/spark/scala-2.12/pom.xml | 970 +++++++++++++++++
.../scala-2.12/src/main/assembly/distribution.xml | 44 +
.../scala-2.12/src/test/resources/etltest.dolphin | 4 +
.../spark/datacalc/TestDeltaCalc.scala | 141 +++
.../spark/datacalc/TestElasticsearchCala.scala | 122 +++
.../engineplugin/spark/datacalc/TestHudiCalc.scala | 146 +++
.../spark/datacalc/TestMongoCala.scala | 120 +++
.../engineplugin/spark/datacalc/TestSolrCala.scala | 121 +++
.../spark/datacalc/TestStarrocksCala.scala | 128 +++
.../spark/client/context/SparkConfig.java | 13 +-
.../YarnApplicationClusterDescriptorAdapter.java | 2 -
.../datacalc/service/LinkisDataSourceContext.java | 4 +
.../datacalc/service/strategy/DmStrategy.java | 36 +
.../service/strategy/KingbaseStrategy.java | 36 +
.../spark/datacalc/sink/DataLakeSinkConfig.java | 71 ++
.../datacalc/sink/ElasticsearchSinkConfig.java | 101 ++
.../spark/datacalc/sink/KafkaSinkConfig.java | 70 ++
.../spark/datacalc/sink/MongoSinkConfig.java | 71 ++
.../spark/datacalc/sink/RedisSinkConfig.java | 90 ++
.../spark/datacalc/sink/RocketmqSinkConfig.java | 66 ++
.../spark/datacalc/sink/SolrSinkConfig.java | 81 ++
.../spark/datacalc/sink/StarrocksSinkConfig.java | 85 ++
.../datacalc/source/DataLakeSourceConfig.java | 56 +
.../datacalc/source/ElasticsearchSourceConfig.java | 95 ++
.../spark/datacalc/source/KafkaSourceConfig.java | 55 +
.../spark/datacalc/source/MongoSourceConfig.java | 55 +
.../spark/datacalc/source/RedisSourceConfig.java | 94 ++
.../datacalc/source/RocketmqSourceConfig.java | 55 +
.../spark/datacalc/source/SolrSourceConfig.java | 45 +
.../datacalc/source/StarrocksSourceConfig.java | 73 ++
.../spark/datacalc/util/PluginUtil.java | 16 +
.../spark/src/main/resources/log4j2.xml | 14 +-
.../spark/Interpreter/Interpreter.scala | 43 -
.../spark/Interpreter/ProcessInterpreter.scala | 125 ---
.../spark/Interpreter/PythonInterpreter.scala | 155 +--
.../engineplugin/spark/SparkEngineConnPlugin.scala | 4 -
.../engineplugin/spark/common/SparkKind.scala | 23 -
.../spark/config/SparkConfiguration.scala | 2 +
.../spark/datacalc/DataCalcExecution.scala | 10 +-
.../spark/datacalc/sink/DataLakeSink.scala | 37 +
.../spark/datacalc/sink/ElasticsearchSink.scala | 55 +
.../spark/datacalc/sink/FileSink.scala | 1 +
.../spark/datacalc/sink/KafkaSink.scala | 47 +
.../spark/datacalc/sink/MongoSink.scala | 52 +
.../spark/datacalc/sink/RedisSink.scala | 53 +
.../spark/datacalc/sink/RocketmqSink.scala | 60 ++
.../spark/datacalc/sink/SolrSink.scala | 52 +
.../spark/datacalc/sink/StarrocksSink.scala | 54 +
.../spark/datacalc/source/DataLakeSource.scala | 41 +
.../datacalc/source/ElasticsearchSource.scala | 48 +
.../spark/datacalc/source/FileSource.scala | 1 +
.../spark/datacalc/source/KafkaSource.scala | 42 +
.../spark/datacalc/source/MongoSource.scala | 45 +
.../spark/datacalc/source/RedisSource.scala | 50 +
.../spark/datacalc/source/RocketmqSource.scala | 44 +
.../spark/datacalc/source/SolrSource.scala | 44 +
.../spark/datacalc/source/StarrocksSource.scala | 49 +
.../engineplugin/spark/executor/SQLSession.scala | 6 +-
.../spark/executor/SparkEngineConnExecutor.scala | 12 +-
.../spark/executor/SparkPythonExecutor.scala | 4 +-
.../spark/executor/SparkScalaExecutor.scala | 4 +-
.../spark/factory/SparkEngineConnFactory.scala | 4 +
.../engineplugin/spark/imexport/ExportData.scala | 13 +-
.../engineplugin/spark/imexport/LoadData.scala | 33 +-
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 2 +-
.../engineplugin/spark/utils/EngineUtils.scala | 4 +-
.../execution/datasources/csv/DolphinToSpark.scala | 26 +-
.../spark/src/test/resources/etltest.dolphin | 4 +
.../spark/datacalc/TestExcelCala.scala | 135 +++
.../spark/datacalc/TestKafkaCala.scala | 118 +++
.../spark/datacalc/TestRedisCalc.scala | 200 ++++
.../spark/datacalc/TestRocketmqCala.scala | 71 ++
linkis-engineconn-plugins/sqoop/pom.xml | 20 +-
.../sqoop/src/main/resources/log4j2.xml | 10 +-
linkis-engineconn-plugins/trino/pom.xml | 4 +-
.../engineplugin/trino/TrinoEngineConnPlugin.java | 78 ++
.../TrinoProcessEngineConnLaunchBuilder.java | 35 +
.../trino/conf/TrinoConfiguration.java | 90 ++
.../engineplugin/trino/conf/TrinoEngineConfig.java | 53 +
.../trino/exception/TrinoClientException.java | 26 +
.../trino/exception/TrinoGrantmaException.java | 26 +
.../exception/TrinoModifySchemaException.java | 26 +
.../exception/TrinoStateInvalidException.java | 26 +
.../trino/executor/TrinoEngineConnExecutor.java | 561 ++++++++++
.../trino/password/CommandPasswordCallback.java | 75 --
.../trino/password/StaticPasswordCallback.java | 40 -
.../linkis/engineplugin/trino/utils/TrinoCode.java | 47 +
.../engineplugin/trino/utils/TrinoSQLHook.java | 34 +
.../main/resources/linkis-engineconn.properties | 1 +
.../trino/src/main/resources/log4j2.xml | 6 +-
.../engineplugin/trino/TrinoEngineConnPlugin.scala | 66 --
.../TrinoProcessEngineConnLaunchBuilder.scala | 37 -
.../trino/conf/TrinoConfiguration.scala | 71 --
.../trino/conf/TrinoEngineConfig.scala | 48 -
.../trino/exception/TrinoException.scala | 32 -
.../trino/executor/TrinoEngineConnExecutor.scala | 534 ----------
.../engineplugin/trino/utils/TrinoCode.scala | 53 -
.../engineplugin/trino/utils/TrinoSQLHook.scala | 36 -
.../linkis/storage/io/client/DefaultIOClient.scala | 4 +-
.../io/iteraceptor/IOMethodInterceptor.scala | 14 +-
.../IOMethodInterceptorCreatorImpl.scala | 4 +-
.../linkis/storage/io/utils/IOClientUtils.scala | 3 +-
linkis-hadoop-hdfs-client-shade/pom.xml | 3 +-
.../catalyst/planner/TaskPlannerTransform.scala | 28 +-
.../physical/CodeLogicalUnitExecTask.scala | 1 +
.../service/ComputationTaskExecutionReceiver.scala | 23 +-
.../ecm/ComputationEngineConnManager.scala | 30 +-
.../ecm/cache/EngineAsyncResponseCache.scala | 16 +-
.../impl/ComputationEngineConnExecutor.scala | 2 +-
.../impl/DefaultEngineAsyncResponseService.scala | 12 +-
.../strategy/async/AsyncExecTaskRunnerImpl.scala | 50 +-
.../utils/OrchestratorLoggerUtils.scala | 37 +
linkis-orchestrator/pom.xml | 1 +
.../server/response/EngineLabelResponse.java | 2 +-
.../mapper/common/CgManagerLabelMapper.xml | 6 +-
.../mapper/common/ConfigurationConfigKeyMapper.xml | 41 -
.../common/ConfigurationConfigValueMapper.xml | 11 +-
.../ConfigurationKeyEngineRelationMapper.xml | 5 +-
.../mapper/common/DatasourceAccessMapper.xml | 8 +-
.../mapper/common/DatasourceEnvMapper.xml | 10 +-
.../mapper/common/DatasourceTypeKeyMapper.xml | 64 --
.../mapper/common/DatasourceTypeMapper.xml | 50 -
.../common/EngineConnPluginBmlResourcesMapper.xml | 98 +-
.../mapper/common/GatewayAuthTokenMapper.xml | 10 +-
.../resources/mapper/common/PsErrorCodeMapper.xml | 47 -
.../common/RmExternalResourceProviderMapper.xml | 12 +-
.../resources/mapper/common/UdfManagerMapper.xml | 6 +-
.../main/resources/mapper/common/UdfTreeMapper.xml | 12 +-
.../mapper/mysql/ConfigurationConfigKeyMapper.xml | 31 +
.../mapper/mysql/DatasourceTypeKeyMapper.xml | 64 ++
.../mapper/mysql/DatasourceTypeMapper.xml | 50 +
.../resources/mapper/mysql/PsErrorCodeMapper.xml | 47 +
.../postgresql/ConfigurationConfigKeyMapper.xml | 68 ++
.../mapper/postgresql/DatasourceTypeKeyMapper.xml | 64 ++
.../mapper/postgresql/DatasourceTypeMapper.xml | 50 +
.../mapper/postgresql/PsErrorCodeMapper.xml | 47 +
.../server/dao/CgManagerLabelMapperTest.java | 45 +
.../dao/ConfigurationConfigKeyMapperTest.java | 86 ++
.../dao/ConfigurationConfigValueMapperTest.java | 65 ++
.../ConfigurationKeyEngineRelationMapperTest.java | 53 +
.../server/dao/DatasourceEnvMapperTest.java | 55 +
.../server/dao/DatasourceTypeKeyMapperTest.java | 39 +
.../server/dao/DatasourceTypeMapperTest.java | 39 +
.../EngineConnPluginBmlResourcesMapperTest.java | 56 +
.../server/dao/GatewayAuthTokenMapperTest.java | 55 +
.../server/dao/PsErrorCodeMapperTest.java | 50 +
.../dao/RmExternalResourceProviderMapperTest.java | 52 +
.../server/dao/UdfManagerMapperTest.java | 47 +
.../server/dao/UdfTreeMapperTest.java | 54 +
.../src/test/resources/application.properties | 17 +-
.../src/test/resources/create.sql | 202 +++-
.../src/test/resources/create_pg.sql | 252 +++++
.../src/test/resources/data.sql | 216 ----
.../linkis-bml/linkis-bml-server/pom.xml | 4 -
.../linkis/bml/service/impl/TaskServiceImpl.java | 2 +-
.../resources/mapper/common/BmlProjectMapper.xml | 62 --
.../resources/mapper/common/DownloadMapper.xml | 6 +-
.../resources/mapper/common/ResourceMapper.xml | 107 --
.../main/resources/mapper/common/TaskMapper.xml | 4 +-
.../main/resources/mapper/common/VersionMapper.xml | 194 ----
.../resources/mapper/mysql/BmlProjectMapper.xml | 78 ++
.../main/resources/mapper/mysql/ResourceMapper.xml | 121 +++
.../main/resources/mapper/mysql/VersionMapper.xml | 243 +++++
.../mapper/postgresql/BmlProjectMapper.xml | 81 ++
.../resources/mapper/postgresql/ResourceMapper.xml | 110 ++
.../resources/mapper/postgresql/VersionMapper.xml | 187 ++++
.../apache/linkis/bml/dao/BmlProjectDaoTest.java | 5 +
.../src/test/resources/application.properties | 4 +
.../src/test/resources/create_pg.sql | 129 +++
.../LinkisConfigurationErrorCodeSummary.java | 2 +-
.../restful/api/ConfigurationRestfulApi.java | 36 +-
.../restful/api/TenantConfigrationRestfulApi.java | 13 +-
.../configuration/service/TenantConfigService.java | 2 +-
.../service/impl/TenantConfigServiceImpl.java | 73 +-
.../main/resources/mapper/common/LabelMapper.xml | 12 +-
.../main/resources/mapper/common/UserIpMapper.xml | 91 --
.../resources/mapper/common/UserTenantMapper.xml | 92 --
.../mapper/{common => mysql}/ConfigMapper.xml | 0
.../main/resources/mapper/mysql/UserIpMapper.xml | 91 ++
.../resources/mapper/mysql/UserTenantMapper.xml | 92 ++
.../resources/mapper/postgresql/ConfigMapper.xml | 265 +++++
.../resources/mapper/postgresql/UserIpMapper.xml | 91 ++
.../mapper/postgresql/UserTenantMapper.xml | 92 ++
.../linkis/configuration/conf/Configuration.scala | 3 +
.../linkis/configuration/dao/ConfigMapperTest.java | 5 +
.../linkis/configuration/dao/UserIpMapperTest.java | 91 ++
.../configuration/dao/UserTenantMapperTest.java | 84 ++
.../restful/api/ConfigurationRestfulApiTest.java | 8 +-
.../src/test/resources/application.properties | 16 +-
.../src/test/resources/create.sql | 65 +-
.../src/test/resources/create_pg.sql | 148 +++
.../src/test/resources/data.sql | 51 -
.../client/builder/RPCHttpContextClientConfig.java | 20 -
.../listener/callback/AbstractCallbackEngine.java | 24 -
.../mapper/common/contextHistoryMapper.xml | 79 --
.../mapper/common/contextIDListenerMapper.xml | 46 -
.../resources/mapper/common/contextIDMapper.xml | 105 --
.../mapper/common/contextKeyListenerMapper.xml | 4 +-
.../resources/mapper/common/contextMapMapper.xml | 168 ---
.../mapper/mysql/contextHistoryMapper.xml | 89 ++
.../mapper/mysql/contextIDListenerMapper.xml | 51 +
.../resources/mapper/mysql/contextIDMapper.xml | 105 ++
.../resources/mapper/mysql/contextMapMapper.xml | 168 +++
.../mapper/postgresql/contextHistoryMapper.xml | 83 ++
.../mapper/postgresql/contextIDListenerMapper.xml | 50 +
.../mapper/postgresql/contextIDMapper.xml | 110 ++
.../mapper/postgresql/contextMapMapper.xml | 172 +++
.../persistence/dao/ContextHistoryMapperTest.java | 6 +-
.../cs/persistence/dao/ContextIDMapperTest.java | 12 +-
.../cs/persistence/dao/ContextMapMapperTest.java | 266 +++++
.../src/test/resources/application.properties | 3 +
.../linkis-cs-server/src/test/resources/create.sql | 16 +
.../src/test/resources/create_pg.sql | 90 ++
.../client/request/MetadataGetColumnsAction.scala | 5 +
.../request/MetadataGetDatabasesAction.scala | 3 +
.../client/request/MetadataGetTablesAction.scala | 4 +
.../GetConnectParamsByDataSourceIdResult.scala | 2 +-
.../response/GetInfoByDataSourceIdResult.scala | 2 +-
.../response/MetadataGetTablePropsResult.scala | 2 +-
.../core/restful/DataSourceCoreRestfulApi.java | 2 +-
.../resources/mapper/common/DataSouceMapper.xml | 144 +--
.../mapper/common/DataSourceEnvMapper.xml | 58 +-
.../mapper/common/DataSourceParamKeyMapper.xml | 60 --
.../mapper/common/DataSourceTypeMapper.xml | 53 -
.../mapper/common/DataSourceVersionMapper.xml | 70 --
.../mapper/mysql/DataSourceParamKeyMapper.xml | 60 ++
.../mapper/mysql/DataSourceTypeMapper.xml | 53 +
.../mapper/mysql/DataSourceVersionMapper.xml | 70 ++
.../mapper/postgresql/DataSourceParamKeyMapper.xml | 59 ++
.../mapper/postgresql/DataSourceTypeMapper.xml | 52 +
.../mapper/postgresql/DataSourceVersionMapper.xml | 71 ++
.../src/test/resources/application.properties | 14 +-
.../server/src/test/resources/create_pg.sql | 119 +++
.../query/common/cache/CacheConfiguration.java | 7 +-
.../query/common/domain/DataSourceTypeEnum.java | 34 +
.../query/common/domain/GenerateSqlInfo.java | 57 +
.../query/common/domain/MetaColumnInfo.java | 9 +
.../common/service/AbstractDbMetaService.java | 34 +
.../query/common/service/GenerateSqlTemplate.java | 68 ++
.../query/common/service/MetadataDbService.java | 20 +
.../server/loader/MetaClassLoaderManager.java | 34 +-
.../query/server/restful/MetadataQueryRestful.java | 114 ++
.../query/server/service/MetadataQueryService.java | 39 +
.../service/impl/MetadataQueryServiceImpl.java | 205 ++++
.../linkis-metadata-query/service/hive/pom.xml | 6 +-
.../metadata/query/service/HiveConnection.java | 10 -
.../metadata/query/service/HiveMetaService.java | 1 -
.../linkis-metadata-query/service/jdbc/pom.xml | 5 -
.../query/service/AbstractSqlConnection.java | 237 +++++
.../query/service/ClickhouseMetaService.java | 24 +-
.../metadata/query/service/Db2MetaService.java | 24 +-
.../metadata/query/service/DmMetaService.java | 24 +-
.../metadata/query/service/DorisMetaService.java | 94 --
.../query/service/GreenplumMetaService.java | 23 +-
.../query/service/KingbaseMetaService.java | 24 +-
.../metadata/query/service/MysqlMetaService.java | 16 +
.../metadata/query/service/OracleMetaService.java | 24 +-
.../query/service/PostgresqlMetaService.java | 23 +-
.../query/service/SqlserverMetaService.java | 24 +-
.../query/service/clickhouse/SqlConnection.java | 116 +-
.../metadata/query/service/db2/SqlConnection.java | 155 +--
.../metadata/query/service/dm/SqlConnection.java | 113 +-
.../query/service/greenplum/SqlConnection.java | 144 +--
.../query/service/kingbase/SqlConnection.java | 133 +--
.../query/service/mysql/SqlConnection.java | 133 +--
.../query/service/oracle/SqlConnection.java | 128 +--
.../query/service/postgres/SqlConnection.java | 144 +--
.../query/service/sqlserver/SqlConnection.java | 119 +--
.../metadata/query/service/KafkaMetaService.java | 5 -
.../linkis-metadata-query/service/mongodb/pom.xml | 2 +-
.../main/resources/mapper/common/HiveMetaDao.xml | 204 ----
.../src/main/resources/mapper/common/MdqDao.xml | 93 --
.../main/resources/mapper/mysql/HiveMetaDao.xml | 273 +++++
.../src/main/resources/mapper/mysql/MdqDao.xml | 100 ++
.../resources/mapper/postgresql/HiveMetaDao.xml | 221 ++++
.../main/resources/mapper/postgresql/MdqDao.xml | 91 ++
.../linkis/metadata/ddl/ImportDDLCreator.scala | 1 -
.../src/test/resources/application.properties | 4 +
.../src/test/resources/create_pg.sql | 233 ++++
.../src/test/resources/application.properties | 15 +-
.../src/test/resources/create.sql | 6 +-
.../src/test/resources/create_pg.sql | 32 +
.../src/test/resources/data.sql | 20 -
.../mapper/common/InsLabelRelationMapper.xml | 203 ----
.../resources/mapper/common/InstanceInfoMapper.xml | 53 -
.../mapper/common/InstanceLabelMapper.xml | 115 --
.../mapper/mysql/InsLabelRelationMapper.xml | 203 ++++
.../resources/mapper/mysql/InstanceInfoMapper.xml | 55 +
.../resources/mapper/mysql/InstanceLabelMapper.xml | 115 ++
.../mapper/postgresql/InsLabelRelationMapper.xml | 202 ++++
.../mapper/postgresql/InstanceInfoMapper.xml | 55 +
.../mapper/postgresql/InstanceLabelMapper.xml | 114 ++
.../label/dao/InsLabelRelationDaoTest.java | 10 +
.../instance/label/dao/InstanceInfoDaoTest.java | 5 +
.../instance/label/dao/InstanceLabelDaoTest.java | 5 +
.../src/test/resources/application.properties | 3 +
.../src/test/resources/create_pg.sql | 65 ++
.../errorcode/JobhistoryErrorCodeSummary.java | 2 +-
.../resources/mapper/common/JobDetailMapper.xml | 22 +-
.../resources/mapper/common/JobHistoryMapper.xml | 232 ----
.../resources/mapper/mysql/JobHistoryMapper.xml | 234 +++++
.../mapper/postgresql/JobHistoryMapper.xml | 232 ++++
.../service/impl/JobHistoryQueryServiceImpl.scala | 2 +
.../linkis/jobhistory/dao/JobDetailMapperTest.java | 95 ++
.../restful/api/QueryRestfulApiTest.java | 4 +-
.../src/test/resources/application.properties | 4 +
.../src/test/resources/create_pg.sql | 62 ++
.../resources/mapper/common/CommonLockMapper.xml | 10 +-
.../src/test/resources/application.properties | 15 +-
.../src/test/resources/create.sql | 5 +
.../src/test/resources/create_pg.sql | 31 +
.../src/test/resources/data.sql | 22 -
.../filesystem/restful/api/BMLFsRestfulApi.java | 11 +-
.../filesystem/restful/api/FsRestfulApi.java | 36 +-
.../src/test/resources/application.properties | 2 +-
.../udf/service/impl/UDFTreeServiceImpl.java | 2 +-
.../src/main/resources/mapper/common/UDFDao.xml | 397 -------
.../main/resources/mapper/common/UDFTreeDao.xml | 56 +-
.../main/resources/mapper/common/UDFVersionDao.xml | 114 --
.../src/main/resources/mapper/mysql/UDFDao.xml | 434 ++++++++
.../main/resources/mapper/mysql/UDFVersionDao.xml | 130 +++
.../main/resources/mapper/postgresql/UDFDao.xml | 404 +++++++
.../resources/mapper/postgresql/UDFVersionDao.xml | 119 +++
.../src/test/resources/application.properties | 17 +-
.../src/test/resources/create.sql | 47 +-
.../src/test/resources/create_pg.sql | 143 +++
.../linkis-udf-service/src/test/resources/data.sql | 61 --
.../src/main/resources/mapper/common/VarMapper.xml | 60 --
.../src/main/resources/mapper/mysql/VarMapper.xml | 64 ++
.../main/resources/mapper/postgresql/VarMapper.xml | 61 ++
.../src/test/resources/application.properties | 16 +-
.../linkis-variable/src/test/resources/create.sql | 18 +-
.../src/test/resources/create_pg.sql | 59 ++
.../linkis-variable/src/test/resources/data.sql | 32 -
.../linkis-service-discovery/linkis-eureka/pom.xml | 51 +-
.../src/main/assembly/distribution.xml | 14 -
.../main/resources/mapper/common/TokenMapper.xml | 6 +-
.../src/test/resources/application.properties | 17 +-
.../src/test/resources/create.sql | 14 +-
.../src/test/resources/create_pg.sql | 45 +
.../src/test/resources/data.sql | 28 -
.../linkis/gateway/security/GatewaySSOUtils.scala | 12 +-
.../linkis/gateway/security/UserRestful.scala | 10 +-
.../linkis/httpclient/dws/response/DWSResult.scala | 4 +-
.../linkis-gateway-server-support/pom.xml | 11 +-
linkis-web/.env | 1 +
linkis-web/package.json | 34 +-
.../release-docs/licenses/LICENSE-autoprefixer.txt | 20 +
.../release-docs/licenses/LICENSE-postcss.txt | 20 +
.../apps/URM/module/functionManagement/index.vue | 2 +-
.../src/apps/URM/module/udfManagement/index.vue | 2 +-
.../src/apps/linkis/assets/styles/console.scss | 7 +-
.../src/apps/linkis/components/variable/index.scss | 1 +
linkis-web/src/apps/linkis/i18n/common/en.json | 15 +-
linkis-web/src/apps/linkis/i18n/common/zh.json | 15 +-
.../src/apps/linkis/module/ECM/engineConn.vue | 5 +-
linkis-web/src/apps/linkis/module/ECM/index.vue | 2 +-
linkis-web/src/apps/linkis/module/ECM/log.vue | 6 +-
.../apps/linkis/module/datasourceAccess/index.vue | 4 +-
.../linkis/module/datasourceEnv/EditForm/index.vue | 17 +-
.../src/apps/linkis/module/datasourceEnv/index.vue | 24 +-
.../apps/linkis/module/datasourceType/index.vue | 4 +-
.../apps/linkis/module/datasourceTypeKey/index.vue | 4 +-
.../src/apps/linkis/module/errorCode/index.vue | 5 +-
.../apps/linkis/module/gatewayAuthToken/index.vue | 6 +-
.../module/globalHistoryManagement/index.vue | 2 +-
.../module/globalHistoryManagement/viewHistory.vue | 1 +
.../apps/linkis/module/ipListManagement/index.vue | 2 +-
.../linkis/module/microServiceManagement/index.vue | 2 +-
.../module/resourceManagement/engineConn.vue | 3 +-
.../linkis/module/resourceManagement/index.vue | 8 +-
.../apps/linkis/module/resourceManagement/log.vue | 6 +-
.../module/rmExternalResourceProvider/index.vue | 13 +-
.../src/apps/linkis/module/setting/setting.vue | 9 +-
.../linkis/module/tenantTagManagement/index.vue | 25 +-
.../src/apps/linkis/module/udfManager/index.vue | 5 +-
.../apps/linkis/module/udfTree/EditForm/index.vue | 109 +-
.../src/apps/linkis/module/udfTree/index.vue | 38 +-
.../src/apps/linkis/module/udfTree/service.js | 4 +-
linkis-web/src/apps/linkis/view/linkis/index.vue | 2 +-
linkis-web/src/common/i18n/en.json | 1 +
linkis-web/src/common/i18n/zh.json | 1 +
.../components/consoleComponent/resultSetList.vue | 6 +-
.../src/components/consoleComponent/toolbar.vue | 7 +
pom.xml | 675 +++++++++---
tool/dependencies/known-dependencies.txt | 351 ++++---
1477 files changed, 65318 insertions(+), 38824 deletions(-)
create mode 160000 .github/actions/chart-testing-action
create mode 160000 .github/actions/kind-action
create mode 100644 .github/workflows/check-sql-pg-script.yml
create mode 100644 .github/workflows/integration-test.yml
create mode 100644 .gitmodules
create mode 100644 docs/configuration/impala.md
create mode 100644 docs/configuration/linkis-metadata-query.md
create mode 100644 docs/impala-usage.md
create mode 100644 docs/info-1.4.0.md
create mode 100644 linkis-commons/linkis-common/src/test/java/org/apache/linkis/common/conf/BDPConfigurationTest.java
create mode 100644 linkis-commons/linkis-common/src/test/java/org/apache/linkis/common/io/FsPathTest.java
create mode 100644 linkis-commons/linkis-common/src/test/java/org/apache/linkis/common/utils/ByteTimeUtilsTest.java
create mode 100644 linkis-commons/linkis-common/src/test/resources/linkis.properties
create mode 100644 linkis-commons/linkis-hadoop-common/src/test/scala/org/apache/linkis/hadoop/common/conf/HDFSUtilsTest.scala
delete mode 100644 linkis-commons/linkis-module/src/main/java/org/apache/linkis/proxy/ProxyUserService.java
delete mode 100644 linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/transform/JavaCollectionSerializer.scala
delete mode 100644 linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/transform/RPCFormats.scala
delete mode 100644 linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/RPCFormatsTest.scala
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/FSFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/LineMetaData.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/LineRecord.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/conf/LinkisStorageConf.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/csv/CSVFsWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/csv/StorageCSVWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/domain/Column.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/domain/DataType.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/domain/Dolphin.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/domain/MethodEntity.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/domain/MethodEntitySerializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/ExcelAnalysisException.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/ExcelFsWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/ExcelXlsReader.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/FirstRowDeal.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/IExcelRowDeal.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/RowToCsvDeal.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/StorageExcelWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/excel/StorageMultiExcelWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/factory/impl/BuildOSSSystem.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/factory/impl/BuildS3FileSystem.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/fs/impl/OSSFileSystem.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/fs/impl/S3FileSystem.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/io/IOClient.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/io/IOClientFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/io/IOMethodInterceptorCreator.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/io/IOMethodInterceptorFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/DefaultResultSetFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/ResultMetaData.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/ResultRecord.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/ResultSetFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/ResultSetReaderFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/ResultSetWriterFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/StorageResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/StorageResultSetReader.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/StorageResultSetWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/html/HtmlResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/io/IOMetaData.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/io/IORecord.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/io/IOResultDeserializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/io/IOResultSerializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/io/IOResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/picture/PictureResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/table/TableMetaData.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/table/TableRecord.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/table/TableResultDeserializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/table/TableResultSerializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/table/TableResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/txt/TextResultDeserializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/txt/TextResultSerializer.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/resultset/txt/TextResultSet.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/Compaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/Parser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/ParserFactory.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/ScriptFsReader.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/ScriptFsWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/ScriptMetaData.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/ScriptRecord.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/Variable.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/VariableParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/compaction/CommonScriptCompaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/compaction/PYScriptCompaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/compaction/QLScriptCompaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/compaction/ScalaScriptCompaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/compaction/ShellScriptCompaction.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/parser/CommonScriptParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/parser/PYScriptParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/parser/QLScriptParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/parser/ScalaScriptParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/parser/ShellScriptParser.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/reader/StorageScriptFsReader.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/script/writer/StorageScriptFsWriter.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/source/AbstractFileSource.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/source/FileSource.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/source/FileSplit.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/source/ResultsetFileSource.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/source/TextFileSource.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/utils/FileSystemUtils.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/utils/StorageConfiguration.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/utils/StorageHelper.java
create mode 100644 linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/utils/StorageUtils.java
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/FSFactory.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/LineMetaData.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/LineRecord.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/conf/LinkisStorageConf.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/csv/CSVFsReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/csv/CSVFsWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/csv/StorageCSVReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/csv/StorageCSVWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/domain/DataType.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/domain/Dolphin.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/domain/MethodEntity.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/ExcelFsReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/ExcelFsWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/ExcelXlsReader.java
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/StorageExcelReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/StorageExcelWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/StorageMultiExcelWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/io/IOClient.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/io/IOMethodInterceptorCreator.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/DefaultResultSetFactory.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultMetaData.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultRecord.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultSetFactory.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultSetReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultSetWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/html/HtmlResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/io/IOMetaData.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/io/IORecord.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/io/IOResultDeserializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/io/IOResultSerializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/io/IOResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/picture/PictureResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/table/TableMetaData.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/table/TableRecord.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/table/TableResultDeserializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/table/TableResultSerializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/table/TableResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/txt/TextResultDeserializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/txt/TextResultSerializer.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/txt/TextResultSet.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/ScriptFsReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/ScriptFsWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/VariableParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/compaction/CommonScriptCompaction.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/compaction/PYScriptCompaction.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/compaction/QLScriptCompaction.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/compaction/ScalaScriptCompaction.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/compaction/ShellScriptCompaction.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/parser/CommonScriptParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/parser/PYScriptParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/parser/QLScriptParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/parser/ScalaScriptParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/parser/ShellScriptParser.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/reader/StorageScriptFsReader.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/writer/StorageScriptFsWriter.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/source/AbstractFileSource.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/source/FileSource.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/source/FileSplit.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/source/ResultsetFileSource.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/source/TextFileSource.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/FileSystemUtils.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageConfiguration.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageHelper.scala
delete mode 100644 linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala
create mode 100644 linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/LineMetaDataTest.java
create mode 100644 linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/resultset/StorageResultSetWriterFactoryTest.java
create mode 100644 linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/source/ResultsetFileSourceTest.java
create mode 100644 linkis-commons/linkis-storage/src/test/resources/result-read-test.dolphin
create mode 100644 linkis-commons/linkis-storage/src/test/resources/storage-read-test.dolphin
delete mode 100644 linkis-computation-governance/linkis-client/linkis-cli/linkis-cli-core/src/main/java/org/apache/linkis/cli/core/constants/CommonKeys.java
create mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/java/org/apache/linkis/governance/common/utils/ECPathUtils.java
create mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/java/org/apache/linkis/governance/common/utils/LoggerUtils.java
delete mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernaceCommonConf.scala
create mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernanceCommonConf.scala
delete mode 100644 linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/ECPathUtils.scala
create mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnLogOperator.java
create mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java
create mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/service/impl/DefaultEngineConnKillService.java
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/operator/EngineConnLogOperator.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/ECMMetricsService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/EngineConnListService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/EngineConnPidCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/EngineConnStatusCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/LogCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/YarnCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultECMMetricsService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultEngineConnKillService.java
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultEngineConnListService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultEngineConnPidCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultEngineConnStatusCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultYarnCallbackService.scala
create mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/ECMListenerService.scala
create mode 100644 linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/test/java/org/apache/linkis/ecm/server/service/impl/DefaultECMRegisterServiceTest.java
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/java/org/apache/linkis/engineconn/once/executor/operator/OperableOnceEngineConnOperator.java
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/operator/OperableOnceEngineConnOperator.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/test/scala/org/apache/linkis/engineconn/computation/executor/upstream/access/ECTaskEntranceInfoAccessHelper.scala
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-common/src/main/java/org/apache/linkis/engineconn/common/password/CommandPasswordCallback.java
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-common/src/main/java/org/apache/linkis/engineconn/common/password/StaticPasswordCallback.java
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/java/org/apache/linkis/engineconn/acessible/executor/log/AbstractLogCache.java
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/java/org/apache/linkis/engineconn/acessible/executor/log/TimeLogCache.java
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/java/org/apache/linkis/engineconn/acessible/executor/operator/impl/EngineConnApplicationInfoOperator.java
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/operator/impl/EngineConnApplicationInfoOperator.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/utils/AccessableExecutorUtils.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/callback/service/EngineConnTimedCallback.scala
delete mode 100644 linkis-computation-governance/linkis-engineconn/linkis-engineconn-plugin-core/src/main/scala/org/apache/linkis/manager/engineplugin/common/exception/EngineConnPluginErrorCode.scala
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/LinkisSQLErrorCode.java
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/UJESSQLErrorCode.java
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/LinkisSQLConnection.scala
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/LinkisSQLException.scala
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/LinkisSQLPreparedStatement.scala
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/LinkisSQLStatement.scala
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/UJESSQLConnection.scala
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/UJESSQLException.scala
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/UJESSQLPreparedStatement.scala
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/UJESSQLStatement.scala
create mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/test/java/org/apache/linkis/ujes/jdbc/LinkisSQLStatementTest.java
delete mode 100644 linkis-computation-governance/linkis-jdbc-driver/src/test/java/org/apache/linkis/ujes/jdbc/UJESSQLStatementTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderConf.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/conf/EngineConnPluginConfiguration.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/interceptor/EngineConnLaunchInterceptor.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoaderFactory.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/AbstractEngineConnBmlResourceGenerator.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/DefaultEngineConnBmlResourceGenerator.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/EngineConnBmlResourceGenerator.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/EngineConnLocalizeResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/EngineConnLocalizeResourceImpl.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnLaunchService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceFactoryService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnResourceFactoryService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnResourceRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/GetEngineConnResourceRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/RefreshAllEngineConnResourceRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/RefreshEngineConnResourceRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/LinkisManagerApplication.java
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/LinkisManagerApplication.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/AMConfiguration.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ApplicationManagerSpringConfiguration.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ConfigurationMapCache.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/DefaultEngineConnConfigurationService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/EngineConnConfigurationService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ManagerMonitorConf.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/converter/DefaultMetricsConverter.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/event/message/EngineConnPidCallbackEvent.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/AMLabelChecker.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/AMLabelFilter.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/DefaultManagerLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/EngineReuseLabelChooser.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/MultiUserEngineReuseLabelChooser.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/locker/DefaultEngineNodeLocker.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/locker/EngineNodeLocker.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEMNodeManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEngineNodeManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/EMNodeManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/EngineNodeManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/AbstractNodePointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultEMNodPointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultEngineNodPointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultNodePointerBuilder.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/recycle/AssignNodeRuleExecutor.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/recycle/RecyclingRuleExecutor.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/DefaultECAvailableRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/DefaultNodeSelector.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/ECAvailableRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/NodeSelector.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/AvailableNodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/ConcurrencyNodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/HotspotExclusionRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/NewECMStandbyRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/NodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/ResourceNodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/ScoreNodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/TaskInfoNodeSelectRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/EMEngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/EngineConnPidCallbackService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/EngineConnStatusCallbackService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/EngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/HeartbeatService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/cache/ConfCacheRemoveBroadcastListener.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultECMOperateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMEngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMInfoService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMRegisterService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMUnregisterService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/ECMOperateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/EMInfoService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/EMRegisterService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/EMUnregisterService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/AbstractEngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineAskEngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineConnCanKillService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineCreateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineInfoService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineOperateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineRecycleService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineReuseService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineStopService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineSwitchService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineAskEngineService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineConnCanKillService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineConnStatusCallbackService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineCreateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineInfoService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineOperateService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineRecycleService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineReuseService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineStopService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineSwitchService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/heartbeat/AMHeartbeatService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/impl/DefaultEngineConnPidCallbackService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/impl/DefaultEngineConnStatusCallbackService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/monitor/NodeHeartbeatMonitor.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/util/LinkisUtils.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/utils/AMUtils.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/utils/DefaultRetryHandler.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/utils/RetryHandler.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/LabelManagerUtils.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/conf/LabelManagerConf.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/score/DefaultNodeLabelScorer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/score/LabelScoreServiceInstance.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/score/NodeLabelScorer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/NodeLabelAddService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/NodeLabelRemoveService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/NodeLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/ResourceLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/UserLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelAddService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelRemoveService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultResourceLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultUserLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/entity/LabelResourceMapping.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/entity/ResourceOperationType.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/external/yarn/YarnAppInfo.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/external/yarn/YarnResourceRequester.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/message/RMMessageService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/restful/RMMonitorRest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/LabelResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/RequestResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/ResourceLockService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/ResourceManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/ChangeType.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/DefaultReqResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/DriverAndYarnReqResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/LabelResourceServiceImpl.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/ResourceLogService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/UserResourceService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/utils/RMUtils.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/utils/UserConfiguration.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/label/LabelChecker.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/label/LabelFilter.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/label/ManagerLabelService.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/metrics/MetricsConverter.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/pointer/EMNodPointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/pointer/EngineNodePointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/pointer/NodePointer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/pointer/NodePointerBuilder.java
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderConf.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/conf/EngineConnPluginConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/interceptor/EngineConnLaunchInterceptor.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoader.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/localize/AbstractEngineConnBmlResourceGenerator.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/localize/DefaultEngineConnBmlResourceGenerator.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/localize/EngineConnBmlResourceGenerator.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnLaunchService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceFactoryService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceFactoryService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/AMConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/ConfigurationMapCache.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/EngineConnConfigurationService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/ManagerMonitorConf.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/converter/DefaultMetricsConverter.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/AMLabelChecker.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/AMLabelFilter.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/DefaultManagerLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/MultiUserEngineReuseLabelChooser.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/locker/DefaultEngineNodeLocker.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/locker/EngineNodeLocker.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/DefaultEMNodeManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/DefaultEngineNodeManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/EMNodeManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/EngineNodeManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/AbstractNodePointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultEMNodPointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultEngineNodPointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultNodePointerBuilder.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/recycle/AssignNodeRuleExecutor.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/recycle/RecyclingRuleExecutor.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/rpc/ManagerRPCFormats.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/DefaultNodeSelector.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/ECAvailableRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/NodeSelector.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/AvailableNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ConcurrencyNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/HotspotExclusionRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/NewECMStandbyRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/NodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/OverLoadNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ResourceNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ScoreNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/TaskInfoNodeSelectRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/EMEngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/EngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/HeartbeatService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/cache/ConfCacheRemoveBroadcastListener.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultECMOperateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMEngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMInfoService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMRegisterService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMUnregisterService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/ECMOperateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/EMInfoService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/EMRegisterService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/EMUnregisterService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/AbstractEngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineAskEngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineConnCanKillService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineConnStatusCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineCreateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineInfoService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineOperateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineRecycleService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineReuseService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineStopService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineSwitchService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineAskEngineService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineConnCanKillService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineConnStatusCallbackService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineCreateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineInfoService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineKillService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineOperateService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineRecycleService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineReuseService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineStopService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineSwitchService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/heartbeat/AMHeartbeatService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/monitor/NodeHeartbeatMonitor.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/utils/AMUtils.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/LabelManagerUtils.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/conf/LabelManagerConf.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/score/DefaultNodeLabelScorer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/score/LabelScoreServiceInstance.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/score/NodeLabelScorer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/NodeLabelAddService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/NodeLabelRemoveService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/NodeLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/ResourceLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/UserLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelAddService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelRemoveService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultResourceLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultUserLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/LabelResourceMap.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/ResourceOperationType.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/external/yarn/YarnAppInfo.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/external/yarn/YarnResourceRequester.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/message/RMMessageService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/restful/RMMonitorRest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/LabelResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/RequestResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/ResourceLockService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/ResourceManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultReqResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DriverAndYarnReqResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/LabelResourceServiceImpl.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/ResourceLogService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/UserResourceService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/UserConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/label/LabelChecker.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/label/LabelFilter.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/label/ManagerLabelService.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/metrics/MetricsConverter.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/EMNodPointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/EngineNodePointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/NodePointer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/NodePointerBuilder.scala
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/Scan.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/WebApplicationServer.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/engineplugin/server/dao/BaseDaoTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/engineplugin/server/dao/EngineConnBmlResourceDaoTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/manager/am/util/ECResourceInfoLinkisUtilsTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/manager/rm/external/dao/ExternalResourceProviderDaoTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/resources/application.properties
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/resources/create.sql
create mode 100644 linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/resources/create_pg.sql
copy linkis-computation-governance/linkis-manager/{linkis-manager-persistence => linkis-application-manager}/src/test/resources/linkis.properties (100%)
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/conf/ManagerCommonConf.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/conf/RMConfiguration.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignEMNodeRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignNodeRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignUserRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/RecyclingRule.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/CPUResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/DriverAndYarnResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/InstanceResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/LoadInstanceResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/LoadResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/MemoryResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/Resource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/SpecialResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/UserAvailableResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/YarnResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/monitor/ManagerMonitor.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/Operator.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/OperatorFactory.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/OperatorFactoryImpl.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/EngineLock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/OperateRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/OperateResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/RequestEngineLock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/RequestEngineUnlock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/RequestManagerUnlock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/ResponseEngineLock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/ResponseEngineUnlock.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/ECMOperateRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/ECMOperateResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/EMResourceRegisterRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/RegisterEMRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/RegisterEMResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineAskAsyncResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineAsyncResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallback.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallbackToAM.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineCreateError.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineCreateSuccess.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineOperateRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineOperateResponse.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/label/LabelReportRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/label/LabelUpdateRequest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResourceProtocol.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResourceUsedProtocol.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResourceWithStatus.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResponseTaskRunningInfo.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResponseTaskYarnResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/utils/ResourceUtils.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/AvailableResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/NotEnoughResource.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/RequestResourceAndWait.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/ResourceInfo.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/ResultResource.java
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/conf/ManagerCommonConf.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/conf/RMConfiguration.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/entity/recycle/RecyclingRule.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/entity/resource/Resource.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/monitor/ManagerMonitor.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/operator/Operator.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/operator/OperatorFactory.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/EngineLock.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/OperateRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/OperateResponse.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/ServiceHealthReport.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/ServiceState.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/ECMOperateRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/ECMOperateResponse.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/EMResourceRegisterRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/RegisterEMRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/RegisterEMResponse.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineAsyncResponse.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallback.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineOperateRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineOperateResponse.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/label/LabelUpdateRequest.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceProtocol.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceWithStatus.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/serializer/NodeResourceSerializer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/serializer/RegisterEMRequestSerializer.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/utils/ResourceUtils.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/rm/ResourceManagerParam.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/rm/ResultResource.scala
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/common/ECResourceRecordMapper.xml
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/common/LabelManagerMapper.xml
delete mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/common/ResourceManagerMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/mysql/ECResourceRecordMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/mysql/LabelManagerMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/mysql/ResourceManagerMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/postgresql/ECResourceRecordMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/postgresql/LabelManagerMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/main/resources/mapper/postgresql/ResourceManagerMapper.xml
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/test/java/org/apache/linkis/manager/dao/ECResourceRecordMapperTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/test/java/org/apache/linkis/manager/dao/LabelManagerMapperTest.java
create mode 100644 linkis-computation-governance/linkis-manager/linkis-manager-persistence/src/test/resources/create_pg.sql
create mode 100644 linkis-dist/package/db/linkis_ddl_pg.sql
create mode 100644 linkis-dist/package/db/linkis_dml_pg.sql
create mode 100644 linkis-dist/package/db/upgrade/1.4.0_schema/mysql/linkis_ddl.sql
create mode 100644 linkis-dist/package/db/upgrade/1.4.0_schema/mysql/linkis_dml.sql
create mode 100644 linkis-dist/package/sbin/kill-ec-process-by-port.sh
mode change 100755 => 100644 linkis-dist/package/sbin/linkis-daemon.sh
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aliyun-java-sdk-core.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aliyun-java-sdk-kms.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aliyun-java-sdk-ram.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aliyun-sdk-oss.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aws-java-sdk-core.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aws-java-sdk-kms.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-aws-java-sdk-s3.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-hadoop-aliyun.txt
copy linkis-dist/{docker/licenses/LICENSE-apache-zookeeper-3.5.9-bin.txt => release-docs/licenses/LICENSE-hazelcast.txt} (100%)
copy linkis-dist/release-docs/licenses/{LICENSE-bval.txt => LICENSE-ion-java.txt} (100%)
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-jmespath-java.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-opentracing-api.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-opentracing-noop.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-opentracing-util.txt
create mode 100644 linkis-dist/release-docs/licenses/LICENSE-postgresql.txt
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/ElasticSearchEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/builder/ElasticSearchProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/conf/ElasticSearchConfiguration.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/conf/ElasticSearchEngineConsoleConf.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/exception/EsConvertResponseException.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/exception/EsParamsIllegalException.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/ElasticSearchExecutor.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClient.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClientFactory.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClientImpl.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClientOperate.java
create mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/client/impl/ElasticSearchExecutorImpl.java
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/ElasticSearchEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/builder/ElasticSearchProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/conf/ElasticSearchConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/conf/ElasticSearchEngineConsoleConf.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsConvertResponseException.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsEngineException.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/exception/EsParamsIllegalException.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchExecutorOrder.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/client/ElasticSearchExecutor.scala
mode change 100644 => 100755 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/client/ElasticSearchResponse.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClient.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/client/EsClientFactory.scala
delete mode 100644 linkis-engineconn-plugins/elasticsearch/src/main/scala/org/apache/linkis/engineplugin/elasticsearch/executor/client/impl/ElasticSearchExecutorImpl.scala
create mode 100644 linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.java
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/interceptor/FlinkJobResCleanInterceptor.scala
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/interceptor/FlinkJobSubmitInterceptor.scala
delete mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.scala
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/resource/FlinkJobLocalResourceCleaner.scala
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/resource/FlinkJobResourceCleaner.scala
create mode 100644 linkis-engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConcurrentConnExecutor.scala
create mode 100644 linkis-engineconn-plugins/impala/pom.xml
create mode 100644 linkis-engineconn-plugins/impala/src/main/assembly/distribution.xml
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/ExecutionListener.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/ImpalaClient.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/ImpalaResultSet.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/exception/ImpalaEngineException.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/exception/ImpalaErrorCodeSummary.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/protocol/ExecHandler.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/protocol/ExecProgress.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/protocol/ExecStatus.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/protocol/ExecSummary.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/protocol/QueryColumn.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/thrift/ImpalaThriftClient.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/thrift/ImpalaThriftExecution.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/thrift/ImpalaThriftResultSetV7.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/thrift/ImpalaThriftSession.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/thrift/ImpalaThriftSessionFactory.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/java/org/apache/linkis/engineplugin/impala/client/util/ThriftUtil.java
create mode 100644 linkis-engineconn-plugins/impala/src/main/resources/linkis-engineconn.properties
create mode 100644 linkis-engineconn-plugins/impala/src/main/resources/log4j2.xml
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/ImpalaEngineConnPlugin.scala
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/builder/ImpalaProcessEngineConnLaunchBuilder.scala
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/conf/ImpalaConfiguration.scala
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/conf/ImpalaEngineConfig.scala
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/executor/ImpalaEngineConnExecutor.scala
create mode 100644 linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/factory/ImpalaEngineConnFactory.scala
create mode 100644 linkis-engineconn-plugins/impala/src/test/scala/org/apache/linkis/engineplugin/impala/executer/TestImpalaEngineConnExecutor.scala
create mode 100644 linkis-engineconn-plugins/io_file/src/test/resources/testIoResult.dolphin
create mode 100644 linkis-engineconn-plugins/io_file/src/test/scala/org/apache/linkis/manager/engineplugin/io/executor/IoEngineConnExecutorTest.java
create mode 100644 linkis-engineconn-plugins/openlookeng/src/main/java/org/apache/linkis/engineplugin/openlookeng/OpenLooKengECPlugin.java
delete mode 100644 linkis-engineconn-plugins/openlookeng/src/main/scala/org/apache/linkis/engineplugin/openlookeng/OpenLooKengECPlugin.scala
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/PrestoEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/builder/PrestoProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/conf/PrestoConfiguration.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/conf/PrestoEngineConf.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/exception/PrestoClientException.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/exception/PrestoStateInvalidException.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.java
create mode 100644 linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/utils/PrestoSQLHook.java
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/PrestoEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/builder/PrestoProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/conf/PrestoConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/conf/PrestoEngineConf.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/exception/PrestoException.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/utils/PrestoSQLHook.scala
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/TestPrestoEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/builder/TestPrestoProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/conf/TestPrestoConfiguration.java
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/exception/TestPrestoException.java
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/factory/TestPrestoEngineConnFactory.java
create mode 100644 linkis-engineconn-plugins/presto/src/test/java/org/apache/linkis/engineplugin/presto/utils/TestPrestoSQLHook.java
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/TestPrestoEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/builder/TestPrestoProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/conf/TestPrestoConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/exception/TestPrestoException.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/factory/TestPrestoEngineConnFactory.scala
delete mode 100644 linkis-engineconn-plugins/presto/src/test/scala/org/apache/linkis/engineplugin/presto/utils/testPrestoSQLHook.scala
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/PythonEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/conf/PythonEngineConfiguration.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/exception/ExecuteException.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/exception/PythonExecuteError.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/exception/PythonSessionStartFailedExeception.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/executor/PythonEngineConnExecutor.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/hook/PythonVersionEngineHook.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/launch/PythonProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/python/src/main/java/org/apache/linkis/manager/engineplugin/python/utils/Kind.java
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/PythonEngineConnPlugin.scala
delete mode 100755 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/conf/PythonEngineConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/exception/NoSupportEngineException.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/exception/PythonSessionNullException.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/executor/PythonEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/hook/PythonVersionEngineHook.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/launch/PythonProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/utils/Kind.scala
delete mode 100644 linkis-engineconn-plugins/python/src/main/scala/org/apache/linkis/manager/engineplugin/python/utils/State.scala
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/TestPythonEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/conf/TestPythonEngineConfiguration.java
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/exception/TestNoSupportEngineException.java
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/executor/TestPythonEngineConnExecutor.java
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/factory/TestPythonEngineConnFactory.java
create mode 100644 linkis-engineconn-plugins/python/src/test/java/org/apache/linkis/manager/engineplugin/python/utils/TestKind.java
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/TestPythonEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/conf/TestPythonEngineConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/exception/TestNoSupportEngineException.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/executor/TestPythonEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/factory/TestPythonEngineConnFactory.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/utils/TestKind.scala
delete mode 100644 linkis-engineconn-plugins/python/src/test/scala/org/apache/linkis/manager/engineplugin/python/utils/TestState.scala
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkSeatunnelZetaClient.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkisSeatunnelFlinkClient.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkisSeatunnelFlinkSQLClient.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkisSeatunnelFlinkV2Client.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkisSeatunnelSparkClient.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/linkis/engineconnplugin/seatunnel/client/LinkisSeatunnelSparkV2Client.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/base/config/PluginFactory.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/flink/FlinkStarter.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/flink/FlinkV2Starter.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/spark/SparkV2Starter.java
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/sql/FlinkSqlStarter.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/java/org/apache/seatunnel/core/zeta/ZetaStarter.java
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/scala/org/apache/linkis/engineconnplugin/seatunnel/config/SeatunnelZetaEnvConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/scala/org/apache/linkis/engineconnplugin/seatunnel/executor/SeatunnelFlinkSQLOnceCodeExecutor.scala
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/scala/org/apache/linkis/engineconnplugin/seatunnel/executor/SeatunnelZetaOnceCodeExecutor.scala
delete mode 100644 linkis-engineconn-plugins/seatunnel/src/main/scala/org/apache/linkis/engineconnplugin/seatunnel/factory/SeatunnelFlinkSQLExecutorFactory.scala
create mode 100644 linkis-engineconn-plugins/seatunnel/src/main/scala/org/apache/linkis/engineconnplugin/seatunnel/factory/SeatunnelZetaExecutorFactory.scala
mode change 100755 => 100644 linkis-engineconn-plugins/shell/pom.xml
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/ShellEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/builder/ShellProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/common/ShellEngineConnPluginConst.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/conf/ShellEngineConnConf.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/exception/NoCorrectUserException.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/exception/ShellCodeErrorException.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/executor/ReaderThread.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/executor/ShellECTaskInfo.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/executor/ShellEngineConnConcurrentExecutor.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/executor/ShellEngineConnExecutor.java
create mode 100644 linkis-engineconn-plugins/shell/src/main/java/org/apache/linkis/manager/engineplugin/shell/executor/YarnAppIdExtractor.java
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/ShellEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/builder/ShellProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/common/ShellEnginePluginConst.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/conf/ShellEngineConnConf.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/exception/NoCorrectUserException.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ReaderThread.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ShellECTaskInfo.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ShellEngineConnConcurrentExecutor.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/ShellEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/executor/YarnAppIdExtractor.scala
mode change 100644 => 100755 linkis-engineconn-plugins/shell/src/main/scala/org/apache/linkis/manager/engineplugin/shell/factory/ShellEngineConnFactory.scala
create mode 100644 linkis-engineconn-plugins/shell/src/test/java/org/apache/linkis/manager/engineplugin/shell/TestShellEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/shell/src/test/java/org/apache/linkis/manager/engineplugin/shell/common/TestShellEngineConnPluginConst.java
create mode 100644 linkis-engineconn-plugins/shell/src/test/java/org/apache/linkis/manager/engineplugin/shell/exception/TestNoCorrectUserException.java
create mode 100644 linkis-engineconn-plugins/shell/src/test/java/org/apache/linkis/manager/engineplugin/shell/executor/TestShellEngineConnExecutor.java
delete mode 100644 linkis-engineconn-plugins/shell/src/test/scala/org/apache/linkis/manager/engineplugin/shell/TestShellEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/test/scala/org/apache/linkis/manager/engineplugin/shell/common/TestShellEngineConnPluginConst.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/test/scala/org/apache/linkis/manager/engineplugin/shell/exception/TestNoCorrectUserException.scala
delete mode 100644 linkis-engineconn-plugins/shell/src/test/scala/org/apache/linkis/manager/engineplugin/shell/executor/TestShellEngineConnExecutor.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/pom.xml
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/main/assembly/distribution.xml
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/resources/etltest.dolphin
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestDeltaCalc.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestElasticsearchCala.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestHudiCalc.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestMongoCala.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestSolrCala.scala
create mode 100644 linkis-engineconn-plugins/spark/scala-2.12/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestStarrocksCala.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/service/strategy/DmStrategy.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/service/strategy/KingbaseStrategy.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/DataLakeSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/ElasticsearchSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/KafkaSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/MongoSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/RedisSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/RocketmqSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/SolrSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/sink/StarrocksSinkConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/DataLakeSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/ElasticsearchSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/KafkaSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/MongoSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/RedisSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/RocketmqSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/SolrSourceConfig.java
create mode 100644 linkis-engineconn-plugins/spark/src/main/java/org/apache/linkis/engineplugin/spark/datacalc/source/StarrocksSourceConfig.java
delete mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/Interpreter/Interpreter.scala
delete mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/Interpreter/ProcessInterpreter.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/DataLakeSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/ElasticsearchSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/KafkaSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/MongoSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/RedisSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/RocketmqSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/SolrSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/sink/StarrocksSink.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/DataLakeSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/ElasticsearchSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/KafkaSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/MongoSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/RedisSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/RocketmqSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/SolrSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/datacalc/source/StarrocksSource.scala
create mode 100644 linkis-engineconn-plugins/spark/src/test/resources/etltest.dolphin
create mode 100644 linkis-engineconn-plugins/spark/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestExcelCala.scala
create mode 100644 linkis-engineconn-plugins/spark/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestKafkaCala.scala
create mode 100644 linkis-engineconn-plugins/spark/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestRedisCalc.scala
create mode 100644 linkis-engineconn-plugins/spark/src/test/scala/org/apache/linkis/engineplugin/spark/datacalc/TestRocketmqCala.scala
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/TrinoEngineConnPlugin.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/builder/TrinoProcessEngineConnLaunchBuilder.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/conf/TrinoConfiguration.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/conf/TrinoEngineConfig.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/exception/TrinoClientException.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/exception/TrinoGrantmaException.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/exception/TrinoModifySchemaException.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/exception/TrinoStateInvalidException.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java
delete mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/password/CommandPasswordCallback.java
delete mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/password/StaticPasswordCallback.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/utils/TrinoCode.java
create mode 100644 linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/utils/TrinoSQLHook.java
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/TrinoEngineConnPlugin.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/builder/TrinoProcessEngineConnLaunchBuilder.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/conf/TrinoConfiguration.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/conf/TrinoEngineConfig.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/exception/TrinoException.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/utils/TrinoCode.scala
delete mode 100644 linkis-engineconn-plugins/trino/src/main/scala/org/apache/linkis/engineplugin/trino/utils/TrinoSQLHook.scala
create mode 100644 linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/utils/OrchestratorLoggerUtils.scala
delete mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/common/ConfigurationConfigKeyMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/common/DatasourceTypeKeyMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/common/DatasourceTypeMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/common/PsErrorCodeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/mysql/ConfigurationConfigKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/mysql/DatasourceTypeKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/mysql/DatasourceTypeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/mysql/PsErrorCodeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/postgresql/ConfigurationConfigKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/postgresql/DatasourceTypeKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/postgresql/DatasourceTypeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/main/resources/mapper/postgresql/PsErrorCodeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/CgManagerLabelMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/ConfigurationConfigKeyMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/ConfigurationConfigValueMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/ConfigurationKeyEngineRelationMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/DatasourceEnvMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/DatasourceTypeKeyMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/DatasourceTypeMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/EngineConnPluginBmlResourcesMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/GatewayAuthTokenMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/PsErrorCodeMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/RmExternalResourceProviderMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/UdfManagerMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/java/org/apache/linkis/basedatamanager/server/dao/UdfTreeMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-basedata-manager/src/test/resources/data.sql
delete mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/common/BmlProjectMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/common/ResourceMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/common/VersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/mysql/BmlProjectMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/mysql/ResourceMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/mysql/VersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/postgresql/BmlProjectMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/postgresql/ResourceMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/main/resources/mapper/postgresql/VersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-bml/linkis-bml-server/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/common/UserIpMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/common/UserTenantMapper.xml
rename linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/{common => mysql}/ConfigMapper.xml (100%)
create mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/mysql/UserIpMapper.xml
create mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/mysql/UserTenantMapper.xml
create mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/postgresql/ConfigMapper.xml
create mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/postgresql/UserIpMapper.xml
create mode 100644 linkis-public-enhancements/linkis-configuration/src/main/resources/mapper/postgresql/UserTenantMapper.xml
create mode 100644 linkis-public-enhancements/linkis-configuration/src/test/java/org/apache/linkis/configuration/dao/UserIpMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-configuration/src/test/java/org/apache/linkis/configuration/dao/UserTenantMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-configuration/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-configuration/src/test/resources/data.sql
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-client/src/main/java/org/apache/linkis/cs/client/builder/RPCHttpContextClientConfig.java
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-listener/src/main/java/org/apache/linkis/cs/listener/callback/AbstractCallbackEngine.java
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/common/contextHistoryMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/common/contextIDListenerMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/common/contextIDMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/common/contextMapMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/mysql/contextHistoryMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/mysql/contextIDListenerMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/mysql/contextIDMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/mysql/contextMapMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/postgresql/contextHistoryMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/postgresql/contextIDListenerMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/postgresql/contextIDMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/main/resources/mapper/postgresql/contextMapMapper.xml
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/test/java/org/apache/linkis/cs/persistence/dao/ContextMapMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-context-service/linkis-cs-server/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/common/DataSourceParamKeyMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/common/DataSourceTypeMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/common/DataSourceVersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/mysql/DataSourceParamKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/mysql/DataSourceTypeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/mysql/DataSourceVersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/postgresql/DataSourceParamKeyMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/postgresql/DataSourceTypeMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/resources/mapper/postgresql/DataSourceVersionMapper.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/test/resources/create_pg.sql
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata-query/common/src/main/java/org/apache/linkis/metadata/query/common/domain/DataSourceTypeEnum.java
create mode 100755 linkis-public-enhancements/linkis-datasource/linkis-metadata-query/common/src/main/java/org/apache/linkis/metadata/query/common/domain/GenerateSqlInfo.java
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata-query/common/src/main/java/org/apache/linkis/metadata/query/common/service/GenerateSqlTemplate.java
create mode 100755 linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/AbstractSqlConnection.java
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/DorisMetaService.java
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/common/HiveMetaDao.xml
delete mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/common/MdqDao.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/mysql/HiveMetaDao.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/mysql/MdqDao.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/postgresql/HiveMetaDao.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/main/resources/mapper/postgresql/MdqDao.xml
create mode 100644 linkis-public-enhancements/linkis-datasource/linkis-metadata/src/test/resources/create_pg.sql
create mode 100644 linkis-public-enhancements/linkis-error-code/linkis-error-code-server/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-error-code/linkis-error-code-server/src/test/resources/data.sql
delete mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/common/InsLabelRelationMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/common/InstanceInfoMapper.xml
delete mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/common/InstanceLabelMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/mysql/InsLabelRelationMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/mysql/InstanceInfoMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/mysql/InstanceLabelMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/postgresql/InsLabelRelationMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/postgresql/InstanceInfoMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/main/resources/mapper/postgresql/InstanceLabelMapper.xml
create mode 100644 linkis-public-enhancements/linkis-instance-label/linkis-instance-label-server/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-jobhistory/src/main/resources/mapper/common/JobHistoryMapper.xml
create mode 100644 linkis-public-enhancements/linkis-jobhistory/src/main/resources/mapper/mysql/JobHistoryMapper.xml
create mode 100644 linkis-public-enhancements/linkis-jobhistory/src/main/resources/mapper/postgresql/JobHistoryMapper.xml
create mode 100644 linkis-public-enhancements/linkis-jobhistory/src/test/java/org/apache/linkis/jobhistory/dao/JobDetailMapperTest.java
create mode 100644 linkis-public-enhancements/linkis-jobhistory/src/test/resources/create_pg.sql
create mode 100644 linkis-public-enhancements/linkis-ps-common-lock/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-ps-common-lock/src/test/resources/data.sql
delete mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/common/UDFDao.xml
delete mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/common/UDFVersionDao.xml
create mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/mysql/UDFDao.xml
create mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/mysql/UDFVersionDao.xml
create mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/postgresql/UDFDao.xml
create mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/main/resources/mapper/postgresql/UDFVersionDao.xml
create mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-udf/linkis-udf-service/src/test/resources/data.sql
delete mode 100644 linkis-public-enhancements/linkis-variable/src/main/resources/mapper/common/VarMapper.xml
create mode 100644 linkis-public-enhancements/linkis-variable/src/main/resources/mapper/mysql/VarMapper.xml
create mode 100644 linkis-public-enhancements/linkis-variable/src/main/resources/mapper/postgresql/VarMapper.xml
create mode 100644 linkis-public-enhancements/linkis-variable/src/test/resources/create_pg.sql
delete mode 100644 linkis-public-enhancements/linkis-variable/src/test/resources/data.sql
create mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/resources/create_pg.sql
delete mode 100644 linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/test/resources/data.sql
create mode 100644 linkis-web/release-docs/licenses/LICENSE-autoprefixer.txt
create mode 100644 linkis-web/release-docs/licenses/LICENSE-postcss.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org