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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
