[jira] [Created] (FLINK-7278) Flink job can stuck while ZK leader reelected during ZK cluster migration

Zhenzhong Xu created FLINK-7278: --- Summary: Flink job can stuck while ZK leader reelected during ZK cluster migration Key: FLINK-7278 URL: https://issues.apache.org/jira/browse/FLINK-7278 Project:

Re: [VOTE] Release Apache Flink-shaded 1.0 (RC2)

+1 - I checked the signatures and sha/md5 sums. - I verified that the published jars only contain the shaded code that they should contain > On 24. Jul 2017, at 17:43, Chesnay Schepler wrote: > > Dear Flink community, > > Please vote on releasing the following candidate

Re: [DISCUSS] Table API / SQL internal timestamp handling

Thanks everybody for the replies so far. Let me answer your questions and reply to your thoughts: Radu: --- First of all, although my proposal is movivated by a join operator, this discussion is about timestamp handling, not about joins in general. - The semantics of outer joins is to emit null

Re: [VOTE] Release Apache Flink-shaded 1.0 (RC2)

+1 - LICENSE and NOTICE are correct - Shaded artifacts contain license when necessary (ASM with BSD license) - Shaded artifact contents is correct - No binaries in the release On Wed, Jul 26, 2017 at 2:08 PM, Aljoscha Krettek wrote: > +1 > > - I checked the

Re: [DISCUSS] Release testing procedures, Flink 1.3.2

Sweet (maybe?)! How did you reproduce data-loss? Best, Aljoscha > On 26. Jul 2017, at 11:13, Piotr Nowojski wrote: > > It took me longer then I expected but I was able reproduce data loss with > older Flink versions while running fling in 3 nodes cluster. I have also

[jira] [Created] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

Aljoscha Krettek created FLINK-7268: --- Summary: Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles Key: FLINK-7268 URL:

Re: [VOTE] Release Apache Flink-shaded 1.0 (RC2)

+1 - dependency versions match those used in Flink - can be built with maven - jars only contain shaded dependencies - the major version number is included in the package declaration - non-Apache2 licenses are bundled in assembled jars - dependencies are not propagated On 26.07.2017 15:37,

RE: is flink' states functionality futile?

Hi, what is the reference you wanted to link in [1]? From: Tzu-Li (Gordon) Tai [via Apache Flink Mailing List archive.] [mailto:ml+s1008284n18936...@n3.nabble.com] Sent: 26 July 2017 05:44 To: Meri Ziv Subject: Re: is flink' states functionality futile?

Re: Use Flink's actor system

Thank you Chesnay and Till. Best, Lorenzo -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Use-Flink-s-actor-system-tp18709p18942.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

[jira] [Created] (FLINK-7270) Add support for dynamic properties to cluster entry point

Till Rohrmann created FLINK-7270: Summary: Add support for dynamic properties to cluster entry point Key: FLINK-7270 URL: https://issues.apache.org/jira/browse/FLINK-7270 Project: Flink

[jira] [Created] (FLINK-7267) Add support for lists of hosts to connect

Hu Hailin created FLINK-7267: Summary: Add support for lists of hosts to connect Key: FLINK-7267 URL: https://issues.apache.org/jira/browse/FLINK-7267 Project: Flink Issue Type: Improvement

RE: [DISCUSS] Table API / SQL internal timestamp handling

Hi everyone, I just want to add that I was referring to NULL values not specifically to timefields but to the event itself. If you have the follow situation Stream 1: |event1 | Stream 2: | | And you have a LEFT JOIN between stream 1 and stream 2

Re: [DISCUSS] Release testing procedures, Flink 1.3.2

It took me longer then I expected but I was able reproduce data loss with older Flink versions while running fling in 3 nodes cluster. I have also validated that at-least-once semantic is fixed for Kafka 0.10 in Flink 1.3-SNAPSHOT. Piotrek > On Jul 20, 2017, at 4:52 PM, Stephan Ewen

Re: [DISCUSS] Table API / SQL internal timestamp handling

Hi Xingcan, IMO, I don't think event-time of join results could be automatically decided by system. Considering batch tables, if users want a event time window aggregation after join, user must specify the time field explicitly (T1.rowtime or T2.rowtime or the computed result of them). So in the

[jira] [Created] (FLINK-7269) Refactor passing of dynamic properties

Till Rohrmann created FLINK-7269: Summary: Refactor passing of dynamic properties Key: FLINK-7269 URL: https://issues.apache.org/jira/browse/FLINK-7269 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

Timo Walther created FLINK-7271: --- Summary: ExpressionReducer does not optimize string-to-time conversion Key: FLINK-7271 URL: https://issues.apache.org/jira/browse/FLINK-7271 Project: Flink

[jira] [Created] (FLINK-7272) Support SQL IN with more 20 elements in streaming

Timo Walther created FLINK-7272: --- Summary: Support SQL IN with more 20 elements in streaming Key: FLINK-7272 URL: https://issues.apache.org/jira/browse/FLINK-7272 Project: Flink Issue Type:

[jira] [Created] (FLINK-7273) Gelly tests with empty graphs

Greg Hogan created FLINK-7273: - Summary: Gelly tests with empty graphs Key: FLINK-7273 URL: https://issues.apache.org/jira/browse/FLINK-7273 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

Egor Litvinenko created FLINK-7274: -- Summary: ParserError NUMERIC_VALUE_FORMAT_ERROR Key: FLINK-7274 URL: https://issues.apache.org/jira/browse/FLINK-7274 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7277) Weighted PageRank

Greg Hogan created FLINK-7277: - Summary: Weighted PageRank Key: FLINK-7277 URL: https://issues.apache.org/jira/browse/FLINK-7277 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-7275) Differentiate between normal and power-user cli options in Gelly examples

Greg Hogan created FLINK-7275: - Summary: Differentiate between normal and power-user cli options in Gelly examples Key: FLINK-7275 URL: https://issues.apache.org/jira/browse/FLINK-7275 Project: Flink

[jira] [Created] (FLINK-7276) Gelly algorithm parameters

Greg Hogan created FLINK-7276: - Summary: Gelly algorithm parameters Key: FLINK-7276 URL: https://issues.apache.org/jira/browse/FLINK-7276 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Table API / SQL internal timestamp handling

Hi Everyone, I like this proposal. The problem we used to have is that we have treated eventtime column as a special timestamp column. An eventtime column is nothing special than all other regular columns, but with a certain flag (eventtime-indicator) inferring that this column can be used as an