HIVE-21227: HIVE-20776 causes view access regression (Na Li reviewed by Karthik Manam...
authorNa Li <lina.li@cloudera.com>
Fri, 8 Feb 2019 15:18:41 +0000 (16:18 +0100)
committerPeter Vary <pvary@cloudera.com>
Fri, 8 Feb 2019 15:18:41 +0000 (16:18 +0100)
standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestFilterHooks.java

index a1826fa..fcd0d44 100644 (file)
@@ -2506,8 +2506,11 @@ public class HiveMetaStoreClient implements IMetaStoreClient, AutoCloseable {
   private void checkDbAndTableFilters(final String catName, final String dbName, final String tblName)
       throws NoSuchObjectException, MetaException {
 
+    // HIVE-20776 causes view access regression
+    // Therefore, do not do filtering here. Call following function only to check
+    // if dbName and tblName is valid
     FilterUtils.checkDbAndTableFilters(
-        isClientFilterEnabled, filterHook, catName, dbName, tblName);
+        false, filterHook, catName, dbName, tblName);
   }
 
   @Override
index 6a0d0aa..49c7d88 100644 (file)
@@ -278,7 +278,7 @@ public class TestFilterHooks {
 
     testFilterForDb(true);
     testFilterForTables(true);
-    testFilterForPartition();
+    testFilterForPartition(true);
   }
 
   /**
@@ -321,7 +321,7 @@ public class TestFilterHooks {
 
     testFilterForDb(false);
     testFilterForTables(false);
-    testFilterForPartition();
+    testFilterForPartition(false);
   }
 
   protected void testFilterForDb(boolean filterAtServer) throws Exception {
@@ -360,7 +360,7 @@ public class TestFilterHooks {
     assertEquals(0, client.getTables(DBNAME1, TAB2).size());
   }
 
-  protected void testFilterForPartition() throws Exception {
+  protected void testFilterForPartition(boolean filterAtServer) throws Exception {
     try {
       assertNotNull(client.getPartition(DBNAME1, TAB2, "name=value1"));
       fail("getPartition() should fail with blocking mode");
@@ -368,11 +368,21 @@ public class TestFilterHooks {
       // Excepted
     }
 
-    try {
-      client.getPartitionsByNames(DBNAME1, TAB2,
-          Lists.newArrayList("name=value1")).size();
-    } catch (NoSuchObjectException e) {
-      // Excepted
+    if (filterAtServer) {
+      // at HMS server, the table of the partitions should be filtered out and result in
+      // NoSuchObjectException
+      try {
+        client.getPartitionsByNames(DBNAME1, TAB2,
+            Lists.newArrayList("name=value1")).size();
+        fail("getPartitionsByNames() should fail with blocking mode at server side");
+      } catch (NoSuchObjectException e) {
+        // Excepted
+      }
+    } else {
+      // at HMS client, we cannot filter the table of the partitions due to
+      // HIVE-21227: HIVE-20776 causes view access regression
+      assertEquals(0, client.getPartitionsByNames(DBNAME1, TAB2,
+          Lists.newArrayList("name=value1")).size());
     }
   }
 }