Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

Hi, We have discovered https://issues.apache.org/jira/browse/FLINK-6780 which effectively makes external catalogs in the table API very difficult to use. It may not be a show stopper but in my opinion it is worth a fix before the release. Regards, Haohui On Tue, May 30, 2017 at 11:22 AM Till

[jira] [Created] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

Haohui Mai created FLINK-6780: - Summary: ExternalTableSource fails to add the processing time and the event time attribute in the row type Key: FLINK-6780 URL: https://issues.apache.org/jira/browse/FLINK-6780

[jira] [Created] (FLINK-6779) Activate strict checkstyle in flink-scala

Greg Hogan created FLINK-6779: - Summary: Activate strict checkstyle in flink-scala Key: FLINK-6779 URL: https://issues.apache.org/jira/browse/FLINK-6779 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6778) Activate strict checkstyle for flink-dist

Greg Hogan created FLINK-6778: - Summary: Activate strict checkstyle for flink-dist Key: FLINK-6778 URL: https://issues.apache.org/jira/browse/FLINK-6778 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6777) Activate strict checkstyle for flink-scala-shell

Greg Hogan created FLINK-6777: - Summary: Activate strict checkstyle for flink-scala-shell Key: FLINK-6777 URL: https://issues.apache.org/jira/browse/FLINK-6777 Project: Flink Issue Type:

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

Just some thoughts concerning the cons for cancelling RC3: - Technically, the release is already delayed since the official release date was the 26th of May - Not sure whether it's a good argument to defer fixing major bugs because they have not been introduced with 1.3.0. It's actually alarming

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

The vote time is over, but I'll keep it open for a bit longer until we've decided regarding Till's issue. On Tue, May 30, 2017 at 6:10 PM, Robert Metzger wrote: > Hi Till, > good catch! That is definitively a severe issue. Probably it didn't > surface yet, because > a) the

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

Hi Till, good catch! That is definitively a severe issue. Probably it didn't surface yet, because a) the code example in the documentation is using a new instance for each state descriptor b) people are using stateless serializers? c) don't have the same state descriptor on the same machine I see

[jira] [Created] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

Stefan Richter created FLINK-6776: - Summary: Use skip instead of seek for small forward repositioning in DFS streams Key: FLINK-6776 URL: https://issues.apache.org/jira/browse/FLINK-6776 Project:

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

I might have found a blocking issue [1]. The problem is that a StateDescriptor cannot be shared by multiple subtasks because they don't duplicate their serializer. As a consequence, things break if you have a stateful serializer. The problem exists since 1.0. However, given that this issue is

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

+1 (binding) - verified source and binary signatures - verified source and binary checksums - verified LICENSEs - verified NOTICEs - built from source Greg > On May 26, 2017, at 12:58 PM, Robert Metzger wrote: > > Hi all, > > this is the second VOTEing release candidate

[jira] [Created] (FLINK-6774) build-helper-maven-plugin version not set

Nico Kruber created FLINK-6774: -- Summary: build-helper-maven-plugin version not set Key: FLINK-6774 URL: https://issues.apache.org/jira/browse/FLINK-6774 Project: Flink Issue Type: Improvement

flink-table sql overlaps time.scala

Hi all, I am playing around with the table API, and I have a doubt about temporal operator overlaps. In particular, a test in the scalarFunctionsTest.testOverlaps checks for false the following intervals: testAllApis( temporalOverlaps("2011-03-10 05:02:02".toTimestamp, 0.second,

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

+1 Tests I did: New features: - Tested rescaling Kinesis Consumer + transparent shard discovery - Tested topology changes on restore: changed chain orderings, added stateful / stateless operators, remove stateful / stateless operators - Tested new Flink CEP features: loop states, quantifiers,

[jira] [Created] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

Stefan Richter created FLINK-6773: - Summary: Use compression (e.g. snappy) for full check/savepoints Key: FLINK-6773 URL: https://issues.apache.org/jira/browse/FLINK-6773 Project: Flink

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

+1 I did: - manually check the release using the new end-to-end tests: https://github.com/apache/flink/pull/3911 . - verify that the source builds - Check the (transitive) dependencies of flink-dist compared to 1.2.x. The new deps are:

[jira] [Created] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

Tzu-Li (Gordon) Tai created FLINK-6772: -- Summary: Incorrect ordering of matched state events in Flink CEP Key: FLINK-6772 URL: https://issues.apache.org/jira/browse/FLINK-6772 Project: Flink

[ANNOUNCE] Flink Forward Berlin (11-13 Sep 2017) Call for Submissions is open now

Dear Flink Community, The Call for Submissions for Flink Forward Berlin 2017 is open now! Since we believe in collaboration, participation and exchange of ideas, we are inviting the Flink community to submit a session. Share your knowledge, applications, use cases and best practices and shape

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

Thank you all for the +1 votes so far. As far as I see it, none of the issues mentioned in the thread are blockers. I've started putting together the blog post for the release announcement. It is ready to review here: https://github.com/apache/flink-web/pull/62 On Mon, May 29, 2017 at 5:16 PM,

[jira] [Created] (FLINK-6771) Create committer guide

Till Rohrmann created FLINK-6771: Summary: Create committer guide Key: FLINK-6771 URL: https://issues.apache.org/jira/browse/FLINK-6771 Project: Flink Issue Type: Wish Components:

[jira] [Created] (FLINK-6770) Add excludeSerializersInCheckpoints to ExeuctionConfig

Tzu-Li (Gordon) Tai created FLINK-6770: -- Summary: Add excludeSerializersInCheckpoints to ExeuctionConfig Key: FLINK-6770 URL: https://issues.apache.org/jira/browse/FLINK-6770 Project: Flink

[jira] [Created] (FLINK-6769) Replace usage of deprecated FileSystem#create(Path, boolean)

Chesnay Schepler created FLINK-6769: --- Summary: Replace usage of deprecated FileSystem#create(Path, boolean) Key: FLINK-6769 URL: https://issues.apache.org/jira/browse/FLINK-6769 Project: Flink

[jira] [Created] (FLINK-6768) Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibility

Till Rohrmann created FLINK-6768: Summary: Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibility Key: FLINK-6768 URL: https://issues.apache.org/jira/browse/FLINK-6768 Project: