You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jd...@apache.org on 2019/07/24 17:58:00 UTC
[hive] branch master updated: HIVE-22034:
HiveStrictManagedMigration updates DB location even with --dryRun setting
on (Jason Dere, reviewed by Ashutosh Chauhan)
This is an automated email from the ASF dual-hosted git repository.
jdere pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new b60398c HIVE-22034: HiveStrictManagedMigration updates DB location even with --dryRun setting on (Jason Dere, reviewed by Ashutosh Chauhan)
b60398c is described below
commit b60398cab8f1f198c066d5e53126815076254b4f
Author: Jason Dere <jd...@cloudera.com>
AuthorDate: Wed Jul 24 10:57:24 2019 -0700
HIVE-22034: HiveStrictManagedMigration updates DB location even with --dryRun setting on (Jason Dere, reviewed by Ashutosh Chauhan)
---
.../apache/hadoop/hive/ql/util/HiveStrictManagedMigration.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/util/HiveStrictManagedMigration.java b/ql/src/java/org/apache/hadoop/hive/ql/util/HiveStrictManagedMigration.java
index 42c4158..9d23c13 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/util/HiveStrictManagedMigration.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/util/HiveStrictManagedMigration.java
@@ -606,10 +606,12 @@ public class HiveStrictManagedMigration {
LOG.error("Not updating database location for {} since an error was encountered. " +
"The migration must be run again for this database.", dbObj.getName());
} else {
- Path newDefaultDbLocation = wh.get().getDefaultDatabasePath(dbName);
- // dbObj after this call would have the new DB location.
- // Keep that in mind if anything below this requires the old DB path.
- hiveUpdater.get().updateDbLocation(dbObj, newDefaultDbLocation);
+ if (!runOptions.dryRun) {
+ Path newDefaultDbLocation = wh.get().getDefaultDatabasePath(dbName);
+ // dbObj after this call would have the new DB location.
+ // Keep that in mind if anything below this requires the old DB path.
+ hiveUpdater.get().updateDbLocation(dbObj, newDefaultDbLocation);
+ }
}
}
} catch (InterruptedException e) {