Checkpoint failed after time out. We observed there has some subtask didn't respond. Any idea will cause this problem?
Data Volume: Under 40k
BackPressure: send to another API at the end of the job which may take some time there.
missing subtask respond External Call:
Future<> future = Producer.send(topic, genericRecord, dataSetID); future.get(); return Boolean.TRUE;