Re: Zeppelin using Spark to access Hbase throws error

2016-10-29 Thread Felix Cheung
Hmm, I don't think I have seen this error specifically, but it is possible the error is caused by config not getting loaded (e.g. Not in classpath) - you might wan to check if it might be the case and if there is any sign of that in the logs. On Sat, Oct 29, 2016 at 2:14 PM -0700, "Mich Tal

Re: Zeppelin using Spark to access Hbase throws error

2016-10-29 Thread Mich Talebzadeh
Hi Felix, Yes it is the same host that I run Spark shell and I start Zeppelin on. Have you observed this before? Thanks Dr Mich Talebzadeh LinkedIn * https://www.linkedin.com/profile/view?id=AAEWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw

Re: Zeppelin using Spark to access Hbase throws error

2016-10-29 Thread Felix Cheung
When you run the code in spark-shell - is that the same machine as where Zeppelin is running? It looks like you are getting socket connection timeout when Spark, running from Zeppelin, is trying to connect to HBASE. _ From: Mich Talebzadeh mailto:mich.talebza...@gm

Zeppelin using Spark to access Hbase throws error

2016-10-29 Thread Mich Talebzadeh
Spark 2.0.1, Zeppelin 0.6.1, hbase-1.2.3 The below code runs fine with Spark shell. import org.apache.spark._ import org.apache.spark.rdd.NewHadoopRDD import org.apache.hadoop.hbase.{HBaseConfiguration, HTableDescriptor} import org.apache.hadoop.hbase.mapreduce.TableInputFormat import org.apache.

UDAF "not found: type UserDefinedAggregateFunction" in zeppelin 0.6.2

2016-10-29 Thread Manjunath, Kiran
I am trying the below sample code Code %spark import org.apache.spark.sql.expressions.MutableAggregationBuffer import org.apache.spark.sql.expressions.UserDefinedAggregateFunction class GeometricMean extends UserDefinedAggregateFunction { def inputSchema: org.apache.spark.sql.types.StructType