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

2016-04-20 Thread Ufuk Celebi
Yeah, sorry, I meant release, not RC. On Wed, Apr 20, 2016 at 10:26 PM, Fabian Hueske wrote: > Ah, OK. Thanks Gyula for clarifying. > > Just had a look at the PR. The fix seems to be quite straightforward. > If you can validate the fix tomorrow and we include it, we could release > 1.0.2 early ne

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

2016-04-20 Thread Fabian Hueske
Ah, OK. Thanks Gyula for clarifying. Just had a look at the PR. The fix seems to be quite straightforward. If you can validate the fix tomorrow and we include it, we could release 1.0.2 early next week. 2016-04-20 22:11 GMT+02:00 Gyula Fóra : > Fabian, I think Ufuk meant about 2 weeks for the ne

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

2016-04-20 Thread Gyula Fóra
Fabian, I think Ufuk meant about 2 weeks for the next bugfix release not RC. I have actually prepared a PR that should fix this problem: https://github.com/apache/flink/pull/1919 regardless of how we decide. I can only test this tomorrow though in the production environment. I can work around thi

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

2016-04-20 Thread Fabian Hueske
Would it take two weeks to fix FLINK-3790 or is there another reason why the next RC would be available in 2 weeks? We released Flink 1.0.1 14 days ago. So we might ship another release in 2 weeks no? 2016-04-20 21:51 GMT+02:00 Konstantin Knauf : > Hi Ufuk, > > for our production use-case FLINK-

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

2016-04-20 Thread Konstantin Knauf
Hi Ufuk, for our production use-case FLINK-3688 is very important, so we would appreciate a quick 1.0.2 release. If you guys can take this into consideration, this would be great. Cheers, Konstantin On 20.04.2016 20:54, Ufuk Celebi wrote: > No problem, Trevor! Thanks for reporting this anyways

[jira] [Created] (FLINK-3798) Clean up RocksDB state backend access modifiers

2016-04-20 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3798: - Summary: Clean up RocksDB state backend access modifiers Key: FLINK-3798 URL: https://issues.apache.org/jira/browse/FLINK-3798 Project: Flink Issue Type: Improveme

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

2016-04-20 Thread Ufuk Celebi
No problem, Trevor! Thanks for reporting this anyways. And thanks to Chiwan and Aljoscha for looking into it as well. I had an offline chat with Gyula about the rolling file sink problem (FLINK-3790) and it looks like this a big issue for their use case against the production HDFS cluster (HA, def

[jira] [Created] (FLINK-3797) Restart flow button

2016-04-20 Thread Maxim Dobryakov (JIRA)
Maxim Dobryakov created FLINK-3797: -- Summary: Restart flow button Key: FLINK-3797 URL: https://issues.apache.org/jira/browse/FLINK-3797 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods

2016-04-20 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3796: - Summary: FileSourceFunction doesn't respect InputFormat's life cycle methods Key: FLINK-3796 URL: https://issues.apache.org/jira/browse/FLINK-3796 Project:

[jira] [Created] (FLINK-3795) Cancel button is hidden on MacBook Pro 13''

2016-04-20 Thread Maxim Dobryakov (JIRA)
Maxim Dobryakov created FLINK-3795: -- Summary: Cancel button is hidden on MacBook Pro 13'' Key: FLINK-3795 URL: https://issues.apache.org/jira/browse/FLINK-3795 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-3794) Add checks for unsupported operations in streaming table API

2016-04-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3794: Summary: Add checks for unsupported operations in streaming table API Key: FLINK-3794 URL: https://issues.apache.org/jira/browse/FLINK-3794 Project: Flink I

[jira] [Created] (FLINK-3793) Re-organize the Table API and SQL docs

2016-04-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3793: Summary: Re-organize the Table API and SQL docs Key: FLINK-3793 URL: https://issues.apache.org/jira/browse/FLINK-3793 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3792) RowTypeInfo equality should not depend on field names

2016-04-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3792: Summary: RowTypeInfo equality should not depend on field names Key: FLINK-3792 URL: https://issues.apache.org/jira/browse/FLINK-3792 Project: Flink Issue Typ

[jira] [Created] (FLINK-3791) Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster

2016-04-20 Thread Maxim Dobryakov (JIRA)
Maxim Dobryakov created FLINK-3791: -- Summary: Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster Key: FLINK-3791 URL: https://issues.apache.org/jira/browse/FLINK

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-04-20 Thread Gábor Horváth
On the second thought I think you are right. I had the impression that there is cyclic dependency between TypeInformation and the serializers but that is not the case. So there is no rewrite needed for TypeInformation in order to be able to use Scala for serializers. According to the proposal unle

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-04-20 Thread Fabian Hueske
Why would you need to rewrite the TypeInformation in Scala? I think we need a way to replace Serializer implementations anyway unless the generated serializers are compatible to the current ones. 2016-04-20 15:53 GMT+02:00 Gábor Horváth : > Hi Fabian, > > I agree that it would be awesome to move

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

2016-04-20 Thread Trevor Grant
I also confirmed. My bad. Trevor Grant Data Scientist https://github.com/rawkintrevo http://stackexchange.com/users/3002022/rawkintrevo http://trevorgrant.org *"Fortunate is he, who is able to know the causes of things." -Virgil* On Wed, Apr 20, 2016 at 8:30 AM, Aljoscha Krettek wrote: > Ch

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-04-20 Thread Gábor Horváth
Hi Fabian, I agree that it would be awesome to move this to its own module/plugin. However in order to be able to write the code generation in Scala I would need to rewrite the type information to use Scala as well. I think I will not have time to do this during the summer, so I think I will stick

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

2016-04-20 Thread Gyula Fóra
I found a potentially blocker issue: https://issues.apache.org/jira/browse/FLINK-3790 What do you think? Gyula Aljoscha Krettek ezt írta (időpont: 2016. ápr. 20., Sze, 15:30): > Chiwan is right. I just downloaded the release binary again and verified > that the problem mentioned in the issue

[jira] [Created] (FLINK-3790) Rolling File sink does not pick up hadoop configuration

2016-04-20 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3790: - Summary: Rolling File sink does not pick up hadoop configuration Key: FLINK-3790 URL: https://issues.apache.org/jira/browse/FLINK-3790 Project: Flink Issue Type: B

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

2016-04-20 Thread Aljoscha Krettek
Chiwan is right. I just downloaded the release binary again and verified that the problem mentioned in the issue does not occur: https://issues.apache.org/jira/browse/FLINK-3701 On Wed, 20 Apr 2016 at 14:51 Chiwan Park wrote: > AFAIK, FLINK-3701 is about Flink 1.1-SNAPSHOT, not Flink 1.0. We ca

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

2016-04-20 Thread Chiwan Park
AFAIK, FLINK-3701 is about Flink 1.1-SNAPSHOT, not Flink 1.0. We can go forward. Regards, Chiwan Park > On Apr 20, 2016, at 9:33 PM, Trevor Grant wrote: > > -1 > > Not a PMC so my down vote doesn't mean anything but... > > https://github.com/apache/flink/pull/1913 > > https://issues.apache.o

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

2016-04-20 Thread Trevor Grant
-1 Not a PMC so my down vote doesn't mean anything but... https://github.com/apache/flink/pull/1913 https://issues.apache.org/jira/browse/FLINK-3701 A busted scala shell is a blocker imho. Trevor Grant Data Scientist https://github.com/rawkintrevo http://stackexchange.com/users/3002022/rawkin

Re: Savepoint for time windows

2016-04-20 Thread Aljoscha Krettek
Hi, setting the uid on the result of the .apply() call is sufficient for the whole window operation, including the windowing and trigger. Could you maybe post some example code of the topology before and after the change and restore from savepoint? Cheers, Aljoscha On Tue, 19 Apr 2016 at 07:33 O

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

2016-04-20 Thread Aljoscha Krettek
+1 I eyeballed the changes and nothing looks suspicious. On Wed, 20 Apr 2016 at 13:21 Fabian Hueske wrote: > Thanks Ufuk for preparing the RC. > > - Checked the diff against release 1.0.1. No dependencies were added or > modified. > - Checked signatures and hashes of all release artifacts. > >

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

2016-04-20 Thread Fabian Hueske
Thanks Ufuk for preparing the RC. - Checked the diff against release 1.0.1. No dependencies were added or modified. - Checked signatures and hashes of all release artifacts. +1 to release this RC. Thanks, Fabian 2016-04-19 21:34 GMT+02:00 Robert Metzger : > Thank you for creating another bugfi