[ https://issues.apache.org/jira/browse/HIVE-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519426#comment-16519426 ]
Sahil Takiar commented on HIVE-19958: ------------------------------------- We only tested Hive 2.3.3 with Spark 2.0.0 so you might want to try Spark 2.0.0 instead - see https://cwiki.apache.org/confluence/display/Hive/Hive+on+Spark%3A+Getting+Started#HiveonSpark:GettingStarted-VersionCompatibility > 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: Major > > 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)