This is an automated email from the ASF dual-hosted git repository.
casion pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
from a8fb845f8 Check spark commands only when ENABLE_SPARK is true and fix
the last print (#4984)
new 172f811dc update default ec idle time to 10 min
new 6558fb2b2 update cs resource file download filename to tmp name
Prevent duplicate file names
new 032a0eb78 ec metrics add last unlock time
new 774b2bfae EC exits unexpectedly and actively kills the task
new 15e0a8f2e code optimize
new 7c9d17a71 fix build issue
new 5aee060cc optimize task log write user to jvm user
new 39aa193bb add template conf feature
new bb7b01014 add entrance metric and consumer can be killed and add task
timeout scan
new a3cf805c8 task log print optimize
new 95855182e error code match log mark to error log
new 5616acc65 add task timeout scan
new 7f1807af8 Fix the occasional loss of logs
new 5c204b244 Merge remote-tracking branch 'upstream/master' into
master-1.5.0
new fe4f1f64b add get all undone task method
new dfb7faf8e add creator task running number limit
new 39081ed78 Fix build issue
new 9ed39efc2 add creator task running number limit
new b704a2aff Merge pull request #4982 from WeDataSphere/master-1.5.0
The 4079 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/linkis/storage/utils/StorageUtils.java | 4 +
.../governance/common/constant/CodeConstants.java | 12 +-
.../governance/common/paser/CodeParser.scala | 3 +-
.../executor/bml/BmlEnginePreExecuteHook.scala | 5 +-
.../executor/conf/ComputationExecutorConf.scala | 6 +
.../computation/executor/cs/CSResourceParser.scala | 20 +-
.../executor/execute/ComputationExecutor.scala | 63 ++++-
.../metrics/ComputationEngineConnMetrics.scala | 8 +
.../service/DefaultNodeHeartbeatMsgManager.scala | 4 +
.../service/TaskExecutionServiceImpl.scala | 115 +++++----
.../upstream/handler/ECTaskKillHandler.scala | 2 +-
.../engineconn/common/conf/EngineConnConf.scala | 4 +
.../conf/AccessibleExecutorConfiguration.scala | 2 +-
.../entrance/conf/EntranceSpringConfiguration.java | 2 +-
.../errorcode/EntranceErrorCodeSummary.java | 5 +
.../restful/EntranceConsumerRestfulApi.java | 88 +++++++
.../entrance/restful/EntranceLabelRestfulApi.java | 33 ++-
.../entrance/restful/EntranceMetricRestfulApi.java | 40 ++-
.../entrance/restful/EntranceRestfulApi.java | 29 +--
.../scheduler/CreatorECTypeDefaultConf.java | 93 +++++++
.../entrance/server/DefaultEntranceServer.java | 2 +-
.../apache/linkis/entrance/EntranceServer.scala | 104 +++++++-
.../linkis/entrance/EntranceWebSocketService.scala | 12 -
.../entrance/conf/EntranceConfiguration.scala | 22 ++
.../interceptor/impl/CommentInterceptor.scala | 1 -
.../linkis/entrance/interceptor/impl/Explain.scala | 72 ++++--
...rceptor.scala => TemplateConfInterceptor.scala} | 14 +-
.../interceptor/impl/TemplateConfUtils.scala | 276 +++++++++++++++++++++
.../impl/VarSubstitutionInterceptor.scala | 18 +-
.../linkis/entrance/log/CacheLogReader.scala | 21 +-
.../linkis/entrance/log/CacheLogWriter.scala | 2 +
.../linkis/entrance/log/ErrorCodeManager.scala | 41 ++-
.../linkis/entrance/log/HDFSCacheLogWriter.scala | 17 +-
.../apache/linkis/entrance/log/LogManager.scala | 16 +-
.../org/apache/linkis/entrance/log/LoopArray.scala | 2 +-
.../EntranceUserParallelOrchestratorPlugin.scala | 40 +--
.../persistence/EntranceResultSetEngine.scala | 28 +--
.../scheduler/EntranceFIFOUserConsumer.scala | 40 ++-
.../entrance/scheduler/EntranceGroupFactory.scala | 120 +++------
.../EntranceParallelConsumerManager.scala | 28 +--
.../cache/CacheOutputExecuteResponse.scala | 24 --
.../scheduler/cache/ReadCacheConsumer.scala | 158 ------------
.../scheduler/cache/ReadCacheConsumerManager.scala | 44 ----
.../entrance/timeout/JobTimeoutManager.scala | 126 +++++-----
.../linkis/entrance/utils/EntranceUtils.scala | 108 ++++++++
.../entrance/interceptor/impl/SQLExplainTest.java | 55 ++++
.../interceptor/impl/TemplateConfUtilsTest.java | 123 +++++++++
.../interceptor/impl/TestCommentHelper.java | 69 ++++++
.../interceptor/impl/TestHDFSCacheLogWriter.java | 82 ++++++
.../manager/label/constant/LabelKeyConstant.java | 4 +
50 files changed, 1569 insertions(+), 638 deletions(-)
copy
linkis-public-enhancements/linkis-pes-common/src/main/java/org/apache/linkis/cs/common/entity/source/YMLContextKey.java
=>
linkis-computation-governance/linkis-computation-governance-common/src/main/java/org/apache/linkis/governance/common/constant/CodeConstants.java
(79%)
create mode 100644
linkis-computation-governance/linkis-entrance/src/main/java/org/apache/linkis/entrance/restful/EntranceConsumerRestfulApi.java
create mode 100644
linkis-computation-governance/linkis-entrance/src/main/java/org/apache/linkis/entrance/scheduler/CreatorECTypeDefaultConf.java
copy
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/{DBInfoCompleteInterceptor.scala
=> TemplateConfInterceptor.scala} (71%)
create mode 100644
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/TemplateConfUtils.scala
delete mode 100644
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/cache/CacheOutputExecuteResponse.scala
delete mode 100644
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/cache/ReadCacheConsumer.scala
delete mode 100644
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/cache/ReadCacheConsumerManager.scala
create mode 100644
linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/utils/EntranceUtils.scala
create mode 100644
linkis-computation-governance/linkis-entrance/src/test/java/org/apache/linkis/entrance/interceptor/impl/SQLExplainTest.java
create mode 100644
linkis-computation-governance/linkis-entrance/src/test/scala/org/apache/linkis/entrance/interceptor/impl/TemplateConfUtilsTest.java
create mode 100644
linkis-computation-governance/linkis-entrance/src/test/scala/org/apache/linkis/entrance/interceptor/impl/TestCommentHelper.java
create mode 100644
linkis-computation-governance/linkis-entrance/src/test/scala/org/apache/linkis/entrance/interceptor/impl/TestHDFSCacheLogWriter.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
