[ 
https://issues.apache.org/jira/browse/HIVE-25346?focusedWorklogId=649855&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-649855
 ]

ASF GitHub Bot logged work on HIVE-25346:
-----------------------------------------

                Author: ASF GitHub Bot
            Created on: 13/Sep/21 07:41
            Start Date: 13/Sep/21 07:41
    Worklog Time Spent: 10m 
      Work Description: pvary commented on a change in pull request #2547:
URL: https://github.com/apache/hive/pull/2547#discussion_r707080469



##########
File path: 
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
##########
@@ -531,7 +531,7 @@ public void cleanTxnToWriteIdTable() throws MetaException {
         String s = "SELECT MIN(\"RES\".\"ID\") AS \"ID\" FROM (" +
             "SELECT MAX(\"TXN_ID\") + 1 AS \"ID\" FROM \"TXNS\" " +
             "UNION " +
-            "SELECT MIN(\"WS_COMMIT_ID\") AS \"ID\" FROM \"WRITE_SET\" " +
+            "SELECT MIN(\"WS_TXNID\") AS \"ID\" FROM \"WRITE_SET\" " +

Review comment:
       This was the original code, so we might want to check 
`findMinOpenTxnGLB`:
   ```
           // First need to find the min_uncommitted_txnid which is currently 
seen by any open transactions.
           // If there are no txns which are currently open or aborted in the 
system, then current value of
           // NEXT_TXN_ID.ntxn_next could be min_uncommitted_txnid.
           long minUncommittedTxnId = findMinOpenTxnGLB(stmt);
   
           // If there are aborted txns, then the minimum aborted txnid could 
be the min_uncommitted_txnid
           // if lesser than both NEXT_TXN_ID.ntxn_next and 
min(MIN_HISTORY_LEVEL .mhl_min_open_txnid).
           String s = "SELECT MIN(\"TXN_ID\") FROM \"TXNS\" WHERE \"TXN_STATE\" 
= " + TxnStatus.ABORTED;
           LOG.debug("Going to execute query <" + s + ">");
           rs = stmt.executeQuery(s);
           if (rs.next()) {
             long minAbortedTxnId = rs.getLong(1);
             if (minAbortedTxnId > 0) {
               minUncommittedTxnId = Math.min(minAbortedTxnId, 
minUncommittedTxnId);
             }
           }
   ```




-- 
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


Issue Time Tracking
-------------------

    Worklog Id:     (was: 649855)
    Time Spent: 6h  (was: 5h 50m)

> cleanTxnToWriteIdTable breaks SNAPSHOT isolation
> ------------------------------------------------
>
>                 Key: HIVE-25346
>                 URL: https://issues.apache.org/jira/browse/HIVE-25346
>             Project: Hive
>          Issue Type: Bug
>            Reporter: Zoltan Chovan
>            Assignee: Zoltan Chovan
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 6h
>  Remaining Estimate: 0h
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to