I don't know why running it inside of Spark would cause issues.
I would double-check the classpath of your application when running in Spark as well as look at the PQS log (HTTP/500 is a server error).
On 10/25/17 6:39 AM, cmbendre wrote:
I am trying to connect to Phoenix queryserver from Spark. Following Scala code works perfectly fine when i run it without spark. *import java.sql.{Connection, DriverManager, PreparedStatement, ResultSet, Statement} Class.forName("org.apache.phoenix.queryserver.client.Driver") val connection= DriverManager.getConnection("jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF"); val statement = connection.createStatement()* But the same code fails with following exception in Spark Shell / Spark Submit - /java.lang.RuntimeException: response code 500 at org.apache.calcite.avatica.remote.RemoteService.apply(RemoteService.java:45) at org.apache.calcite.avatica.remote.JsonService.apply(JsonService.java:235) at org.apache.calcite.avatica.remote.RemoteMeta.connectionSync(RemoteMeta.java:97) at org.apache.calcite.avatica.remote.RemoteMeta.createStatement(RemoteMeta.java:65) at org.apache.calcite.avatica.AvaticaStatement.<init>(AvaticaStatement.java:83) at org.apache.calcite.avatica.AvaticaJdbc41Factory$AvaticaJdbc41Statement.<init>(AvaticaJdbc41Factory.java:114) at org.apache.calcite.avatica.AvaticaJdbc41Factory.newStatement(AvaticaJdbc41Factory.java:73) at org.apache.calcite.avatica.AvaticaConnection.createStatement(AvaticaConnection.java:263) at org.apache.calcite.avatica.AvaticaConnection.createStatement(AvaticaConnection.java:110) at org.apache.calcite.avatica.AvaticaConnection.createStatement(AvaticaConnection.java:51) ... 48 elided/ I am using Spark 2.1.0 along with Phoenix 4.11 with HBase 1.3. I could not find any similar error on the internet. Please help. -- Sent from: http://apache-phoenix-user-list.1124778.n5.nabble.com/