Hi,

I found log "Metrics Tick: Not enough data to calculate spout lag.” in my 
topology and then topology becomes inactive.

I check the source:
  if (_partitions != null && _partitions.size() == _partitionToOffset.size()) {
……}else {
   LOG.info("Metrics Tick: Not enough data to calculate spout lag.");
}

What situation will cause  _partitions != null or _partitions.size() 
==_partitionToOffset.size()?

Thanks,
Sachin

Reply via email to