code: private void checkStability() {
      if ((_watermarksInserted.getCount() - _watermarksSwept.getCount()) > _watermarkLagThreshold) {
        log.error("Setting abort flag for Watermark tracking because the lag between the "
            + "watermarksInserted: {} and watermarksSwept: {} is greater than the threshold: {}",
            _watermarksInserted.getCount(), _watermarksSwept.getCount(), _watermarkLagThreshold);
        _abort.set(true);
      }
    }
docs: Check if the memory footprint of the data structure is within bounds