[jira] [Created] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration

Martin Liesenberg created FLINK-3888: Summary: Custom Aggregator with Convergence can't be registered directly with DeltaIteration Key: FLINK-3888 URL: https://issues.apache.org/jira/browse/FLINK

Re: Introducing a PR template

flink/pull/1729 Martin Liesenberg schrieb am Di., 23. Feb. 2016 um 00:12 Uhr: > sure. will take that into account. Thanks for the input. > > best regards > martin > > Maximilian Michels schrieb am So., 21. Feb. 2016 um > 13:49 Uhr: > >> Hi Martin, >> >>

[jira] [Created] (FLINK-3529) Add pull request template

Martin Liesenberg created FLINK-3529: Summary: Add pull request template Key: FLINK-3529 URL: https://issues.apache.org/jira/browse/FLINK-3529 Project: Flink Issue Type: Task

Re: Introducing a PR template

ough, because "install" does only copy the > results > >> into the local Maven repository (~/.m2/repository). > >> > >> So I think > >> - [ ] Tests pass (`mvn test`) > >> - [ ] Build passes (`mvn install`) > >> - [ ] Chec

Introducing a PR template

Based on the recent discussion in the email thread 'Extending and improving our "How to contribute" page', I propose to introduce the following template for PRs Thanks for contributing to Apache Flink, before you open your PR please kindly take into consideration the following check list. Onc

Re: Extending and improving our "How to contribute" page

minder for people who didn't read the > how-to-contribute section of the README :) > > Cheers, > Max > > On Thu, Feb 18, 2016 at 9:31 AM, Martin Liesenberg > wrote: > > Hi, > > > > GitHub just introduced a way to supply PR templates. [1] > > > &

Re: Extending and improving our "How to contribute" page

Hi, GitHub just introduced a way to supply PR templates. [1] To support the changes discussed here, we could add a simple template with check boxes like: [ ] did you add tests [ ] did you check against the coding guidelines [ ] is there a jira supporting the PR Let me know what you think. The la

Re: Flink "Material"

It might also be useful to link to the training materials which can be found here: http://dataartisans.github.io/flink-training/ Best regards Martin Maximilian Michels schrieb am Mi., 28. Okt. 2015 10:53: > Yes, you can find lots of Flink slides on the Slideshare. > > On Tue, Oct 27, 2015 at 9:

Re: Apache flink with Elastic Search

Elasticsearch does not support streaming in the sense, that you subscribe to a search query and as new documents come in, you will get any matching your query. There is a rather long discussion in one of the issues in the ES repository on GitHub concerning this (active for 4 years now) [1] It does

Re: Apache Flink vs MapReduce

There is a stackoverflow post with a rather detailed answer on the two systems. You can find it here: http://stackoverflow.com/questions/29923035/how-does-apache-flink-compare-to-mapreduce-on-hadoop Best regards. Vikram Santhosh schrieb am Mo., 28. Sep. 2015 15:55: > Hello , > > My name is Vikr

Re: Tests - Unit Tests versus Integration Tests

Should there be a concerted effort to reduce the amount of unnecessary integration tests and cover those cases by unit tests? We could collect the cases in a ticket and work through the list one by one, no? Best regards, Martin Chiwan Park schrieb am Fr., 18. Sep. 2015 um 12:33 Uhr: > Hi Steph

Re: Does flink support groupByKey([numTasks])

Hi, as far as I can tell there is no direct equivalent, which is probably due to the underlying execution models. I think the desired behaviour can be expressed by something along the lines of: stream.groupBy(0).window(Count.of()) where: stream is a DataStream> and would be the batch size of you

[jira] [Created] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram

Martin Liesenberg created FLINK-2628: Summary: Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram Key: FLINK-2628 URL: https://issues.apache.org/jira/browse/FLINK-2628 Project