You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by wa...@apache.org on 2022/05/09 07:53:04 UTC
[incubator-linkis] 03/03: optimize code
This is an automated email from the ASF dual-hosted git repository.
wangzhen pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit d3b4b443e02e590d0958a14bc8158196d2c23977
Author: peacewong <wp...@gmail.com>
AuthorDate: Mon May 9 15:09:33 2022 +0800
optimize code
---
.../linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala b/linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala
index d91225d95..53bf60169 100644
--- a/linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala
+++ b/linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala
@@ -406,7 +406,7 @@ class HiveEngineConnExecutor(id: Int,
}
logger.debug(s"hive progress is $totalProgress")
- val newProgress = if (totalProgress.isNaN || totalProgress.isInfinite) currentBegin else totalProgress + currentBegin
+ val newProgress = if (totalProgress.isNaN || totalProgress.isInfinite) currentBegin else totalProgress + currentBegin
val oldProgress = ProgressUtils.getOldProgress(this.engineExecutorContext)
if(newProgress < oldProgress) oldProgress else {
ProgressUtils.putProgress(newProgress, this.engineExecutorContext)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org