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 <ningyuanchi...@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 >
