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..97f0e0b 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,8 @@ import org.apache.hadoop.io.IOUtils; import com.google.common.collect.Collections2; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.DataOutputStream; import java.io.IOException; @@ -39,6 +41,7 @@ import java.util.UUID; public class Utils { + private static Logger LOG = LoggerFactory.getLogger(Utils.class); public static final String BOOTSTRAP_DUMP_STATE_KEY_PREFIX = "bootstrap.dump.state."; public enum ReplDumpState { @@ -111,6 +114,8 @@ 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; } @@ -123,6 +128,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); } } }