我们使用ambari创建了hdp和metron集群。我们用Kafka输入数据。我们有Kafka制作人Kafka主题和Kafka消费者。似乎所有Kafka的工作都做得很好,但在风暴中我们遇到了如下错误:
Error: Grok parser unable to initialize grok parser: Unable to load /patterns/nova from either classpath or HDFS at org.apache.metron.parsers.GrokParser.init
有人知道我们为什么会犯这个错误吗?谢谢
2条答案
按热度按时间6qqygrtg1#
这可能是因为您已经创建了一个新的grok解析器,但是没有将该模式及其支持的模式上载到指定的hdfs位置。尝试在hdfs中创建/patterns文件夹,并将grok模式上传到一个名为nova的文件中。然后,您应该重新启动解析器拓扑,它应该找到模式。请注意,路径必须与zookeeper中grok解析器配置的解析器配置中给出的路径匹配。
ldfqzlk82#
假设您的模式在hdfs中,您必须在解析器中使用/apps/metron/patterns/nova作为grokpath。我也面临同样的问题。这就解决了问题。