[
https://issues.apache.org/jira/browse/HIVE-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
t oo updated HIVE-19958:
------------------------
Priority: Blocker (was: Major)
> hive on spark - count(*) error when running spark standalone against s3
> external tables
> ---------------------------------------------------------------------------------------
>
> Key: HIVE-19958
> URL: https://issues.apache.org/jira/browse/HIVE-19958
> Project: Hive
> Issue Type: Bug
> Components: Spark
> Affects Versions: 2.3.2, 2.3.3
> Reporter: t oo
> Priority: Blocker
>
> I am running 'Hive on Spark' with hive v2.3.3 and Spark v2.0.0 running in
> spark standalone mode with no yarn/hdfs. My hive tables are external pointing
> to S3. My hive-site has spark.submit.deployMode set to client. spark.master
> set to spark://actualmaster:7077 and in the spark ui I see the spark master
> has available worker with resources.
> In beeline I run select * from table; This works. Then in beeline I run
> select count(*) from table; and i get error below:
> /usr/lib/apache-hive-2.3.3-bin/lib/hive-exec-2.3.3.jar contains the so called
> missing class and hive2 is started with nohup $HIVE_HOME/bin/hive --service
> hiveserver2 --hiveconf hive.server2.thrift.port=10000 --hiveconf
> hive.root.logger=INFO,console &>> $HIVE_HOME/logs/hiveserver2.log &
> Below error is from viewing the 'job' in the sparkUI:
> {code:java}
>
> Failed stageid0: mapPartitionsToPair at MapTran.java:40
>
> java.lang.NoClassDefFoundError:
> Lorg/apache/hive/spark/counter/SparkCounters;
> at java.lang.Class.getDeclaredFields0(Native Method)
> at java.lang.Class.privateGetDeclaredFields(Class.java:2583)
> at java.lang.Class.getDeclaredField(Class.java:2068)
> at java.io.ObjectStreamClass.getDeclaredSUID(ObjectStreamClass.java:1803)
> at java.io.ObjectStreamClass.access$700(ObjectStreamClass.java:79)
> at java.io.ObjectStreamClass$2.run(ObjectStreamClass.java:494)
> at java.io.ObjectStreamClass$2.run(ObjectStreamClass.java:482)
> at java.security.AccessController.doPrivileged(Native Method)
> at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:482)
> at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:379)
> at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:669)
> at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1875)
> at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1744)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2032)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:426)
> at
> org.apache.spark.serializer.JavaDeserializationStream.readObject(JavaSerializer.scala:75)
> at
> org.apache.spark.serializer.JavaSerializerInstance.deserialize(JavaSerializer.scala:114)
> at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:71)
> at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:47)
> at org.apache.spark.scheduler.Task.run(Task.scala:85)
> at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:274)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.ClassNotFoundException:
> org.apache.hive.spark.counter.SparkCounters
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> ... 45 more
>
> {code}
>
> Note that if I do this in beeline (set spark.master=local;) then the count(*)
> works. What am I missing to make it work without setting spark.master to
> local ?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
