diff --git a/ql/src/test/org/apache/hadoop/hive/ql/TestTxnLoadData.java b/ql/src/test/org/apache/hadoop/hive/ql/TestTxnLoadData.java index fb88f25285..45f9e522f2 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/TestTxnLoadData.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/TestTxnLoadData.java @@ -378,10 +378,10 @@ public void testValidations() throws Exception { runStatementOnDriver("create table Tstage (a int, b int) stored as orc tblproperties('transactional'='false')"); //this creates an ORC data file with correct schema under table root runStatementOnDriver("insert into Tstage values(1,2),(3,4)"); - CommandProcessorResponse cpr = runStatementOnDriverNegative("load data local inpath '" + getWarehouseDir() + "' into table T"); - // This condition should not occur with the new support of rewriting load into IAS. - Assert.assertFalse(cpr.getErrorMessage().contains("Load into bucketed tables are disabled")); + // This will work with the new support of rewriting load into IAS. + runStatementOnDriver("load data local inpath '" + getWarehouseDir() + "/Tstage' into table T"); } + private void checkExpected(List rs, String[][] expected, String msg) { super.checkExpected(rs, expected, msg, LOG, true); } diff --git a/storage-api/src/java/org/apache/hadoop/hive/common/ValidTxnWriteIdList.java b/storage-api/src/java/org/apache/hadoop/hive/common/ValidTxnWriteIdList.java index 9867a81a7b..46b2238fe9 100644 --- a/storage-api/src/java/org/apache/hadoop/hive/common/ValidTxnWriteIdList.java +++ b/storage-api/src/java/org/apache/hadoop/hive/common/ValidTxnWriteIdList.java @@ -57,8 +57,9 @@ public void addTableValidWriteIdList(ValidWriteIdList validWriteIds) { // Input fullTableName is of format . public ValidWriteIdList getTableValidWriteIdList(String fullTableName) { - if (tablesValidWriteIdList.containsKey(fullTableName)) { - return tablesValidWriteIdList.get(fullTableName); + String fullNameLowerCase = fullTableName.toLowerCase(); + if (tablesValidWriteIdList.containsKey(fullNameLowerCase)) { + return tablesValidWriteIdList.get(fullNameLowerCase); } return null; }