samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yi Pan <nickpa...@gmail.com>
Subject Re: Picking up checkpoint when upgrade to 0.10.0 from 0.9?
Date Tue, 22 Mar 2016 20:33:06 GMT
Hi, Yuanchi,

Did you check your configuration of task.checkpoint.system? What are the
config value you used in 0.9 and what's the current configuration in 0.10?
If you can share your config before and after the upgrade, + the container
log from 0.10, we can be more helpful.

Thanks!

-Yi

On Tue, Mar 22, 2016 at 1:19 PM, Yuanchi Ning <ningyuanchi320@gmail.com>
wrote:

> 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
> though.
> Any ideas? thanks!
>
> Yuanchi
>
>
> --
> Yuanchi Ning
>

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