* fix(filer.sync): initializing the offset is related to the path
* fix(filer.sync): the offset maybe to be set to 0.
Co-authored-by: zhihao.qu <zhihao.qu@ly.com>
// use processor.processedTsWatermark instead of the lastTsNs from the most recent job
// use processor.processedTsWatermark instead of the lastTsNs from the most recent job
now:=time.Now().UnixNano()
now:=time.Now().UnixNano()
glog.V(0).Infof("sync %s to %s progressed to %v %0.2f/sec",sourceFiler,targetFiler,time.Unix(0,processor.processedTsWatermark),float64(counter)/(float64(now-lastLogTsNs)/1e9))
glog.V(0).Infof("sync %s to %s progressed to %v %0.2f/sec",sourceFiler,targetFiler,time.Unix(0,processor.processedTsWatermark),float64(counter)/(float64(now-lastLogTsNs)/1e9))