CassandraCqlIncrementalState should try to recalculate the state before persist , not just retry the same query multiple time.