Hi all, Just to let you know, we already figured it out the problem, issue was that we had a dependency version conflict that result in a mixed of 0.9.1 and 0.10.0 samza libraries in the same classpath.
Thanks, Jose L Barrueta On Wed, Feb 24, 2016 at 1:24 PM, José Barrueta <j...@stormpath.com> wrote: > Hi all, > > Currently we have some Jobs working with Samza v0.9.1 (kafka running on > v0.9.0) for a couple of those Jobs we'd like to upgrade them to Samza > v0.10.0, is there a documents that details the path for upgrading the Job > to latest version? > > We already applied the new coordinator property: > *job.coordinator.system=kafka* > > Now when we try to start the new job, we get: > > 11:42:42.873 [main] INFO kafka.utils.VerifiableProperties - Property > zookeeper.connect is overridden to 192.168.99.100:2181 > Exception in thread "main" java.lang.AbstractMethodError: > org.apache.samza.system.kafka.KafkaSystemConsumerMetrics.org > $apache$samza$metrics$MetricsHelper$_setter_$metricGroup_$eq(Lorg/apache/samza/metrics/MetricGroup;)V > at > org.apache.samza.metrics.MetricsHelper$class.$init$(MetricsHelper.scala:35) > at > org.apache.samza.system.kafka.KafkaSystemConsumerMetrics.<init>(KafkaSystemConsumerMetrics.scala:30) > at > org.apache.samza.system.kafka.KafkaSystemFactory.getConsumer(KafkaSystemFactory.scala:44) > at > org.apache.samza.system.kafka.KafkaSystemFactory.getConsumer(KafkaSystemFactory.scala:41) > at > org.apache.samza.coordinator.stream.CoordinatorStreamSystemFactory.getCoordinatorStreamSystemConsumer(CoordinatorStreamSystemFactory.scala:40) > at org.apache.samza.job.JobRunner.run(JobRunner.scala:95) > at org.apache.samza.job.JobRunner$.main(JobRunner.scala:66) > at org.apache.samza.job.JobRunner.main(JobRunner.scala) > > > Has anyone experienced this error? Can someone help us to run this task > successfully? > > Thanks, > > Jose L. Barrueta > >
