vinoyang created FLINK-11737:
Summary: Support MultipleOutputs output
Key: FLINK-11737
URL: https://issues.apache.org/jira/browse/FLINK-11737
Project: Flink
Issue Type: Improvement
Comp
Hi,
The Apache Flink community is very happy to announce the release of
Apache Flink 1.6.4, which is the fourth bugfix release for the Apache
Flink 1.6 series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streami
Thanks Jincheng for managing the release and everybody who contributed!
Best, Hequn
On Mon, Feb 25, 2019 at 9:46 AM jincheng sun
wrote:
> Hi,
>
> The Apache Flink community is very happy to announce the release of
> Apache Flink 1.6.4, which is the fourth bugfix release for the Apache
> Flink 1
@jincheng sun Thanks for being the release
manager. Great work!
Glad to see Flink 1.6.4!
Best,
Vino
Hequn Cheng 于2019年2月25日周一 上午9:51写道：
> Thanks Jincheng for managing the release and everybody who contributed!
>
> Best, Hequn
>
> On Mon, Feb 25, 2019 at 9:46 AM jincheng sun
> wrote:
>
> > Hi
thinktothings created FLINK-11738:
-
Summary: Caused by: akka.pattern.AskTimeoutException: Ask timed
out on
[Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]]
after [1 ms]. Sender[null] sent
Hi Roshan,
I think the final watermark is generated by the source operator which wraps
user-defined source function and emit a final watermark when source
function finished [1]. And the watermark operator (which wraps your
assignTimestampsAndWatermarks) will forward only the final watermark [2].
Thanks for being the release manager Jingcheng.
The 1.6.4 release contains a couple of important fixes.
Thank you and the community for all the hard work which made this release
possible.
Best,
Jark
On Mon, 25 Feb 2019 at 10:09, vino yang wrote:
> @jincheng sun Thanks for being the release
>
Hi Chesnay,
It might be easier to discuss some implementation details in the PR review
instead of in the FLIP discussion thread. I have a patch for Kafka
connectors ready but haven't submitted the PR yet. Hopefully that will help
explain a bit more.
** Re: metric type binding
This is a valid poin
xulinjie created FLINK-11739:
Summary: Markdown Syntax Errors in Flink-Web Chinese Documents
Key: FLINK-11739
URL: https://issues.apache.org/jira/browse/FLINK-11739
Project: Flink
Issue Type: Bug
