OLAP 查询 Spark 不适用于 Janusgraph

编程问答 2022-05-30

问题描述

在 Janusgraph 和 Apache Spark 中使用 OLAP 处理。它没有提高性能，反而降级了。

查询：

g.V().has('property1','ABC').inE().outV().has('property2',33).properties('property1','property2').group().by(key).by(value().sum())

错误：

14:15:42 WARN  org.apache.spark.storage.BlockManager  - Block rdd_11_1 Could not be removed as it was not found on disk or in memory
14:15:42 ERROR org.apache.spark.executor.Executor  - Exception in task 3.0 in stage 4.0 (TID 18)
java.lang.NoSuchMethodError: net.jpountz.lz4.LZ4BlockInputStream.<init>(Ljava/io/InputStream;Z)V
    at org.apache.spark.io.LZ4CompressionCodec.compressedInputStream(CompressionCodec.scala:122)
    at org.apache.spark.serializer.SerializerManager.wrapForCompression(SerializerManager.scala:163)
    at org.apache.spark.serializer.SerializerManager.wrapStream(SerializerManager.scala:124)
    at org.apache.spark.shuffle.BlockStoreShuffleReader$$anonfun$3.apply(BlockStoreShuffleReader.scala:50)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-sparkgremlinjanusgrapholapolap