.build()
> )
> .print();
>
> env.execute("Timeout Retry Example");
> }
> }
>
>
> I hope that gives you the information you need? Let me know if there's
> anything else I can to help troubleshoot. I'm
pretty new to Flink, so I might well
just have misunderstood something or set something up incorrectly.
Thanks in advance,
Yoni.
____
From: Lincoln Lee
Sent: 14 December 2022 13:51
To: Yoni Gibbs
Cc: user@flink.apache.org
Subject: Re: AsyncDataStream: Retries keep exe
hi,
Is this case running like a it case locally, or a streaming job running
on a cluster? If it's the former, one thing I can think of is local testing
using bounded datasource(has few test records) that will end input very
fastly and then trigger the endOfInput logic of AsyncWaitOperator, that
