我正尝试使用Spark 2.0.2从hbase数据库(1.2.5)中获取数据,此页面中的代码为:https://github.com/apache/hbase/blob/master/hbase-spark/src/main/java/org/apache/hadoop/hbase/Spark/example/hbaseContext/javahbasebulkgetexample.java
但我得到了这个错误:
线程“main”java.lang.noClassDeffounderRror:org/apache/spark/logging at java.lang.ClassLoader.defineclass1(本机方法)at java.lang.ClassLoader.defineclass(classLoader.java:763)at java.security.secureClassLoader.defineclass(secureClassLoader.java:142)atmpl.java:62)在sun.reflect.delegatingmethodaccessorimpl.java:43)在java.lang.reflect.method.invoke(method.java:498)在org.apache.spark.deploy.sparksubmit$.org$apache$spark$deploy$sparksubmit$$runmain(Sparksubmit.scala:736)在org.apache.spark.deploy.sparksubmit$.dorunmain$1(Sparksubmit.scala:185)在
我在网上看到日志类只存在于Spark1.5.2和更低版本中。
是否有任何解决方案使其工作即使与Spark2.0.2?
与此相关的bug很少:
我的Spark Consumer因“记录”错误而失败。我在浏览时发现错误是由于JAR不兼容造成的。我使用的是Spark 1.6.3,所有依赖项都用在pom中,xml是1.6.3。但我还是犯了同样的错误。下面是我的maven结构和执行时抛出的错误。 我的pom。xml:
以下是我的构建。SBT内容:
我在运行代码时遇到以下异常: 线程“main”java.lang.noClassDeffounderror:org/apache/spark/logging在java.lang.ClassLoader.DefineClass1(Native Method),在java.security.secureClassLoader.DefineClass1(classLoader.java:760),在ja
问题内容: 我总是遇到以下错误。有人可以帮我吗? 当我编译以下代码时。我已经在网上搜索了,但没有找到解决方案。添加saveToCassandra时出现错误。 我的pom是以下内容。 问题答案: org.apache.spark.Logging在Spark版本1.5.2或更低版本中可用。它不在2.0.0中。请更改版本如下
我试图用火花流在推特上找到流行的标签。 twitter4j-stream-4.0.4.jar Spark-Streaming-Twitter2.10-1.0.0.jar 在代码上,齐柏林飞船工作得很好 任何帮助都将不胜感激! 谢谢。