I fixed the problem indicated in your comment and added an extra test for
that.
CI is currently running the tests.
Niels
On Tue, Jun 19, 2018 at 12:19 PM, Ted Yu wrote:
> Interesting enhancement.
>
> I left a minor comment on the PR.
>
> Cheers
>
> On Tue, Jun 19, 2018 at 12:26 AM, Niels Basjes
Interesting enhancement.
I left a minor comment on the PR.
Cheers
On Tue, Jun 19, 2018 at 12:26 AM, Niels Basjes wrote:
> Hi,
>
> Yesterday we ran into problems regarding the distribution of records across
> Kafka where Flink was used as the producer. So we fixed this and realized
> that the c
Hi,
Yesterday we ran into problems regarding the distribution of records across
Kafka where Flink was used as the producer. So we fixed this and realized
that the code to do this would be useful to others.
I put up a Jira ticket and pull request yesterday and it passes all
automated tests.
Please
