I am attempting to use unaligned checkpointing with AsyncDataStream, but the checkpoints sit in "start delay" until the job finishes. I am brand new to Flink, so it is entirely reasonable to assume the problem is with my code.
I published my test code at https://github.com/phxnsharp/AsyncDataStreamCheckpointReproduction Searching the web seems to indicate the most common issue is asyncInvoke blocking. I added a test to make sure that that is not true. Any help would be greatly appreciated! Thanks, Nathan
