You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2021/11/09 09:52:50 UTC
[incubator-linkis] branch dev-1.0.3 updated (fd8f667 -> 8af9d00)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a change to branch dev-1.0.3
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git.
from fd8f667 Merge pull request #1059 from saLeox/dev-1.0.3
new 6f7d902 Fixes the bug which will cause the job failed when InsertOperation stopped.
new a8ba20d Fixes some bugs for Flink EngineConn.
new 454efd5 Optimize flink EngineConn in prod mode, reduce the print log of job status.
new f0b293f Optimize flink EngineConn in prod mode for jar application submitting.
new 44b7f69 Optimize the BmlResources launch style of flink jar EngineConn.
new 06f2c33 Optimize the execution of Once EngineConn.
new bb5c01a Optimize the shutdown process of Once EngineConn.
new 013eb8e Optimize the localization process of private BmlResource.
new 8158db1 Add some logs for engineConn launch.
new 56c0fbd Optimize OnceEngineConn architecture.
new 9f23e62 Optimize the kill operation of Flink computation executor.
new b18d617 Fix a bug that will cause the Insert sql to never stop during debugging.
new 8af9d00 Merge pull request #1070 from wushengyeyouya/dev-1.0.3
The 1391 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/ecm/core/conf/ECMErrorCode.scala | 2 +
.../impl/AbstractEngineConnLaunchService.scala | 1 +
.../impl/BmlResourceLocalizationService.scala | 21 ++++++--
.../engineconn/once/executor/OnceExecutor.scala | 16 +++---
.../executor/creation/OnceExecutorManager.scala | 53 ++++++++++++++++++
.../execution/OnceEngineConnExecution.scala | 63 ++++++++++++++++------
.../execute/ComputationEngineConnExecution.scala | 2 +-
.../engineconn/launch/EngineConnServer.scala | 6 +--
.../YarnApplicationClusterDescriptorAdapter.java | 13 ++---
.../factory/LinkisYarnClusterClientFactory.java | 14 ++---
.../client/sql/operation/impl/InsertOperation.java | 15 ++++--
.../flink/config/FlinkEnvConfiguration.scala | 4 +-
.../flink/executor/FlinkJarOnceExecutor.scala | 1 +
.../flink/executor/FlinkOnceExecutor.scala | 31 ++++-------
.../executor/FlinkSQLComputationExecutor.scala | 32 ++++++-----
.../flink/factory/FlinkEngineConnFactory.scala | 13 ++++-
.../launch/FlinkEngineConnLaunchBuilder.scala | 48 +++++++++++++++++
17 files changed, 249 insertions(+), 86 deletions(-)
create mode 100644 linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/creation/OnceExecutorManager.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org