验证和拆分记录处理器 kylo 时出错

Error in validate and split records processor kylo

我在线程 "main" java.lang.NoClassDefFoundError 中收到 异常:org/xerial/snappy/SnappyInputStream 错误 在标准摄取模板中的验证和拆分记录处理器中我无法解决。

csv 和 json 数据都会发生这种情况。

谁能帮我解决这个问题。

找到解决方案..是因为snappy-java的jar版本不匹配导致的。 最初我添加了 snappy-java-1.0.4.1 造成了上述问题。

将 snappy-java-1.1.0 添加到 spark 后 classpath.txt 问题得到解决!