@Achu Thambi
Are you sure that your remove client has no N/W issue? I mean are you able to connect to the zk hosts like following:
Example if your connection URL is as following
private static String url = "jdbc:hive2://erie3.example.com:2181,erie1.example.com:2181,erie4.example.com:2181,erie2.example.com:2181/;serviceDiscoveryMode=zooKeeper;zooKeeperNamespace=hiveserver2";
- Then try to do a telnet from the client machine to findout if it is able to connect to the mentioned hosts and ports?
# telnet erie1.example.com 2181
# telnet erie2.example.com 2181
# telnet erie3.example.com 2181
# telnet erie4.example.com 2181
.
- Also please refer to the simple HiveClient demo that i placed at my Github repo to see if it works and may you can compare it with your client.
https://github.com/jaysensharma/MiddlewareMagicDemos/blob/master/HDP_Ambari/Hive/HiveJavaClient/src/...
.
For quick testing i wrote the following code to validate if DB creation is happening fine or not?
package client;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class HiveClientDemo {
private static String commonDriverName = "org.apache.hive.jdbc.HiveDriver";
private static String url = "jdbc:hive2://erie3.example.com:2181,erie1.example.com:2181,erie4.example.com:2181,erie2.example.com:2181/;serviceDiscoveryMode=zooKeeper;zooKeeperNamespace=hiveserver2";
private static String userName = "hive";
private static String userPass = "hive";
public static void main(String[] args) throws Exception {
Class.forName(commonDriverName);
Connection con = DriverManager.getConnection(url, userName, userPass);
System.out.println("\n\t Got Connection: " + con);
System.out.println("*** List the existing Databases....");
Statement stmt = con.createStatement();
String sql = "show databases";
System.out.println("Executing Query: " + sql);
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
System.out.println(rs.getString(1));
}
sql = "create database Test12345DB";
System.out.println("Executing Query: " + sql);
stmt.execute(sql);
System.out.println("*** After Creating a new Database....");
sql = "show databases";
System.out.println("Executing Query: " + sql);
rs = stmt.executeQuery(sql);
while (rs.next()) {
System.out.println(rs.getString(1));
}
}
}-
I got the following output that shows the newly created Database is showing up properly.
Got Connection: org.apache.hive.jdbc.HiveConnection@65e3690
*** List the existing Databases....
Executing Query: show databases
abcd
default
movielens
myretail
test
test1
test3
testdb
testdb_a
testdb_c
Executing Query: create database Test12345DB
*** After Creating a new Database....
Executing Query: show databases
abcd
default
movielens
myretail
test
test1
test12345db
test3
testdb
testdb_a
.
Please compare the above code with yours and let us know if you see any difference.
- Still if it fails to connect Or fails to create a database then please share the complete stack trace of the error/exception that you receive at the client side.
.
