Re: [DISCUSS] Adding support for Hadoop 3 and removing flink-shaded-hadoop

Hi Chesnay, Hi Robert, I have a bit of a naive question. I assume the reason for introducing flink-shaded-hadoop were dependency conflicts between Hadoop, Flink and/or user code. When we drop it now is it because a) it was not worth it (value provided did not justify maintenance overhead and issu

[ANNOUNCE] Weekly Community Update 2020/18

Dear community, happy to share - a brief - community update this week with an update on Flink 1.10.1, our application to Google Season of Docs 2020, a discussion to support Hadoop 3, a recap of Flink Forward Virtual 2020 and a bit more. Flink Development == * [releases] Yu has publis

Re: [VOTE] Release 1.10.1, release candidate #2

Thanks a lot for addressing the issues from the last release candidate and creating this one! +1 (binding) - Started Flink on YARN on Google Cloud DataProc by setting HADOOP_CLASSPATH - checked staging repo On Sat, May 2, 2020 at 6:57 PM Thomas Weise wrote: > +1 (binding) > > Checked signatu

[jira] [Created] (FLINK-17497) Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0"

Robert Metzger created FLINK-17497: -- Summary: Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0" Key: FLINK-17497 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

Robert Metzger created FLINK-17498: -- Summary: MapCancelingITCase.testMapCancelling fails with timeout Key: FLINK-17498 URL: https://issues.apache.org/jira/browse/FLINK-17498 Project: Flink I

Re: Flink 1.9.2 why always checkpoint expired

Hi >From the picture and the previous eamil. you use RocksDBStateBackend, and all the operators chained together, checkpoint timeout set to 2min. Do you have keyed state in your job (do you have `keyby` in your job)? I'll share some experience to find out the reason of checkpoint timeout problem

[jira] [Created] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

Adam Laczynski created FLINK-17499: -- Summary: LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers Key: FLINK-17499 URL: https://issues.

Re: [DISCUSS] flink-connector-rabbitmq api changes

Hi, Okay so keep the current constructors as is, create new ones with more granular parsing of the results. Sounds like a good plan. How do we proceed from here ? Regards, Karim Mansour On Fri, May 1, 2020 at 5:03 PM Austin Cawley-Edwards < austin.caw...@gmail.com> wrote: > Hey, > > (Switching

[GitHub] [flink-web] hequn8128 commented on a change in pull request #330: Add Apache Flink release 1.10.1

hequn8128 commented on a change in pull request #330: URL: https://github.com/apache/flink-web/pull/330#discussion_r419198602 ## File path: _posts/2020-05-05-release-1.10.1.md ## @@ -0,0 +1,370 @@ +--- +layout: post +title: "Apache Flink 1.10.1 Released" +date: 2020-05-05 12

Re: "[VOTE] FLIP-108: edit the Public API"

+1 (non-binding) Thank you~ Xintong Song On Sat, May 2, 2020 at 9:46 PM Becket Qin wrote: > +1. The API change sounds good to me. > > Thanks, > > Jiangjie (Becket) Qin > > On Fri, May 1, 2020 at 10:25 PM Yu Li wrote: > > > +1 > > > > I could see there's a thorough discussion and the solutio