diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java index eade36f..948ebf7 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java @@ -196,14 +196,14 @@ private Long bootStrapDump(Path dumpRoot, DumpMetaData dmd, Path cmRoot) throws Path dbRoot = dumpDbMetadata(dbName, dumpRoot); dumpFunctionMetadata(dbName, dumpRoot); - String uniqueKey = Utils.setDbBootstrapDumpState(hiveDb, dbName); + String uniqueKey = Utils.setDbBootstrapDumpState(hiveDb, dbName, LOG); for (String tblName : Utils.matchesTbl(hiveDb, dbName, work.tableNameOrPattern)) { LOG.debug( "analyzeReplDump dumping table: " + tblName + " to db root " + dbRoot.toUri()); dumpTable(dbName, tblName, dbRoot); dumpConstraintMetadata(dbName, tblName, dbRoot); } - Utils.resetDbBootstrapDumpState(hiveDb, dbName, uniqueKey); + Utils.resetDbBootstrapDumpState(hiveDb, dbName, uniqueKey, LOG); replLogger.endLog(bootDumpBeginReplId.toString()); } Long bootDumpEndReplId = hiveDb.getMSC().getCurrentNotificationEventId().getEventId(); diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java index a1da629..a638f0e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java @@ -29,6 +29,7 @@ import org.apache.hadoop.io.IOUtils; import com.google.common.collect.Collections2; +import org.slf4j.Logger; import java.io.DataOutputStream; import java.io.IOException; @@ -90,7 +91,8 @@ public static void writeOutput(List values, Path outputFile, HiveConf hi }); } - public static String setDbBootstrapDumpState(Hive hiveDb, String dbName) throws HiveException { + public static String setDbBootstrapDumpState(Hive hiveDb, String dbName, Logger LOG) + throws HiveException { Database database = hiveDb.getDatabase(dbName); if (database == null) { return null; @@ -111,11 +113,13 @@ public static String setDbBootstrapDumpState(Hive hiveDb, String dbName) throws } hiveDb.alterDatabase(dbName, database); + LOG.info("REPL DUMP:: Set property for Database: {}, Property: {}, Value: {}", + dbName, uniqueKey, Utils.ReplDumpState.ACTIVE.name()); return uniqueKey; } public static void resetDbBootstrapDumpState(Hive hiveDb, String dbName, - String uniqueKey) throws HiveException { + String uniqueKey, Logger LOG) throws HiveException { Database database = hiveDb.getDatabase(dbName); if (database != null) { Map params = database.getParameters(); @@ -123,6 +127,7 @@ public static void resetDbBootstrapDumpState(Hive hiveDb, String dbName, params.remove(uniqueKey); database.setParameters(params); hiveDb.alterDatabase(dbName, database); + LOG.info("REPL DUMP:: Reset property for Database: {}, Property: {}", dbName, uniqueKey); } } }