Github user jinossy commented on a diff in the pull request:
https://github.com/apache/tajo/pull/936#discussion_r50494584
--- Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/Stage.java ---
@@ -1415,8 +1434,9 @@ public StageState transition(Stage stage, StageEvent
stageEvent) {
stage.abort(StageState.KILLED);
return StageState.KILLED;
} else {
- LOG.error("Invalid State " + stage.getSynchronizedState() + "
State");
- stage.abort(StageState.ERROR);
+ TajoInternalError error = new TajoInternalError("Invalid State
" + stage.getSynchronizedState() + " State");
--- End diff --
@jihoonson
this else clause seems to never be executed. I will remove this code block
for clarify
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---