[GitHub] [hive] deniskuzZ commented on a diff in pull request #3172: HIVE-26107: Worker shouldn't inject duplicate entries in `ready for cleaning` state into the compaction queue

[GitBox]

deniskuzZ commented on code in PR #3172:
URL: https://github.com/apache/hive/pull/3172#discussion_r860674098


##########
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java:
##########
@@ -197,6 +198,9 @@ static void gatherStats(CompactionInfo ci, HiveConf conf, 
String userName, Strin
           statusUpdaterConf.set(TezConfiguration.TEZ_QUEUE_NAME, 
compactionQueueName);
         }
         SessionState sessionState = 
DriverUtils.setUpSessionState(statusUpdaterConf, userName, true);
+        Map<String, String> hiveVariables = sessionState.getHiveVariables();
+        hiveVariables.put(Constants.INSIDE_COMPACTION_TRANSACTION_FLAG, 
"true");
+        sessionState.setHiveVariables(hiveVariables);

Review Comment:
   could we create sessionState.setHiveVariable() method in SessionState?



-- 
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: gitbox-unsubscr...@hive.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: gitbox-unsubscr...@hive.apache.org
For additional commands, e-mail: gitbox-h...@hive.apache.org