[jira] [Commented] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library

2015-04-30 Thread narayana reddy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521105#comment-14521105 ] narayana reddy commented on FLINK-1749: --- Hi Till Rohrmann,

[jira] [Resolved] (FLINK-1843) Job History gets cleared too fast

2015-04-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1843. --- Resolution: Fixed Job History gets cleared too fast

[jira] [Commented] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library

2015-04-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521119#comment-14521119 ] Till Rohrmann commented on FLINK-1749: -- Hi Narayana, great to hear that you want to

[jira] [Commented] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library

2015-04-30 Thread narayana reddy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521127#comment-14521127 ] narayana reddy commented on FLINK-1749: --- Thank you Till Rohrmann. Add Boosting

[jira] [Updated] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library

2015-04-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1749: - Assignee: narayana reddy Add Boosting algorithm for ensemble learning to machine learning

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

2015-04-30 Thread mustafa elbehery (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521195#comment-14521195 ] mustafa elbehery commented on FLINK-1959: - I just tried with DOP 1,2 and 5 .. All

[jira] [Created] (FLINK-1962) Add Gelly Scala API

2015-04-30 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1962: Summary: Add Gelly Scala API Key: FLINK-1962 URL: https://issues.apache.org/jira/browse/FLINK-1962 Project: Flink Issue Type: Task Components:

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-04-30 Thread Sebastian Schelter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521276#comment-14521276 ] Sebastian Schelter commented on FLINK-1962: --- Let me know once you have an

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29426482 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-1963) Improve distinct() transformation

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1963: - Labels: starter (was: start) Improve distinct() transformation

[jira] [Updated] (FLINK-1963) Improve distinct() transformation

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1963: - Description: The `distinct()` transformation is a bit limited right now with respect to

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29426706 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521507#comment-14521507 ] Fabian Hueske commented on FLINK-1951: -- It was a bit tricky and took some time but I

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29432849 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/642#discussion_r29447805 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/Client.java --- @@ -420,6 +428,60 @@ public JobSubmissionResult run(JobGraph jobGraph,

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521829#comment-14521829 ] ASF GitHub Bot commented on FLINK-1818: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521849#comment-14521849 ] ASF GitHub Bot commented on FLINK-1818: --- Github user mxm commented on the pull

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521839#comment-14521839 ] ASF GitHub Bot commented on FLINK-1818: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/642#discussion_r29447781 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/Client.java --- @@ -420,6 +428,60 @@ public JobSubmissionResult run(JobGraph jobGraph,

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521826#comment-14521826 ] ASF GitHub Bot commented on FLINK-1818: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521828#comment-14521828 ] ASF GitHub Bot commented on FLINK-1818: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

2015-04-30 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/642#issuecomment-97882155 Thank you for your pull request @rainiraj. I have made some comments. If you addressed these we would be happy to merge your changes. Feel free to ask if anything is unclear.

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

2015-04-30 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/642#discussion_r29462715 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/Client.java --- @@ -420,6 +428,60 @@ public JobSubmissionResult run(JobGraph jobGraph,

[GitHub] flink pull request: [streaming] New Source and state checkpointing...

2015-04-30 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/643 [streaming] New Source and state checkpointing interfaces These interfaces allow streaming sources/operators to interact with the state checkpointing in a more precise manner. The

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

2015-04-30 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-97956542 I think this looks good now ! I think this needs a test (integration test), otherwise it probably gets broken by some change soon. Starting a

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29431402 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29431391 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29431413 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -475,11 +479,21 @@ class JobManager(val flinkConfiguration:

[GitHub] flink pull request: [scheduling] implement backtracking of interme...

2015-04-30 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/640#discussion_r29432295 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Backtracking.java --- @@ -0,0 +1,252 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521661#comment-14521661 ] ASF GitHub Bot commented on FLINK-1951: --- GitHub user fhueske opened a pull request:

[jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521663#comment-14521663 ] ASF GitHub Bot commented on FLINK-1951: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-30 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521678#comment-14521678 ] Vasia Kalavri commented on FLINK-1951: -- wow thanks a lot for the nice explanation and

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521681#comment-14521681 ] ASF GitHub Bot commented on FLINK-1818: --- GitHub user rainiraj opened a pull request:

[jira] [Updated] (FLINK-1965) Implement the Orthant-wise Limited Memory QuasiNewton optimization algorithm, a variant of L-BFGS that handles L1 regularization

2015-04-30 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1965: --- Description: The Orthant-wise Limited Memory QuasiNewton (OWL-QN) is a quasi-Newton

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

2015-04-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521669#comment-14521669 ] Robert Metzger commented on FLINK-1690: --- Another instance

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

2015-04-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521736#comment-14521736 ] Stephan Ewen commented on FLINK-1690: - This one is interesting, it is not Test