I wrote a simple program to read data from HBase, the program works find in
Cloudera backed by HDFS. The program works fine on SPARK RUNTIME 1.6 on
Cloudera. But does NOT work on EMR with Spark Runtime 2.2.1.
But getting an exception while testing data on EMR with S3.
// Spark conf
Spar
Simple Java Program to Connect to Phoenix DB:
SparkConf sparkConf = new SparkConf();
sparkConf.setAppName("Using-spark-phoenix-df");
sparkConf.setMaster("local[*]");
JavaSparkContext sc = new JavaSparkContext(sparkConf);
I have a simple program that works fine in the local mode. But I am having
issues when I try to run the program in yarn-cluster mode. I know usually
no such method happens when compile and run version mismatch but I made sure
I took the same version.
205 [main] INFO org.spark_project.jetty.ser
I have written four lines of simple spark program to process data in Phoenix
table:
queryString = getQueryFullString( );// Get data from Phoenix table select
col from table
JavaPairRDD phRDD = jsc.newAPIHadoopRDD(
configuration,
Ph
--
Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/
-
To unsubscribe e-mail: user-unsubscr...@spark.apache.org