如何解决OLAP 查询 Spark 不适用于 Janusgraph
在 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 举报，一经查实，本站将立刻删除。
