Hi Till,
Thanks for raising this candidate, I found this
https://github.com/apache/flink/pull/5705 is still not merged, should we get it
into flink-1.5, I ask this because I found it on the bug list on the JIRA
release notes that you provided.
Best Regards,
Sihua Zhou
发自网易邮箱大师
On 04/3/2018
PR to provide the hooks: https://github.com/apache/flink/pull/5803
On Mon, Apr 2, 2018 at 6:14 PM, Thomas Weise wrote:
> Hi,
>
> I’m working on implementing retry for getRecords in FlinkKinesisConsumer.
> We occasionally get transient socket read timeouts. Instead of bubbling up
> the exceptio
Thomas Weise created FLINK-9124:
---
Summary: Allow customization of KinesisProxy.getRecords read
timeout and retry
Key: FLINK-9124
URL: https://issues.apache.org/jira/browse/FLINK-9124
Project: Flink
Hi,
I’m working on implementing retry for getRecords in FlinkKinesisConsumer.
We occasionally get transient socket read timeouts. Instead of bubbling up
the exception and forcing a topology reset to checkpoint, we want to retry
getRecords. We also want to work with a lower socket read timeout than
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.5.0,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
Julio Biason created FLINK-9123:
---
Summary: Scala version of ProcessFunction doesn't work
Key: FLINK-9123
URL: https://issues.apache.org/jira/browse/FLINK-9123
Project: Flink
Issue Type: Bug
aitozi created FLINK-9122:
-
Summary: NFASerialize deserailze failed and cause other exception
Key: FLINK-9122
URL: https://issues.apache.org/jira/browse/FLINK-9122
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-9121:
Summary: Remove Flip-6 prefixes from code base
Key: FLINK-9121
URL: https://issues.apache.org/jira/browse/FLINK-9121
Project: Flink
Issue Type: Improvement
