potential fix for HiveMetaStoreBridge cleanup commented out code
potential fix for HiveMetaStoreBridge cleanup commented out code potential fix for HiveMetaStoreBridge Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/786b1f3b Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/786b1f3b Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/786b1f3b Branch: refs/remotes/origin/master Commit: 786b1f3b63157e7d8cf09b1bd5ef862729bab29c Parents: 64c7844 Author: Aaron Dossett <[email protected]> Authored: Mon May 4 12:56:15 2015 -0500 Committer: Aaron Dossett <[email protected]> Committed: Mon May 4 14:39:25 2015 -0500 ---------------------------------------------------------------------- .../apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/786b1f3b/addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java ---------------------------------------------------------------------- diff --git a/addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java b/addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java index 6084a68..0a36c36 100755 --- a/addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java +++ b/addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/bridge/HiveMetaStoreBridge.java @@ -203,10 +203,7 @@ public class HiveMetaStoreBridge { Referenceable dbReferenceable, Referenceable tableReferenceable, Referenceable sdReferenceable) throws Exception { - Table table = new Table(); - table.setDbName(db); - table.setTableName(tableName); - Set<Partition> tableParts = hiveClient.getAllPartitionsOf(table); + Set<Partition> tableParts = hiveClient.getAllPartitionsOf(new Table(Table.getEmptyTable(db, tableName))); if (tableParts.size() > 0) { for (Partition hivePart : tableParts) {
