Flink 1.1.0 Preview RC0

[Ufuk Celebi-2]

Dear community,

===============
FLINK 1.1.0 RC0
===============

I've now created a "preview RC" for the upcoming 1.1.0 release,
including everything in master up to cb7824
(https://github.com/uce/flink/tree/release-1.1.0-rc0).

There are still some blocking issues and important pull requests to be
merged (see below), but nevertheless I would like to start testing
Flink for the release in order to get the process going.

In past major releases, we needed to create many release candidates,
often for fixing just some small issues. I would like to speed up the
release process by collecting the last remaining issues with the RC0.
Once these issues are resolved, we can start voting on RC1. This is
also when I will create the release-1.1 branch.

We have a Wiki page
https://cwiki.apache.org/confluence/display/FLINK/Releasing containing
some common release verification tasks.

Also, production users are encouraged to participate in the release
verification process.

Here are the preview binaries located:
http://home.apache.org/~uce/flink-1.1.0-rc0/

This is the staging repository:
https://repository.apache.org/content/repositories/orgapacheflink-1097

To use the release candidate in an existing Maven project, set the
Flink version to 1.1.0 and the repository URL to
https://repository.apache.org/content/repositories/orgapacheflink-1097.

The POM should look like this:

<properties>
   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
   <flink.version>1.1.0</flink.version>
</properties>

<repositories>
   <repository>
      <id>flink.release-staging</id>
      <name>Apache Development Snapshot Repository</name>
      <url>https://repository.apache.org/content/repositories/orgapacheflink-1097</url>
      <releases><enabled>true</enabled></releases>
      <snapshots><enabled>false</enabled></snapshots>
   </repository>
</repositories>

===========
OPEN ISSUES
===========

The following are important to be fixed/merged before the release:
- Savepoint headers: PR #2083 (https://github.com/apache/flink/pull/2083)
  * includes FLINK-4154 (https://issues.apache.org/jira/browse/FLINK-4154)
- Savepoint disposal with user class loader: #2194
(https://github.com/apache/flink/pull/2194)
- Cassandra sink exception check: #2183
(https://github.com/apache/flink/pull/2183)
- Prevent Metrics log flooding: #2135
(https://github.com/apache/flink/pull/2135)
- CEP serialization: #2202 (https://github.com/apache/flink/pull/2202)
- HA BLOB store life-cycle: https://issues.apache.org/jira/browse/FLINK-4150

Nice to have:
- Hash-based combine: #1517 https://github.com/apache/flink/pull/1517

Feel free to add issues/PRs to the list and please report any issues
you encounter during testing in this thread.

[Stefan Richter]

Hi Ufuk,

Thanks for starting this thread. I think we should solve https://issues.apache.org/jira/browse/FLINK-4166 <https://issues.apache.org/jira/browse/FLINK-4166> for this version, because it can easily become a blocker when running multiple Flink applications on a clusters with HA  (see related issue for one example).

> Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>
> Dear community,
>
> ===============
> FLINK 1.1.0 RC0
> ===============
>
> I've now created a "preview RC" for the upcoming 1.1.0 release,
> including everything in master up to cb7824
> (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>
> There are still some blocking issues and important pull requests to be
> merged (see below), but nevertheless I would like to start testing
> Flink for the release in order to get the process going.
>
> In past major releases, we needed to create many release candidates,
> often for fixing just some small issues. I would like to speed up the
> release process by collecting the last remaining issues with the RC0.
> Once these issues are resolved, we can start voting on RC1. This is
> also when I will create the release-1.1 branch.
>
> We have a Wiki page
> https://cwiki.apache.org/confluence/display/FLINK/Releasing containing
> some common release verification tasks.
>
> Also, production users are encouraged to participate in the release
> verification process.
>
> Here are the preview binaries located:
> http://home.apache.org/~uce/flink-1.1.0-rc0/
>
> This is the staging repository:
> https://repository.apache.org/content/repositories/orgapacheflink-1097
>
> To use the release candidate in an existing Maven project, set the
> Flink version to 1.1.0 and the repository URL to
> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>
> The POM should look like this:
>
> <properties>
>   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>   <flink.version>1.1.0</flink.version>
> </properties>
>
> <repositories>
>   <repository>
>      <id>flink.release-staging</id>
>      <name>Apache Development Snapshot Repository</name>
>      <url>https://repository.apache.org/content/repositories/orgapacheflink-1097</url>
>      <releases><enabled>true</enabled></releases>
>      <snapshots><enabled>false</enabled></snapshots>
>   </repository>
> </repositories>
>
> ===========
> OPEN ISSUES
> ===========
>
> The following are important to be fixed/merged before the release:
> - Savepoint headers: PR #2083 (https://github.com/apache/flink/pull/2083)
>  * includes FLINK-4154 (https://issues.apache.org/jira/browse/FLINK-4154)
> - Savepoint disposal with user class loader: #2194
> (https://github.com/apache/flink/pull/2194)
> - Cassandra sink exception check: #2183
> (https://github.com/apache/flink/pull/2183)
> - Prevent Metrics log flooding: #2135
> (https://github.com/apache/flink/pull/2135)
> - CEP serialization: #2202 (https://github.com/apache/flink/pull/2202)
> - HA BLOB store life-cycle: https://issues.apache.org/jira/browse/FLINK-4150
>
> Nice to have:
> - Hash-based combine: #1517 https://github.com/apache/flink/pull/1517
>
> Feel free to add issues/PRs to the list and please report any issues
> you encounter during testing in this thread.

[Robert Metzger]

There are still 7 blockers for the release:
https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
most of them are assigned, some even have a pending pull request.

On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <[hidden email]
> wrote:

> Hi Ufuk,
>
> Thanks for starting this thread. I think we should solve
> https://issues.apache.org/jira/browse/FLINK-4166 <
> https://issues.apache.org/jira/browse/FLINK-4166> for this version,
> because it can easily become a blocker when running multiple Flink
> applications on a clusters with HA  (see related issue for one example).
>
> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> >
> > Dear community,
> >
> > ===============
> > FLINK 1.1.0 RC0
> > ===============
> >
> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> > including everything in master up to cb7824
> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> >
> > There are still some blocking issues and important pull requests to be
> > merged (see below), but nevertheless I would like to start testing
> > Flink for the release in order to get the process going.
> >
> > In past major releases, we needed to create many release candidates,
> > often for fixing just some small issues. I would like to speed up the
> > release process by collecting the last remaining issues with the RC0.
> > Once these issues are resolved, we can start voting on RC1. This is
> > also when I will create the release-1.1 branch.
> >
> > We have a Wiki page
> > https://cwiki.apache.org/confluence/display/FLINK/Releasing containing
> > some common release verification tasks.
> >
> > Also, production users are encouraged to participate in the release
> > verification process.
> >
> > Here are the preview binaries located:
> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> >
> > This is the staging repository:
> > https://repository.apache.org/content/repositories/orgapacheflink-1097
> >
> > To use the release candidate in an existing Maven project, set the
> > Flink version to 1.1.0 and the repository URL to
> > https://repository.apache.org/content/repositories/orgapacheflink-1097.
> >
> > The POM should look like this:
> >
> > <properties>
> >   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> >   <flink.version>1.1.0</flink.version>
> > </properties>
> >
> > <repositories>
> >   <repository>
> >      <id>flink.release-staging</id>
> >      <name>Apache Development Snapshot Repository</name>
> >      <url>
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> </url>
> >      <releases><enabled>true</enabled></releases>
> >      <snapshots><enabled>false</enabled></snapshots>
> >   </repository>
> > </repositories>
> >
> > ===========
> > OPEN ISSUES
> > ===========
> >
> > The following are important to be fixed/merged before the release:
> > - Savepoint headers: PR #2083 (https://github.com/apache/flink/pull/2083
> )
> >  * includes FLINK-4154 (https://issues.apache.org/jira/browse/FLINK-4154
> )
> > - Savepoint disposal with user class loader: #2194
> > (https://github.com/apache/flink/pull/2194)
> > - Cassandra sink exception check: #2183
> > (https://github.com/apache/flink/pull/2183)
> > - Prevent Metrics log flooding: #2135
> > (https://github.com/apache/flink/pull/2135)
> > - CEP serialization: #2202 (https://github.com/apache/flink/pull/2202)
> > - HA BLOB store life-cycle:
> https://issues.apache.org/jira/browse/FLINK-4150
> >
> > Nice to have:
> > - Hash-based combine: #1517 https://github.com/apache/flink/pull/1517
> >
> > Feel free to add issues/PRs to the list and please report any issues
> > you encounter during testing in this thread.
>
>

[Ufuk Celebi-2]

Most actually have a pending PR, except:
https://issues.apache.org/jira/browse/FLINK-4207,
https://issues.apache.org/jira/browse/FLINK-4201.

I will assign FLINK-4201 to myself and hope to fix it over the
weekend. The issue Stefan mentioned also has a pending PR by now.

Hope to create the first RC next week... @Aljoscha, Stephan: any idea
about fixing FLINK-4207?

– Ufuk

On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]> wrote:

> There are still 7 blockers for the release:
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> most of them are assigned, some even have a pending pull request.
>
> On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <[hidden email]
>> wrote:
>
>> Hi Ufuk,
>>
>> Thanks for starting this thread. I think we should solve
>> https://issues.apache.org/jira/browse/FLINK-4166 <
>> https://issues.apache.org/jira/browse/FLINK-4166> for this version,
>> because it can easily become a blocker when running multiple Flink
>> applications on a clusters with HA  (see related issue for one example).
>>
>> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>> >
>> > Dear community,
>> >
>> > ===============
>> > FLINK 1.1.0 RC0
>> > ===============
>> >
>> > I've now created a "preview RC" for the upcoming 1.1.0 release,
>> > including everything in master up to cb7824
>> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>> >
>> > There are still some blocking issues and important pull requests to be
>> > merged (see below), but nevertheless I would like to start testing
>> > Flink for the release in order to get the process going.
>> >
>> > In past major releases, we needed to create many release candidates,
>> > often for fixing just some small issues. I would like to speed up the
>> > release process by collecting the last remaining issues with the RC0.
>> > Once these issues are resolved, we can start voting on RC1. This is
>> > also when I will create the release-1.1 branch.
>> >
>> > We have a Wiki page
>> > https://cwiki.apache.org/confluence/display/FLINK/Releasing containing
>> > some common release verification tasks.
>> >
>> > Also, production users are encouraged to participate in the release
>> > verification process.
>> >
>> > Here are the preview binaries located:
>> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>> >
>> > This is the staging repository:
>> > https://repository.apache.org/content/repositories/orgapacheflink-1097
>> >
>> > To use the release candidate in an existing Maven project, set the
>> > Flink version to 1.1.0 and the repository URL to
>> > https://repository.apache.org/content/repositories/orgapacheflink-1097.
>> >
>> > The POM should look like this:
>> >
>> > <properties>
>> >   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>> >   <flink.version>1.1.0</flink.version>
>> > </properties>
>> >
>> > <repositories>
>> >   <repository>
>> >      <id>flink.release-staging</id>
>> >      <name>Apache Development Snapshot Repository</name>
>> >      <url>
>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>> </url>
>> >      <releases><enabled>true</enabled></releases>
>> >      <snapshots><enabled>false</enabled></snapshots>
>> >   </repository>
>> > </repositories>
>> >
>> > ===========
>> > OPEN ISSUES
>> > ===========
>> >
>> > The following are important to be fixed/merged before the release:
>> > - Savepoint headers: PR #2083 (https://github.com/apache/flink/pull/2083
>> )
>> >  * includes FLINK-4154 (https://issues.apache.org/jira/browse/FLINK-4154
>> )
>> > - Savepoint disposal with user class loader: #2194
>> > (https://github.com/apache/flink/pull/2194)
>> > - Cassandra sink exception check: #2183
>> > (https://github.com/apache/flink/pull/2183)
>> > - Prevent Metrics log flooding: #2135
>> > (https://github.com/apache/flink/pull/2135)
>> > - CEP serialization: #2202 (https://github.com/apache/flink/pull/2202)
>> > - HA BLOB store life-cycle:
>> https://issues.apache.org/jira/browse/FLINK-4150
>> >
>> > Nice to have:
>> > - Hash-based combine: #1517 https://github.com/apache/flink/pull/1517
>> >
>> > Feel free to add issues/PRs to the list and please report any issues
>> > you encounter during testing in this thread.
>>
>>

[Aljoscha Krettek-2]

Not yet, but Kostas is investigating.

On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:

> Most actually have a pending PR, except:
> https://issues.apache.org/jira/browse/FLINK-4207,
> https://issues.apache.org/jira/browse/FLINK-4201.
>
> I will assign FLINK-4201 to myself and hope to fix it over the
> weekend. The issue Stefan mentioned also has a pending PR by now.
>
> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
> about fixing FLINK-4207?
>
> – Ufuk
>
> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
> wrote:
> > There are still 7 blockers for the release:
> >
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> > most of them are assigned, some even have a pending pull request.
> >
> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> [hidden email]
> >> wrote:
> >
> >> Hi Ufuk,
> >>
> >> Thanks for starting this thread. I think we should solve
> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> >> https://issues.apache.org/jira/browse/FLINK-4166> for this version,
> >> because it can easily become a blocker when running multiple Flink
> >> applications on a clusters with HA  (see related issue for one example).
> >>
> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> >> >
> >> > Dear community,
> >> >
> >> > ===============
> >> > FLINK 1.1.0 RC0
> >> > ===============
> >> >
> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> >> > including everything in master up to cb7824
> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> >> >
> >> > There are still some blocking issues and important pull requests to be
> >> > merged (see below), but nevertheless I would like to start testing
> >> > Flink for the release in order to get the process going.
> >> >
> >> > In past major releases, we needed to create many release candidates,
> >> > often for fixing just some small issues. I would like to speed up the
> >> > release process by collecting the last remaining issues with the RC0.
> >> > Once these issues are resolved, we can start voting on RC1. This is
> >> > also when I will create the release-1.1 branch.
> >> >
> >> > We have a Wiki page
> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
> containing
> >> > some common release verification tasks.
> >> >
> >> > Also, production users are encouraged to participate in the release
> >> > verification process.
> >> >
> >> > Here are the preview binaries located:
> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> >> >
> >> > This is the staging repository:
> >> >
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >> >
> >> > To use the release candidate in an existing Maven project, set the
> >> > Flink version to 1.1.0 and the repository URL to
> >> >
> https://repository.apache.org/content/repositories/orgapacheflink-1097.
> >> >
> >> > The POM should look like this:
> >> >
> >> > <properties>
> >> >   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> >> >   <flink.version>1.1.0</flink.version>
> >> > </properties>
> >> >
> >> > <repositories>
> >> >   <repository>
> >> >      <id>flink.release-staging</id>
> >> >      <name>Apache Development Snapshot Repository</name>
> >> >      <url>
> >> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >> </url>
> >> >      <releases><enabled>true</enabled></releases>
> >> >      <snapshots><enabled>false</enabled></snapshots>
> >> >   </repository>
> >> > </repositories>
> >> >
> >> > ===========
> >> > OPEN ISSUES
> >> > ===========
> >> >
> >> > The following are important to be fixed/merged before the release:
> >> > - Savepoint headers: PR #2083 (
> https://github.com/apache/flink/pull/2083
> >> )
> >> >  * includes FLINK-4154 (
> https://issues.apache.org/jira/browse/FLINK-4154
> >> )
> >> > - Savepoint disposal with user class loader: #2194
> >> > (https://github.com/apache/flink/pull/2194)
> >> > - Cassandra sink exception check: #2183
> >> > (https://github.com/apache/flink/pull/2183)
> >> > - Prevent Metrics log flooding: #2135
> >> > (https://github.com/apache/flink/pull/2135)
> >> > - CEP serialization: #2202 (https://github.com/apache/flink/pull/2202
> )
> >> > - HA BLOB store life-cycle:
> >> https://issues.apache.org/jira/browse/FLINK-4150
> >> >
> >> > Nice to have:
> >> > - Hash-based combine: #1517 https://github.com/apache/flink/pull/1517
> >> >
> >> > Feel free to add issues/PRs to the list and please report any issues
> >> > you encounter during testing in this thread.
> >>
> >>
>

[Ufuk Celebi-2]

Hey all,

although there was no feedback for this preview RC, most of the issues
mentioned in the release are either resolved or open PRs. Once the
following PRs have been merged, I would like to create RC1 and the
release-1.1 branch. Feedback to this list is highly appreciated.

Open PRs (awaiting review/review in progress):
- https://github.com/apache/flink/pull/2276: Forward suspend to
checkpoint coordinator
- https://github.com/apache/flink/pull/2257: Allow re-registration of
TMs at resource manager
- https://github.com/apache/flink/pull/2226: Move Metrics API to separate module

Open PRs (to be merged):
- https://github.com/apache/flink/pull/2273: Only allow/require query
for Tuple Stream in CassandraSink
- https://github.com/apache/flink/pull/2271: Add restarting time JM metric
- https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
on BlobServer shut down
- https://github.com/apache/flink/pull/2194: Add savepoint headers

Open issues w/o PRs:
- https://issues.apache.org/jira/browse/FLINK-4239: Set Default
Allowed Lateness to Zero and Make Triggers Non-Purging
- https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
becomes very slow with allowed lateness

@Aljoscha, Kostas: do you have an idea when these will be addressed?

On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]> wrote:

> Not yet, but Kostas is investigating.
>
> On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>
>> Most actually have a pending PR, except:
>> https://issues.apache.org/jira/browse/FLINK-4207,
>> https://issues.apache.org/jira/browse/FLINK-4201.
>>
>> I will assign FLINK-4201 to myself and hope to fix it over the
>> weekend. The issue Stefan mentioned also has a pending PR by now.
>>
>> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
>> about fixing FLINK-4207?
>>
>> – Ufuk
>>
>> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
>> wrote:
>> > There are still 7 blockers for the release:
>> >
>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>> > most of them are assigned, some even have a pending pull request.
>> >
>> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>> [hidden email]
>> >> wrote:
>> >
>> >> Hi Ufuk,
>> >>
>> >> Thanks for starting this thread. I think we should solve
>> >> https://issues.apache.org/jira/browse/FLINK-4166 <
>> >> https://issues.apache.org/jira/browse/FLINK-4166> for this version,
>> >> because it can easily become a blocker when running multiple Flink
>> >> applications on a clusters with HA  (see related issue for one example).
>> >>
>> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>> >> >
>> >> > Dear community,
>> >> >
>> >> > ===============
>> >> > FLINK 1.1.0 RC0
>> >> > ===============
>> >> >
>> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
>> >> > including everything in master up to cb7824
>> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>> >> >
>> >> > There are still some blocking issues and important pull requests to be
>> >> > merged (see below), but nevertheless I would like to start testing
>> >> > Flink for the release in order to get the process going.
>> >> >
>> >> > In past major releases, we needed to create many release candidates,
>> >> > often for fixing just some small issues. I would like to speed up the
>> >> > release process by collecting the last remaining issues with the RC0.
>> >> > Once these issues are resolved, we can start voting on RC1. This is
>> >> > also when I will create the release-1.1 branch.
>> >> >
>> >> > We have a Wiki page
>> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
>> containing
>> >> > some common release verification tasks.
>> >> >
>> >> > Also, production users are encouraged to participate in the release
>> >> > verification process.
>> >> >
>> >> > Here are the preview binaries located:
>> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>> >> >
>> >> > This is the staging repository:
>> >> >
>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>> >> >
>> >> > To use the release candidate in an existing Maven project, set the
>> >> > Flink version to 1.1.0 and the repository URL to
>> >> >
>> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>> >> >
>> >> > The POM should look like this:
>> >> >
>> >> > <properties>
>> >> >   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>> >> >   <flink.version>1.1.0</flink.version>
>> >> > </properties>
>> >> >
>> >> > <repositories>
>> >> >   <repository>
>> >> >      <id>flink.release-staging</id>
>> >> >      <name>Apache Development Snapshot Repository</name>
>> >> >      <url>
>> >> https://repository.apache.org/content/repositories/orgapacheflink-1097
>> >> </url>
>> >> >      <releases><enabled>true</enabled></releases>
>> >> >      <snapshots><enabled>false</enabled></snapshots>
>> >> >   </repository>
>> >> > </repositories>
>> >> >
>> >> > ===========
>> >> > OPEN ISSUES
>> >> > ===========
>> >> >
>> >> > The following are important to be fixed/merged before the release:
>> >> > - Savepoint headers: PR #2083 (
>> https://github.com/apache/flink/pull/2083
>> >> )
>> >> >  * includes FLINK-4154 (
>> https://issues.apache.org/jira/browse/FLINK-4154
>> >> )
>> >> > - Savepoint disposal with user class loader: #2194
>> >> > (https://github.com/apache/flink/pull/2194)
>> >> > - Cassandra sink exception check: #2183
>> >> > (https://github.com/apache/flink/pull/2183)
>> >> > - Prevent Metrics log flooding: #2135
>> >> > (https://github.com/apache/flink/pull/2135)
>> >> > - CEP serialization: #2202 (https://github.com/apache/flink/pull/2202
>> )
>> >> > - HA BLOB store life-cycle:
>> >> https://issues.apache.org/jira/browse/FLINK-4150
>> >> >
>> >> > Nice to have:
>> >> > - Hash-based combine: #1517 https://github.com/apache/flink/pull/1517
>> >> >
>> >> > Feel free to add issues/PRs to the list and please report any issues
>> >> > you encounter during testing in this thread.
>> >>
>> >>
>>

[Aljoscha Krettek-2]

Sounds good!

This one I just merged: https://github.com/apache/flink/pull/2273 (Only
allow/require query
for Tuple Stream in CassandraSink)

For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR:
https://github.com/apache/flink/pull/2278

On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:

> Hey all,
>
> although there was no feedback for this preview RC, most of the issues
> mentioned in the release are either resolved or open PRs. Once the
> following PRs have been merged, I would like to create RC1 and the
> release-1.1 branch. Feedback to this list is highly appreciated.
>
> Open PRs (awaiting review/review in progress):
> - https://github.com/apache/flink/pull/2276: Forward suspend to
> checkpoint coordinator
> - https://github.com/apache/flink/pull/2257: Allow re-registration of
> TMs at resource manager
> - https://github.com/apache/flink/pull/2226: Move Metrics API to separate
> module
>
> Open PRs (to be merged):
> - https://github.com/apache/flink/pull/2273: Only allow/require query
> for Tuple Stream in CassandraSink
> - https://github.com/apache/flink/pull/2271: Add restarting time JM metric
> - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
> on BlobServer shut down
> - https://github.com/apache/flink/pull/2194: Add savepoint headers
>
> Open issues w/o PRs:
> - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
> Allowed Lateness to Zero and Make Triggers Non-Purging
> - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
> becomes very slow with allowed lateness
>
> @Aljoscha, Kostas: do you have an idea when these will be addressed?
>
> On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]>
> wrote:
> > Not yet, but Kostas is investigating.
> >
> > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
> >
> >> Most actually have a pending PR, except:
> >> https://issues.apache.org/jira/browse/FLINK-4207,
> >> https://issues.apache.org/jira/browse/FLINK-4201.
> >>
> >> I will assign FLINK-4201 to myself and hope to fix it over the
> >> weekend. The issue Stefan mentioned also has a pending PR by now.
> >>
> >> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
> >> about fixing FLINK-4207?
> >>
> >> – Ufuk
> >>
> >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
> >> wrote:
> >> > There are still 7 blockers for the release:
> >> >
> >>
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> >> > most of them are assigned, some even have a pending pull request.
> >> >
> >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> >> [hidden email]
> >> >> wrote:
> >> >
> >> >> Hi Ufuk,
> >> >>
> >> >> Thanks for starting this thread. I think we should solve
> >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this version,
> >> >> because it can easily become a blocker when running multiple Flink
> >> >> applications on a clusters with HA  (see related issue for one
> example).
> >> >>
> >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> >> >> >
> >> >> > Dear community,
> >> >> >
> >> >> > ===============
> >> >> > FLINK 1.1.0 RC0
> >> >> > ===============
> >> >> >
> >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> >> >> > including everything in master up to cb7824
> >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> >> >> >
> >> >> > There are still some blocking issues and important pull requests
> to be
> >> >> > merged (see below), but nevertheless I would like to start testing
> >> >> > Flink for the release in order to get the process going.
> >> >> >
> >> >> > In past major releases, we needed to create many release
> candidates,
> >> >> > often for fixing just some small issues. I would like to speed up
> the
> >> >> > release process by collecting the last remaining issues with the
> RC0.
> >> >> > Once these issues are resolved, we can start voting on RC1. This is
> >> >> > also when I will create the release-1.1 branch.
> >> >> >
> >> >> > We have a Wiki page
> >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
> >> containing
> >> >> > some common release verification tasks.
> >> >> >
> >> >> > Also, production users are encouraged to participate in the release
> >> >> > verification process.
> >> >> >
> >> >> > Here are the preview binaries located:
> >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> >> >> >
> >> >> > This is the staging repository:
> >> >> >
> >> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >> >> >
> >> >> > To use the release candidate in an existing Maven project, set the
> >> >> > Flink version to 1.1.0 and the repository URL to
> >> >> >
> >> https://repository.apache.org/content/repositories/orgapacheflink-1097.
> >> >> >
> >> >> > The POM should look like this:
> >> >> >
> >> >> > <properties>
> >> >> >
>  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> >> >> >   <flink.version>1.1.0</flink.version>
> >> >> > </properties>
> >> >> >
> >> >> > <repositories>
> >> >> >   <repository>
> >> >> >      <id>flink.release-staging</id>
> >> >> >      <name>Apache Development Snapshot Repository</name>
> >> >> >      <url>
> >> >>
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >> >> </url>
> >> >> >      <releases><enabled>true</enabled></releases>
> >> >> >      <snapshots><enabled>false</enabled></snapshots>
> >> >> >   </repository>
> >> >> > </repositories>
> >> >> >
> >> >> > ===========
> >> >> > OPEN ISSUES
> >> >> > ===========
> >> >> >
> >> >> > The following are important to be fixed/merged before the release:
> >> >> > - Savepoint headers: PR #2083 (
> >> https://github.com/apache/flink/pull/2083
> >> >> )
> >> >> >  * includes FLINK-4154 (
> >> https://issues.apache.org/jira/browse/FLINK-4154
> >> >> )
> >> >> > - Savepoint disposal with user class loader: #2194
> >> >> > (https://github.com/apache/flink/pull/2194)
> >> >> > - Cassandra sink exception check: #2183
> >> >> > (https://github.com/apache/flink/pull/2183)
> >> >> > - Prevent Metrics log flooding: #2135
> >> >> > (https://github.com/apache/flink/pull/2135)
> >> >> > - CEP serialization: #2202 (
> https://github.com/apache/flink/pull/2202
> >> )
> >> >> > - HA BLOB store life-cycle:
> >> >> https://issues.apache.org/jira/browse/FLINK-4150
> >> >> >
> >> >> > Nice to have:
> >> >> > - Hash-based combine: #1517
> https://github.com/apache/flink/pull/1517
> >> >> >
> >> >> > Feel free to add issues/PRs to the list and please report any
> issues
> >> >> > you encounter during testing in this thread.
> >> >>
> >> >>
> >>
>

[Stephan Ewen]

Looking into - https://github.com/apache/flink/pull/2226: Move Metrics API
to separate module

On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
wrote:

> Sounds good!
>
> This one I just merged: https://github.com/apache/flink/pull/2273 (Only
> allow/require query
> for Tuple Stream in CassandraSink)
>
> For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
> Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR:
> https://github.com/apache/flink/pull/2278
>
> On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>
> > Hey all,
> >
> > although there was no feedback for this preview RC, most of the issues
> > mentioned in the release are either resolved or open PRs. Once the
> > following PRs have been merged, I would like to create RC1 and the
> > release-1.1 branch. Feedback to this list is highly appreciated.
> >
> > Open PRs (awaiting review/review in progress):
> > - https://github.com/apache/flink/pull/2276: Forward suspend to
> > checkpoint coordinator
> > - https://github.com/apache/flink/pull/2257: Allow re-registration of
> > TMs at resource manager
> > - https://github.com/apache/flink/pull/2226: Move Metrics API to
> separate
> > module
> >
> > Open PRs (to be merged):
> > - https://github.com/apache/flink/pull/2273: Only allow/require query
> > for Tuple Stream in CassandraSink
> > - https://github.com/apache/flink/pull/2271: Add restarting time JM
> metric
> > - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
> > on BlobServer shut down
> > - https://github.com/apache/flink/pull/2194: Add savepoint headers
> >
> > Open issues w/o PRs:
> > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
> > Allowed Lateness to Zero and Make Triggers Non-Purging
> > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
> > becomes very slow with allowed lateness
> >
> > @Aljoscha, Kostas: do you have an idea when these will be addressed?
> >
> > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]>
> > wrote:
> > > Not yet, but Kostas is investigating.
> > >
> > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
> > >
> > >> Most actually have a pending PR, except:
> > >> https://issues.apache.org/jira/browse/FLINK-4207,
> > >> https://issues.apache.org/jira/browse/FLINK-4201.
> > >>
> > >> I will assign FLINK-4201 to myself and hope to fix it over the
> > >> weekend. The issue Stefan mentioned also has a pending PR by now.
> > >>
> > >> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
> > >> about fixing FLINK-4207?
> > >>
> > >> – Ufuk
> > >>
> > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
> > >> wrote:
> > >> > There are still 7 blockers for the release:
> > >> >
> > >>
> >
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> > >> > most of them are assigned, some even have a pending pull request.
> > >> >
> > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> > >> [hidden email]
> > >> >> wrote:
> > >> >
> > >> >> Hi Ufuk,
> > >> >>
> > >> >> Thanks for starting this thread. I think we should solve
> > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
> version,
> > >> >> because it can easily become a blocker when running multiple Flink
> > >> >> applications on a clusters with HA  (see related issue for one
> > example).
> > >> >>
> > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> > >> >> >
> > >> >> > Dear community,
> > >> >> >
> > >> >> > ===============
> > >> >> > FLINK 1.1.0 RC0
> > >> >> > ===============
> > >> >> >
> > >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> > >> >> > including everything in master up to cb7824
> > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> > >> >> >
> > >> >> > There are still some blocking issues and important pull requests
> > to be
> > >> >> > merged (see below), but nevertheless I would like to start
> testing
> > >> >> > Flink for the release in order to get the process going.
> > >> >> >
> > >> >> > In past major releases, we needed to create many release
> > candidates,
> > >> >> > often for fixing just some small issues. I would like to speed up
> > the
> > >> >> > release process by collecting the last remaining issues with the
> > RC0.
> > >> >> > Once these issues are resolved, we can start voting on RC1. This
> is
> > >> >> > also when I will create the release-1.1 branch.
> > >> >> >
> > >> >> > We have a Wiki page
> > >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
> > >> containing
> > >> >> > some common release verification tasks.
> > >> >> >
> > >> >> > Also, production users are encouraged to participate in the
> release
> > >> >> > verification process.
> > >> >> >
> > >> >> > Here are the preview binaries located:
> > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> > >> >> >
> > >> >> > This is the staging repository:
> > >> >> >
> > >>
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> > >> >> >
> > >> >> > To use the release candidate in an existing Maven project, set
> the
> > >> >> > Flink version to 1.1.0 and the repository URL to
> > >> >> >
> > >>
> https://repository.apache.org/content/repositories/orgapacheflink-1097.
> > >> >> >
> > >> >> > The POM should look like this:
> > >> >> >
> > >> >> > <properties>
> > >> >> >
> >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> > >> >> >   <flink.version>1.1.0</flink.version>
> > >> >> > </properties>
> > >> >> >
> > >> >> > <repositories>
> > >> >> >   <repository>
> > >> >> >      <id>flink.release-staging</id>
> > >> >> >      <name>Apache Development Snapshot Repository</name>
> > >> >> >      <url>
> > >> >>
> > https://repository.apache.org/content/repositories/orgapacheflink-1097
> > >> >> </url>
> > >> >> >      <releases><enabled>true</enabled></releases>
> > >> >> >      <snapshots><enabled>false</enabled></snapshots>
> > >> >> >   </repository>
> > >> >> > </repositories>
> > >> >> >
> > >> >> > ===========
> > >> >> > OPEN ISSUES
> > >> >> > ===========
> > >> >> >
> > >> >> > The following are important to be fixed/merged before the
> release:
> > >> >> > - Savepoint headers: PR #2083 (
> > >> https://github.com/apache/flink/pull/2083
> > >> >> )
> > >> >> >  * includes FLINK-4154 (
> > >> https://issues.apache.org/jira/browse/FLINK-4154
> > >> >> )
> > >> >> > - Savepoint disposal with user class loader: #2194
> > >> >> > (https://github.com/apache/flink/pull/2194)
> > >> >> > - Cassandra sink exception check: #2183
> > >> >> > (https://github.com/apache/flink/pull/2183)
> > >> >> > - Prevent Metrics log flooding: #2135
> > >> >> > (https://github.com/apache/flink/pull/2135)
> > >> >> > - CEP serialization: #2202 (
> > https://github.com/apache/flink/pull/2202
> > >> )
> > >> >> > - HA BLOB store life-cycle:
> > >> >> https://issues.apache.org/jira/browse/FLINK-4150
> > >> >> >
> > >> >> > Nice to have:
> > >> >> > - Hash-based combine: #1517
> > https://github.com/apache/flink/pull/1517
> > >> >> >
> > >> >> > Feel free to add issues/PRs to the list and please report any
> > issues
> > >> >> > you encounter during testing in this thread.
> > >> >>
> > >> >>
> > >>
> >
>

[Kostas Kloudas]

There is an open PR now for https://issues.apache.org/jira/browse/FLINK-4207 <https://issues.apache.org/jira/browse/FLINK-4207>

Kostas

> On Jul 21, 2016, at 3:38 PM, Stephan Ewen <[hidden email]> wrote:
>
> Looking into - https://github.com/apache/flink/pull/2226: Move Metrics API
> to separate module
>
> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
> wrote:
>
>> Sounds good!
>>
>> This one I just merged: https://github.com/apache/flink/pull/2273 (Only
>> allow/require query
>> for Tuple Stream in CassandraSink)
>>
>> For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
>> Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR:
>> https://github.com/apache/flink/pull/2278
>>
>> On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>>
>>> Hey all,
>>>
>>> although there was no feedback for this preview RC, most of the issues
>>> mentioned in the release are either resolved or open PRs. Once the
>>> following PRs have been merged, I would like to create RC1 and the
>>> release-1.1 branch. Feedback to this list is highly appreciated.
>>>
>>> Open PRs (awaiting review/review in progress):
>>> - https://github.com/apache/flink/pull/2276: Forward suspend to
>>> checkpoint coordinator
>>> - https://github.com/apache/flink/pull/2257: Allow re-registration of
>>> TMs at resource manager
>>> - https://github.com/apache/flink/pull/2226: Move Metrics API to
>> separate
>>> module
>>>
>>> Open PRs (to be merged):
>>> - https://github.com/apache/flink/pull/2273: Only allow/require query
>>> for Tuple Stream in CassandraSink
>>> - https://github.com/apache/flink/pull/2271: Add restarting time JM
>> metric
>>> - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
>>> on BlobServer shut down
>>> - https://github.com/apache/flink/pull/2194: Add savepoint headers
>>>
>>> Open issues w/o PRs:
>>> - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>>> Allowed Lateness to Zero and Make Triggers Non-Purging
>>> - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>>> becomes very slow with allowed lateness
>>>
>>> @Aljoscha, Kostas: do you have an idea when these will be addressed?
>>>
>>> On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]>
>>> wrote:
>>>> Not yet, but Kostas is investigating.
>>>>
>>>> On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>>>>
>>>>> Most actually have a pending PR, except:
>>>>> https://issues.apache.org/jira/browse/FLINK-4207,
>>>>> https://issues.apache.org/jira/browse/FLINK-4201.
>>>>>
>>>>> I will assign FLINK-4201 to myself and hope to fix it over the
>>>>> weekend. The issue Stefan mentioned also has a pending PR by now.
>>>>>
>>>>> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
>>>>> about fixing FLINK-4207?
>>>>>
>>>>> – Ufuk
>>>>>
>>>>> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
>>>>> wrote:
>>>>>> There are still 7 blockers for the release:
>>>>>>
>>>>>
>>>
>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>>>>>> most of them are assigned, some even have a pending pull request.
>>>>>>
>>>>>> On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>>>>> [hidden email]
>>>>>>> wrote:
>>>>>>
>>>>>>> Hi Ufuk,
>>>>>>>
>>>>>>> Thanks for starting this thread. I think we should solve
>>>>>>> https://issues.apache.org/jira/browse/FLINK-4166 <
>>>>>>> https://issues.apache.org/jira/browse/FLINK-4166> for this
>> version,
>>>>>>> because it can easily become a blocker when running multiple Flink
>>>>>>> applications on a clusters with HA  (see related issue for one
>>> example).
>>>>>>>
>>>>>>>> Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>>>>>>>>
>>>>>>>> Dear community,
>>>>>>>>
>>>>>>>> ===============
>>>>>>>> FLINK 1.1.0 RC0
>>>>>>>> ===============
>>>>>>>>
>>>>>>>> I've now created a "preview RC" for the upcoming 1.1.0 release,
>>>>>>>> including everything in master up to cb7824
>>>>>>>> (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>>>>>>>>
>>>>>>>> There are still some blocking issues and important pull requests
>>> to be
>>>>>>>> merged (see below), but nevertheless I would like to start
>> testing
>>>>>>>> Flink for the release in order to get the process going.
>>>>>>>>
>>>>>>>> In past major releases, we needed to create many release
>>> candidates,
>>>>>>>> often for fixing just some small issues. I would like to speed up
>>> the
>>>>>>>> release process by collecting the last remaining issues with the
>>> RC0.
>>>>>>>> Once these issues are resolved, we can start voting on RC1. This
>> is
>>>>>>>> also when I will create the release-1.1 branch.
>>>>>>>>
>>>>>>>> We have a Wiki page
>>>>>>>> https://cwiki.apache.org/confluence/display/FLINK/Releasing
>>>>> containing
>>>>>>>> some common release verification tasks.
>>>>>>>>
>>>>>>>> Also, production users are encouraged to participate in the
>> release
>>>>>>>> verification process.
>>>>>>>>
>>>>>>>> Here are the preview binaries located:
>>>>>>>> http://home.apache.org/~uce/flink-1.1.0-rc0/
>>>>>>>>
>>>>>>>> This is the staging repository:
>>>>>>>>
>>>>>
>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>>>>>>>
>>>>>>>> To use the release candidate in an existing Maven project, set
>> the
>>>>>>>> Flink version to 1.1.0 and the repository URL to
>>>>>>>>
>>>>>
>> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>>>>>>>>
>>>>>>>> The POM should look like this:
>>>>>>>>
>>>>>>>> <properties>
>>>>>>>>
>>> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>>>>>>>>  <flink.version>1.1.0</flink.version>
>>>>>>>> </properties>
>>>>>>>>
>>>>>>>> <repositories>
>>>>>>>>  <repository>
>>>>>>>>     <id>flink.release-staging</id>
>>>>>>>>     <name>Apache Development Snapshot Repository</name>
>>>>>>>>     <url>
>>>>>>>
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>>>>>> </url>
>>>>>>>>     <releases><enabled>true</enabled></releases>
>>>>>>>>     <snapshots><enabled>false</enabled></snapshots>
>>>>>>>>  </repository>
>>>>>>>> </repositories>
>>>>>>>>
>>>>>>>> ===========
>>>>>>>> OPEN ISSUES
>>>>>>>> ===========
>>>>>>>>
>>>>>>>> The following are important to be fixed/merged before the
>> release:
>>>>>>>> - Savepoint headers: PR #2083 (
>>>>> https://github.com/apache/flink/pull/2083
>>>>>>> )
>>>>>>>> * includes FLINK-4154 (
>>>>> https://issues.apache.org/jira/browse/FLINK-4154
>>>>>>> )
>>>>>>>> - Savepoint disposal with user class loader: #2194
>>>>>>>> (https://github.com/apache/flink/pull/2194)
>>>>>>>> - Cassandra sink exception check: #2183
>>>>>>>> (https://github.com/apache/flink/pull/2183)
>>>>>>>> - Prevent Metrics log flooding: #2135
>>>>>>>> (https://github.com/apache/flink/pull/2135)
>>>>>>>> - CEP serialization: #2202 (
>>> https://github.com/apache/flink/pull/2202
>>>>> )
>>>>>>>> - HA BLOB store life-cycle:
>>>>>>> https://issues.apache.org/jira/browse/FLINK-4150
>>>>>>>>
>>>>>>>> Nice to have:
>>>>>>>> - Hash-based combine: #1517
>>> https://github.com/apache/flink/pull/1517
>>>>>>>>
>>>>>>>> Feel free to add issues/PRs to the list and please report any
>>> issues
>>>>>>>> you encounter during testing in this thread.
>>>>>>>
>>>>>>>
>>>>>
>>>
>>

[Kostas Kloudas]

I think Aljoscha is having a look.

> On Jul 21, 2016, at 3:39 PM, Kostas Kloudas <[hidden email]> wrote:
>
> There is an open PR now for https://issues.apache.org/jira/browse/FLINK-4207 <https://issues.apache.org/jira/browse/FLINK-4207>
>
> Kostas
>
>> On Jul 21, 2016, at 3:38 PM, Stephan Ewen <[hidden email] <mailto:[hidden email]>> wrote:
>>
>> Looking into - https://github.com/apache/flink/pull/2226: <https://github.com/apache/flink/pull/2226:> Move Metrics API
>> to separate module
>>
>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email] <mailto:[hidden email]>>
>> wrote:
>>
>>> Sounds good!
>>>
>>> This one I just merged: https://github.com/apache/flink/pull/2273 <https://github.com/apache/flink/pull/2273> (Only
>>> allow/require query
>>> for Tuple Stream in CassandraSink)
>>>
>>> For https://issues.apache.org/jira/browse/FLINK-4239 <https://issues.apache.org/jira/browse/FLINK-4239> (Set Default
>>> Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR:
>>> https://github.com/apache/flink/pull/2278 <https://github.com/apache/flink/pull/2278>
>>>
>>> On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>>>
>>>> Hey all,
>>>>
>>>> although there was no feedback for this preview RC, most of the issues
>>>> mentioned in the release are either resolved or open PRs. Once the
>>>> following PRs have been merged, I would like to create RC1 and the
>>>> release-1.1 branch. Feedback to this list is highly appreciated.
>>>>
>>>> Open PRs (awaiting review/review in progress):
>>>> - https://github.com/apache/flink/pull/2276: Forward suspend to
>>>> checkpoint coordinator
>>>> - https://github.com/apache/flink/pull/2257: Allow re-registration of
>>>> TMs at resource manager
>>>> - https://github.com/apache/flink/pull/2226: Move Metrics API to
>>> separate
>>>> module
>>>>
>>>> Open PRs (to be merged):
>>>> - https://github.com/apache/flink/pull/2273: Only allow/require query
>>>> for Tuple Stream in CassandraSink
>>>> - https://github.com/apache/flink/pull/2271: Add restarting time JM
>>> metric
>>>> - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
>>>> on BlobServer shut down
>>>> - https://github.com/apache/flink/pull/2194: Add savepoint headers
>>>>
>>>> Open issues w/o PRs:
>>>> - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>>>> Allowed Lateness to Zero and Make Triggers Non-Purging
>>>> - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>>>> becomes very slow with allowed lateness
>>>>
>>>> @Aljoscha, Kostas: do you have an idea when these will be addressed?
>>>>
>>>> On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]>
>>>> wrote:
>>>>> Not yet, but Kostas is investigating.
>>>>>
>>>>> On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>>>>>
>>>>>> Most actually have a pending PR, except:
>>>>>> https://issues.apache.org/jira/browse/FLINK-4207,
>>>>>> https://issues.apache.org/jira/browse/FLINK-4201.
>>>>>>
>>>>>> I will assign FLINK-4201 to myself and hope to fix it over the
>>>>>> weekend. The issue Stefan mentioned also has a pending PR by now.
>>>>>>
>>>>>> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
>>>>>> about fixing FLINK-4207?
>>>>>>
>>>>>> – Ufuk
>>>>>>
>>>>>> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
>>>>>> wrote:
>>>>>>> There are still 7 blockers for the release:
>>>>>>>
>>>>>>
>>>>
>>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>>>>>>> most of them are assigned, some even have a pending pull request.
>>>>>>>
>>>>>>> On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>>>>>> [hidden email]
>>>>>>>> wrote:
>>>>>>>
>>>>>>>> Hi Ufuk,
>>>>>>>>
>>>>>>>> Thanks for starting this thread. I think we should solve
>>>>>>>> https://issues.apache.org/jira/browse/FLINK-4166 <
>>>>>>>> https://issues.apache.org/jira/browse/FLINK-4166> for this
>>> version,
>>>>>>>> because it can easily become a blocker when running multiple Flink
>>>>>>>> applications on a clusters with HA  (see related issue for one
>>>> example).
>>>>>>>>
>>>>>>>>> Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>>>>>>>>>
>>>>>>>>> Dear community,
>>>>>>>>>
>>>>>>>>> ===============
>>>>>>>>> FLINK 1.1.0 RC0
>>>>>>>>> ===============
>>>>>>>>>
>>>>>>>>> I've now created a "preview RC" for the upcoming 1.1.0 release,
>>>>>>>>> including everything in master up to cb7824
>>>>>>>>> (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>>>>>>>>>
>>>>>>>>> There are still some blocking issues and important pull requests
>>>> to be
>>>>>>>>> merged (see below), but nevertheless I would like to start
>>> testing
>>>>>>>>> Flink for the release in order to get the process going.
>>>>>>>>>
>>>>>>>>> In past major releases, we needed to create many release
>>>> candidates,
>>>>>>>>> often for fixing just some small issues. I would like to speed up
>>>> the
>>>>>>>>> release process by collecting the last remaining issues with the
>>>> RC0.
>>>>>>>>> Once these issues are resolved, we can start voting on RC1. This
>>> is
>>>>>>>>> also when I will create the release-1.1 branch.
>>>>>>>>>
>>>>>>>>> We have a Wiki page
>>>>>>>>> https://cwiki.apache.org/confluence/display/FLINK/Releasing
>>>>>> containing
>>>>>>>>> some common release verification tasks.
>>>>>>>>>
>>>>>>>>> Also, production users are encouraged to participate in the
>>> release
>>>>>>>>> verification process.
>>>>>>>>>
>>>>>>>>> Here are the preview binaries located:
>>>>>>>>> http://home.apache.org/~uce/flink-1.1.0-rc0/
>>>>>>>>>
>>>>>>>>> This is the staging repository:
>>>>>>>>>
>>>>>>
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>>>>>>>>
>>>>>>>>> To use the release candidate in an existing Maven project, set
>>> the
>>>>>>>>> Flink version to 1.1.0 and the repository URL to
>>>>>>>>>
>>>>>>
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>>>>>>>>>
>>>>>>>>> The POM should look like this:
>>>>>>>>>
>>>>>>>>> <properties>
>>>>>>>>>
>>>> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>>>>>>>>>  <flink.version>1.1.0</flink.version>
>>>>>>>>> </properties>
>>>>>>>>>
>>>>>>>>> <repositories>
>>>>>>>>>  <repository>
>>>>>>>>>     <id>flink.release-staging</id>
>>>>>>>>>     <name>Apache Development Snapshot Repository</name>
>>>>>>>>>     <url>
>>>>>>>>
>>>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>>>>>>> </url>
>>>>>>>>>     <releases><enabled>true</enabled></releases>
>>>>>>>>>     <snapshots><enabled>false</enabled></snapshots>
>>>>>>>>>  </repository>
>>>>>>>>> </repositories>
>>>>>>>>>
>>>>>>>>> ===========
>>>>>>>>> OPEN ISSUES
>>>>>>>>> ===========
>>>>>>>>>
>>>>>>>>> The following are important to be fixed/merged before the
>>> release:
>>>>>>>>> - Savepoint headers: PR #2083 (
>>>>>> https://github.com/apache/flink/pull/2083
>>>>>>>> )
>>>>>>>>> * includes FLINK-4154 (
>>>>>> https://issues.apache.org/jira/browse/FLINK-4154
>>>>>>>> )
>>>>>>>>> - Savepoint disposal with user class loader: #2194
>>>>>>>>> (https://github.com/apache/flink/pull/2194)
>>>>>>>>> - Cassandra sink exception check: #2183
>>>>>>>>> (https://github.com/apache/flink/pull/2183)
>>>>>>>>> - Prevent Metrics log flooding: #2135
>>>>>>>>> (https://github.com/apache/flink/pull/2135)
>>>>>>>>> - CEP serialization: #2202 (
>>>> https://github.com/apache/flink/pull/2202
>>>>>> )
>>>>>>>>> - HA BLOB store life-cycle:
>>>>>>>> https://issues.apache.org/jira/browse/FLINK-4150
>>>>>>>>>
>>>>>>>>> Nice to have:
>>>>>>>>> - Hash-based combine: #1517
>>>> https://github.com/apache/flink/pull/1517
>>>>>>>>>
>>>>>>>>> Feel free to add issues/PRs to the list and please report any
>>>> issues
>>>>>>>>> you encounter during testing in this thread.
>>>>>>>>
>>>>>>>>
>>>>>>
>>>>
>>>
>

[Flavio Pompermaier]

Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
This would be very useful to us..

Best,
Flavio

On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
wrote:

> Sounds good!
>
> This one I just merged: https://github.com/apache/flink/pull/2273 (Only
> allow/require query
> for Tuple Stream in CassandraSink)
>
> For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
> Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR:
> https://github.com/apache/flink/pull/2278
>
> On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>
> > Hey all,
> >
> > although there was no feedback for this preview RC, most of the issues
> > mentioned in the release are either resolved or open PRs. Once the
> > following PRs have been merged, I would like to create RC1 and the
> > release-1.1 branch. Feedback to this list is highly appreciated.
> >
> > Open PRs (awaiting review/review in progress):
> > - https://github.com/apache/flink/pull/2276: Forward suspend to
> > checkpoint coordinator
> > - https://github.com/apache/flink/pull/2257: Allow re-registration of
> > TMs at resource manager
> > - https://github.com/apache/flink/pull/2226: Move Metrics API to
> separate
> > module
> >
> > Open PRs (to be merged):
> > - https://github.com/apache/flink/pull/2273: Only allow/require query
> > for Tuple Stream in CassandraSink
> > - https://github.com/apache/flink/pull/2271: Add restarting time JM
> metric
> > - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
> > on BlobServer shut down
> > - https://github.com/apache/flink/pull/2194: Add savepoint headers
> >
> > Open issues w/o PRs:
> > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
> > Allowed Lateness to Zero and Make Triggers Non-Purging
> > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
> > becomes very slow with allowed lateness
> >
> > @Aljoscha, Kostas: do you have an idea when these will be addressed?
> >
> > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <[hidden email]>
> > wrote:
> > > Not yet, but Kostas is investigating.
> > >
> > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
> > >
> > >> Most actually have a pending PR, except:
> > >> https://issues.apache.org/jira/browse/FLINK-4207,
> > >> https://issues.apache.org/jira/browse/FLINK-4201.
> > >>
> > >> I will assign FLINK-4201 to myself and hope to fix it over the
> > >> weekend. The issue Stefan mentioned also has a pending PR by now.
> > >>
> > >> Hope to create the first RC next week... @Aljoscha, Stephan: any idea
> > >> about fixing FLINK-4207?
> > >>
> > >> – Ufuk
> > >>
> > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <[hidden email]>
> > >> wrote:
> > >> > There are still 7 blockers for the release:
> > >> >
> > >>
> >
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> > >> > most of them are assigned, some even have a pending pull request.
> > >> >
> > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> > >> [hidden email]
> > >> >> wrote:
> > >> >
> > >> >> Hi Ufuk,
> > >> >>
> > >> >> Thanks for starting this thread. I think we should solve
> > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
> version,
> > >> >> because it can easily become a blocker when running multiple Flink
> > >> >> applications on a clusters with HA  (see related issue for one
> > example).
> > >> >>
> > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> > >> >> >
> > >> >> > Dear community,
> > >> >> >
> > >> >> > ===============
> > >> >> > FLINK 1.1.0 RC0
> > >> >> > ===============
> > >> >> >
> > >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> > >> >> > including everything in master up to cb7824
> > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> > >> >> >
> > >> >> > There are still some blocking issues and important pull requests
> > to be
> > >> >> > merged (see below), but nevertheless I would like to start
> testing
> > >> >> > Flink for the release in order to get the process going.
> > >> >> >
> > >> >> > In past major releases, we needed to create many release
> > candidates,
> > >> >> > often for fixing just some small issues. I would like to speed up
> > the
> > >> >> > release process by collecting the last remaining issues with the
> > RC0.
> > >> >> > Once these issues are resolved, we can start voting on RC1. This
> is
> > >> >> > also when I will create the release-1.1 branch.
> > >> >> >
> > >> >> > We have a Wiki page
> > >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
> > >> containing
> > >> >> > some common release verification tasks.
> > >> >> >
> > >> >> > Also, production users are encouraged to participate in the
> release
> > >> >> > verification process.
> > >> >> >
> > >> >> > Here are the preview binaries located:
> > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> > >> >> >
> > >> >> > This is the staging repository:
> > >> >> >
> > >>
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> > >> >> >
> > >> >> > To use the release candidate in an existing Maven project, set
> the
> > >> >> > Flink version to 1.1.0 and the repository URL to
> > >> >> >
> > >>
> https://repository.apache.org/content/repositories/orgapacheflink-1097.
> > >> >> >
> > >> >> > The POM should look like this:
> > >> >> >
> > >> >> > <properties>
> > >> >> >
> >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> > >> >> >   <flink.version>1.1.0</flink.version>
> > >> >> > </properties>
> > >> >> >
> > >> >> > <repositories>
> > >> >> >   <repository>
> > >> >> >      <id>flink.release-staging</id>
> > >> >> >      <name>Apache Development Snapshot Repository</name>
> > >> >> >      <url>
> > >> >>
> > https://repository.apache.org/content/repositories/orgapacheflink-1097
> > >> >> </url>
> > >> >> >      <releases><enabled>true</enabled></releases>
> > >> >> >      <snapshots><enabled>false</enabled></snapshots>
> > >> >> >   </repository>
> > >> >> > </repositories>
> > >> >> >
> > >> >> > ===========
> > >> >> > OPEN ISSUES
> > >> >> > ===========
> > >> >> >
> > >> >> > The following are important to be fixed/merged before the
> release:
> > >> >> > - Savepoint headers: PR #2083 (
> > >> https://github.com/apache/flink/pull/2083
> > >> >> )
> > >> >> >  * includes FLINK-4154 (
> > >> https://issues.apache.org/jira/browse/FLINK-4154
> > >> >> )
> > >> >> > - Savepoint disposal with user class loader: #2194
> > >> >> > (https://github.com/apache/flink/pull/2194)
> > >> >> > - Cassandra sink exception check: #2183
> > >> >> > (https://github.com/apache/flink/pull/2183)
> > >> >> > - Prevent Metrics log flooding: #2135
> > >> >> > (https://github.com/apache/flink/pull/2135)
> > >> >> > - CEP serialization: #2202 (
> > https://github.com/apache/flink/pull/2202
> > >> )
> > >> >> > - HA BLOB store life-cycle:
> > >> >> https://issues.apache.org/jira/browse/FLINK-4150
> > >> >> >
> > >> >> > Nice to have:
> > >> >> > - Hash-based combine: #1517
> > https://github.com/apache/flink/pull/1517
> > >> >> >
> > >> >> > Feel free to add issues/PRs to the list and please report any
> > issues
> > >> >> > you encounter during testing in this thread.
> > >> >>
> > >> >>
> > >>
> >
>

[Till Rohrmann]

https://github.com/apache/flink/pull/2257 should almost be mergable. There
is only an issue with one test which only occurs on Travis. But I think I
found the culprit. Currently, testing it on Travis again.

On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <[hidden email]>
wrote:

> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
> This would be very useful to us..
>
> Best,
> Flavio
>
> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
> wrote:
>
> > Sounds good!
> >
> > This one I just merged: https://github.com/apache/flink/pull/2273 (Only
> > allow/require query
> > for Tuple Stream in CassandraSink)
> >
> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a
> PR:
> > https://github.com/apache/flink/pull/2278
> >
> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
> >
> > > Hey all,
> > >
> > > although there was no feedback for this preview RC, most of the issues
> > > mentioned in the release are either resolved or open PRs. Once the
> > > following PRs have been merged, I would like to create RC1 and the
> > > release-1.1 branch. Feedback to this list is highly appreciated.
> > >
> > > Open PRs (awaiting review/review in progress):
> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
> > > checkpoint coordinator
> > > - https://github.com/apache/flink/pull/2257: Allow re-registration of
> > > TMs at resource manager
> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
> > separate
> > > module
> > >
> > > Open PRs (to be merged):
> > > - https://github.com/apache/flink/pull/2273: Only allow/require query
> > > for Tuple Stream in CassandraSink
> > > - https://github.com/apache/flink/pull/2271: Add restarting time JM
> > metric
> > > - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
> > > on BlobServer shut down
> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
> > >
> > > Open issues w/o PRs:
> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
> > > Allowed Lateness to Zero and Make Triggers Non-Purging
> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
> > > becomes very slow with allowed lateness
> > >
> > > @Aljoscha, Kostas: do you have an idea when these will be addressed?
> > >
> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
> [hidden email]>
> > > wrote:
> > > > Not yet, but Kostas is investigating.
> > > >
> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
> > > >
> > > >> Most actually have a pending PR, except:
> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
> > > >>
> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
> > > >> weekend. The issue Stefan mentioned also has a pending PR by now.
> > > >>
> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
> idea
> > > >> about fixing FLINK-4207?
> > > >>
> > > >> – Ufuk
> > > >>
> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
> [hidden email]>
> > > >> wrote:
> > > >> > There are still 7 blockers for the release:
> > > >> >
> > > >>
> > >
> >
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> > > >> > most of them are assigned, some even have a pending pull request.
> > > >> >
> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> > > >> [hidden email]
> > > >> >> wrote:
> > > >> >
> > > >> >> Hi Ufuk,
> > > >> >>
> > > >> >> Thanks for starting this thread. I think we should solve
> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
> > version,
> > > >> >> because it can easily become a blocker when running multiple
> Flink
> > > >> >> applications on a clusters with HA  (see related issue for one
> > > example).
> > > >> >>
> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
> > > >> >> >
> > > >> >> > Dear community,
> > > >> >> >
> > > >> >> > ===============
> > > >> >> > FLINK 1.1.0 RC0
> > > >> >> > ===============
> > > >> >> >
> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
> > > >> >> > including everything in master up to cb7824
> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> > > >> >> >
> > > >> >> > There are still some blocking issues and important pull
> requests
> > > to be
> > > >> >> > merged (see below), but nevertheless I would like to start
> > testing
> > > >> >> > Flink for the release in order to get the process going.
> > > >> >> >
> > > >> >> > In past major releases, we needed to create many release
> > > candidates,
> > > >> >> > often for fixing just some small issues. I would like to speed
> up
> > > the
> > > >> >> > release process by collecting the last remaining issues with
> the
> > > RC0.
> > > >> >> > Once these issues are resolved, we can start voting on RC1.
> This
> > is
> > > >> >> > also when I will create the release-1.1 branch.
> > > >> >> >
> > > >> >> > We have a Wiki page
> > > >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
> > > >> containing
> > > >> >> > some common release verification tasks.
> > > >> >> >
> > > >> >> > Also, production users are encouraged to participate in the
> > release
> > > >> >> > verification process.
> > > >> >> >
> > > >> >> > Here are the preview binaries located:
> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> > > >> >> >
> > > >> >> > This is the staging repository:
> > > >> >> >
> > > >>
> > https://repository.apache.org/content/repositories/orgapacheflink-1097
> > > >> >> >
> > > >> >> > To use the release candidate in an existing Maven project, set
> > the
> > > >> >> > Flink version to 1.1.0 and the repository URL to
> > > >> >> >
> > > >>
> > https://repository.apache.org/content/repositories/orgapacheflink-1097.
> > > >> >> >
> > > >> >> > The POM should look like this:
> > > >> >> >
> > > >> >> > <properties>
> > > >> >> >
> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> > > >> >> >   <flink.version>1.1.0</flink.version>
> > > >> >> > </properties>
> > > >> >> >
> > > >> >> > <repositories>
> > > >> >> >   <repository>
> > > >> >> >      <id>flink.release-staging</id>
> > > >> >> >      <name>Apache Development Snapshot Repository</name>
> > > >> >> >      <url>
> > > >> >>
> > > https://repository.apache.org/content/repositories/orgapacheflink-1097
> > > >> >> </url>
> > > >> >> >      <releases><enabled>true</enabled></releases>
> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
> > > >> >> >   </repository>
> > > >> >> > </repositories>
> > > >> >> >
> > > >> >> > ===========
> > > >> >> > OPEN ISSUES
> > > >> >> > ===========
> > > >> >> >
> > > >> >> > The following are important to be fixed/merged before the
> > release:
> > > >> >> > - Savepoint headers: PR #2083 (
> > > >> https://github.com/apache/flink/pull/2083
> > > >> >> )
> > > >> >> >  * includes FLINK-4154 (
> > > >> https://issues.apache.org/jira/browse/FLINK-4154
> > > >> >> )
> > > >> >> > - Savepoint disposal with user class loader: #2194
> > > >> >> > (https://github.com/apache/flink/pull/2194)
> > > >> >> > - Cassandra sink exception check: #2183
> > > >> >> > (https://github.com/apache/flink/pull/2183)
> > > >> >> > - Prevent Metrics log flooding: #2135
> > > >> >> > (https://github.com/apache/flink/pull/2135)
> > > >> >> > - CEP serialization: #2202 (
> > > https://github.com/apache/flink/pull/2202
> > > >> )
> > > >> >> > - HA BLOB store life-cycle:
> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
> > > >> >> >
> > > >> >> > Nice to have:
> > > >> >> > - Hash-based combine: #1517
> > > https://github.com/apache/flink/pull/1517
> > > >> >> >
> > > >> >> > Feel free to add issues/PRs to the list and please report any
> > > issues
> > > >> >> > you encounter during testing in this thread.
> > > >> >>
> > > >> >>
> > > >>
> > >
> >
>

[Ufuk Celebi-2]

The following PRs are still open. I will create the RC as soon as they
are merged. In any case I will fork off the release-1.1 branch by the
end of today (CET 6:00 PM), so that we are not blocking regular Flink
development.

- https://github.com/apache/flink/pull/2257: Allow re-registration of
TMs at resource manager => All good except for a Travis test issue.
@Max: You are looking into this, correct?

- https://github.com/apache/flink/pull/2226: Move Metrics API to
separate module => Chesnay updated this, we need a review here.
@Aljoscha: You were involved in this. Can you review this?

- https://github.com/apache/flink/pull/2277: WindowOperator becomes
very slow with allowed lateness => Needs another round of review.
@Aljoscha: You did the initial review. Can you review the addressed
comments again?

- https://github.com/apache/flink/pull/2194 => merging this now

- https://github.com/apache/flink/pull/2278 => merging this now

- https://github.com/apache/flink/pull/2286 => merging this now



On Thu, Jul 21, 2016 at 4:44 PM, Till Rohrmann <[hidden email]> wrote:

> https://github.com/apache/flink/pull/2257 should almost be mergable. There
> is only an issue with one test which only occurs on Travis. But I think I
> found the culprit. Currently, testing it on Travis again.
>
> On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <[hidden email]>
> wrote:
>
>> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
>> This would be very useful to us..
>>
>> Best,
>> Flavio
>>
>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
>> wrote:
>>
>> > Sounds good!
>> >
>> > This one I just merged: https://github.com/apache/flink/pull/2273 (Only
>> > allow/require query
>> > for Tuple Stream in CassandraSink)
>> >
>> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
>> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a
>> PR:
>> > https://github.com/apache/flink/pull/2278
>> >
>> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>> >
>> > > Hey all,
>> > >
>> > > although there was no feedback for this preview RC, most of the issues
>> > > mentioned in the release are either resolved or open PRs. Once the
>> > > following PRs have been merged, I would like to create RC1 and the
>> > > release-1.1 branch. Feedback to this list is highly appreciated.
>> > >
>> > > Open PRs (awaiting review/review in progress):
>> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
>> > > checkpoint coordinator
>> > > - https://github.com/apache/flink/pull/2257: Allow re-registration of
>> > > TMs at resource manager
>> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>> > separate
>> > > module
>> > >
>> > > Open PRs (to be merged):
>> > > - https://github.com/apache/flink/pull/2273: Only allow/require query
>> > > for Tuple Stream in CassandraSink
>> > > - https://github.com/apache/flink/pull/2271: Add restarting time JM
>> > metric
>> > > - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
>> > > on BlobServer shut down
>> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
>> > >
>> > > Open issues w/o PRs:
>> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>> > > Allowed Lateness to Zero and Make Triggers Non-Purging
>> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>> > > becomes very slow with allowed lateness
>> > >
>> > > @Aljoscha, Kostas: do you have an idea when these will be addressed?
>> > >
>> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
>> [hidden email]>
>> > > wrote:
>> > > > Not yet, but Kostas is investigating.
>> > > >
>> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>> > > >
>> > > >> Most actually have a pending PR, except:
>> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
>> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
>> > > >>
>> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
>> > > >> weekend. The issue Stefan mentioned also has a pending PR by now.
>> > > >>
>> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
>> idea
>> > > >> about fixing FLINK-4207?
>> > > >>
>> > > >> – Ufuk
>> > > >>
>> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
>> [hidden email]>
>> > > >> wrote:
>> > > >> > There are still 7 blockers for the release:
>> > > >> >
>> > > >>
>> > >
>> >
>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>> > > >> > most of them are assigned, some even have a pending pull request.
>> > > >> >
>> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>> > > >> [hidden email]
>> > > >> >> wrote:
>> > > >> >
>> > > >> >> Hi Ufuk,
>> > > >> >>
>> > > >> >> Thanks for starting this thread. I think we should solve
>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
>> > version,
>> > > >> >> because it can easily become a blocker when running multiple
>> Flink
>> > > >> >> applications on a clusters with HA  (see related issue for one
>> > > example).
>> > > >> >>
>> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>> > > >> >> >
>> > > >> >> > Dear community,
>> > > >> >> >
>> > > >> >> > ===============
>> > > >> >> > FLINK 1.1.0 RC0
>> > > >> >> > ===============
>> > > >> >> >
>> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
>> > > >> >> > including everything in master up to cb7824
>> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>> > > >> >> >
>> > > >> >> > There are still some blocking issues and important pull
>> requests
>> > > to be
>> > > >> >> > merged (see below), but nevertheless I would like to start
>> > testing
>> > > >> >> > Flink for the release in order to get the process going.
>> > > >> >> >
>> > > >> >> > In past major releases, we needed to create many release
>> > > candidates,
>> > > >> >> > often for fixing just some small issues. I would like to speed
>> up
>> > > the
>> > > >> >> > release process by collecting the last remaining issues with
>> the
>> > > RC0.
>> > > >> >> > Once these issues are resolved, we can start voting on RC1.
>> This
>> > is
>> > > >> >> > also when I will create the release-1.1 branch.
>> > > >> >> >
>> > > >> >> > We have a Wiki page
>> > > >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
>> > > >> containing
>> > > >> >> > some common release verification tasks.
>> > > >> >> >
>> > > >> >> > Also, production users are encouraged to participate in the
>> > release
>> > > >> >> > verification process.
>> > > >> >> >
>> > > >> >> > Here are the preview binaries located:
>> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>> > > >> >> >
>> > > >> >> > This is the staging repository:
>> > > >> >> >
>> > > >>
>> > https://repository.apache.org/content/repositories/orgapacheflink-1097
>> > > >> >> >
>> > > >> >> > To use the release candidate in an existing Maven project, set
>> > the
>> > > >> >> > Flink version to 1.1.0 and the repository URL to
>> > > >> >> >
>> > > >>
>> > https://repository.apache.org/content/repositories/orgapacheflink-1097.
>> > > >> >> >
>> > > >> >> > The POM should look like this:
>> > > >> >> >
>> > > >> >> > <properties>
>> > > >> >> >
>> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>> > > >> >> >   <flink.version>1.1.0</flink.version>
>> > > >> >> > </properties>
>> > > >> >> >
>> > > >> >> > <repositories>
>> > > >> >> >   <repository>
>> > > >> >> >      <id>flink.release-staging</id>
>> > > >> >> >      <name>Apache Development Snapshot Repository</name>
>> > > >> >> >      <url>
>> > > >> >>
>> > > https://repository.apache.org/content/repositories/orgapacheflink-1097
>> > > >> >> </url>
>> > > >> >> >      <releases><enabled>true</enabled></releases>
>> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
>> > > >> >> >   </repository>
>> > > >> >> > </repositories>
>> > > >> >> >
>> > > >> >> > ===========
>> > > >> >> > OPEN ISSUES
>> > > >> >> > ===========
>> > > >> >> >
>> > > >> >> > The following are important to be fixed/merged before the
>> > release:
>> > > >> >> > - Savepoint headers: PR #2083 (
>> > > >> https://github.com/apache/flink/pull/2083
>> > > >> >> )
>> > > >> >> >  * includes FLINK-4154 (
>> > > >> https://issues.apache.org/jira/browse/FLINK-4154
>> > > >> >> )
>> > > >> >> > - Savepoint disposal with user class loader: #2194
>> > > >> >> > (https://github.com/apache/flink/pull/2194)
>> > > >> >> > - Cassandra sink exception check: #2183
>> > > >> >> > (https://github.com/apache/flink/pull/2183)
>> > > >> >> > - Prevent Metrics log flooding: #2135
>> > > >> >> > (https://github.com/apache/flink/pull/2135)
>> > > >> >> > - CEP serialization: #2202 (
>> > > https://github.com/apache/flink/pull/2202
>> > > >> )
>> > > >> >> > - HA BLOB store life-cycle:
>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
>> > > >> >> >
>> > > >> >> > Nice to have:
>> > > >> >> > - Hash-based combine: #1517
>> > > https://github.com/apache/flink/pull/1517
>> > > >> >> >
>> > > >> >> > Feel free to add issues/PRs to the list and please report any
>> > > issues
>> > > >> >> > you encounter during testing in this thread.
>> > > >> >>
>> > > >> >>
>> > > >>
>> > >
>> >
>>

[mxm]

Yes, I'm done with the investigation for
https://github.com/apache/flink/pull/2257. Merging before 6 pm CET.

On Tue, Jul 26, 2016 at 10:52 AM, Ufuk Celebi <[hidden email]> wrote:

> The following PRs are still open. I will create the RC as soon as they
> are merged. In any case I will fork off the release-1.1 branch by the
> end of today (CET 6:00 PM), so that we are not blocking regular Flink
> development.
>
> - https://github.com/apache/flink/pull/2257: Allow re-registration of
> TMs at resource manager => All good except for a Travis test issue.
> @Max: You are looking into this, correct?
>
> - https://github.com/apache/flink/pull/2226: Move Metrics API to
> separate module => Chesnay updated this, we need a review here.
> @Aljoscha: You were involved in this. Can you review this?
>
> - https://github.com/apache/flink/pull/2277: WindowOperator becomes
> very slow with allowed lateness => Needs another round of review.
> @Aljoscha: You did the initial review. Can you review the addressed
> comments again?
>
> - https://github.com/apache/flink/pull/2194 => merging this now
>
> - https://github.com/apache/flink/pull/2278 => merging this now
>
> - https://github.com/apache/flink/pull/2286 => merging this now
>
>
>
> On Thu, Jul 21, 2016 at 4:44 PM, Till Rohrmann <[hidden email]> wrote:
>> https://github.com/apache/flink/pull/2257 should almost be mergable. There
>> is only an issue with one test which only occurs on Travis. But I think I
>> found the culprit. Currently, testing it on Travis again.
>>
>> On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <[hidden email]>
>> wrote:
>>
>>> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
>>> This would be very useful to us..
>>>
>>> Best,
>>> Flavio
>>>
>>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]>
>>> wrote:
>>>
>>> > Sounds good!
>>> >
>>> > This one I just merged: https://github.com/apache/flink/pull/2273 (Only
>>> > allow/require query
>>> > for Tuple Stream in CassandraSink)
>>> >
>>> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
>>> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a
>>> PR:
>>> > https://github.com/apache/flink/pull/2278
>>> >
>>> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>>> >
>>> > > Hey all,
>>> > >
>>> > > although there was no feedback for this preview RC, most of the issues
>>> > > mentioned in the release are either resolved or open PRs. Once the
>>> > > following PRs have been merged, I would like to create RC1 and the
>>> > > release-1.1 branch. Feedback to this list is highly appreciated.
>>> > >
>>> > > Open PRs (awaiting review/review in progress):
>>> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
>>> > > checkpoint coordinator
>>> > > - https://github.com/apache/flink/pull/2257: Allow re-registration of
>>> > > TMs at resource manager
>>> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>>> > separate
>>> > > module
>>> > >
>>> > > Open PRs (to be merged):
>>> > > - https://github.com/apache/flink/pull/2273: Only allow/require query
>>> > > for Tuple Stream in CassandraSink
>>> > > - https://github.com/apache/flink/pull/2271: Add restarting time JM
>>> > metric
>>> > > - https://github.com/apache/flink/pull/2256: Don't clean up BlobStore
>>> > > on BlobServer shut down
>>> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
>>> > >
>>> > > Open issues w/o PRs:
>>> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>>> > > Allowed Lateness to Zero and Make Triggers Non-Purging
>>> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>>> > > becomes very slow with allowed lateness
>>> > >
>>> > > @Aljoscha, Kostas: do you have an idea when these will be addressed?
>>> > >
>>> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
>>> [hidden email]>
>>> > > wrote:
>>> > > > Not yet, but Kostas is investigating.
>>> > > >
>>> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>>> > > >
>>> > > >> Most actually have a pending PR, except:
>>> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
>>> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
>>> > > >>
>>> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
>>> > > >> weekend. The issue Stefan mentioned also has a pending PR by now.
>>> > > >>
>>> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
>>> idea
>>> > > >> about fixing FLINK-4207?
>>> > > >>
>>> > > >> – Ufuk
>>> > > >>
>>> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
>>> [hidden email]>
>>> > > >> wrote:
>>> > > >> > There are still 7 blockers for the release:
>>> > > >> >
>>> > > >>
>>> > >
>>> >
>>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>>> > > >> > most of them are assigned, some even have a pending pull request.
>>> > > >> >
>>> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>>> > > >> [hidden email]
>>> > > >> >> wrote:
>>> > > >> >
>>> > > >> >> Hi Ufuk,
>>> > > >> >>
>>> > > >> >> Thanks for starting this thread. I think we should solve
>>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
>>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
>>> > version,
>>> > > >> >> because it can easily become a blocker when running multiple
>>> Flink
>>> > > >> >> applications on a clusters with HA  (see related issue for one
>>> > > example).
>>> > > >> >>
>>> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]>:
>>> > > >> >> >
>>> > > >> >> > Dear community,
>>> > > >> >> >
>>> > > >> >> > ===============
>>> > > >> >> > FLINK 1.1.0 RC0
>>> > > >> >> > ===============
>>> > > >> >> >
>>> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0 release,
>>> > > >> >> > including everything in master up to cb7824
>>> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>>> > > >> >> >
>>> > > >> >> > There are still some blocking issues and important pull
>>> requests
>>> > > to be
>>> > > >> >> > merged (see below), but nevertheless I would like to start
>>> > testing
>>> > > >> >> > Flink for the release in order to get the process going.
>>> > > >> >> >
>>> > > >> >> > In past major releases, we needed to create many release
>>> > > candidates,
>>> > > >> >> > often for fixing just some small issues. I would like to speed
>>> up
>>> > > the
>>> > > >> >> > release process by collecting the last remaining issues with
>>> the
>>> > > RC0.
>>> > > >> >> > Once these issues are resolved, we can start voting on RC1.
>>> This
>>> > is
>>> > > >> >> > also when I will create the release-1.1 branch.
>>> > > >> >> >
>>> > > >> >> > We have a Wiki page
>>> > > >> >> > https://cwiki.apache.org/confluence/display/FLINK/Releasing
>>> > > >> containing
>>> > > >> >> > some common release verification tasks.
>>> > > >> >> >
>>> > > >> >> > Also, production users are encouraged to participate in the
>>> > release
>>> > > >> >> > verification process.
>>> > > >> >> >
>>> > > >> >> > Here are the preview binaries located:
>>> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>>> > > >> >> >
>>> > > >> >> > This is the staging repository:
>>> > > >> >> >
>>> > > >>
>>> > https://repository.apache.org/content/repositories/orgapacheflink-1097
>>> > > >> >> >
>>> > > >> >> > To use the release candidate in an existing Maven project, set
>>> > the
>>> > > >> >> > Flink version to 1.1.0 and the repository URL to
>>> > > >> >> >
>>> > > >>
>>> > https://repository.apache.org/content/repositories/orgapacheflink-1097.
>>> > > >> >> >
>>> > > >> >> > The POM should look like this:
>>> > > >> >> >
>>> > > >> >> > <properties>
>>> > > >> >> >
>>> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>>> > > >> >> >   <flink.version>1.1.0</flink.version>
>>> > > >> >> > </properties>
>>> > > >> >> >
>>> > > >> >> > <repositories>
>>> > > >> >> >   <repository>
>>> > > >> >> >      <id>flink.release-staging</id>
>>> > > >> >> >      <name>Apache Development Snapshot Repository</name>
>>> > > >> >> >      <url>
>>> > > >> >>
>>> > > https://repository.apache.org/content/repositories/orgapacheflink-1097
>>> > > >> >> </url>
>>> > > >> >> >      <releases><enabled>true</enabled></releases>
>>> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
>>> > > >> >> >   </repository>
>>> > > >> >> > </repositories>
>>> > > >> >> >
>>> > > >> >> > ===========
>>> > > >> >> > OPEN ISSUES
>>> > > >> >> > ===========
>>> > > >> >> >
>>> > > >> >> > The following are important to be fixed/merged before the
>>> > release:
>>> > > >> >> > - Savepoint headers: PR #2083 (
>>> > > >> https://github.com/apache/flink/pull/2083
>>> > > >> >> )
>>> > > >> >> >  * includes FLINK-4154 (
>>> > > >> https://issues.apache.org/jira/browse/FLINK-4154
>>> > > >> >> )
>>> > > >> >> > - Savepoint disposal with user class loader: #2194
>>> > > >> >> > (https://github.com/apache/flink/pull/2194)
>>> > > >> >> > - Cassandra sink exception check: #2183
>>> > > >> >> > (https://github.com/apache/flink/pull/2183)
>>> > > >> >> > - Prevent Metrics log flooding: #2135
>>> > > >> >> > (https://github.com/apache/flink/pull/2135)
>>> > > >> >> > - CEP serialization: #2202 (
>>> > > https://github.com/apache/flink/pull/2202
>>> > > >> )
>>> > > >> >> > - HA BLOB store life-cycle:
>>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
>>> > > >> >> >
>>> > > >> >> > Nice to have:
>>> > > >> >> > - Hash-based combine: #1517
>>> > > https://github.com/apache/flink/pull/1517
>>> > > >> >> >
>>> > > >> >> > Feel free to add issues/PRs to the list and please report any
>>> > > issues
>>> > > >> >> > you encounter during testing in this thread.
>>> > > >> >>
>>> > > >> >>
>>> > > >>
>>> > >
>>> >
>>>

[Aljoscha Krettek-2]

I'm running tests locally now because of the Travis problems. Will merge as
soon as they pass for both the window slowness fix and the multiple metrics
reporters change.

On Tue, 26 Jul 2016 at 14:47 Maximilian Michels <[hidden email]> wrote:

> Yes, I'm done with the investigation for
> https://github.com/apache/flink/pull/2257. Merging before 6 pm CET.
>
> On Tue, Jul 26, 2016 at 10:52 AM, Ufuk Celebi <[hidden email]> wrote:
> > The following PRs are still open. I will create the RC as soon as they
> > are merged. In any case I will fork off the release-1.1 branch by the
> > end of today (CET 6:00 PM), so that we are not blocking regular Flink
> > development.
> >
> > - https://github.com/apache/flink/pull/2257: Allow re-registration of
> > TMs at resource manager => All good except for a Travis test issue.
> > @Max: You are looking into this, correct?
> >
> > - https://github.com/apache/flink/pull/2226: Move Metrics API to
> > separate module => Chesnay updated this, we need a review here.
> > @Aljoscha: You were involved in this. Can you review this?
> >
> > - https://github.com/apache/flink/pull/2277: WindowOperator becomes
> > very slow with allowed lateness => Needs another round of review.
> > @Aljoscha: You did the initial review. Can you review the addressed
> > comments again?
> >
> > - https://github.com/apache/flink/pull/2194 => merging this now
> >
> > - https://github.com/apache/flink/pull/2278 => merging this now
> >
> > - https://github.com/apache/flink/pull/2286 => merging this now
> >
> >
> >
> > On Thu, Jul 21, 2016 at 4:44 PM, Till Rohrmann <[hidden email]>
> wrote:
> >> https://github.com/apache/flink/pull/2257 should almost be mergable.
> There
> >> is only an issue with one test which only occurs on Travis. But I think
> I
> >> found the culprit. Currently, testing it on Travis again.
> >>
> >> On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <
> [hidden email]>
> >> wrote:
> >>
> >>> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
> >>> This would be very useful to us..
> >>>
> >>> Best,
> >>> Flavio
> >>>
> >>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]
> >
> >>> wrote:
> >>>
> >>> > Sounds good!
> >>> >
> >>> > This one I just merged: https://github.com/apache/flink/pull/2273
> (Only
> >>> > allow/require query
> >>> > for Tuple Stream in CassandraSink)
> >>> >
> >>> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
> >>> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just
> opened a
> >>> PR:
> >>> > https://github.com/apache/flink/pull/2278
> >>> >
> >>> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
> >>> >
> >>> > > Hey all,
> >>> > >
> >>> > > although there was no feedback for this preview RC, most of the
> issues
> >>> > > mentioned in the release are either resolved or open PRs. Once the
> >>> > > following PRs have been merged, I would like to create RC1 and the
> >>> > > release-1.1 branch. Feedback to this list is highly appreciated.
> >>> > >
> >>> > > Open PRs (awaiting review/review in progress):
> >>> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
> >>> > > checkpoint coordinator
> >>> > > - https://github.com/apache/flink/pull/2257: Allow
> re-registration of
> >>> > > TMs at resource manager
> >>> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
> >>> > separate
> >>> > > module
> >>> > >
> >>> > > Open PRs (to be merged):
> >>> > > - https://github.com/apache/flink/pull/2273: Only allow/require
> query
> >>> > > for Tuple Stream in CassandraSink
> >>> > > - https://github.com/apache/flink/pull/2271: Add restarting time
> JM
> >>> > metric
> >>> > > - https://github.com/apache/flink/pull/2256: Don't clean up
> BlobStore
> >>> > > on BlobServer shut down
> >>> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
> >>> > >
> >>> > > Open issues w/o PRs:
> >>> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
> >>> > > Allowed Lateness to Zero and Make Triggers Non-Purging
> >>> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
> >>> > > becomes very slow with allowed lateness
> >>> > >
> >>> > > @Aljoscha, Kostas: do you have an idea when these will be
> addressed?
> >>> > >
> >>> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
> >>> [hidden email]>
> >>> > > wrote:
> >>> > > > Not yet, but Kostas is investigating.
> >>> > > >
> >>> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
> >>> > > >
> >>> > > >> Most actually have a pending PR, except:
> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
> >>> > > >>
> >>> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
> >>> > > >> weekend. The issue Stefan mentioned also has a pending PR by
> now.
> >>> > > >>
> >>> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
> >>> idea
> >>> > > >> about fixing FLINK-4207?
> >>> > > >>
> >>> > > >> – Ufuk
> >>> > > >>
> >>> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
> >>> [hidden email]>
> >>> > > >> wrote:
> >>> > > >> > There are still 7 blockers for the release:
> >>> > > >> >
> >>> > > >>
> >>> > >
> >>> >
> >>>
> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
> >>> > > >> > most of them are assigned, some even have a pending pull
> request.
> >>> > > >> >
> >>> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
> >>> > > >> [hidden email]
> >>> > > >> >> wrote:
> >>> > > >> >
> >>> > > >> >> Hi Ufuk,
> >>> > > >> >>
> >>> > > >> >> Thanks for starting this thread. I think we should solve
> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
> >>> > version,
> >>> > > >> >> because it can easily become a blocker when running multiple
> >>> Flink
> >>> > > >> >> applications on a clusters with HA  (see related issue for
> one
> >>> > > example).
> >>> > > >> >>
> >>> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]
> >:
> >>> > > >> >> >
> >>> > > >> >> > Dear community,
> >>> > > >> >> >
> >>> > > >> >> > ===============
> >>> > > >> >> > FLINK 1.1.0 RC0
> >>> > > >> >> > ===============
> >>> > > >> >> >
> >>> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0
> release,
> >>> > > >> >> > including everything in master up to cb7824
> >>> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
> >>> > > >> >> >
> >>> > > >> >> > There are still some blocking issues and important pull
> >>> requests
> >>> > > to be
> >>> > > >> >> > merged (see below), but nevertheless I would like to start
> >>> > testing
> >>> > > >> >> > Flink for the release in order to get the process going.
> >>> > > >> >> >
> >>> > > >> >> > In past major releases, we needed to create many release
> >>> > > candidates,
> >>> > > >> >> > often for fixing just some small issues. I would like to
> speed
> >>> up
> >>> > > the
> >>> > > >> >> > release process by collecting the last remaining issues
> with
> >>> the
> >>> > > RC0.
> >>> > > >> >> > Once these issues are resolved, we can start voting on RC1.
> >>> This
> >>> > is
> >>> > > >> >> > also when I will create the release-1.1 branch.
> >>> > > >> >> >
> >>> > > >> >> > We have a Wiki page
> >>> > > >> >> >
> https://cwiki.apache.org/confluence/display/FLINK/Releasing
> >>> > > >> containing
> >>> > > >> >> > some common release verification tasks.
> >>> > > >> >> >
> >>> > > >> >> > Also, production users are encouraged to participate in the
> >>> > release
> >>> > > >> >> > verification process.
> >>> > > >> >> >
> >>> > > >> >> > Here are the preview binaries located:
> >>> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
> >>> > > >> >> >
> >>> > > >> >> > This is the staging repository:
> >>> > > >> >> >
> >>> > > >>
> >>> >
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >>> > > >> >> >
> >>> > > >> >> > To use the release candidate in an existing Maven project,
> set
> >>> > the
> >>> > > >> >> > Flink version to 1.1.0 and the repository URL to
> >>> > > >> >> >
> >>> > > >>
> >>> >
> https://repository.apache.org/content/repositories/orgapacheflink-1097.
> >>> > > >> >> >
> >>> > > >> >> > The POM should look like this:
> >>> > > >> >> >
> >>> > > >> >> > <properties>
> >>> > > >> >> >
> >>> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> >>> > > >> >> >   <flink.version>1.1.0</flink.version>
> >>> > > >> >> > </properties>
> >>> > > >> >> >
> >>> > > >> >> > <repositories>
> >>> > > >> >> >   <repository>
> >>> > > >> >> >      <id>flink.release-staging</id>
> >>> > > >> >> >      <name>Apache Development Snapshot Repository</name>
> >>> > > >> >> >      <url>
> >>> > > >> >>
> >>> > >
> https://repository.apache.org/content/repositories/orgapacheflink-1097
> >>> > > >> >> </url>
> >>> > > >> >> >      <releases><enabled>true</enabled></releases>
> >>> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
> >>> > > >> >> >   </repository>
> >>> > > >> >> > </repositories>
> >>> > > >> >> >
> >>> > > >> >> > ===========
> >>> > > >> >> > OPEN ISSUES
> >>> > > >> >> > ===========
> >>> > > >> >> >
> >>> > > >> >> > The following are important to be fixed/merged before the
> >>> > release:
> >>> > > >> >> > - Savepoint headers: PR #2083 (
> >>> > > >> https://github.com/apache/flink/pull/2083
> >>> > > >> >> )
> >>> > > >> >> >  * includes FLINK-4154 (
> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4154
> >>> > > >> >> )
> >>> > > >> >> > - Savepoint disposal with user class loader: #2194
> >>> > > >> >> > (https://github.com/apache/flink/pull/2194)
> >>> > > >> >> > - Cassandra sink exception check: #2183
> >>> > > >> >> > (https://github.com/apache/flink/pull/2183)
> >>> > > >> >> > - Prevent Metrics log flooding: #2135
> >>> > > >> >> > (https://github.com/apache/flink/pull/2135)
> >>> > > >> >> > - CEP serialization: #2202 (
> >>> > > https://github.com/apache/flink/pull/2202
> >>> > > >> )
> >>> > > >> >> > - HA BLOB store life-cycle:
> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
> >>> > > >> >> >
> >>> > > >> >> > Nice to have:
> >>> > > >> >> > - Hash-based combine: #1517
> >>> > > https://github.com/apache/flink/pull/1517
> >>> > > >> >> >
> >>> > > >> >> > Feel free to add issues/PRs to the list and please report
> any
> >>> > > issues
> >>> > > >> >> > you encounter during testing in this thread.
> >>> > > >> >>
> >>> > > >> >>
> >>> > > >>
> >>> > >
> >>> >
> >>>
>

[Ufuk Celebi-2]

Very happy to hear this. I will create the RC and release branch later
today after both PRs have been merged. :-)

On Tue, Jul 26, 2016 at 4:21 PM, Aljoscha Krettek <[hidden email]> wrote:

> I'm running tests locally now because of the Travis problems. Will merge as
> soon as they pass for both the window slowness fix and the multiple metrics
> reporters change.
>
> On Tue, 26 Jul 2016 at 14:47 Maximilian Michels <[hidden email]> wrote:
>
>> Yes, I'm done with the investigation for
>> https://github.com/apache/flink/pull/2257. Merging before 6 pm CET.
>>
>> On Tue, Jul 26, 2016 at 10:52 AM, Ufuk Celebi <[hidden email]> wrote:
>> > The following PRs are still open. I will create the RC as soon as they
>> > are merged. In any case I will fork off the release-1.1 branch by the
>> > end of today (CET 6:00 PM), so that we are not blocking regular Flink
>> > development.
>> >
>> > - https://github.com/apache/flink/pull/2257: Allow re-registration of
>> > TMs at resource manager => All good except for a Travis test issue.
>> > @Max: You are looking into this, correct?
>> >
>> > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>> > separate module => Chesnay updated this, we need a review here.
>> > @Aljoscha: You were involved in this. Can you review this?
>> >
>> > - https://github.com/apache/flink/pull/2277: WindowOperator becomes
>> > very slow with allowed lateness => Needs another round of review.
>> > @Aljoscha: You did the initial review. Can you review the addressed
>> > comments again?
>> >
>> > - https://github.com/apache/flink/pull/2194 => merging this now
>> >
>> > - https://github.com/apache/flink/pull/2278 => merging this now
>> >
>> > - https://github.com/apache/flink/pull/2286 => merging this now
>> >
>> >
>> >
>> > On Thu, Jul 21, 2016 at 4:44 PM, Till Rohrmann <[hidden email]>
>> wrote:
>> >> https://github.com/apache/flink/pull/2257 should almost be mergable.
>> There
>> >> is only an issue with one test which only occurs on Travis. But I think
>> I
>> >> found the culprit. Currently, testing it on Travis again.
>> >>
>> >> On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <
>> [hidden email]>
>> >> wrote:
>> >>
>> >>> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
>> >>> This would be very useful to us..
>> >>>
>> >>> Best,
>> >>> Flavio
>> >>>
>> >>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]
>> >
>> >>> wrote:
>> >>>
>> >>> > Sounds good!
>> >>> >
>> >>> > This one I just merged: https://github.com/apache/flink/pull/2273
>> (Only
>> >>> > allow/require query
>> >>> > for Tuple Stream in CassandraSink)
>> >>> >
>> >>> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
>> >>> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just
>> opened a
>> >>> PR:
>> >>> > https://github.com/apache/flink/pull/2278
>> >>> >
>> >>> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>> >>> >
>> >>> > > Hey all,
>> >>> > >
>> >>> > > although there was no feedback for this preview RC, most of the
>> issues
>> >>> > > mentioned in the release are either resolved or open PRs. Once the
>> >>> > > following PRs have been merged, I would like to create RC1 and the
>> >>> > > release-1.1 branch. Feedback to this list is highly appreciated.
>> >>> > >
>> >>> > > Open PRs (awaiting review/review in progress):
>> >>> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
>> >>> > > checkpoint coordinator
>> >>> > > - https://github.com/apache/flink/pull/2257: Allow
>> re-registration of
>> >>> > > TMs at resource manager
>> >>> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>> >>> > separate
>> >>> > > module
>> >>> > >
>> >>> > > Open PRs (to be merged):
>> >>> > > - https://github.com/apache/flink/pull/2273: Only allow/require
>> query
>> >>> > > for Tuple Stream in CassandraSink
>> >>> > > - https://github.com/apache/flink/pull/2271: Add restarting time
>> JM
>> >>> > metric
>> >>> > > - https://github.com/apache/flink/pull/2256: Don't clean up
>> BlobStore
>> >>> > > on BlobServer shut down
>> >>> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
>> >>> > >
>> >>> > > Open issues w/o PRs:
>> >>> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>> >>> > > Allowed Lateness to Zero and Make Triggers Non-Purging
>> >>> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>> >>> > > becomes very slow with allowed lateness
>> >>> > >
>> >>> > > @Aljoscha, Kostas: do you have an idea when these will be
>> addressed?
>> >>> > >
>> >>> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
>> >>> [hidden email]>
>> >>> > > wrote:
>> >>> > > > Not yet, but Kostas is investigating.
>> >>> > > >
>> >>> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>> >>> > > >
>> >>> > > >> Most actually have a pending PR, except:
>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
>> >>> > > >>
>> >>> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
>> >>> > > >> weekend. The issue Stefan mentioned also has a pending PR by
>> now.
>> >>> > > >>
>> >>> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
>> >>> idea
>> >>> > > >> about fixing FLINK-4207?
>> >>> > > >>
>> >>> > > >> – Ufuk
>> >>> > > >>
>> >>> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
>> >>> [hidden email]>
>> >>> > > >> wrote:
>> >>> > > >> > There are still 7 blockers for the release:
>> >>> > > >> >
>> >>> > > >>
>> >>> > >
>> >>> >
>> >>>
>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>> >>> > > >> > most of them are assigned, some even have a pending pull
>> request.
>> >>> > > >> >
>> >>> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>> >>> > > >> [hidden email]
>> >>> > > >> >> wrote:
>> >>> > > >> >
>> >>> > > >> >> Hi Ufuk,
>> >>> > > >> >>
>> >>> > > >> >> Thanks for starting this thread. I think we should solve
>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
>> >>> > version,
>> >>> > > >> >> because it can easily become a blocker when running multiple
>> >>> Flink
>> >>> > > >> >> applications on a clusters with HA  (see related issue for
>> one
>> >>> > > example).
>> >>> > > >> >>
>> >>> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]
>> >:
>> >>> > > >> >> >
>> >>> > > >> >> > Dear community,
>> >>> > > >> >> >
>> >>> > > >> >> > ===============
>> >>> > > >> >> > FLINK 1.1.0 RC0
>> >>> > > >> >> > ===============
>> >>> > > >> >> >
>> >>> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0
>> release,
>> >>> > > >> >> > including everything in master up to cb7824
>> >>> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>> >>> > > >> >> >
>> >>> > > >> >> > There are still some blocking issues and important pull
>> >>> requests
>> >>> > > to be
>> >>> > > >> >> > merged (see below), but nevertheless I would like to start
>> >>> > testing
>> >>> > > >> >> > Flink for the release in order to get the process going.
>> >>> > > >> >> >
>> >>> > > >> >> > In past major releases, we needed to create many release
>> >>> > > candidates,
>> >>> > > >> >> > often for fixing just some small issues. I would like to
>> speed
>> >>> up
>> >>> > > the
>> >>> > > >> >> > release process by collecting the last remaining issues
>> with
>> >>> the
>> >>> > > RC0.
>> >>> > > >> >> > Once these issues are resolved, we can start voting on RC1.
>> >>> This
>> >>> > is
>> >>> > > >> >> > also when I will create the release-1.1 branch.
>> >>> > > >> >> >
>> >>> > > >> >> > We have a Wiki page
>> >>> > > >> >> >
>> https://cwiki.apache.org/confluence/display/FLINK/Releasing
>> >>> > > >> containing
>> >>> > > >> >> > some common release verification tasks.
>> >>> > > >> >> >
>> >>> > > >> >> > Also, production users are encouraged to participate in the
>> >>> > release
>> >>> > > >> >> > verification process.
>> >>> > > >> >> >
>> >>> > > >> >> > Here are the preview binaries located:
>> >>> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>> >>> > > >> >> >
>> >>> > > >> >> > This is the staging repository:
>> >>> > > >> >> >
>> >>> > > >>
>> >>> >
>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>> >>> > > >> >> >
>> >>> > > >> >> > To use the release candidate in an existing Maven project,
>> set
>> >>> > the
>> >>> > > >> >> > Flink version to 1.1.0 and the repository URL to
>> >>> > > >> >> >
>> >>> > > >>
>> >>> >
>> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>> >>> > > >> >> >
>> >>> > > >> >> > The POM should look like this:
>> >>> > > >> >> >
>> >>> > > >> >> > <properties>
>> >>> > > >> >> >
>> >>> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>> >>> > > >> >> >   <flink.version>1.1.0</flink.version>
>> >>> > > >> >> > </properties>
>> >>> > > >> >> >
>> >>> > > >> >> > <repositories>
>> >>> > > >> >> >   <repository>
>> >>> > > >> >> >      <id>flink.release-staging</id>
>> >>> > > >> >> >      <name>Apache Development Snapshot Repository</name>
>> >>> > > >> >> >      <url>
>> >>> > > >> >>
>> >>> > >
>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>> >>> > > >> >> </url>
>> >>> > > >> >> >      <releases><enabled>true</enabled></releases>
>> >>> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
>> >>> > > >> >> >   </repository>
>> >>> > > >> >> > </repositories>
>> >>> > > >> >> >
>> >>> > > >> >> > ===========
>> >>> > > >> >> > OPEN ISSUES
>> >>> > > >> >> > ===========
>> >>> > > >> >> >
>> >>> > > >> >> > The following are important to be fixed/merged before the
>> >>> > release:
>> >>> > > >> >> > - Savepoint headers: PR #2083 (
>> >>> > > >> https://github.com/apache/flink/pull/2083
>> >>> > > >> >> )
>> >>> > > >> >> >  * includes FLINK-4154 (
>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4154
>> >>> > > >> >> )
>> >>> > > >> >> > - Savepoint disposal with user class loader: #2194
>> >>> > > >> >> > (https://github.com/apache/flink/pull/2194)
>> >>> > > >> >> > - Cassandra sink exception check: #2183
>> >>> > > >> >> > (https://github.com/apache/flink/pull/2183)
>> >>> > > >> >> > - Prevent Metrics log flooding: #2135
>> >>> > > >> >> > (https://github.com/apache/flink/pull/2135)
>> >>> > > >> >> > - CEP serialization: #2202 (
>> >>> > > https://github.com/apache/flink/pull/2202
>> >>> > > >> )
>> >>> > > >> >> > - HA BLOB store life-cycle:
>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
>> >>> > > >> >> >
>> >>> > > >> >> > Nice to have:
>> >>> > > >> >> > - Hash-based combine: #1517
>> >>> > > https://github.com/apache/flink/pull/1517
>> >>> > > >> >> >
>> >>> > > >> >> > Feel free to add issues/PRs to the list and please report
>> any
>> >>> > > issues
>> >>> > > >> >> > you encounter during testing in this thread.
>> >>> > > >> >>
>> >>> > > >> >>
>> >>> > > >>
>> >>> > >
>> >>> >
>> >>>
>>

[Ufuk Celebi-2]

Everything has been merged and I've now created the release-1.1 branch
from commit 12bf7c1.

I will create the RC1 asap and start the vote soon. Thanks to everyone
who was involved in fixing and reporting issues! :-)

On Tue, Jul 26, 2016 at 4:32 PM, Ufuk Celebi <[hidden email]> wrote:

> Very happy to hear this. I will create the RC and release branch later
> today after both PRs have been merged. :-)
>
> On Tue, Jul 26, 2016 at 4:21 PM, Aljoscha Krettek <[hidden email]> wrote:
>> I'm running tests locally now because of the Travis problems. Will merge as
>> soon as they pass for both the window slowness fix and the multiple metrics
>> reporters change.
>>
>> On Tue, 26 Jul 2016 at 14:47 Maximilian Michels <[hidden email]> wrote:
>>
>>> Yes, I'm done with the investigation for
>>> https://github.com/apache/flink/pull/2257. Merging before 6 pm CET.
>>>
>>> On Tue, Jul 26, 2016 at 10:52 AM, Ufuk Celebi <[hidden email]> wrote:
>>> > The following PRs are still open. I will create the RC as soon as they
>>> > are merged. In any case I will fork off the release-1.1 branch by the
>>> > end of today (CET 6:00 PM), so that we are not blocking regular Flink
>>> > development.
>>> >
>>> > - https://github.com/apache/flink/pull/2257: Allow re-registration of
>>> > TMs at resource manager => All good except for a Travis test issue.
>>> > @Max: You are looking into this, correct?
>>> >
>>> > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>>> > separate module => Chesnay updated this, we need a review here.
>>> > @Aljoscha: You were involved in this. Can you review this?
>>> >
>>> > - https://github.com/apache/flink/pull/2277: WindowOperator becomes
>>> > very slow with allowed lateness => Needs another round of review.
>>> > @Aljoscha: You did the initial review. Can you review the addressed
>>> > comments again?
>>> >
>>> > - https://github.com/apache/flink/pull/2194 => merging this now
>>> >
>>> > - https://github.com/apache/flink/pull/2278 => merging this now
>>> >
>>> > - https://github.com/apache/flink/pull/2286 => merging this now
>>> >
>>> >
>>> >
>>> > On Thu, Jul 21, 2016 at 4:44 PM, Till Rohrmann <[hidden email]>
>>> wrote:
>>> >> https://github.com/apache/flink/pull/2257 should almost be mergable.
>>> There
>>> >> is only an issue with one test which only occurs on Travis. But I think
>>> I
>>> >> found the culprit. Currently, testing it on Travis again.
>>> >>
>>> >> On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier <
>>> [hidden email]>
>>> >> wrote:
>>> >>
>>> >>> Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ?
>>> >>> This would be very useful to us..
>>> >>>
>>> >>> Best,
>>> >>> Flavio
>>> >>>
>>> >>> On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek <[hidden email]
>>> >
>>> >>> wrote:
>>> >>>
>>> >>> > Sounds good!
>>> >>> >
>>> >>> > This one I just merged: https://github.com/apache/flink/pull/2273
>>> (Only
>>> >>> > allow/require query
>>> >>> > for Tuple Stream in CassandraSink)
>>> >>> >
>>> >>> > For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default
>>> >>> > Allowed Lateness to Zero and Make Triggers Non-Purging) I just
>>> opened a
>>> >>> PR:
>>> >>> > https://github.com/apache/flink/pull/2278
>>> >>> >
>>> >>> > On Thu, 21 Jul 2016 at 15:16 Ufuk Celebi <[hidden email]> wrote:
>>> >>> >
>>> >>> > > Hey all,
>>> >>> > >
>>> >>> > > although there was no feedback for this preview RC, most of the
>>> issues
>>> >>> > > mentioned in the release are either resolved or open PRs. Once the
>>> >>> > > following PRs have been merged, I would like to create RC1 and the
>>> >>> > > release-1.1 branch. Feedback to this list is highly appreciated.
>>> >>> > >
>>> >>> > > Open PRs (awaiting review/review in progress):
>>> >>> > > - https://github.com/apache/flink/pull/2276: Forward suspend to
>>> >>> > > checkpoint coordinator
>>> >>> > > - https://github.com/apache/flink/pull/2257: Allow
>>> re-registration of
>>> >>> > > TMs at resource manager
>>> >>> > > - https://github.com/apache/flink/pull/2226: Move Metrics API to
>>> >>> > separate
>>> >>> > > module
>>> >>> > >
>>> >>> > > Open PRs (to be merged):
>>> >>> > > - https://github.com/apache/flink/pull/2273: Only allow/require
>>> query
>>> >>> > > for Tuple Stream in CassandraSink
>>> >>> > > - https://github.com/apache/flink/pull/2271: Add restarting time
>>> JM
>>> >>> > metric
>>> >>> > > - https://github.com/apache/flink/pull/2256: Don't clean up
>>> BlobStore
>>> >>> > > on BlobServer shut down
>>> >>> > > - https://github.com/apache/flink/pull/2194: Add savepoint headers
>>> >>> > >
>>> >>> > > Open issues w/o PRs:
>>> >>> > > - https://issues.apache.org/jira/browse/FLINK-4239: Set Default
>>> >>> > > Allowed Lateness to Zero and Make Triggers Non-Purging
>>> >>> > > - https://issues.apache.org/jira/browse/FLINK-4207: WindowOperator
>>> >>> > > becomes very slow with allowed lateness
>>> >>> > >
>>> >>> > > @Aljoscha, Kostas: do you have an idea when these will be
>>> addressed?
>>> >>> > >
>>> >>> > > On Mon, Jul 18, 2016 at 11:05 AM, Aljoscha Krettek <
>>> >>> [hidden email]>
>>> >>> > > wrote:
>>> >>> > > > Not yet, but Kostas is investigating.
>>> >>> > > >
>>> >>> > > > On Fri, 15 Jul 2016 at 18:21 Ufuk Celebi <[hidden email]> wrote:
>>> >>> > > >
>>> >>> > > >> Most actually have a pending PR, except:
>>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4207,
>>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4201.
>>> >>> > > >>
>>> >>> > > >> I will assign FLINK-4201 to myself and hope to fix it over the
>>> >>> > > >> weekend. The issue Stefan mentioned also has a pending PR by
>>> now.
>>> >>> > > >>
>>> >>> > > >> Hope to create the first RC next week... @Aljoscha, Stephan: any
>>> >>> idea
>>> >>> > > >> about fixing FLINK-4207?
>>> >>> > > >>
>>> >>> > > >> – Ufuk
>>> >>> > > >>
>>> >>> > > >> On Fri, Jul 15, 2016 at 4:21 PM, Robert Metzger <
>>> >>> [hidden email]>
>>> >>> > > >> wrote:
>>> >>> > > >> > There are still 7 blockers for the release:
>>> >>> > > >> >
>>> >>> > > >>
>>> >>> > >
>>> >>> >
>>> >>>
>>> https://issues.apache.org/jira/browse/FLINK-4207?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20priority%20%3D%20Blocker%20ORDER%20BY%20key%20DESC
>>> >>> > > >> > most of them are assigned, some even have a pending pull
>>> request.
>>> >>> > > >> >
>>> >>> > > >> > On Thu, Jul 7, 2016 at 11:26 AM, Stefan Richter <
>>> >>> > > >> [hidden email]
>>> >>> > > >> >> wrote:
>>> >>> > > >> >
>>> >>> > > >> >> Hi Ufuk,
>>> >>> > > >> >>
>>> >>> > > >> >> Thanks for starting this thread. I think we should solve
>>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166 <
>>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4166> for this
>>> >>> > version,
>>> >>> > > >> >> because it can easily become a blocker when running multiple
>>> >>> Flink
>>> >>> > > >> >> applications on a clusters with HA  (see related issue for
>>> one
>>> >>> > > example).
>>> >>> > > >> >>
>>> >>> > > >> >> > Am 07.07.2016 um 11:02 schrieb Ufuk Celebi <[hidden email]
>>> >:
>>> >>> > > >> >> >
>>> >>> > > >> >> > Dear community,
>>> >>> > > >> >> >
>>> >>> > > >> >> > ===============
>>> >>> > > >> >> > FLINK 1.1.0 RC0
>>> >>> > > >> >> > ===============
>>> >>> > > >> >> >
>>> >>> > > >> >> > I've now created a "preview RC" for the upcoming 1.1.0
>>> release,
>>> >>> > > >> >> > including everything in master up to cb7824
>>> >>> > > >> >> > (https://github.com/uce/flink/tree/release-1.1.0-rc0).
>>> >>> > > >> >> >
>>> >>> > > >> >> > There are still some blocking issues and important pull
>>> >>> requests
>>> >>> > > to be
>>> >>> > > >> >> > merged (see below), but nevertheless I would like to start
>>> >>> > testing
>>> >>> > > >> >> > Flink for the release in order to get the process going.
>>> >>> > > >> >> >
>>> >>> > > >> >> > In past major releases, we needed to create many release
>>> >>> > > candidates,
>>> >>> > > >> >> > often for fixing just some small issues. I would like to
>>> speed
>>> >>> up
>>> >>> > > the
>>> >>> > > >> >> > release process by collecting the last remaining issues
>>> with
>>> >>> the
>>> >>> > > RC0.
>>> >>> > > >> >> > Once these issues are resolved, we can start voting on RC1.
>>> >>> This
>>> >>> > is
>>> >>> > > >> >> > also when I will create the release-1.1 branch.
>>> >>> > > >> >> >
>>> >>> > > >> >> > We have a Wiki page
>>> >>> > > >> >> >
>>> https://cwiki.apache.org/confluence/display/FLINK/Releasing
>>> >>> > > >> containing
>>> >>> > > >> >> > some common release verification tasks.
>>> >>> > > >> >> >
>>> >>> > > >> >> > Also, production users are encouraged to participate in the
>>> >>> > release
>>> >>> > > >> >> > verification process.
>>> >>> > > >> >> >
>>> >>> > > >> >> > Here are the preview binaries located:
>>> >>> > > >> >> > http://home.apache.org/~uce/flink-1.1.0-rc0/
>>> >>> > > >> >> >
>>> >>> > > >> >> > This is the staging repository:
>>> >>> > > >> >> >
>>> >>> > > >>
>>> >>> >
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>> >>> > > >> >> >
>>> >>> > > >> >> > To use the release candidate in an existing Maven project,
>>> set
>>> >>> > the
>>> >>> > > >> >> > Flink version to 1.1.0 and the repository URL to
>>> >>> > > >> >> >
>>> >>> > > >>
>>> >>> >
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097.
>>> >>> > > >> >> >
>>> >>> > > >> >> > The POM should look like this:
>>> >>> > > >> >> >
>>> >>> > > >> >> > <properties>
>>> >>> > > >> >> >
>>> >>> > >  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>>> >>> > > >> >> >   <flink.version>1.1.0</flink.version>
>>> >>> > > >> >> > </properties>
>>> >>> > > >> >> >
>>> >>> > > >> >> > <repositories>
>>> >>> > > >> >> >   <repository>
>>> >>> > > >> >> >      <id>flink.release-staging</id>
>>> >>> > > >> >> >      <name>Apache Development Snapshot Repository</name>
>>> >>> > > >> >> >      <url>
>>> >>> > > >> >>
>>> >>> > >
>>> https://repository.apache.org/content/repositories/orgapacheflink-1097
>>> >>> > > >> >> </url>
>>> >>> > > >> >> >      <releases><enabled>true</enabled></releases>
>>> >>> > > >> >> >      <snapshots><enabled>false</enabled></snapshots>
>>> >>> > > >> >> >   </repository>
>>> >>> > > >> >> > </repositories>
>>> >>> > > >> >> >
>>> >>> > > >> >> > ===========
>>> >>> > > >> >> > OPEN ISSUES
>>> >>> > > >> >> > ===========
>>> >>> > > >> >> >
>>> >>> > > >> >> > The following are important to be fixed/merged before the
>>> >>> > release:
>>> >>> > > >> >> > - Savepoint headers: PR #2083 (
>>> >>> > > >> https://github.com/apache/flink/pull/2083
>>> >>> > > >> >> )
>>> >>> > > >> >> >  * includes FLINK-4154 (
>>> >>> > > >> https://issues.apache.org/jira/browse/FLINK-4154
>>> >>> > > >> >> )
>>> >>> > > >> >> > - Savepoint disposal with user class loader: #2194
>>> >>> > > >> >> > (https://github.com/apache/flink/pull/2194)
>>> >>> > > >> >> > - Cassandra sink exception check: #2183
>>> >>> > > >> >> > (https://github.com/apache/flink/pull/2183)
>>> >>> > > >> >> > - Prevent Metrics log flooding: #2135
>>> >>> > > >> >> > (https://github.com/apache/flink/pull/2135)
>>> >>> > > >> >> > - CEP serialization: #2202 (
>>> >>> > > https://github.com/apache/flink/pull/2202
>>> >>> > > >> )
>>> >>> > > >> >> > - HA BLOB store life-cycle:
>>> >>> > > >> >> https://issues.apache.org/jira/browse/FLINK-4150
>>> >>> > > >> >> >
>>> >>> > > >> >> > Nice to have:
>>> >>> > > >> >> > - Hash-based combine: #1517
>>> >>> > > https://github.com/apache/flink/pull/1517
>>> >>> > > >> >> >
>>> >>> > > >> >> > Feel free to add issues/PRs to the list and please report
>>> any
>>> >>> > > issues
>>> >>> > > >> >> > you encounter during testing in this thread.
>>> >>> > > >> >>
>>> >>> > > >> >>
>>> >>> > > >>
>>> >>> > >
>>> >>> >
>>> >>>
>>>