You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by ? ?? <wa...@outlook.com> on 2018/02/01 06:11:16 UTC
NoClassDefFoundError: Could not initialize class
com.yammer.metrics.Metrics
Hi,
I am using KafkaSpout to ingest data into Storm. The versions are:
Storm-1.1.0
Storm-kafka 1.1.0
kafka_2.10-0.8.2.2
The program worked well at the beginning, but at some point the KafkaSpout threw an exception and the program seemed stuck there afterwards. The program can proceed after restarted but the exception recurs occasionally.
Below is the log:
java.lang.NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics at kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:85) at kafka.consumer.FetchRequestAndResponseMetrics.newTimer(FetchRequestAndResponseStats.scala:26) at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:35) at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequestAndResponseStats.scala:46) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.utils.Pool.getAndMaybePut(Pool.scala:61) at kafka.consumer.FetchRequestAndResponseStatsRegistry$.getFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:63) at kafka.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:39) at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:34) at org.apache.storm.kafka.DynamicPartitionConnections.register(DynamicPartitionConnections.java:60) at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:96) at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:108) at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:130) at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:748)
Could anybody tell me why?
________________________________
wangchunchao@outlook.com
Re: RE: NoClassDefFoundError: Could not initialize class
com.yammer.metrics.Metrics
Posted by ? ?? <wa...@outlook.com>.
yes, it is. It is metrics-core-2.2.0.jar. I have checked all the brokers.
________________________________
wangchunchao@outlook.com
From: TSANG, Brilly<ma...@hk.daiwacm.com>
Date: 2018-02-01 14:54
To: users<ma...@kafka.apache.org>; user<ma...@storm.apache.org>
Subject: RE: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics
Just make sure metrics-core-x.x.x.jar is in your class path. That jar should be in your <kafka_installation_directory>/libs.
I am using kafka_2.11-1.0.0 so I don't have the exact version number of metrics-core for you.
Regards,
Brilly
-----Original Message-----
From: ? ?? [mailto:wangchunchao@outlook.com]
Sent: Thursday, February 01, 2018 2:11 PM
To: users; user
Subject: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics
Hi,
I am using KafkaSpout to ingest data into Storm. The versions are:
Storm-1.1.0
Storm-kafka 1.1.0
kafka_2.10-0.8.2.2
The program worked well at the beginning, but at some point the KafkaSpout threw an exception and the program seemed stuck there afterwards. The program can proceed after restarted but the exception recurs occasionally.
Below is the log:
java.lang.NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics at kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:85) at kafka.consumer.FetchRequestAndResponseMetrics.newTimer(FetchRequestAndResponseStats.scala:26) at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:35) at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequestAndResponseStats.scala:46) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.utils.Pool.getAndMaybePut(Pool.scala:61) at kafka.consumer.FetchRequestAndResponseStatsRegistry$.getFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:63) at kafka.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:39) at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:34) at org.apache.storm.kafka.DynamicPartitionConnections.register(DynamicPartitionConnections.java:60) at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:96) at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:108) at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:130) at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:748)
Could anybody tell me why?
________________________________
wangchunchao@outlook.com
________________________________
********************************************************************************
DISCLAIMER:
This email and any attachment(s) are intended solely for the person(s) named above, and are or may contain information of a proprietary or confidential nature. If you are not the intended recipient(s), you should delete this message immediately. Any use, disclosure or distribution of this message without our prior consent is strictly prohibited.
This message may be subject to errors, incomplete or late delivery, interruption, interception, modification, or may contain viruses. Neither Daiwa Capital Markets Hong Kong Limited, its subsidiaries, affiliates nor their officers or employees represent or warrant the accuracy or completeness, nor accept any responsibility or liability whatsoever for any use of or reliance upon, this email or any of the contents hereof. The contents of this message are for information purposes only, and subject to change without notice.
This message is not and is not intended to be an offer or solicitation to buy or sell any securities or financial products, nor does any recommendation, opinion or advice necessarily reflect those of Daiwa Capital Markets Hong Kong Limited, its subsidiaries or affiliates.
********************************************************************************
RE: NoClassDefFoundError: Could not initialize class
com.yammer.metrics.Metrics
Posted by "TSANG, Brilly" <br...@hk.daiwacm.com>.
Just make sure metrics-core-x.x.x.jar is in your class path. That jar should be in your <kafka_installation_directory>/libs.
I am using kafka_2.11-1.0.0 so I don't have the exact version number of metrics-core for you.
Regards,
Brilly
-----Original Message-----
From: ? ?? [mailto:wangchunchao@outlook.com]
Sent: Thursday, February 01, 2018 2:11 PM
To: users; user
Subject: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics
Hi,
I am using KafkaSpout to ingest data into Storm. The versions are:
Storm-1.1.0
Storm-kafka 1.1.0
kafka_2.10-0.8.2.2
The program worked well at the beginning, but at some point the KafkaSpout threw an exception and the program seemed stuck there afterwards. The program can proceed after restarted but the exception recurs occasionally.
Below is the log:
java.lang.NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics at kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:85) at kafka.consumer.FetchRequestAndResponseMetrics.newTimer(FetchRequestAndResponseStats.scala:26) at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:35) at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequestAndResponseStats.scala:46) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.utils.Pool.getAndMaybePut(Pool.scala:61) at kafka.consumer.FetchRequestAndResponseStatsRegistry$.getFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:63) at kafka.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:39) at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:34) at org.apache.storm.kafka.DynamicPartitionConnections.register(DynamicPartitionConnections.java:60) at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:96) at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:108) at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:130) at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:748)
Could anybody tell me why?
________________________________
wangchunchao@outlook.com
________________________________
********************************************************************************
DISCLAIMER:
This email and any attachment(s) are intended solely for the person(s) named above, and are or may contain information of a proprietary or confidential nature. If you are not the intended recipient(s), you should delete this message immediately. Any use, disclosure or distribution of this message without our prior consent is strictly prohibited.
This message may be subject to errors, incomplete or late delivery, interruption, interception, modification, or may contain viruses. Neither Daiwa Capital Markets Hong Kong Limited, its subsidiaries, affiliates nor their officers or employees represent or warrant the accuracy or completeness, nor accept any responsibility or liability whatsoever for any use of or reliance upon, this email or any of the contents hereof. The contents of this message are for information purposes only, and subject to change without notice.
This message is not and is not intended to be an offer or solicitation to buy or sell any securities or financial products, nor does any recommendation, opinion or advice necessarily reflect those of Daiwa Capital Markets Hong Kong Limited, its subsidiaries or affiliates.
********************************************************************************