I ran your code in the IDE and it worked just fine; checkpoints are
being completed and results are printed to the console.
Can you expand on how you run the job?
On 02/07/2022 00:26, Nathan Sharp wrote:
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
