[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543734#comment-14543734 ] Alexander Alexandrov commented on FLINK-1731: - I would go with a {{DataSet}}

[jira] [Updated] (FLINK-1743) Add multinomial logistic regression to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Alexandrov updated FLINK-1743: Assignee: (was: Alexander Alexandrov) Add multinomial logistic regression to

[jira] [Updated] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Alexandrov updated FLINK-1731: Assignee: (was: Alexander Alexandrov) Add kMeans clustering algorithm to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543670#comment-14543670 ] Peter Schrott commented on FLINK-1731: -- Hi flink people, as we now figured out how

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543643#comment-14543643 ] Alexander Alexandrov commented on FLINK-1731: - [~peedeeX21] for some reason I

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543734#comment-14543734 ] Alexander Alexandrov edited comment on FLINK-1731 at 5/14/15 2:35 PM:

[jira] [Created] (FLINK-2013) Create generalized linear model framework

Theodore Vasiloudis created FLINK-2013: -- Summary: Create generalized linear model framework Key: FLINK-2013 URL: https://issues.apache.org/jira/browse/FLINK-2013 Project: Flink Issue

[jira] [Created] (FLINK-2015) Add ridge regression

Theodore Vasiloudis created FLINK-2015: -- Summary: Add ridge regression Key: FLINK-2015 URL: https://issues.apache.org/jira/browse/FLINK-2015 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543711#comment-14543711 ] Theodore Vasiloudis commented on FLINK-1731: Since the centroids will have to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543647#comment-14543647 ] Robert Metzger commented on FLINK-1731: --- [~aalexandrov]: only users with Contributor

[jira] [Assigned] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott reassigned FLINK-1731: Assignee: Peter Schrott (was: Alexander Alexandrov) Add kMeans clustering algorithm to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543648#comment-14543648 ] Peter Schrott commented on FLINK-1731: -- Great! Thanks! Add kMeans clustering

[jira] [Updated] (FLINK-2013) Create generalized linear model framework

[ https://issues.apache.org/jira/browse/FLINK-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-2013: --- Description: [Generalized linear

[GitHub] flink pull request: [FLINK-2004] Fix memory leak in presense of fa...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/674 [FLINK-2004] Fix memory leak in presense of failed checkpoints for Kafka Source You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink

[jira] [Commented] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543782#comment-14543782 ] ASF GitHub Bot commented on FLINK-2004: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-2008] Fix broker failure test case

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/675 [FLINK-2008] Fix broker failure test case You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink stephan_kafka Alternatively you can

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543858#comment-14543858 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1990] [staging table] Support upper cas...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/667#issuecomment-102076699 Can you post a link to the failed run? Or is it on your local machine? Some of the streaming test cases fail sometimes right now, this is a known problem. --- If your

[jira] [Commented] (FLINK-1990) Uppercase AS keyword not allowed in select expression

[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543871#comment-14543871 ] ASF GitHub Bot commented on FLINK-1990: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30342062 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -0,0 +1,220 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1727) Add decision tree to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544095#comment-14544095 ] Sachin Goel commented on FLINK-1727: The approach in [1] seems the most generic to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544164#comment-14544164 ] Theodore Vasiloudis commented on FLINK-1731: Yeah that might be the better

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544069#comment-14544069 ] ASF GitHub Bot commented on FLINK-1525: --- Github user hsaputra commented on a diff in

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/664#issuecomment-102111410 Hi @rmetzger, just did a pass and other than comments about unused test and broken Travis due to check style I think this PR is ready to go. +1 --- If your project is

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544074#comment-14544074 ] ASF GitHub Bot commented on FLINK-1525: --- Github user hsaputra commented on the pull

[jira] [Commented] (FLINK-1727) Add decision tree to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544091#comment-14544091 ] Sachin Goel commented on FLINK-1727: I would like to work on this. I'm already half

[jira] [Created] (FLINK-2014) Add LASSO regression

Theodore Vasiloudis created FLINK-2014: -- Summary: Add LASSO regression Key: FLINK-2014 URL: https://issues.apache.org/jira/browse/FLINK-2014 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times

[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543824#comment-14543824 ] ASF GitHub Bot commented on FLINK-2008: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30331086 --- Diff: flink-staging/flink-scala-shell/src/main/java/org.apache.flink/api/java/ScalaShellRemoteEnvironment.java --- @@ -0,0 +1,84 @@ + --- End

[GitHub] flink pull request: [FLINK-1398] Introduce extractSingleField() in...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/308#issuecomment-102077233 I think the consensus was that we don't want to have such a method in the DataSet API. We can, however, put a utility for this in flink-contrib. This utility should

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543876#comment-14543876 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1398) A new DataSet function: extractElementFromTuple

[ https://issues.apache.org/jira/browse/FLINK-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543875#comment-14543875 ] ASF GitHub Bot commented on FLINK-1398: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30331698 --- Diff: flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala --- @@ -0,0 +1,100 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30331377 --- Diff: flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkILoop.scala --- @@ -0,0 +1,199 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543869#comment-14543869 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-102069667 Amazing! I'm super excited to see this finally implemented. I'll soon review the changes. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543825#comment-14543825 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543829#comment-14543829 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30330465 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1337,11 +1336,16 @@ public long count() throws Exception { /**

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543859#comment-14543859 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543862#comment-14543862 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30330874 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala --- @@ -1327,8 +1327,8 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30330912 --- Diff: flink-staging/flink-scala-shell/pom.xml --- @@ -0,0 +1,246 @@ +?xml version=1.0 encoding=UTF-8? +!-- +Licensed to the Apache Software

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user nikste commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-102086481 thanks for the comments Robert, I'll fix the stuff tomorrow! Indeed, the Scala shell itself is not so much code, most of the changes are caused by the change of

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543936#comment-14543936 ] ASF GitHub Bot commented on FLINK-1907: --- Github user nikste commented on the pull

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

GitHub user lokeshrajaram reopened a pull request: https://github.com/apache/flink/pull/673 [FLINK-1711] - Converted all usages of Commons Validate to Guava Checks(for Java classes), Scala predef require(for Scala classes) [FLINK-1711] - Converted all usages of Commons Validate to

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

Github user lokeshrajaram closed the pull request at: https://github.com/apache/flink/pull/673 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Resolved] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

[ https://issues.apache.org/jira/browse/FLINK-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1949. --- Resolution: Pending Closed Fix Version/s: 0.9

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543827#comment-14543827 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30329898 --- Diff: docs/scala_shell_quickstart.md --- @@ -0,0 +1,72 @@ +--- +title: Quickstart: Scala Shell +--- +!-- +Licensed to the Apache

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543835#comment-14543835 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543917#comment-14543917 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-102082153 The change looks good, I had some easy to resolve comments. Sadly, it seems that most of the changes are caused by the semantics change of `print()` ... the

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30330062 --- Diff: docs/scala_shell_quickstart.md --- @@ -0,0 +1,72 @@ +--- +title: Quickstart: Scala Shell +--- +!-- +Licensed to the Apache

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543866#comment-14543866 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543867#comment-14543867 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Closed] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

[ https://issues.apache.org/jira/browse/FLINK-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1949. - YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543865#comment-14543865 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30331151 --- Diff: flink-staging/flink-scala-shell/src/main/java/org.apache.flink/api/java/ScalaShellRemoteEnvironment.java --- @@ -0,0 +1,84 @@ + +package

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30331192 --- Diff: flink-staging/flink-scala-shell/src/main/java/org.apache.flink/api/java/ScalaShellRemoteEnvironment.java --- @@ -0,0 +1,84 @@ + +package

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30330524 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -85,4 +87,14 @@ public String toString() { return

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543838#comment-14543838 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543938#comment-14543938 ] ASF GitHub Bot commented on FLINK-1711: --- Github user lokeshrajaram closed the pull

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543940#comment-14543940 ] ASF GitHub Bot commented on FLINK-1711: --- GitHub user lokeshrajaram reopened a pull

[jira] [Created] (FLINK-2016) Add elastic net regression

Theodore Vasiloudis created FLINK-2016: -- Summary: Add elastic net regression Key: FLINK-2016 URL: https://issues.apache.org/jira/browse/FLINK-2016 Project: Flink Issue Type: New Feature

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/672#discussion_r30329764 --- Diff: docs/scala_shell_quickstart.md --- @@ -0,0 +1,72 @@ +--- +title: Quickstart: Scala Shell +--- +!-- +Licensed to the Apache

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543826#comment-14543826 ] ASF GitHub Bot commented on FLINK-1907: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: Pluggable state backend added

GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/676 Pluggable state backend added This PR introduces the pluggable state backends using StateHandleProviders and extends the StateHandle interface with a discard method for cleaning up the unnecessary

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544451#comment-14544451 ] ASF GitHub Bot commented on FLINK-297: -- Github user StephanEwen commented on the pull

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=1457#comment-1457 ] ASF GitHub Bot commented on FLINK-297: -- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-102184072 A simple way to try this out is to execute the class `TestRunner` in the `flink-runtime-web` project. It starts a mini cluster, starts the new web server and runs

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/677 [FLINK-297] [web frontend] First part of JobManager runtime monitor REST AP This pull requests is the first step towards the new JobManager monitoring web frontend. The code for the new

[jira] [Commented] (FLINK-1976) Add ForwardedFields* hints for the optimizer

[ https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543390#comment-14543390 ] ASF GitHub Bot commented on FLINK-1976: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1976][gelly] Added ForwardedFields Anno...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/663#issuecomment-101972007 Guys, Maybe it makes sense to merge this :) It's been here for a while. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543408#comment-14543408 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-101978637 Hi @vasia, I had a look at the new branch. The changes look good, degrees are no longer exposed to the user and the current approach removes the need to

[jira] [Created] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

Andra Lungu created FLINK-2012: -- Summary: addVertices, addEdges, removeVertices, removeEdges methods Key: FLINK-2012 URL: https://issues.apache.org/jira/browse/FLINK-2012 Project: Flink Issue

[jira] [Commented] (FLINK-1398) A new DataSet function: extractElementFromTuple

[ https://issues.apache.org/jira/browse/FLINK-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543419#comment-14543419 ] ASF GitHub Bot commented on FLINK-1398: --- Github user FelixNeutatz commented on the

[GitHub] flink pull request: [FLINK-1398] Introduce extractSingleField() in...

Github user FelixNeutatz commented on the pull request: https://github.com/apache/flink/pull/308#issuecomment-101981739 So, what is the final decision here? this seems like a lot of code for something that can be achieved using a simple mapper -- that is exactly the

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543449#comment-14543449 ] ASF GitHub Bot commented on FLINK-1707: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1707][WIP]Add an Affinity Propagation L...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/649#issuecomment-101989242 @joey001, How did you rebase this? It should not normally contain everyone's commits... Right now it looks like 18 people participated in the implementation

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

Github user lokeshrajaram closed the pull request at: https://github.com/apache/flink/pull/673 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

GitHub user lokeshrajaram reopened a pull request: https://github.com/apache/flink/pull/673 [FLINK-1711] - Converted all usages of Commons Validate to Guava Checks(for Java classes), Scala predef require(for Scala classes) [FLINK-1711] - Converted all usages of Commons Validate to

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14544863#comment-14544863 ] ASF GitHub Bot commented on FLINK-1711: --- Github user lokeshrajaram closed the pull