You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@linkis.apache.org by GitBox <gi...@apache.org> on 2022/05/07 09:58:19 UTC
[GitHub] [incubator-linkis] peacewong opened a new pull request, #2088: Fix hive task progress rollback issue
peacewong opened a new pull request, #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088
### What is the purpose of the change
close #2079
### Brief change log
- Fix hive task progress rollback issue
- Add a separate ec status scan time configuration
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] wForget commented on a diff in pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
wForget commented on code in PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088#discussion_r867680033
##########
linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala:
##########
@@ -405,8 +406,12 @@ class HiveEngineConnExecutor(id: Int,
}
logger.debug(s"hive progress is $totalProgress")
- if (totalProgress.isNaN || totalProgress.isInfinite) return currentBegin
- totalProgress + currentBegin
+ val newProgress = if (totalProgress.isNaN || totalProgress.isInfinite) currentBegin else totalProgress + currentBegin
Review Comment:
nit: extra space before currentBegin
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] peacewong commented on a diff in pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
peacewong commented on code in PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088#discussion_r867698847
##########
linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala:
##########
@@ -405,8 +406,12 @@ class HiveEngineConnExecutor(id: Int,
}
logger.debug(s"hive progress is $totalProgress")
- if (totalProgress.isNaN || totalProgress.isInfinite) return currentBegin
- totalProgress + currentBegin
+ val newProgress = if (totalProgress.isNaN || totalProgress.isInfinite) currentBegin else totalProgress + currentBegin
Review Comment:
> nit: extra space before currentBegin
I will fix this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] codecov[bot] commented on pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
codecov[bot] commented on PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088#issuecomment-1120181881
# [Codecov](https://codecov.io/gh/apache/incubator-linkis/pull/2088?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
> Merging [#2088](https://codecov.io/gh/apache/incubator-linkis/pull/2088?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (506e608) into [dev-1.1.2](https://codecov.io/gh/apache/incubator-linkis/commit/e1ec0127d4ca92aa21dbd6f65f948cda1f1ec50b?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (e1ec012) will **not change** coverage.
> The diff coverage is `n/a`.
```diff
@@ Coverage Diff @@
## dev-1.1.2 #2088 +/- ##
============================================
Coverage 18.45% 18.45%
Complexity 703 703
============================================
Files 344 344
Lines 10723 10723
Branches 1608 1608
============================================
Hits 1979 1979
Misses 8539 8539
Partials 205 205
```
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/incubator-linkis/pull/2088?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/incubator-linkis/pull/2088?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Last update [e1ec012...506e608](https://codecov.io/gh/apache/incubator-linkis/pull/2088?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] wForget commented on pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
wForget commented on PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088#issuecomment-1120764500
Thanks, merged into master.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] wForget merged pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
wForget merged PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org
[GitHub] [incubator-linkis] wForget commented on a diff in pull request #2088: Fix hive task progress rollback issue
Posted by GitBox <gi...@apache.org>.
wForget commented on code in PR #2088:
URL: https://github.com/apache/incubator-linkis/pull/2088#discussion_r867680033
##########
linkis-engineconn-plugins/engineconn-plugins/hive/src/main/scala/org/apache/linkis/engineplugin/hive/executor/HiveEngineConnExecutor.scala:
##########
@@ -405,8 +406,12 @@ class HiveEngineConnExecutor(id: Int,
}
logger.debug(s"hive progress is $totalProgress")
- if (totalProgress.isNaN || totalProgress.isInfinite) return currentBegin
- totalProgress + currentBegin
+ val newProgress = if (totalProgress.isNaN || totalProgress.isInfinite) currentBegin else totalProgress + currentBegin
Review Comment:
nit: extra space
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@linkis.apache.org
For additional commands, e-mail: notifications-help@linkis.apache.org