[jira] [Created] (FLINK-2302) Allow multiple instances to run on single host

2015-06-30 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2302: -- Summary: Allow multiple instances to run on single host Key: FLINK-2302 URL: https://issues.apache.org/jira/browse/FLINK-2302 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2301: --- Summary: In BarrierBuffer newer Barriers trigger old Checkpoints Key: FLINK-2301 URL: https://issues.apache.org/jira/browse/FLINK-2301 Project: Flink I

[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

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 wrote: > >> Hi Matthias, >> >> +1 for stop, but it's only a name :) The rest of your ch

[jira] [Created] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-06-30 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2299: -- Summary: The slot on which the task maanger was scheduled was killed Key: FLINK-2299 URL: https://issues.apache.org/jira/browse/FLINK-2299 Project: Flink Issue

[jira] [Created] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2298: - Summary: Allow setting custom YARN application names through the CLI Key: FLINK-2298 URL: https://issues.apache.org/jira/browse/FLINK-2298 Project: Flink

[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 wrote: > +1 > > - tested local-mode and cluster-mode for h

[jira] [Created] (FLINK-2297) Add threshold setting for SVM binary predictions

2015-06-30 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2297: -- Summary: Add threshold setting for SVM binary predictions Key: FLINK-2297 URL: https://issues.apache.org/jira/browse/FLINK-2297 Project: Flink Is

[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 Compon

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 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 Checkpointed interfac

[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

[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

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 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 bug there, I

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 wrote: > > Hi Chiwan, > > at the moment the single element PredictOperation only supports > non-distributed models. This means that it expects the

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 spo

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

2015-06-30 Thread Ufuk Celebi
On 30 Jun 2015, at 10:26, Fabian Hueske 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: Off-by-one issues in the windowing code

2015-06-30 Thread Maximilian Michels
Hey Marton, Thanks for spotting the two issues and fixing the first one. Those should definitely be fixed in 0.9.1. Cheers, Max On Mon, Jun 29, 2015 at 11:14 AM, Gyula Fóra wrote: > The second issue is related to parallel time based aggregations. I think we > should fix this for 0.9.1. > > Als

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

2015-06-30 Thread Till Rohrmann
+1 for "stop" On Tue, Jun 30, 2015 at 10:26 AM, Fabian Hueske wrote: > 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 >:

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 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 : > > > From the same series of experiments: > > > > I am basically running an algorithm that

[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: Di

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 : > Hi, > > I am working on https://issues.apache.org/jira/browse/FLINK-2111 > > Stephan an

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 : > From the same series of experiments: > > I am basically running an algorithm that simulates a Gather Sum Apply > Iteration that performs Traingle Count (Why simulate it? Bec

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 Vasi

[jira] [Created] (FLINK-2292) Report accumulators periodically while job is running

2015-06-30 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2292: - Summary: Report accumulators periodically while job is running Key: FLINK-2292 URL: https://issues.apache.org/jira/browse/FLINK-2292 Project: Flink

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 wrote: > As you can see from status.apache.org, the host is currently down. I hope > the