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..3d74b1d35a 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,13 +260,12 @@ 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 (!EximUtil.shouldExportTable(replicationSpec, tableHandle)) { + return; } - if (tableHandle == null){ - replicationSpec.setNoop(true); + if (replicationSpec == null) { + replicationSpec = new ReplicationSpec(); // instantiate default values if not specified } try (JsonWriter writer = new JsonWriter(fs, metadataPath)) { 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); }