Hi,
I am running with Spark 1.5.2 on cluster 2.3.4 with zeppelin
0.6.0-snap. When I am using Angular display system to read phoenix table
getting error of
java.lang.ClassCastException:
org.apache.spark.sql.catalyst.expressions.GenericMutableRow cannot be cast to
org.apache.spark.sql.Row.
But with Spark 1.4.1 it is running fine.
My code is:
%dep
z.reset
z.load("/usr/hdp/current/phoenix-client/phoenix-4.4.0.2.3.4.0-3485-client.jar")
z.load("/usr/hdp/current/phoenix-clientphoenix-core-4.4.0.2.3.4.0-3485.jar")
z.load("/usr/hdp/current/phoenix-client/phoenix-spark-4.4.0.2.3.4.0-3485.jar")
import org.apache.phoenix.spark._
import org.apache.phoenix.spark.PhoenixRDD._
val test = sqlContext.load(
"org.apache.phoenix.spark",
scala.collection.immutable.Map("table" -> "ZTEST",
"zkUrl" -> "localhost:/hbase-unsecure")
)
test.show
Thanks & Regards
Vikash Kumar
