diff --git ql/src/java/org/apache/hadoop/hive/ql/util/UpgradeTool.java ql/src/java/org/apache/hadoop/hive/ql/util/UpgradeTool.java index c523a76659..cb966a7b2e 100644 --- ql/src/java/org/apache/hadoop/hive/ql/util/UpgradeTool.java +++ ql/src/java/org/apache/hadoop/hive/ql/util/UpgradeTool.java @@ -367,8 +367,8 @@ static void handleRenameFiles(Table t, Path p, boolean execute, Configuration co //but will have to look at ORC footers - treat these as copyN files? numCopyNFiles++; } - int wrtieId = fileId / numBuckets + 1;//start with delta_1 (not delta_0) - Path deltaDir = new Path(p, AcidUtils.deltaSubdir(wrtieId, wrtieId)); + int writeId = fileId / numBuckets + 1; // start with delta_1 (not delta_0) + Path deltaDir = new Path(p, AcidUtils.deltaSubdir(writeId, writeId)); if (execute) { if (!fs.mkdirs(deltaDir)) { String msg = "Failed to create directory " + deltaDir; diff --git standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java index 2df61b41ea..6585a9a3ba 100644 --- standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java +++ standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java @@ -1673,7 +1673,7 @@ public void performWriteSetGC() { commitHighWaterMark = lowestOpenTxnId; } int delCnt = stmt.executeUpdate("delete from WRITE_SET where ws_commit_id < " + commitHighWaterMark); - LOG.info("Deleted " + delCnt + " obsolete rows from WRTIE_SET"); + LOG.info("Deleted {} obsolete rows from WRITE_SET", delCnt); dbConn.commit(); } catch (SQLException ex) { LOG.warn("WriteSet GC failed due to " + getMessage(ex), ex);