Hello, I'm running into a weird error and not sure what's going on. Does anybody have any idea?

org.apache.flink.runtime.io.network.partition.PartitionNotFoundException: Partition 512d1b5e6860de484fc7792beb466764#0@0b1dc40d062b680b0258b6b4cb90041d not found.
	at org.apache.flink.runtime.io.network.partition.ResultPartitionManager.createSubpartitionView(ResultPartitionManager.java:70)
	at org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestSubpartition(LocalInputChannel.java:135)
	at org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel$1.run(LocalInputChannel.java:185)
	at java.base/java.util.TimerThread.mainLoop(Unknown Source)
	at java.base/java.util.TimerThread.run(Unknown Source)

My flink job is on 1.15

Are you using Kafka and if so, has there been a change in the partitions for that topic?

Yes, I am using KafkaSource. I recently moved from FlinkKafkaConsumer to KafkaSource. There shouldn't be any change in the partitions for the topic. This is a stack overflow which is exactly the issue I am having but I couldn't get his proposed fix to work for deserializing the CompletedCheckpoint: https://stackoverflow.com/questions/75363084/jobs-stuck-while-trying-to-restart-from-a-checkpoint

Have you followed the migration guide to move from FlinkKafkaConsumer to KafkaSource?