Hi,
I was wondering whether we should release Flink 0.10.1 soon, as there are some issues we've identified: (pending PRs) - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state - FLINK-3021 Fix class loading issue for streaming sources - FLINK-2989 job cancel button doesn't work on YARN (merged) - FLINK-2977 Using reflection to load HBase Kerberos tokens - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency Anything else that you would like to add? Do you think we can manage to merge the four PRs until tomorrow and then start the RC? |
Hey,
I would also add FLINK-3012 and FLINK-3036 (both pending PRs). Thanks! -Vasia. On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> wrote: > Hi, > > I was wondering whether we should release Flink 0.10.1 soon, as there are > some issues we've identified: > > (pending PRs) > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > conflict > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > - FLINK-3021 Fix class loading issue for streaming sources > - FLINK-2989 job cancel button doesn't work on YARN > > (merged) > - FLINK-2977 Using reflection to load HBase Kerberos tokens > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > Anything else that you would like to add? > > Do you think we can manage to merge the four PRs until tomorrow and then > start the RC? > |
+1 for a timely 0.10.1 release
I would like to add FLINK-2974 - periodic kafka offset committer for case where checkpointing is deactivated On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < [hidden email]> wrote: > Hey, > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > Thanks! > -Vasia. > > On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> wrote: > > > Hi, > > > > I was wondering whether we should release Flink 0.10.1 soon, as there are > > some issues we've identified: > > > > (pending PRs) > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > conflict > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > - FLINK-3021 Fix class loading issue for streaming sources > > - FLINK-2989 job cancel button doesn't work on YARN > > > > (merged) > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > Anything else that you would like to add? > > > > Do you think we can manage to merge the four PRs until tomorrow and then > > start the RC? > > > |
@Vasia, do you mean FLINK-3013 or FLINK-3012?
Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> wrote: > +1 for a timely 0.10.1 release > > I would like to add FLINK-2974 - periodic kafka offset committer for case > where checkpointing is deactivated > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > [hidden email]> wrote: > > > Hey, > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > Thanks! > > -Vasia. > > > > On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> > wrote: > > > > > Hi, > > > > > > I was wondering whether we should release Flink 0.10.1 soon, as there > are > > > some issues we've identified: > > > > > > (pending PRs) > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > > conflict > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > - FLINK-3021 Fix class loading issue for streaming sources > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > (merged) > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > > > > Anything else that you would like to add? > > > > > > Do you think we can manage to merge the four PRs until tomorrow and > then > > > start the RC? > > > > > > |
Big +1
I think the mentioned issues cover all important fixes. – Ufuk > On 18 Nov 2015, at 13:49, Till Rohrmann <[hidden email]> wrote: > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> wrote: > >> +1 for a timely 0.10.1 release >> >> I would like to add FLINK-2974 - periodic kafka offset committer for case >> where checkpointing is deactivated >> >> On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < >> [hidden email]> wrote: >> >>> Hey, >>> >>> I would also add FLINK-3012 and FLINK-3036 (both pending PRs). >>> >>> Thanks! >>> -Vasia. >>> >>> On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> >> wrote: >>> >>>> Hi, >>>> >>>> I was wondering whether we should release Flink 0.10.1 soon, as there >> are >>>> some issues we've identified: >>>> >>>> (pending PRs) >>>> - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class >>>> conflict >>>> - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state >>>> - FLINK-3021 Fix class loading issue for streaming sources >>>> - FLINK-2989 job cancel button doesn't work on YARN >>>> >>>> (merged) >>>> - FLINK-2977 Using reflection to load HBase Kerberos tokens >>>> - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour >>>> - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey >>>> - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency >>>> >>>> >>>> Anything else that you would like to add? >>>> >>>> Do you think we can manage to merge the four PRs until tomorrow and >> then >>>> start the RC? >>>> >>> >> |
*FLINK-3013 you're right :)
On 18 November 2015 at 13:52, Ufuk Celebi <[hidden email]> wrote: > Big +1 > > I think the mentioned issues cover all important fixes. > > – Ufuk > > > On 18 Nov 2015, at 13:49, Till Rohrmann <[hidden email]> wrote: > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> wrote: > > > >> +1 for a timely 0.10.1 release > >> > >> I would like to add FLINK-2974 - periodic kafka offset committer for > case > >> where checkpointing is deactivated > >> > >> On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > >> [hidden email]> wrote: > >> > >>> Hey, > >>> > >>> I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > >>> > >>> Thanks! > >>> -Vasia. > >>> > >>> On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> > >> wrote: > >>> > >>>> Hi, > >>>> > >>>> I was wondering whether we should release Flink 0.10.1 soon, as there > >> are > >>>> some issues we've identified: > >>>> > >>>> (pending PRs) > >>>> - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > >>>> conflict > >>>> - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > >>>> - FLINK-3021 Fix class loading issue for streaming sources > >>>> - FLINK-2989 job cancel button doesn't work on YARN > >>>> > >>>> (merged) > >>>> - FLINK-2977 Using reflection to load HBase Kerberos tokens > >>>> - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > >>>> - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > >>>> - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > >>>> > >>>> > >>>> Anything else that you would like to add? > >>>> > >>>> Do you think we can manage to merge the four PRs until tomorrow and > >> then > >>>> start the RC? > >>>> > >>> > >> > > |
In reply to this post by Till Rohrmann
Would be nice to have Flink-2949 in the mix, but I won't be able to get to
it until early next week. On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann <[hidden email]> wrote: > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> wrote: > > > +1 for a timely 0.10.1 release > > > > I would like to add FLINK-2974 - periodic kafka offset committer for case > > where checkpointing is deactivated > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > [hidden email]> wrote: > > > > > Hey, > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > > > Thanks! > > > -Vasia. > > > > > > On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> > > wrote: > > > > > > > Hi, > > > > > > > > I was wondering whether we should release Flink 0.10.1 soon, as there > > are > > > > some issues we've identified: > > > > > > > > (pending PRs) > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > class > > > > conflict > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > (merged) > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > stratey > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > Do you think we can manage to merge the four PRs until tomorrow and > > then > > > > start the RC? > > > > > > > > > > |
@Suneel: I think that's OK for the next major release :)
On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi <[hidden email]> wrote: > Would be nice to have Flink-2949 in the mix, but I won't be able to get to > it until early next week. > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann <[hidden email]> > wrote: > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> wrote: > > > > > +1 for a timely 0.10.1 release > > > > > > I would like to add FLINK-2974 - periodic kafka offset committer for > case > > > where checkpointing is deactivated > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > [hidden email]> wrote: > > > > > > > Hey, > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > > > > > Thanks! > > > > -Vasia. > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> > > > wrote: > > > > > > > > > Hi, > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 soon, as > there > > > are > > > > > some issues we've identified: > > > > > > > > > > (pending PRs) > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > > class > > > > > conflict > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > (merged) > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > stratey > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > Do you think we can manage to merge the four PRs until tomorrow and > > > then > > > > > start the RC? > > > > > > > > > > > > > > > |
@Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 is a new
feature. The 0.10.1 release is intended as a bugfix release only. FLINK-3013 and FLINK-3036 have been merged to master only. Are there plans to merge it to "release-0.10" as well? The list of issues now looks as follows: (pending PRs) - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state - FLINK-3021 Fix class loading issue for streaming sources - FLINK-2974 Add periodic offset committer for Kafka (merged) - FLINK-2977 Using reflection to load HBase Kerberos tokens - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency (merged since my first email) - FLINK-2989 job cancel button doesn't work on YARN On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: > @Suneel: I think that's OK for the next major release :) > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi <[hidden email]> > wrote: > > > Would be nice to have Flink-2949 in the mix, but I won't be able to get > to > > it until early next week. > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann <[hidden email]> > > wrote: > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> > wrote: > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset committer for > > case > > > > where checkpointing is deactivated > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > [hidden email]> wrote: > > > > > > > > > Hey, > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > > > > > > > Thanks! > > > > > -Vasia. > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger <[hidden email]> > > > > wrote: > > > > > > > > > > > Hi, > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 soon, as > > there > > > > are > > > > > > some issues we've identified: > > > > > > > > > > > > (pending PRs) > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > > > class > > > > > > conflict > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > (merged) > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > Behaviour > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > > stratey > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > Do you think we can manage to merge the four PRs until tomorrow > and > > > > then > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > |
Yes forgot about merging them to release-0.10. Will do it right away.
On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> wrote: > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 is a new > feature. The 0.10.1 release is intended as a bugfix release only. > > FLINK-3013 and FLINK-3036 have been merged to master only. Are there plans > to merge it to "release-0.10" as well? > > The list of issues now looks as follows: > > (pending PRs) > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > conflict > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > - FLINK-3021 Fix class loading issue for streaming sources > - FLINK-2974 Add periodic offset committer for Kafka > > > (merged) > - FLINK-2977 Using reflection to load HBase Kerberos tokens > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > (merged since my first email) > - FLINK-2989 job cancel button doesn't work on YARN > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: > > > @Suneel: I think that's OK for the next major release :) > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi <[hidden email]> > > wrote: > > > > > Would be nice to have Flink-2949 in the mix, but I won't be able to get > > to > > > it until early next week. > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann <[hidden email]> > > > wrote: > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> > > wrote: > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset committer > for > > > case > > > > > where checkpointing is deactivated > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > [hidden email]> wrote: > > > > > > > > > > > Hey, > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > > > > > > > > > Thanks! > > > > > > -Vasia. > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > [hidden email]> > > > > > wrote: > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 soon, as > > > there > > > > > are > > > > > > > some issues we've identified: > > > > > > > > > > > > > > (pending PRs) > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due > to > > > > class > > > > > > > conflict > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > (merged) > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > Behaviour > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > > > stratey > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > dependency > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs until tomorrow > > and > > > > > then > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
@Till Should the recent updates to docs/apis/streaming-guide.md be also
merged to 'release 0.10'? There are other related PRs pending. On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email]> wrote: > Yes forgot about merging them to release-0.10. Will do it right away. > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> wrote: > > > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 is a > new > > feature. The 0.10.1 release is intended as a bugfix release only. > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are there > plans > > to merge it to "release-0.10" as well? > > > > The list of issues now looks as follows: > > > > (pending PRs) > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > conflict > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > - FLINK-3021 Fix class loading issue for streaming sources > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > (merged) > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > (merged since my first email) > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > [hidden email]> > > > wrote: > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be able to > get > > > to > > > > it until early next week. > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann <[hidden email] > > > > > > wrote: > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> > > > wrote: > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset committer > > for > > > > case > > > > > > where checkpointing is deactivated > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending PRs). > > > > > > > > > > > > > > Thanks! > > > > > > > -Vasia. > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > [hidden email]> > > > > > > wrote: > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 soon, > as > > > > there > > > > > > are > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due > > to > > > > > class > > > > > > > > conflict > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > (merged) > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > Behaviour > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > detection > > > > > stratey > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > dependency > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs until > tomorrow > > > and > > > > > > then > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
If they cover things which are also wrongly documented in 0.10, then they
should be merged to 0.10-release as well. On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi <[hidden email]> wrote: > @Till Should the recent updates to docs/apis/streaming-guide.md be also > merged to 'release 0.10'? There are other related PRs pending. > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email]> > wrote: > > > Yes forgot about merging them to release-0.10. Will do it right away. > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> wrote: > > > > > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 is a > > new > > > feature. The 0.10.1 release is intended as a bugfix release only. > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are there > > plans > > > to merge it to "release-0.10" as well? > > > > > > The list of issues now looks as follows: > > > > > > (pending PRs) > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > > conflict > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > - FLINK-3021 Fix class loading issue for streaming sources > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > (merged) > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > (merged since my first email) > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > [hidden email]> > > > > wrote: > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be able to > > get > > > > to > > > > > it until early next week. > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > [hidden email] > > > > > > > > wrote: > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> > > > > wrote: > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset > committer > > > for > > > > > case > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending > PRs). > > > > > > > > > > > > > > > > Thanks! > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > [hidden email]> > > > > > > > wrote: > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 > soon, > > as > > > > > there > > > > > > > are > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), > due > > > to > > > > > > class > > > > > > > > > conflict > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > > Behaviour > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > detection > > > > > > stratey > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs until > > tomorrow > > > > and > > > > > > > then > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
+1 for a 0.10.1 release pretty soon.
I merged FLINK-2989 (job cancel button doesn't work on YARN). On Thu, Nov 19, 2015 at 10:10 AM, Till Rohrmann <[hidden email]> wrote: > If they cover things which are also wrongly documented in 0.10, then they > should be merged to 0.10-release as well. > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi <[hidden email]> > wrote: > >> @Till Should the recent updates to docs/apis/streaming-guide.md be also >> merged to 'release 0.10'? There are other related PRs pending. >> >> On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email]> >> wrote: >> >> > Yes forgot about merging them to release-0.10. Will do it right away. >> > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> wrote: >> > >> > > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 is a >> > new >> > > feature. The 0.10.1 release is intended as a bugfix release only. >> > > >> > > FLINK-3013 and FLINK-3036 have been merged to master only. Are there >> > plans >> > > to merge it to "release-0.10" as well? >> > > >> > > The list of issues now looks as follows: >> > > >> > > (pending PRs) >> > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class >> > > conflict >> > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state >> > > - FLINK-3021 Fix class loading issue for streaming sources >> > > - FLINK-2974 Add periodic offset committer for Kafka >> > > >> > > >> > > (merged) >> > > - FLINK-2977 Using reflection to load HBase Kerberos tokens >> > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour >> > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey >> > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency >> > > (merged since my first email) >> > > - FLINK-2989 job cancel button doesn't work on YARN >> > > >> > > >> > > >> > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: >> > > >> > > > @Suneel: I think that's OK for the next major release :) >> > > > >> > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < >> > [hidden email]> >> > > > wrote: >> > > > >> > > > > Would be nice to have Flink-2949 in the mix, but I won't be able to >> > get >> > > > to >> > > > > it until early next week. >> > > > > >> > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < >> [hidden email] >> > > >> > > > > wrote: >> > > > > >> > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? >> > > > > > >> > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. >> > > > > > >> > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen <[hidden email]> >> > > > wrote: >> > > > > > >> > > > > > > +1 for a timely 0.10.1 release >> > > > > > > >> > > > > > > I would like to add FLINK-2974 - periodic kafka offset >> committer >> > > for >> > > > > case >> > > > > > > where checkpointing is deactivated >> > > > > > > >> > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < >> > > > > > > [hidden email]> wrote: >> > > > > > > >> > > > > > > > Hey, >> > > > > > > > >> > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending >> PRs). >> > > > > > > > >> > > > > > > > Thanks! >> > > > > > > > -Vasia. >> > > > > > > > >> > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < >> > > [hidden email]> >> > > > > > > wrote: >> > > > > > > > >> > > > > > > > > Hi, >> > > > > > > > > >> > > > > > > > > I was wondering whether we should release Flink 0.10.1 >> soon, >> > as >> > > > > there >> > > > > > > are >> > > > > > > > > some issues we've identified: >> > > > > > > > > >> > > > > > > > > (pending PRs) >> > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), >> due >> > > to >> > > > > > class >> > > > > > > > > conflict >> > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state >> > > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources >> > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN >> > > > > > > > > >> > > > > > > > > (merged) >> > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens >> > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() >> > > > Behaviour >> > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address >> > detection >> > > > > > stratey >> > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient >> > > dependency >> > > > > > > > > >> > > > > > > > > >> > > > > > > > > Anything else that you would like to add? >> > > > > > > > > >> > > > > > > > > Do you think we can manage to merge the four PRs until >> > tomorrow >> > > > and >> > > > > > > then >> > > > > > > > > start the RC? >> > > > > > > > > >> > > > > > > > >> > > > > > > >> > > > > > >> > > > > >> > > > >> > > >> > >> |
In reply to this post by till.rohrmann
Flink-3017, Flink-3022, and some hotfixes u had put in over the past few
days. Flink-3041 and Flink-3043 are pending PRs at the moment. On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann <[hidden email]> wrote: > If they cover things which are also wrongly documented in 0.10, then they > should be merged to 0.10-release as well. > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi <[hidden email]> > wrote: > > > @Till Should the recent updates to docs/apis/streaming-guide.md be also > > merged to 'release 0.10'? There are other related PRs pending. > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email]> > > wrote: > > > > > Yes forgot about merging them to release-0.10. Will do it right away. > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> wrote: > > > > > > > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 > is a > > > new > > > > feature. The 0.10.1 release is intended as a bugfix release only. > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are there > > > plans > > > > to merge it to "release-0.10" as well? > > > > > > > > The list of issues now looks as follows: > > > > > > > > (pending PRs) > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > class > > > > conflict > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > (merged) > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > stratey > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > (merged since my first email) > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> wrote: > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > [hidden email]> > > > > > wrote: > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be able > to > > > get > > > > > to > > > > > > it until early next week. > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > [hidden email] > > > > > > > > > > wrote: > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > [hidden email]> > > > > > wrote: > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset > > committer > > > > for > > > > > > case > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending > > PRs). > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > [hidden email]> > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 > > soon, > > > as > > > > > > there > > > > > > > > are > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), > > due > > > > to > > > > > > > class > > > > > > > > > > conflict > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming > sources > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos > tokens > > > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > > > Behaviour > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > > detection > > > > > > > stratey > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs until > > > tomorrow > > > > > and > > > > > > > > then > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Looks like we didn't manage to merge everything today.
(pending PRs) - FLINK-3021 Fix class loading issue for streaming sources - FLINK-2974 Add periodic offset committer for Kafka (merged) - FLINK-2977 Using reflection to load HBase Kerberos tokens - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency (merged since my first email) - FLINK-2989 job cancel button doesn't work on YARN - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state Is anybody volunteering to be a release manager? On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi <[hidden email]> wrote: > Flink-3017, Flink-3022, and some hotfixes u had put in over the past few > days. > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann <[hidden email]> > wrote: > > > If they cover things which are also wrongly documented in 0.10, then they > > should be merged to 0.10-release as well. > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi <[hidden email] > > > > wrote: > > > > > @Till Should the recent updates to docs/apis/streaming-guide.md be > also > > > merged to 'release 0.10'? There are other related PRs pending. > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email]> > > > wrote: > > > > > > > Yes forgot about merging them to release-0.10. Will do it right away. > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> > wrote: > > > > > > > > > @Suneel, I think https://issues.apache.org/jira/browse/FLINK-2949 > > is a > > > > new > > > > > feature. The 0.10.1 release is intended as a bugfix release only. > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are > there > > > > plans > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > (pending PRs) > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > > class > > > > > conflict > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > (merged) > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > stratey > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > (merged since my first email) > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> > wrote: > > > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > [hidden email]> > > > > > > wrote: > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be > able > > to > > > > get > > > > > > to > > > > > > > it until early next week. > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > [hidden email] > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this afternoon. > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > [hidden email]> > > > > > > wrote: > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset > > > committer > > > > > for > > > > > > > case > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both pending > > > PRs). > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > [hidden email]> > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink 0.10.1 > > > soon, > > > > as > > > > > > > there > > > > > > > > > are > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 > (HDP), > > > due > > > > > to > > > > > > > > class > > > > > > > > > > > conflict > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING > state > > > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming > > sources > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos > > tokens > > > > > > > > > > > - FLINK-3024 Fix > TimestampExtractor.getCurrentWatermark() > > > > > > Behaviour > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > > > detection > > > > > > > > stratey > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs until > > > > tomorrow > > > > > > and > > > > > > > > > then > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Let me look at FLINK-2974 (open PR) to see if it can be merged...
On Thu, Nov 19, 2015 at 10:09 PM, Robert Metzger <[hidden email]> wrote: > Looks like we didn't manage to merge everything today. > > (pending PRs) > - FLINK-3021 Fix class loading issue for streaming sources > - FLINK-2974 Add periodic offset committer for Kafka > > (merged) > - FLINK-2977 Using reflection to load HBase Kerberos tokens > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > (merged since my first email) > - FLINK-2989 job cancel button doesn't work on YARN > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > conflict > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > Is anybody volunteering to be a release manager? > > > On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi <[hidden email]> > wrote: > > > Flink-3017, Flink-3022, and some hotfixes u had put in over the past few > > days. > > > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann <[hidden email]> > > wrote: > > > > > If they cover things which are also wrongly documented in 0.10, then > they > > > should be merged to 0.10-release as well. > > > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi < > [hidden email] > > > > > > wrote: > > > > > > > @Till Should the recent updates to docs/apis/streaming-guide.md be > > also > > > > merged to 'release 0.10'? There are other related PRs pending. > > > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann <[hidden email] > > > > > > wrote: > > > > > > > > > Yes forgot about merging them to release-0.10. Will do it right > away. > > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> > > wrote: > > > > > > > > > > > @Suneel, I think > https://issues.apache.org/jira/browse/FLINK-2949 > > > is a > > > > > new > > > > > > feature. The 0.10.1 release is intended as a bugfix release only. > > > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are > > there > > > > > plans > > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > > > (pending PRs) > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > > > class > > > > > > conflict > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > > > > (merged) > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > Behaviour > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > > stratey > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > > (merged since my first email) > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> > > wrote: > > > > > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > > [hidden email]> > > > > > > > wrote: > > > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be > > able > > > to > > > > > get > > > > > > > to > > > > > > > > it until early next week. > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > > [hidden email] > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this > afternoon. > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > > [hidden email]> > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset > > > > committer > > > > > > for > > > > > > > > case > > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both > pending > > > > PRs). > > > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > > [hidden email]> > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink > 0.10.1 > > > > soon, > > > > > as > > > > > > > > there > > > > > > > > > > are > > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 > > (HDP), > > > > due > > > > > > to > > > > > > > > > class > > > > > > > > > > > > conflict > > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING > > state > > > > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming > > > sources > > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos > > > tokens > > > > > > > > > > > > - FLINK-3024 Fix > > TimestampExtractor.getCurrentWatermark() > > > > > > > Behaviour > > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > > > > detection > > > > > > > > > stratey > > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive > ZkClient > > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs > until > > > > > tomorrow > > > > > > > and > > > > > > > > > > then > > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Great, thank you!
Let me know if there is any issue, I'll address it asap. The PR is not building anymore because you've pushed an update to the Kafka documentation. I can rebase and merge the PR once you give me green light ;) Till has merged FLINK-3021, so we might be able to have a first RC today. On Fri, Nov 20, 2015 at 11:05 AM, Stephan Ewen <[hidden email]> wrote: > Let me look at FLINK-2974 (open PR) to see if it can be merged... > > On Thu, Nov 19, 2015 at 10:09 PM, Robert Metzger <[hidden email]> > wrote: > > > Looks like we didn't manage to merge everything today. > > > > (pending PRs) > > - FLINK-3021 Fix class loading issue for streaming sources > > - FLINK-2974 Add periodic offset committer for Kafka > > > > (merged) > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > (merged since my first email) > > - FLINK-2989 job cancel button doesn't work on YARN > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > conflict > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > Is anybody volunteering to be a release manager? > > > > > > On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi <[hidden email]> > > wrote: > > > > > Flink-3017, Flink-3022, and some hotfixes u had put in over the past > few > > > days. > > > > > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > > > > > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann < > [hidden email]> > > > wrote: > > > > > > > If they cover things which are also wrongly documented in 0.10, then > > they > > > > should be merged to 0.10-release as well. > > > > > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi < > > [hidden email] > > > > > > > > wrote: > > > > > > > > > @Till Should the recent updates to docs/apis/streaming-guide.md be > > > also > > > > > merged to 'release 0.10'? There are other related PRs pending. > > > > > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann < > [hidden email] > > > > > > > > wrote: > > > > > > > > > > > Yes forgot about merging them to release-0.10. Will do it right > > away. > > > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email]> > > > wrote: > > > > > > > > > > > > > @Suneel, I think > > https://issues.apache.org/jira/browse/FLINK-2949 > > > > is a > > > > > > new > > > > > > > feature. The 0.10.1 release is intended as a bugfix release > only. > > > > > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. Are > > > there > > > > > > plans > > > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > > > > > (pending PRs) > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due > to > > > > class > > > > > > > conflict > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > Behaviour > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > > > stratey > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > dependency > > > > > > > (merged since my first email) > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email]> > > > wrote: > > > > > > > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > > > [hidden email]> > > > > > > > > wrote: > > > > > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't be > > > able > > > > to > > > > > > get > > > > > > > > to > > > > > > > > > it until early next week. > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > > > [hidden email] > > > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this > > afternoon. > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > > > [hidden email]> > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka offset > > > > > committer > > > > > > > for > > > > > > > > > case > > > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both > > pending > > > > > PRs). > > > > > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > > > [hidden email]> > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink > > 0.10.1 > > > > > soon, > > > > > > as > > > > > > > > > there > > > > > > > > > > > are > > > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 > > > (HDP), > > > > > due > > > > > > > to > > > > > > > > > > class > > > > > > > > > > > > > conflict > > > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING > > > state > > > > > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming > > > > sources > > > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase > Kerberos > > > > tokens > > > > > > > > > > > > > - FLINK-3024 Fix > > > TimestampExtractor.getCurrentWatermark() > > > > > > > > Behaviour > > > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST > address > > > > > > detection > > > > > > > > > > stratey > > > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive > > ZkClient > > > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs > > until > > > > > > tomorrow > > > > > > > > and > > > > > > > > > > > then > > > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Actually, I still have another bug related to the optimizer which I would
like to include if possible. The problem is that the optimizer is not able to push properties properly out of a bulk iteration which in some cases can lead to rejected Flink jobs. On Fri, Nov 20, 2015 at 11:10 AM, Robert Metzger <[hidden email]> wrote: > Great, thank you! > > Let me know if there is any issue, I'll address it asap. The PR is not > building anymore because you've pushed an update to the Kafka > documentation. I can rebase and merge the PR once you give me green light > ;) > > Till has merged FLINK-3021, so we might be able to have a first RC today. > > > On Fri, Nov 20, 2015 at 11:05 AM, Stephan Ewen <[hidden email]> wrote: > > > Let me look at FLINK-2974 (open PR) to see if it can be merged... > > > > On Thu, Nov 19, 2015 at 10:09 PM, Robert Metzger <[hidden email]> > > wrote: > > > > > Looks like we didn't manage to merge everything today. > > > > > > (pending PRs) > > > - FLINK-3021 Fix class loading issue for streaming sources > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > (merged) > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection stratey > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > (merged since my first email) > > > - FLINK-2989 job cancel button doesn't work on YARN > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to class > > > conflict > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > Is anybody volunteering to be a release manager? > > > > > > > > > On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi <[hidden email]> > > > wrote: > > > > > > > Flink-3017, Flink-3022, and some hotfixes u had put in over the past > > few > > > > days. > > > > > > > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > > > > > > > > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann < > > [hidden email]> > > > > wrote: > > > > > > > > > If they cover things which are also wrongly documented in 0.10, > then > > > they > > > > > should be merged to 0.10-release as well. > > > > > > > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi < > > > [hidden email] > > > > > > > > > > wrote: > > > > > > > > > > > @Till Should the recent updates to docs/apis/streaming-guide.md > be > > > > also > > > > > > merged to 'release 0.10'? There are other related PRs pending. > > > > > > > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann < > > [hidden email] > > > > > > > > > > wrote: > > > > > > > > > > > > > Yes forgot about merging them to release-0.10. Will do it right > > > away. > > > > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" <[hidden email] > > > > > > wrote: > > > > > > > > > > > > > > > @Suneel, I think > > > https://issues.apache.org/jira/browse/FLINK-2949 > > > > > is a > > > > > > > new > > > > > > > > feature. The 0.10.1 release is intended as a bugfix release > > only. > > > > > > > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. > Are > > > > there > > > > > > > plans > > > > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due > > to > > > > > class > > > > > > > > conflict > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > Behaviour > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > detection > > > > > stratey > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > dependency > > > > > > > > (merged since my first email) > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi <[hidden email] > > > > > > wrote: > > > > > > > > > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > > > > [hidden email]> > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I won't > be > > > > able > > > > > to > > > > > > > get > > > > > > > > > to > > > > > > > > > > it until early next week. > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > > > > [hidden email] > > > > > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this > > > afternoon. > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > > > > [hidden email]> > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka > offset > > > > > > committer > > > > > > > > for > > > > > > > > > > case > > > > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri < > > > > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both > > > pending > > > > > > PRs). > > > > > > > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > > > > [hidden email]> > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink > > > 0.10.1 > > > > > > soon, > > > > > > > as > > > > > > > > > > there > > > > > > > > > > > > are > > > > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop > 2.7.1 > > > > (HDP), > > > > > > due > > > > > > > > to > > > > > > > > > > > class > > > > > > > > > > > > > > conflict > > > > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in > RESTARTING > > > > state > > > > > > > > > > > > > > - FLINK-3021 Fix class loading issue for > streaming > > > > > sources > > > > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on > YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase > > Kerberos > > > > > tokens > > > > > > > > > > > > > > - FLINK-3024 Fix > > > > TimestampExtractor.getCurrentWatermark() > > > > > > > > > Behaviour > > > > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST > > address > > > > > > > detection > > > > > > > > > > > stratey > > > > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive > > > ZkClient > > > > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four PRs > > > until > > > > > > > tomorrow > > > > > > > > > and > > > > > > > > > > > > then > > > > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Hi all,
Wouldnt you think that it would make sense to wait a week or so to find all the hot issues with the current release? To me it feels a little bit like rushing this out and we will have almost the same situation afterwards. I might be wrong but I think people should get a chance to try this out. In any case I would +1 for the quick release if everyone else thinks thats the way, these are just my thoughts. Gyula On Fri, Nov 20, 2015 at 11:13 AM Till Rohrmann <[hidden email]> wrote: > Actually, I still have another bug related to the optimizer which I would > like to include if possible. The problem is that the optimizer is not able > to push properties properly out of a bulk iteration which in some cases can > lead to rejected Flink jobs. > > On Fri, Nov 20, 2015 at 11:10 AM, Robert Metzger <[hidden email]> > wrote: > > > Great, thank you! > > > > Let me know if there is any issue, I'll address it asap. The PR is not > > building anymore because you've pushed an update to the Kafka > > documentation. I can rebase and merge the PR once you give me green light > > ;) > > > > Till has merged FLINK-3021, so we might be able to have a first RC today. > > > > > > On Fri, Nov 20, 2015 at 11:05 AM, Stephan Ewen <[hidden email]> wrote: > > > > > Let me look at FLINK-2974 (open PR) to see if it can be merged... > > > > > > On Thu, Nov 19, 2015 at 10:09 PM, Robert Metzger <[hidden email]> > > > wrote: > > > > > > > Looks like we didn't manage to merge everything today. > > > > > > > > (pending PRs) > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > (merged) > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > stratey > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > (merged since my first email) > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > class > > > > conflict > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > > > > Is anybody volunteering to be a release manager? > > > > > > > > > > > > On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi <[hidden email]> > > > > wrote: > > > > > > > > > Flink-3017, Flink-3022, and some hotfixes u had put in over the > past > > > few > > > > > days. > > > > > > > > > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann < > > > [hidden email]> > > > > > wrote: > > > > > > > > > > > If they cover things which are also wrongly documented in 0.10, > > then > > > > they > > > > > > should be merged to 0.10-release as well. > > > > > > > > > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi < > > > > [hidden email] > > > > > > > > > > > > wrote: > > > > > > > > > > > > > @Till Should the recent updates to docs/apis/ > streaming-guide.md > > be > > > > > also > > > > > > > merged to 'release 0.10'? There are other related PRs pending. > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann < > > > [hidden email] > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > Yes forgot about merging them to release-0.10. Will do it > right > > > > away. > > > > > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" < > [hidden email] > > > > > > > > wrote: > > > > > > > > > > > > > > > > > @Suneel, I think > > > > https://issues.apache.org/jira/browse/FLINK-2949 > > > > > > is a > > > > > > > > new > > > > > > > > > feature. The 0.10.1 release is intended as a bugfix release > > > only. > > > > > > > > > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master only. > > Are > > > > > there > > > > > > > > plans > > > > > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), > due > > > to > > > > > > class > > > > > > > > > conflict > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > > Behaviour > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > detection > > > > > > stratey > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > > dependency > > > > > > > > > (merged since my first email) > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi < > [hidden email] > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > @Suneel: I think that's OK for the next major release :) > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > > > > > [hidden email]> > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I > won't > > be > > > > > able > > > > > > to > > > > > > > > get > > > > > > > > > > to > > > > > > > > > > > it until early next week. > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > > > > > [hidden email] > > > > > > > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this > > > > afternoon. > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > > > > > [hidden email]> > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka > > offset > > > > > > > committer > > > > > > > > > for > > > > > > > > > > > case > > > > > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki Kalavri > < > > > > > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 (both > > > > pending > > > > > > > PRs). > > > > > > > > > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > > > > > [hidden email]> > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release Flink > > > > 0.10.1 > > > > > > > soon, > > > > > > > > as > > > > > > > > > > > there > > > > > > > > > > > > > are > > > > > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop > > 2.7.1 > > > > > (HDP), > > > > > > > due > > > > > > > > > to > > > > > > > > > > > > class > > > > > > > > > > > > > > > conflict > > > > > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in > > RESTARTING > > > > > state > > > > > > > > > > > > > > > - FLINK-3021 Fix class loading issue for > > streaming > > > > > > sources > > > > > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on > > YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase > > > Kerberos > > > > > > tokens > > > > > > > > > > > > > > > - FLINK-3024 Fix > > > > > TimestampExtractor.getCurrentWatermark() > > > > > > > > > > Behaviour > > > > > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST > > > address > > > > > > > > detection > > > > > > > > > > > > stratey > > > > > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive > > > > ZkClient > > > > > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four > PRs > > > > until > > > > > > > > tomorrow > > > > > > > > > > and > > > > > > > > > > > > > then > > > > > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
From my experience, frequent bugfix releases are highly appreciated by
users. There are some pretty serious fixes people are waiting for, and we can certainly do a 0.10.2 in a bit, if people find more issues. On Fri, Nov 20, 2015 at 11:25 AM, Gyula Fóra <[hidden email]> wrote: > Hi all, > > Wouldnt you think that it would make sense to wait a week or so to find all > the hot issues with the current release? > > To me it feels a little bit like rushing this out and we will have almost > the same situation afterwards. > > I might be wrong but I think people should get a chance to try this out. > > In any case I would +1 for the quick release if everyone else thinks thats > the way, these are just my thoughts. > > Gyula > On Fri, Nov 20, 2015 at 11:13 AM Till Rohrmann <[hidden email]> > wrote: > > > Actually, I still have another bug related to the optimizer which I would > > like to include if possible. The problem is that the optimizer is not > able > > to push properties properly out of a bulk iteration which in some cases > can > > lead to rejected Flink jobs. > > > > On Fri, Nov 20, 2015 at 11:10 AM, Robert Metzger <[hidden email]> > > wrote: > > > > > Great, thank you! > > > > > > Let me know if there is any issue, I'll address it asap. The PR is not > > > building anymore because you've pushed an update to the Kafka > > > documentation. I can rebase and merge the PR once you give me green > light > > > ;) > > > > > > Till has merged FLINK-3021, so we might be able to have a first RC > today. > > > > > > > > > On Fri, Nov 20, 2015 at 11:05 AM, Stephan Ewen <[hidden email]> > wrote: > > > > > > > Let me look at FLINK-2974 (open PR) to see if it can be merged... > > > > > > > > On Thu, Nov 19, 2015 at 10:09 PM, Robert Metzger < > [hidden email]> > > > > wrote: > > > > > > > > > Looks like we didn't manage to merge everything today. > > > > > > > > > > (pending PRs) > > > > > - FLINK-3021 Fix class loading issue for streaming sources > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > (merged) > > > > > - FLINK-2977 Using reflection to load HBase Kerberos tokens > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() Behaviour > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address detection > > stratey > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient dependency > > > > > (merged since my first email) > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), due to > > class > > > > > conflict > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > > > > > > > Is anybody volunteering to be a release manager? > > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 10:16 AM, Suneel Marthi < > [hidden email]> > > > > > wrote: > > > > > > > > > > > Flink-3017, Flink-3022, and some hotfixes u had put in over the > > past > > > > few > > > > > > days. > > > > > > > > > > > > Flink-3041 and Flink-3043 are pending PRs at the moment. > > > > > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 4:10 AM, Till Rohrmann < > > > > [hidden email]> > > > > > > wrote: > > > > > > > > > > > > > If they cover things which are also wrongly documented in 0.10, > > > then > > > > > they > > > > > > > should be merged to 0.10-release as well. > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 10:01 AM, Suneel Marthi < > > > > > [hidden email] > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > @Till Should the recent updates to docs/apis/ > > streaming-guide.md > > > be > > > > > > also > > > > > > > > merged to 'release 0.10'? There are other related PRs > pending. > > > > > > > > > > > > > > > > On Thu, Nov 19, 2015 at 3:42 AM, Till Rohrmann < > > > > [hidden email] > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > Yes forgot about merging them to release-0.10. Will do it > > right > > > > > away. > > > > > > > > > On Nov 19, 2015 9:40 AM, "Robert Metzger" < > > [hidden email] > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > @Suneel, I think > > > > > https://issues.apache.org/jira/browse/FLINK-2949 > > > > > > > is a > > > > > > > > > new > > > > > > > > > > feature. The 0.10.1 release is intended as a bugfix > release > > > > only. > > > > > > > > > > > > > > > > > > > > FLINK-3013 and FLINK-3036 have been merged to master > only. > > > Are > > > > > > there > > > > > > > > > plans > > > > > > > > > > to merge it to "release-0.10" as well? > > > > > > > > > > > > > > > > > > > > The list of issues now looks as follows: > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop 2.7.1 (HDP), > > due > > > > to > > > > > > > class > > > > > > > > > > conflict > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in RESTARTING state > > > > > > > > > > - FLINK-3021 Fix class loading issue for streaming > sources > > > > > > > > > > - FLINK-2974 Add periodic offset committer for Kafka > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > - FLINK-2977 Using reflection to load HBase Kerberos > tokens > > > > > > > > > > - FLINK-3024 Fix TimestampExtractor.getCurrentWatermark() > > > > > Behaviour > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST address > > > detection > > > > > > > stratey > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive ZkClient > > > > dependency > > > > > > > > > > (merged since my first email) > > > > > > > > > > - FLINK-2989 job cancel button doesn't work on YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:35 PM, Ufuk Celebi < > > [hidden email] > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > @Suneel: I think that's OK for the next major release > :) > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 2:17 PM, Suneel Marthi < > > > > > > > > > [hidden email]> > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > Would be nice to have Flink-2949 in the mix, but I > > won't > > > be > > > > > > able > > > > > > > to > > > > > > > > > get > > > > > > > > > > > to > > > > > > > > > > > > it until early next week. > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 7:49 AM, Till Rohrmann < > > > > > > > > [hidden email] > > > > > > > > > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > @Vasia, do you mean FLINK-3013 or FLINK-3012? > > > > > > > > > > > > > > > > > > > > > > > > > > Will merge PRs for FLINK-3036 and FLINK-3013 this > > > > > afternoon. > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 1:47 PM, Stephan Ewen < > > > > > > > [hidden email]> > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > +1 for a timely 0.10.1 release > > > > > > > > > > > > > > > > > > > > > > > > > > > > I would like to add FLINK-2974 - periodic kafka > > > offset > > > > > > > > committer > > > > > > > > > > for > > > > > > > > > > > > case > > > > > > > > > > > > > > where checkpointing is deactivated > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Nov 18, 2015 at 12:34 PM, Vasiliki > Kalavri > > < > > > > > > > > > > > > > > [hidden email]> wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Hey, > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > I would also add FLINK-3012 and FLINK-3036 > (both > > > > > pending > > > > > > > > PRs). > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Thanks! > > > > > > > > > > > > > > > -Vasia. > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On 18 November 2015 at 12:24, Robert Metzger < > > > > > > > > > > [hidden email]> > > > > > > > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > I was wondering whether we should release > Flink > > > > > 0.10.1 > > > > > > > > soon, > > > > > > > > > as > > > > > > > > > > > > there > > > > > > > > > > > > > > are > > > > > > > > > > > > > > > > some issues we've identified: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > (pending PRs) > > > > > > > > > > > > > > > > - FLINK-3032: Flink does not start on Hadoop > > > 2.7.1 > > > > > > (HDP), > > > > > > > > due > > > > > > > > > > to > > > > > > > > > > > > > class > > > > > > > > > > > > > > > > conflict > > > > > > > > > > > > > > > > - FLINK-3011, 3019, 3028 Cancel jobs in > > > RESTARTING > > > > > > state > > > > > > > > > > > > > > > > - FLINK-3021 Fix class loading issue for > > > streaming > > > > > > > sources > > > > > > > > > > > > > > > > - FLINK-2989 job cancel button doesn't work > on > > > YARN > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > (merged) > > > > > > > > > > > > > > > > - FLINK-2977 Using reflection to load HBase > > > > Kerberos > > > > > > > tokens > > > > > > > > > > > > > > > > - FLINK-3024 Fix > > > > > > TimestampExtractor.getCurrentWatermark() > > > > > > > > > > > Behaviour > > > > > > > > > > > > > > > > - FLINK-2967 Increase timeout for LOCAL_HOST > > > > address > > > > > > > > > detection > > > > > > > > > > > > > stratey > > > > > > > > > > > > > > > > - FLINK-3025 [kafka consumer] Bump transitive > > > > > ZkClient > > > > > > > > > > dependency > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Anything else that you would like to add? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Do you think we can manage to merge the four > > PRs > > > > > until > > > > > > > > > tomorrow > > > > > > > > > > > and > > > > > > > > > > > > > > then > > > > > > > > > > > > > > > > start the RC? > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > |
Free forum by Nabble | Edit this page |