[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

2016-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306251#comment-15306251 ] ASF GitHub Bot commented on FLINK-3477: --- Github user ggevay commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ...

2016-05-29 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r65024796 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala --- @@ -282,27 +283,57 @@ class GroupedDataSet[T: ClassTag]( }

[jira] [Updated] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes

2016-05-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3958: -- Description: In GraphiteReporter#getReporter(): {code} com.codahale.metrics.graphite.GraphiteReporter.Builder

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-05-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread

2016-05-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2016-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306163#comment-15306163 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski closed the pull request at:

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/2048#issuecomment-222398251 Sounds good, about to close --- 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

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread danielblazevski
Github user danielblazevski closed the pull request at: https://github.com/apache/flink/pull/2048 --- 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

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/2048#issuecomment-222397683 @chiwanpark happy to wait. Should I close and re-open a PR when that's done or just leave this open knowing that it will not begin being reviewed until the

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/2048#issuecomment-222397141 Hi @danielblazevski, thanks for opening pull request. I would like to split approximative knn and exact knn. If the approximative method needs exact knn

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/2048#issuecomment-222390974 btw, not sure what the standards are, should I squash all this into one commit before doing a PR? Or do you occasionally like to see many commits of a PR?

[GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh...

2016-05-29 Thread danielblazevski
GitHub user danielblazevski opened a pull request: https://github.com/apache/flink/pull/2048 [Flink 1934] Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library I added approximate knn algorithms. In another PR, there are two exact methods, one basic

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2016-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306122#comment-15306122 ] ASF GitHub Bot commented on FLINK-1745: --- GitHub user danielblazevski opened a pull request:

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

2016-05-29 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306054#comment-15306054 ] Vasia Kalavri commented on FLINK-1707: -- Thank you [~joseprupi]! When you are ready, open a PR and let

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-05-29 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306053#comment-15306053 ] Vasia Kalavri commented on FLINK-1536: -- Hi [~rohit13k], a graph in gelly is represented by 2

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

2016-05-29 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306051#comment-15306051 ] Josep RubiĆ³ commented on FLINK-1707: Hey Vasia, https://github.com/joseprupi/flink

[jira] [Assigned] (FLINK-3985) A metric with the name * was already registered

2016-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3985: --- Assignee: Chesnay Schepler > A metric with the name * was already registered >

[jira] [Created] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

2016-05-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3990: --- Summary: ZooKeeperLeaderElectionTest kills the JVM Key: FLINK-3990 URL: https://issues.apache.org/jira/browse/FLINK-3990 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-3323) Nifi connector not documented

2016-05-29 Thread Suneel Marthi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi reassigned FLINK-3323: Assignee: Suneel Marthi > Nifi connector not documented > - >

[jira] [Resolved] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

2016-05-29 Thread Suneel Marthi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi resolved FLINK-3405. -- Resolution: Fixed Fix Version/s: 1.0.4 1.1.0 > Extend NiFiSource with

[jira] [Reopened] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

2016-05-29 Thread Suneel Marthi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi reopened FLINK-3405: -- Sorry, marked as Resolved by mistake. > Extend NiFiSource with interface StoppableFunction >

[jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

2016-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305775#comment-15305775 ] ASF GitHub Bot commented on FLINK-3405: --- Github user smarthi commented on the pull request:

[GitHub] flink pull request: FLINK-3405: Extend NiFiSource with interface S...

2016-05-29 Thread smarthi
Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/2047#issuecomment-222344951 I started to add some NiFi integration tests which are presently lacking, but realized that it would be better to have that as part of a different jira. --- If your

[jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

2016-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305774#comment-15305774 ] ASF GitHub Bot commented on FLINK-3405: --- GitHub user smarthi opened a pull request:

[GitHub] flink pull request: FLINK-3405: Extend NiFiSource with interface S...

2016-05-29 Thread smarthi
GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/2047 FLINK-3405: Extend NiFiSource with interface StoppableFunction Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.