samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yuanchi Ning <>
Subject Picking up checkpoint when upgrade to 0.10.0 from 0.9?
Date Tue, 22 Mar 2016 20:19:01 GMT
Hi All,

When we test upgrading our existing Samza job from 0.9 to 0.10, we saw our
Kafka Lag metric (KafkaSystemConsumerMetrics "messages-behind-high-watermark
") kept zero.
Since we stopped the old job for a while and then restart the job with 0.10
using the same name, the lag should at least spike at the beginning. In the
application master we did see it's picking up the same checkpoint topic
Any ideas? thanks!


Yuanchi Ning

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message