[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306279#comment-15306279
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65027607
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java
---
@@ -0,0 +1,305 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306278#comment-15306278
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65027557
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java
---
@@ -42,34 +44,38 @@
* Combine operator for Reduce
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306270#comment-15306270
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65026385
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java
---
@@ -42,34 +44,38 @@
* Combine operator for Reduce
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306251#comment-15306251
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
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](
}
[
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 b
[
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 nextEv
[
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()) {
t
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306163#comment-15306163
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user danielblazevski closed the pull
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 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 featur
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/2048#issuecomment-222398107
I think that closing this and re-opening after #1220 is merged is better
because reviewing is easier.
---
If your project is set up for it, you can reply to this ema
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
other
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
implementatio
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 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 al
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306122#comment-15306122
]
ASF GitHub Bot commented on FLINK-1745:
---
GitHub user danielblazevski opened a pull r
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306054#comment-15306054
]
Vasia Kalavri commented on FLINK-1707:
--
Thank you [~joseprupi]! When you are ready, o
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306053#comment-15306053
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~rohit13k],
a graph in gelly is represent
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306051#comment-15306051
]
Josep Rubió commented on FLINK-1707:
Hey Vasia,
https://github.com/joseprupi/flink
ht
[
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
> --
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
[
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
> -
>
>
26 matches
Mail list logo
