[
https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603905#comment-14603905
]
ASF GitHub Bot commented on FLINK-2230:
---
Github user Shiti commented on the pull req
Github user Shiti commented on the pull request:
https://github.com/apache/flink/pull/867#issuecomment-115936916
@StephanEwen, Apologies, I didn't notice the earlier message in jira.
Something wrong with my GMail settings, most of the messages from jira and
mailing list went into Spam
[
https://issues.apache.org/jira/browse/FLINK-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603569#comment-14603569
]
Aljoscha Krettek commented on FLINK-2122:
-
Why did you close this one?
> Make all
Gyula Fora created FLINK-2281:
-
Summary: Allow chaining of operators with multiple inputs
Key: FLINK-2281
URL: https://issues.apache.org/jira/browse/FLINK-2281
Project: Flink
Issue Type: Improvem
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/860#discussion_r33386546
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamFoldTest.java
---
@@ -1,57 +0,0 @@
[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603450#comment-14603450
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603424#comment-14603424
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/860#discussion_r33385182
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamFoldTest.java
---
@@ -1,57 +0,0 @@
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603418#comment-14603418
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-115832961
Wouldn't it make sense to implement custom partitioning in a way that it
allows to return a array of indexes like in the ChannelSelector interface?
Returning only 1 index
[
https://issues.apache.org/jira/browse/FLINK-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2136.
-
Resolution: Fixed
> Test the streaming scala API
>
>
> Key: F
[
https://issues.apache.org/jira/browse/FLINK-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1645.
-
Resolution: Not A Problem
> Move StreamingClassloaderITCase to flink-streaming
> -
[
https://issues.apache.org/jira/browse/FLINK-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1853.
-
Resolution: Fixed
> TopSpeedWindowing example cannot be run from the ComandLine or Webclient
> ---
[
https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1534.
-
Resolution: Won't Fix
> GSoC project: Distributed pattern matching over Flink streaming
>
[
https://issues.apache.org/jira/browse/FLINK-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2039.
-
Resolution: Fixed
> Streaming API's sum(String) does not work for Tuples
> ---
[
https://issues.apache.org/jira/browse/FLINK-1972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1972.
-
Resolution: Fixed
> Remove instanceID in streaming tasks
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2081.
-
Resolution: Not A Problem
> Change order of restore state and open for Streaming Operators
> -
[
https://issues.apache.org/jira/browse/FLINK-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2122.
-
Resolution: Fixed
> Make all internal streaming operators Checkpointable
> ---
[
https://issues.apache.org/jira/browse/FLINK-1838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1838.
-
Resolution: Done
> Update streaming programming guide
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1869.
-
Resolution: Fixed
> Make StreamDiscretizers chainable
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2129.
-
Resolution: Fixed
> User state checkpointing works only for serializable state
> -
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603295#comment-14603295
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603293#comment-14603293
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/870#issuecomment-115808761
merging
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/870
---
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 is enabl
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/868#issuecomment-115770279
Thanks @mxm , yeah I guess it is a refactoring. I was trying to figure out
what changes make it more flexible.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603193#comment-14603193
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/870#issuecomment-115762324
Ah ok, I was just confused since in the new test for it the same stream is
used as feedback and result. :sweat_smile:
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603173#comment-14603173
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/870#issuecomment-115756972
There is nothing tricky there:
In java every record in the stream passed to closewith() will be fed back.
(And closeWith returns this stream).
In scala it
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603161#comment-14603161
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/870#issuecomment-115750835
This looks reasonable. How does the user not specify which elements are
feedback and which go to the downstream operator?
---
If your project is set up for it, you can
GitHub user gaborhermann opened a pull request:
https://github.com/apache/flink/pull/872
[FLINK-2138] Added custom partitioning to DataStream
Custom partitioning added to DataStream in order to be more consistent with
the batch API.
You can merge this pull request into a Git reposi
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603152#comment-14603152
]
ASF GitHub Bot commented on FLINK-2138:
---
GitHub user gaborhermann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14603027#comment-14603027
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user senorcarbone commented on the p
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/870#issuecomment-115724842
no more wrapper types :+1:
I approve
---
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 pro
Fabian Hueske created FLINK-2280:
Summary: GenericTypeComparator.compare() does not respect
ascending flag
Key: FLINK-2280
URL: https://issues.apache.org/jira/browse/FLINK-2280
Project: Flink
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33359906
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/MLUtilsSuite.scala ---
@@ -109,4 +109,41 @@ class MLUtilsSuite extends FlatSpec with Match
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-115706555
My last comment concerns the return type of createHistogram, having a
runtime return type would be ideal, but I'm not considering it a blocker right
now.
When @
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33358232
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602905#comment-14602905
]
ASF GitHub Bot commented on FLINK-2116:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/772#issuecomment-115697593
Yeah, it's not carved into stone. I mean this holds true for the whole
library.
---
If your project is set up for it, you can reply to this email and have your
repl
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33357307
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/OnlineHistogram.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602901#comment-14602901
]
Till Rohrmann commented on FLINK-1736:
--
I actually implemented a simple {{CountVector
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33356751
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33356576
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33356477
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33356340
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33356107
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33355896
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala
---
@@ -0,0 +1,337 @@
+/*
+ * Licensed to the Apac
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-115689621
Hi @shghatge ,
I left my set of comments inline. They are mostly related to coding style
issues. I guess you should revisit the previous comments here.
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602879#comment-14602879
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the pul
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33355373
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java
---
@@ -156,4 +181,17 @@ public
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602873#comment-14602873
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r33355362
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/MLUtils.scala ---
@@ -119,4 +120,23 @@ object MLUtils {
stringRepresentatio
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33355251
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java
---
@@ -150,20 +149,15 @@ private static boolean parsePa
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602872#comment-14602872
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33355180
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java
---
@@ -119,23 +113,32 @@ private static boolean
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602871#comment-14602871
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354695
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602863#comment-14602863
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602861#comment-14602861
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602858#comment-14602858
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354654
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354571
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354597
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602859#comment-14602859
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354535
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602857#comment-14602857
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602854#comment-14602854
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354309
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602853#comment-14602853
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354136
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -282,6 +282,54 @@ public void flatMap(Edge edge,
Collector> out)
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602852#comment-14602852
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33354071
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -282,6 +282,54 @@ public void flatMap(Edge edge,
Collector> out)
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r33353966
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -282,6 +282,54 @@ public void flatMap(Edge edge,
Collector> out)
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602850#comment-14602850
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602847#comment-14602847
]
Sachin Goel commented on FLINK-1736:
Hi Alexander, are there any updates on this?
> A
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602812#comment-14602812
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-115662194
I agree. I just did not want to change the current pattern... However, we
should do it the right way in this PR, too. I will update the code accordingly.
---
If your proje
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/871#discussion_r33350986
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala
---
@@ -172,9 +173,46 @@ object Predictor {
}
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602806#comment-14602806
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602804#comment-14602804
]
ASF GitHub Bot commented on FLINK-2116:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/772#issuecomment-115660064
So I guess we are keeping the naming for now. If we come up with something
to avoid confusion with Scorer.evaluate() in the future we can take another
look at this.
--
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/871#discussion_r33350057
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/Score.scala
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602787#comment-14602787
]
Theodore Vasiloudis commented on FLINK-2108:
Ongoing work here: https://github
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gábor Hermann reassigned FLINK-2138:
Assignee: Gábor Hermann
> PartitionCustom for streaming
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602783#comment-14602783
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on a diff in
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/871
[FLINK-2157] [ml] [WIP] Create evaluation framework for ML library
WIP PR for the model evaluation framework for FlinkML.
The evaluation follow sklearn's paradigm, where a Scorer object is
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602781#comment-14602781
]
ASF GitHub Bot commented on FLINK-2157:
---
GitHub user thvasilo opened a pull request:
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-115654768
Thank you Sachin, I'll go over again this today.
---
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
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-115653886
Okay. Finished. The function definition is
``` scala
createHistogram(bins: Int) : DataSet[OnlineHistogram] = {
...
}
```
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602729#comment-14602729
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602728#comment-14602728
]
ASF GitHub Bot commented on FLINK-2279:
---
GitHub user gyfora opened a pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-115652174
This comment is not a blocker for merging this. Let's just not write future
tests like this, and whenever we touch something, we could on-the-fly migrate
the tests to
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/870
[FLINK-2279] [streaming] Add Connected Iteration
This PR introduces a new feature that allows the users to treat the
iteration head in a streaming iteration as a ConnectedDataStream of the
original a
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602726#comment-14602726
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-115652087
All in all this looks good.
The only think that strikes me is the of the test pattern(that way used
also before by the tests. I am not a big fan of validating
Gyula Fora created FLINK-2279:
-
Summary: Allow treating iteration head as ConnectedDataStream
Key: FLINK-2279
URL: https://issues.apache.org/jira/browse/FLINK-2279
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602686#comment-14602686
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user tillrohrmann commented on the p
1 - 100 of 131 matches
Mail list logo
