import java.io.*;
import java.util.*;
import java.sql.*;
import org.apache.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.apache.hadoop.security.UserGroupInformation;
public class helloworld {
public static void main(String[] args) throws SQLException,ClassNotFoundException,InstantiationException,IllegalAccessException {
Driver hiveDriver;
Connection con;
String connection_string;
Properties props = new Properties();
connection_string = "jdbc:hive2://****/default;principal=mapr/*****;kerberosAuthType=fromSubject";
System.out.println( "Full connection string is: " + connection_string );
hiveDriver = (Driver)Class.forName("org.apache.hive.jdbc.HiveDriver").newInstance();
System.out.println("BEFORE");
con = hiveDriver.connect( connection_string, props );
System.out.println("AFTER");
Statement stmt = con.createStatement();
// See if show tables works
ResultSet res;
String sql = "show tables" ;
System.out.println("Running: " + sql);
stmt.executeQuery(sql);
System.out.println("Done with show tables");
}
}
While executing the code i'm getting kerberos user_name: prompt and while giving the user name and password im getting error as could not open client transport jdbc uri
... View more
