[jira] [Created] (FLINK-4620) Automatically creating savepoints

2016-09-14 Thread Niels Basjes (JIRA)
Niels Basjes created FLINK-4620: --- Summary: Automatically creating savepoints Key: FLINK-4620 URL: https://issues.apache.org/jira/browse/FLINK-4620 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

2016-09-14 Thread Maciej Prochniak (JIRA)
Maciej Prochniak created FLINK-4619: --- Summary: JobManager does not answer to client when restore from savepoint fails Key: FLINK-4619 URL: https://issues.apache.org/jira/browse/FLINK-4619 Project:

Re: Implementing FLIP-2 and FLIP-4

2016-09-14 Thread AJ Heller
Thank you, Aljoscha! I look forward to reading the papers you mentioned. Regarding FLIP-2, are there any new use cases that a Window Function Context enables? If not, my understanding is that adding a this context would be an optimization over what is currently possible, but maybe inefficient.

Gelly Library. Need an example

2016-09-14 Thread Olga Golovneva
Hi devs, Do you know if there is an example (besides ITCase) of usage of Summarization Library in Gelly? I'm having some problems trying to use it in my code. Particularly, I cannot print output edges ( it throws the following exception: Exception in thread "main"

Re: Implementing FLIP-2 and FLIP-4

2016-09-14 Thread Aljoscha Krettek
Hi AJ, the idea for evictors initially came from IBM Infosphere Streams, if I'm not mistaken: http://www.ibm.com/support/knowledgecenter/SSCRJU_4.0.0/com.ibm.streams.dev.doc/doc/windowhandling.html The first version of the windowing system used a combination of triggers/evictors to do the

Re: checkpointing a OneInputStreamOperator/AbstractStreamOperator

2016-09-14 Thread Aljoscha Krettek
Hi, yes, this observation is correct. It's a current limitation in Flink that I was trying to address with this issue https://issues.apache.org/jira/browse/FLINK-3582 and the PR I created for it. By now, that PR is quite outdated but we should maybe put in the effort to finish this now. +Stefan

[jira] [Created] (FLINK-4618) Last kafka message gets consumed twice when restarting job

2016-09-14 Thread Melmoth (JIRA)
Melmoth created FLINK-4618: -- Summary: Last kafka message gets consumed twice when restarting job Key: FLINK-4618 URL: https://issues.apache.org/jira/browse/FLINK-4618 Project: Flink Issue Type: Bug

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

2016-09-14 Thread Henry Saputra
HI David, Thanks so much for the interest to contribute to Apache Flink. To help review and DISCUSS for new feature in Flink, please do submit FLIP [1] proposal. It will help the PMCs managing the new feature proposals and keep resources with ASF realm. Thanks, Henry [1]