.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
Hi,
I've got a Kinesis consumer which reacts to each record by doing some async
work using an implementation of RichAsyncFunction. I'm adding a retry strategy.
After x failed attempts I want this to time out and give up by returning no
data (i.e. not be treated as a failure).
Here is a cut dow
