Hi' i'm getting the following exception when i run a query from a java jar:
2015-10-12 12:54:15,839 INFO: org.apache.tajo.rpc.RpcProtos
(channelActive(206)) - Connection established successfully :
/TajoMaster:26002
2015-10-12 12:54:16,145 ERROR: org.apache.tajo.rpc.RpcProtos
(exceptionCaught(199)) - RPC Exception:Message missing required fields:
resultCode
My method is the following:
public void Tajo() {
try{
Class.forName("org.apache.tajo.jdbc.TajoDriver");
Connection conn =
DriverManager.getConnection("jdbc:tajo://TajoMaster:26002/default");
Statement stmt = null;
ResultSet rs=null;
FileWriter file = null;
PrintWriter pw = null;
try {
stmt = conn.createStatement();
rs = stmt.executeQuery("SELECT count(*) from JSONTABLE;");
int Cont=rs.getMetaData().getColumnCount();
file = new FileWriter("/opt/20151012-TEST.txt");
pw = new PrintWriter(archivo);
while(rs.next())
{
pw.println(rs.getString(1));
}
} finally {
if (rs != null) rs.close();
if (stmt != null) stmt.close();
if (conn != null) conn.close();
try {
if (null != file) file.close();
if (pw != null) pw.close();
} catch (Exception e2) {
e2.printStackTrace();
}
}
}catch(Exception e){
e.printStackTrace();
}
}
|