Major Description
Currently if a the checkpoint log or state log partition count increases on job restart due to the inclusion of new streams with a higher partition count, the corresponding Kafka topics are increased to accommodate this change. In the case of the the checkpoint log, we will get a job failure at startup. We should compare the current partition size with the required and size upward if necessary at job start.