You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by rm...@apache.org on 2016/08/19 22:03:32 UTC
incubator-ranger git commit: RANGER-1153 : Ranger HivePluginUnitTest
improvements to avoid build failure
Repository: incubator-ranger
Updated Branches:
refs/heads/master bf3f09542 -> ac5a03667
RANGER-1153 : Ranger HivePluginUnitTest improvements to avoid build failure
Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/ac5a0366
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/ac5a0366
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/ac5a0366
Branch: refs/heads/master
Commit: ac5a03667cf167eb7a1d83d2c9aae8c2ab946494
Parents: bf3f095
Author: rmani <rm...@hortonworks.com>
Authored: Fri Aug 19 15:03:25 2016 -0700
Committer: rmani <rm...@hortonworks.com>
Committed: Fri Aug 19 15:03:25 2016 -0700
----------------------------------------------------------------------
.../services/hive/HIVERangerAuthorizerTest.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/ac5a0366/hive-agent/src/test/java/org/apache/ranger/services/hive/HIVERangerAuthorizerTest.java
----------------------------------------------------------------------
diff --git a/hive-agent/src/test/java/org/apache/ranger/services/hive/HIVERangerAuthorizerTest.java b/hive-agent/src/test/java/org/apache/ranger/services/hive/HIVERangerAuthorizerTest.java
index d3d67d9..959310e 100644
--- a/hive-agent/src/test/java/org/apache/ranger/services/hive/HIVERangerAuthorizerTest.java
+++ b/hive-agent/src/test/java/org/apache/ranger/services/hive/HIVERangerAuthorizerTest.java
@@ -96,7 +96,7 @@ public class HIVERangerAuthorizerTest {
Connection connection = DriverManager.getConnection(initialUrl, "admin", "admin");
Statement statement = connection.createStatement();
- statement.execute("CREATE DATABASE rangerauthz");
+ statement.execute("CREATE DATABASE IF NOT EXISTS rangerauthz");
statement.close();
connection.close();
@@ -106,7 +106,7 @@ public class HIVERangerAuthorizerTest {
connection = DriverManager.getConnection(url, "admin", "admin");
statement = connection.createStatement();
// statement.execute("CREATE TABLE WORDS (word STRING, count INT)");
- statement.execute("create table words (word STRING, count INT) row format delimited fields terminated by '\t' stored as textfile");
+ statement.execute("create table if not exists words (word STRING, count INT) row format delimited fields terminated by '\t' stored as textfile");
// Copy "wordcount.txt" to "target" to avoid overwriting it during load
java.io.File inputFile = new java.io.File(HIVERangerAuthorizerTest.class.getResource("../../../../../wordcount.txt").toURI());
@@ -311,7 +311,7 @@ public class HIVERangerAuthorizerTest {
Connection connection = DriverManager.getConnection(url, "bob", "bob");
Statement statement = connection.createStatement();
- statement.execute("CREATE DATABASE bobtemp");
+ statement.execute("CREATE DATABASE if not exists bobtemp");
statement.close();
connection.close();
@@ -321,7 +321,7 @@ public class HIVERangerAuthorizerTest {
statement = connection.createStatement();
try {
- statement.execute("CREATE DATABASE alicetemp");
+ statement.execute("CREATE DATABASE if not exists alicetemp");
Assert.fail("Failure expected on an unauthorized call");
} catch (SQLException ex) {
// expected
@@ -357,7 +357,7 @@ public class HIVERangerAuthorizerTest {
Connection connection = DriverManager.getConnection(url, "admin", "admin");
Statement statement = connection.createStatement();
- statement.execute("CREATE DATABASE admintemp");
+ statement.execute("CREATE DATABASE if not exists admintemp");
statement.close();
connection.close();
@@ -366,7 +366,7 @@ public class HIVERangerAuthorizerTest {
url = "jdbc:hive2://localhost:" + port + "/admintemp";
connection = DriverManager.getConnection(url, "admin", "admin");
statement = connection.createStatement();
- statement.execute("CREATE TABLE WORDS (word STRING, count INT)");
+ statement.execute("CREATE TABLE if not exists WORDS (word STRING, count INT)");
statement.close();
connection.close();
@@ -403,7 +403,7 @@ public class HIVERangerAuthorizerTest {
String url = "jdbc:hive2://localhost:" + port + "/rangerauthz";
Connection connection = DriverManager.getConnection(url, "admin", "admin");
Statement statement = connection.createStatement();
- statement.execute("CREATE TABLE WORDS2 (word STRING, count INT)");
+ statement.execute("CREATE TABLE if not exists WORDS2 (word STRING, count INT)");
statement.close();
connection.close();
@@ -440,7 +440,7 @@ public class HIVERangerAuthorizerTest {
// Create a new table as admin
Connection connection = DriverManager.getConnection(url, "admin", "admin");
Statement statement = connection.createStatement();
- statement.execute("CREATE TABLE WORDS2 (word STRING, count INT)");
+ statement.execute("CREATE TABLE IF NOT EXISTS WORDS2 (word STRING, count INT)");
statement.close();
connection.close();