RE: STREAM SQL inner queries

Hi Fabian, Thanks for this perspective. I agree with you. I will wait a couple of more days to see if others will provide additional feedback. After this I will start working to define the jira issue that we can refine. Also as you mentioned, I believe there will be several iterations and refin

[jira] [Created] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

Zhijiang Wang created FLINK-5703: Summary: ExecutionGraph recovery based on reconciliation with TaskManager reports Key: FLINK-5703 URL: https://issues.apache.org/jira/browse/FLINK-5703 Project: Flink

[jira] [Created] (FLINK-5702) Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised

Tzu-Li (Gordon) Tai created FLINK-5702: -- Summary: Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised Key: FLINK-5702 URL: https://issues.apache.org/jira/browse/FLINK-570

[jira] [Created] (FLINK-5701) FlinkKafkaPrdocuer violates at-least-once by not handling failed records

Tzu-Li (Gordon) Tai created FLINK-5701: -- Summary: FlinkKafkaPrdocuer violates at-least-once by not handling failed records Key: FLINK-5701 URL: https://issues.apache.org/jira/browse/FLINK-5701 Pr

Re: STREAM SQL inner queries

Hi Radu, I think mostly processing time queries will fall into the category of queries that will never require to update a previously emitted result. Event-time queries have to prepare for late arriving data (which is not possible with processing time) and use cases that require event-time usually

Re: [RESULT][VOTE] Release Apache Flink 1.2.0 (RC3)

Thanks for all your effort Robert and the rest of the team! :-) On Thu, Feb 2, 2017 at 11:43 AM, Robert Metzger wrote: > I hereby officially close the voting of the 1.2.0 release with 8 +1 votes > (5 binding) and no -1 votes. > > +1 votes: > - Ufuk > - Stephan > - Gordon (non-binding) > - Sree (n

Re: Flink with Yarn on MapR

I was able to resolve this issue by referring to this issue In short, I had to modify flink's pom.xml to change the zookeeper version to the zookeeper mapr version and this error the disappears. But, I do have ran into a separate issue, which

[jira] [Created] (FLINK-5700) Document akka.client.timeout

Till Rohrmann created FLINK-5700: Summary: Document akka.client.timeout Key: FLINK-5700 URL: https://issues.apache.org/jira/browse/FLINK-5700 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

Till Rohrmann created FLINK-5699: Summary: Cancel with savepoint fails with a NPE if savepoint target directory not set Key: FLINK-5699 URL: https://issues.apache.org/jira/browse/FLINK-5699 Project: F

Re: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Sounds good to me Stefano! Best, Fabian 2017-02-01 13:43 GMT+01:00 Stefano Bortoli : > Hi all, > > I was thinking to open a JIRA for the procTime() function so that it could > be merged before and others could use it as well. What do you think? > > Regards, > Stefano > > > -Original Message-

[jira] [Created] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

Anton Solovev created FLINK-5698: Summary: Add NestedFieldsProjectableTableSource interface Key: FLINK-5698 URL: https://issues.apache.org/jira/browse/FLINK-5698 Project: Flink Issue Type: Im

[RESULT][VOTE] Release Apache Flink 1.2.0 (RC3)

I hereby officially close the voting of the 1.2.0 release with 8 +1 votes (5 binding) and no -1 votes. +1 votes: - Ufuk - Stephan - Gordon (non-binding) - Sree (non-binding) - Gyula - Robert - Till - Fokko (non-binding) Thanks a lot to everybody who helped testing this and the previous release c

[jira] [Created] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

Tzu-Li (Gordon) Tai created FLINK-5697: -- Summary: Add per-shard watermarks for FlinkKinesisConsumer Key: FLINK-5697 URL: https://issues.apache.org/jira/browse/FLINK-5697 Project: Flink I