Spark - Livy - Hive Table User

2017-12-18 Thread Sudha KS
The tables created are in the name livy: drwxrwxrwx+ - livy hdfs 0 2017-12-18 09:38 /apps/hive/warehouse/dev.db/tbl 1. Df.write.saveAsTable() 2. spark.sql("CREATE TABLE tbl (key INT, value STRING)") whereas, the create table from hive shell is 'hive'/proxyuser:

RE: Cloudera - How to switch to the newly added Spark service (Spark2) from Spark 1.6 in CDH 5.12

2017-09-19 Thread Sudha KS
To set Spark2 as default, refer https://www.cloudera.com/documentation/spark2/latest/topics/spark2_admin.html#default_tools -Original Message- From: Gaurav1809 [mailto:gauravhpan...@gmail.com] Sent: Wednesday, September 20, 2017 9:16 AM To: user@spark.apache.org Subject: Cloudera - How

RE: SparkSession via HS2 - Error: Yarn application has already ended

2017-07-05 Thread Sudha KS
While testing like this, it does not read hive-site.xml, spark-env.sh of the cluster (had to pass in SparkSession.builder().config()). Is there a way to make it read spark config present in the cluster? From: Sudha KS Sent: Wednesday, July 5, 2017 6:45 PM To: user@spark.apache.org Subject: RE

RE: SparkSession via HS2 - Error: Yarn application has already ended

2017-07-05 Thread Sudha KS
ator.java:133) at org.apache.hadoop.hive.ql.exec.MapOperator$MapOpCtx.forward(MapOperator.java:170) at org.apache.hadoop.hive.ql.exec.MapOperator.process(MapOperator.java:555) ... 18 more Is there a way to resolve this error? On Wed, Jul 5, 2017 at 2:01 PM, Sudha KS <sudha...@fuzzylogix.com<mailto:sudha..

RE: SparkSession via HS2 - Error -spark.yarn.jars not read

2017-07-05 Thread Sudha KS
The property "spark.yarn.jars" available via /usr/hdp/current/spark2-client/conf/spark-default.conf spark.yarn.jars hdfs://ambari03.fuzzyl.com:8020/hdp/apps/2.6.1.0-129/spark2 Is there any other way to set/read/pass this property "spark.yarn.jars" ? From: Su

SparkSession via HS2 - Error -spark.yarn.jars not read

2017-07-05 Thread Sudha KS
Why does "spark.yarn.jars" property not read, in this HDP 2.6 , Spark2.1.1 cluster: 0: jdbc:hive2://localhost:1/db> set spark.yarn.jars; +--+--+ | set

SparkSession via HS2 - is it supported?

2017-07-04 Thread Sudha KS
This is the code: created a java class by extending org.apache.hadoop.hive.ql.udf.generic.GenericUDTF; ,and creates a sparkSession as- SparkSession spark = SparkSession.builder().enableHiveSupport().master("yarn-client").appName("SampleSparkUDTF_yarnV1").getOrCreate(); ,and tries to

test mail

2017-07-04 Thread Sudha KS