Re: [DISCUSS / VOTE] Signal name to kill streaming jobs

2015-06-30 Thread Ufuk Celebi
On 30 Jun 2015, at 10:26, Fabian Hueske fhue...@gmail.com wrote: Hi, thanks for starting this thread! I prefer stop over terminate because it sounds more graceful. A temporary stop could be called pause. +1 to stop. – Ufuk

Re: [DISCUSS / VOTE] Signal name to kill streaming jobs

2015-06-30 Thread Aljoscha Krettek
+1 for stop, because terminate sounds very harsh On Tue, 30 Jun 2015 at 10:45 Maximilian Michels m...@apache.org wrote: Hi Matthias, +1 for stop, but it's only a name :) The rest of your changes deserve much more attention. Because I have also worked on the ExecutionGraph and also fixed a

Re: Documentation not reachable

2015-06-30 Thread Maximilian Michels
Unfortunately, the buildbot master (which serves the documentation files) has been compromised. The Infra team is working hard to cleanup / replace the host. On Mon, Jun 29, 2015 at 12:28 PM, Robert Metzger rmetz...@apache.org wrote: As you can see from status.apache.org, the host is currently

Re: Monitoring a Flink Job

2015-06-30 Thread Fabian Hueske
Hi Andra, sure, if you do the logging for each record (or group of records) using a list accumulator is a very bad idea. If you don't need exact stats for each vertex but rather a distribution over all vertices, you can use a histogram accumulator. If you need exact vertex stats, I'd go with

Re: [Runtime] Division by Zero Exception

2015-06-30 Thread Andra Lungu
Sure! FLINK-2293 On Tue, Jun 30, 2015 at 10:22 AM, Fabian Hueske fhue...@gmail.com wrote: That looks like a serious bug. :-( Can you open a JIRA for that? Thanks, Fabian 2015-06-29 23:24 GMT+02:00 Andra Lungu lungu.an...@gmail.com: From the same series of experiments: I am basically

Re: [DISCUSS / VOTE] Signal name to kill streaming jobs

2015-06-30 Thread Maximilian Michels
Hi Matthias, +1 for stop, but it's only a name :) The rest of your changes deserve much more attention. Because I have also worked on the ExecutionGraph and also fixed a bug there, I agree with Stephan that we shouldn't change the logic of the state machine. It will lead to very subtle hard to

Re: [Runtime] Division by Zero Exception

2015-06-30 Thread Fabian Hueske
That looks like a serious bug. :-( Can you open a JIRA for that? Thanks, Fabian 2015-06-29 23:24 GMT+02:00 Andra Lungu lungu.an...@gmail.com: From the same series of experiments: I am basically running an algorithm that simulates a Gather Sum Apply Iteration that performs Traingle Count

[jira] [Created] (FLINK-2293) Division by Zero Exception

2015-06-30 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2293: -- Summary: Division by Zero Exception Key: FLINK-2293 URL: https://issues.apache.org/jira/browse/FLINK-2293 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS / VOTE] Signal name to kill streaming jobs

2015-06-30 Thread Fabian Hueske
Hi, thanks for starting this thread! I prefer stop over terminate because it sounds more graceful. A temporary stop could be called pause. Cheers, Fabian 2015-06-29 13:42 GMT+02:00 Matthias J. Sax mj...@informatik.hu-berlin.de: Hi, I am working on

Re: [flink-ml] How to use ParameterMap in predict method?

2015-06-30 Thread Chiwan Park
Thanks Till :) I reimplemented my implementation using PredictDataSetOperation. Regards, Chiwan Park On Jun 29, 2015, at 7:41 PM, Till Rohrmann till.rohrm...@gmail.com wrote: Hi Chiwan, at the moment the single element PredictOperation only supports non-distributed models. This means

Re: Replacing Checkpointed interface with field annotations

2015-06-30 Thread Hermann Gábor
Wow, this looks pretty concise. I really like it! On Mon, Jun 29, 2015 at 3:27 PM Gyula Fóra gyf...@apache.org wrote: Hey all! Just to add something new to the end of the discussion list. After some discussion with Seif, and Paris, I have added a commit that replaces the use of the

[jira] [Created] (FLINK-2294) Keyed State does not work with DOP=1

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2294: --- Summary: Keyed State does not work with DOP=1 Key: FLINK-2294 URL: https://issues.apache.org/jira/browse/FLINK-2294 Project: Flink Issue Type: Bug

[RESULT] [VOTE] Release additional convenience binaries for Flink 0.9.0

2015-06-30 Thread Robert Metzger
The vote has passed with 3 +1 votes from PMC members: Ufuk Celebi Aljoscha Krettek Robert Metzger I will now release the additional binaries and update the website in the next 24 hours. On Sat, Jun 27, 2015 at 9:11 AM, Aljoscha Krettek aljos...@apache.org wrote: +1 - tested local-mode and

[jira] [Created] (FLINK-2296) Checkpoint committing broken

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2296: - Summary: Checkpoint committing broken Key: FLINK-2296 URL: https://issues.apache.org/jira/browse/FLINK-2296 Project: Flink Issue Type: Bug

Re: [DISCUSS / VOTE] Signal name to kill streaming jobs

2015-06-30 Thread Matthias J. Sax
Thanks for your feedback. The vote in clear: stop wins On 06/30/2015 10:51 AM, Aljoscha Krettek wrote: +1 for stop, because terminate sounds very harsh On Tue, 30 Jun 2015 at 10:45 Maximilian Michels m...@apache.org wrote: Hi Matthias, +1 for stop, but it's only a name :) The rest of

[jira] [Created] (FLINK-2300) Links on FAQ page not rendered correctly

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2300: - Summary: Links on FAQ page not rendered correctly Key: FLINK-2300 URL: https://issues.apache.org/jira/browse/FLINK-2300 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2295: --- Summary: TwoInput Task do not react to/forward checkpoint barriers Key: FLINK-2295 URL: https://issues.apache.org/jira/browse/FLINK-2295 Project: Flink