Jiayi Liao created FLINK-10348:
--
Summary: Solve data skew when consuming data from kafka
Key: FLINK-10348
URL: https://issues.apache.org/jira/browse/FLINK-10348
Project: Flink
Issue Type: New Fe
Any chance we may see a 1.4.3 release with the ZK fixes?
On Fri, Sep 14, 2018 at 8:29 AM Till Rohrmann wrote:
> Hi everyone,
>
> it has already been a couple of weeks since we released Flink 1.5.3 and
> Flink 1.6.0. In both release branches are important bug fixes from which
> our users can bene
Till Rohrmann created FLINK-10347:
-
Summary: Kafka09SecuredRunITCase failed on Travis
Key: FLINK-10347
URL: https://issues.apache.org/jira/browse/FLINK-10347
Project: Flink
Issue Type: Bug
Hi everyone,
it has already been a couple of weeks since we released Flink 1.5.3 and
Flink 1.6.0. In both release branches are important bug fixes from which
our users can benefit (1.5.4: 23 resolved issues, 1.6.1: 60 resolved
issues). Therefore, I propose to create the next bug fix release for Fl
Hi Niels and Richard,
I would be very happy about having a PubSub connector in Flink. Having it in
Flink means that you don't have manual effort for tracking API changes and I
think having a production user is incentive enough for them (you) to maintain
the connector.
I'm afraid we don't have
Hi all,
We (Richard and I) would really appreciate it if you guys could review
the new feature we created (see below).
It is something we really need in production and thought it would be
best if it can be a native part of the Flink toolset.
Please indicate what we need to change/improve in order
Till Rohrmann created FLINK-10346:
-
Summary: MemoryStateBackend does not clean up checkpoint directory
Key: FLINK-10346
URL: https://issues.apache.org/jira/browse/FLINK-10346
Project: Flink
I
