Repository: hive
Updated Branches:
  refs/heads/master 4bba139d3 -> 188f7fb47


HIVE-17681: HIVE-17681: Need to log bootstrap dump progress state property to 
HS2 logs (Sankar Hariappan, reviewed by Anishek Agarwal)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/188f7fb4
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/188f7fb4
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/188f7fb4

Branch: refs/heads/master
Commit: 188f7fb47aec3f98ef53965ba6ae84e23bd26f59
Parents: 4bba139
Author: Sankar Hariappan <[email protected]>
Authored: Thu Oct 5 18:31:55 2017 +0530
Committer: Sankar Hariappan <[email protected]>
Committed: Thu Oct 5 18:31:55 2017 +0530

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/188f7fb4/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java
----------------------------------------------------------------------
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.hive.ql.parse.SemanticException;
 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.Map;
 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 class Utils {
     }
 
     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 class Utils {
         params.remove(uniqueKey);
         database.setParameters(params);
         hiveDb.alterDatabase(dbName, database);
+        LOG.info("REPL DUMP:: Reset property for Database: {}, Property: {}", 
dbName, uniqueKey);
       }
     }
   }

Reply via email to