Thanks! PR created and noted on the ticket.
On Wed, Feb 9, 2022 at 3:42 AM Till Rohrmann wrote:
> Hi Galen,
>
> Great to hear it :-) I've assigned you to the ticket [1]. Next you can open
> a PR against the repository and we will review it.
>
> [1]
Hi Galen,
Great to hear it :-) I've assigned you to the ticket [1]. Next you can open
a PR against the repository and we will review it.
[1] https://issues.apache.org/jira/browse/FLINK-25933
Cheers,
Till
On Tue, Feb 8, 2022 at 11:58 PM Galen Warren
wrote:
> I'm ready to pick this one up, I
I'm ready to pick this one up, I have some code that's working locally.
Shall I create a PR?
On Wed, Feb 2, 2022 at 3:17 PM Igal Shilman wrote:
> Great, ping me when you would like to pick this up.
>
> For the related issue, I think that can be a good addition indeed!
>
> On Wed, Feb 2, 2022
Ah, nevermind. I was misunderstanding how maxRequestDuration related to the
retries.
Locally, I had Flink set not to retry on failure, so once
maxRequestDuration expired without a successful result, Flink itself was
stopping, and I wasn't seeing the function get called again. But I see now
that,
Great, ping me when you would like to pick this up.
For the related issue, I think that can be a good addition indeed!
On Wed, Feb 2, 2022 at 8:55 PM Galen Warren wrote:
> Gotcha, thanks. I may be able to work on that one in a couple weeks if
> you're looking for help.
>
> Unrelated question
Gotcha, thanks. I may be able to work on that one in a couple weeks if
you're looking for help.
Unrelated question -- another thing that would be useful for me would be
the ability to set a maximum backoff interval in BoundedExponentialBackoff
or the async equivalent. My situation is this. I'd
Hi Galen,
You are right, it is not possible, but there is no real reason for that.
We should fix this, and I've created the following JIRA issue [1]
[1] https://issues.apache.org/jira/browse/FLINK-25933
On Wed, Feb 2, 2022 at 6:30 PM Galen Warren wrote:
> Is it possible to choose the async
Is it possible to choose the async HTTP transport using
RequestReplyFunctionBuilder? It looks to me that it is not, but I wanted to
double check. Thanks.
