diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java index ece5495d28..3e073e23b4 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java @@ -260,15 +260,9 @@ public static void createExportDump(FileSystem fs, Path metadataPath, org.apache.hadoop.hive.ql.metadata.Table tableHandle, Iterable partitions, ReplicationSpec replicationSpec) throws SemanticException, IOException { - - if (replicationSpec == null){ - replicationSpec = new ReplicationSpec(); // instantiate default values if not specified - } - - if (tableHandle == null){ - replicationSpec.setNoop(true); + if (!EximUtil.shouldExportTable(replicationSpec, tableHandle)) { + return; } - try (JsonWriter writer = new JsonWriter(fs, metadataPath)) { if (replicationSpec.isInReplicationScope()) { new ReplicationSpecSerializer().writeTo(writer, replicationSpec); diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/events/CreateTableHandler.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/events/CreateTableHandler.java index ef6f340013..9ff227ec58 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/events/CreateTableHandler.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/events/CreateTableHandler.java @@ -47,11 +47,6 @@ public void handle(Context withinContext) throws Exception { } Table qlMdTable = new Table(tobj); - - if (!EximUtil.shouldExportTable(withinContext.replicationSpec, qlMdTable)) { - return; - } - if (qlMdTable.isView()) { withinContext.replicationSpec.setIsMetadataOnly(true); }