Sorry for that inconvenience. You are right about mentioning that in the
release notes (adding it even after the release).
We'll take that as feedback for the next release.
On Tue, Sep 27, 2016 at 9:42 PM, Chen Bekor wrote:
> thanks. worth mentioning in the release notes of 1.1.2 that file so
thanks. worth mentioning in the release notes of 1.1.2 that file source is
broken. we spent a substantial time on trying to figure out what's the
root cause.
On Sep 27, 2016 9:40 PM, "Stephan Ewen" wrote:
> Sorry for the inconvenience. This is a known issue and being fixed for
> Flink 1.1.3 - t
Sorry for the inconvenience. This is a known issue and being fixed for
Flink 1.1.3 - the problem is that the streaming File sources were reworked
to continuously monitor the File System, but the watermarks are not handled
correctly.
https://issues.apache.org/jira/browse/FLINK-4329
So far, 2/3 par
Hi Chen,
Please upload your Flink scala library dependencies.
Regards
Sunny.
On Tue, Sep 27, 2016 at 5:56 PM, Chen Bekor wrote:
> Hi,
>
> Since upgrading to flink 1.1.2 from 1.0.2 - I'm experiencing regression in
> my code. In order to Isolate the issue I have written a small flink job
> that
Hi,
Since upgrading to flink 1.1.2 from 1.0.2 - I'm experiencing regression in
my code. In order to Isolate the issue I have written a small flink job
that demonstrates that.
The job does some time based window operations with an input csv file (in
the example below - count the number of events o
