Aljoscha Krettek created FLINK-2277:
---
Summary: In Scala API delta Iterations can not be set to unmanaged
Key: FLINK-2277
URL: https://issues.apache.org/jira/browse/FLINK-2277
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2277:
Labels: Starter (was: )
In Scala API delta Iterations can not be set to unmanaged
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-115574532
Hello Sachin,
although we will for now postpone adding the histogram function to
DataSetUtil, we should still have some external functionality for this PR.
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
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603161#comment-14603161
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user aljoscha commented on the pull
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
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602662#comment-14602662
]
ASF GitHub Bot commented on FLINK-2278:
---
GitHub user ChristophAl opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602729#comment-14602729
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user StephanEwen commented on the
[
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-tabpanelfocusedCommentId=14602783#comment-14602783
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on a diff in
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(EdgeK, EV edge,
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
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
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
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
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603193#comment-14603193
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user aljoscha commented on the pull
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 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
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603027#comment-14603027
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user senorcarbone commented on the
[
https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602901#comment-14602901
]
Till Rohrmann commented on FLINK-1736:
--
I actually implemented a simple
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602905#comment-14602905
]
ASF GitHub Bot commented on FLINK-2116:
---
Github user tillrohrmann commented on the
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
[
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-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1645.
-
Resolution: Not A Problem
Move StreamingClassloaderITCase to flink-streaming
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
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
[
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-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-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-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2136.
-
Resolution: Fixed
Test the streaming scala API
Key:
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
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603293#comment-14603293
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user gyfora commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603295#comment-14603295
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user asfgit closed the pull request
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
[
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-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-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
-
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
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
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603152#comment-14603152
]
ASF GitHub Bot commented on FLINK-2138:
---
GitHub user gaborhermann opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603173#comment-14603173
]
ASF GitHub Bot commented on FLINK-2279:
---
Github user gyfora commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603569#comment-14603569
]
Aljoscha Krettek commented on FLINK-2122:
-
Why did you close this one?
Make all
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-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14603450#comment-14603450
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user gyfora commented on a diff in
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:
Christoph Alt created FLINK-2278:
Summary: SparseVector created from Breeze Sparsevector has wrong
size
Key: FLINK-2278
URL: https://issues.apache.org/jira/browse/FLINK-2278
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christoph Alt updated FLINK-2278:
-
Description:
The following code doesn't return true when testing equality of two
SparseVectors,
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christoph Alt updated FLINK-2278:
-
Description:
The following code doesn't return true when testing equality of two
SparseVectors,
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/844
---
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
[
https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602651#comment-14602651
]
ASF GitHub Bot commented on FLINK-2116:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/772
---
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
[
https://issues.apache.org/jira/browse/FLINK-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2214.
Resolution: Fixed
Fixed via 38ee125e49544c329d3723e12bbf21c046af8964
ALS predict and
[
https://issues.apache.org/jira/browse/FLINK-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602650#comment-14602650
]
ASF GitHub Bot commented on FLINK-2214:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2116.
--
Resolution: Fixed
Added via 7a7a294033ef99c596e59f670e2e4ae9262f5c5f
Make pipeline extension
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602654#comment-14602654
]
Till Rohrmann commented on FLINK-2278:
--
That's a good catch. I'll fix it immediately.
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
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602601#comment-14602601
]
ASF GitHub Bot commented on FLINK-2235:
---
Github user mxm commented on the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/868#discussion_r33340726
--- Diff: tools/create_release_files.sh ---
@@ -138,7 +146,7 @@ make_binary_release() {
echo Files in uberjar: $NUM_FILES_IN_UBERJAR. Uberjar: $UBERJAR
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/868#issuecomment-115601791
@hsaputra This is just refactoring. I think your changes improve the
readability of the code. Like Ufuk mentioned, it does not necessarily make the
script more flexible. Due
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/868#discussion_r33340734
--- Diff: tools/create_release_files.sh ---
@@ -85,37 +87,43 @@ else
fi
+prepare() {
+ # prepare
+ git clone
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/869#issuecomment-115638055
Sorry, I saw your PR too late. I just fixed the issue in the master.
A side note: You missed the `BreezeVectorConverter` in `SparseVector`.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602682#comment-14602682
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user tillrohrmann commented on the
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
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2278:
Assignee: Till Rohrmann
SparseVector created from Breeze Sparsevector has wrong size
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2278.
--
Resolution: Fixed
Fixed via bc3684e69aff1a73f7fb3a62b097e9fbb311cd71
SparseVector created
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602806#comment-14602806
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on a diff in
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-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14602863#comment-14602863
]
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 {
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
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
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602678#comment-14602678
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user chiwanpark commented on the
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/869#issuecomment-115636110
Nice catch and looks good to merge. :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602685#comment-14602685
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user ChristophAl commented on the
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
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602781#comment-14602781
]
ASF GitHub Bot commented on FLINK-2157:
---
GitHub user thvasilo opened a pull request:
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-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602879#comment-14602879
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the
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
GitHub user ChristophAl opened a pull request:
https://github.com/apache/flink/pull/869
[FLINK-2278] [ml] changed Vector fromBreeze
fromBreeze now takes the actual dimensionality instead of the non-zero
elements as size
You can merge this pull request into a Git repository by
Github user ChristophAl closed the pull request at:
https://github.com/apache/flink/pull/869
---
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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/869#issuecomment-115640417
Next time, you can directly assign the JIRA issue to yourself when you
create it, then we know that you will be working on this issue. Can you please
close this PR
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602687#comment-14602687
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user ChristophAl closed the pull
[
https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602686#comment-14602686
]
ASF GitHub Bot commented on FLINK-2278:
---
Github user tillrohrmann commented on the
Github user ChristophAl commented on the pull request:
https://github.com/apache/flink/pull/869#issuecomment-115640388
No worries,
and thanks for the note, I did indeed miss that!
---
If your project is set up for it, you can reply to this email and have your
reply appear on
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:
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
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602812#comment-14602812
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user mjsax commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602850#comment-14602850
]
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_r33353966
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -282,6 +282,54 @@ public void flatMap(EdgeK, EV edge,
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
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602858#comment-14602858
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
1 - 100 of 124 matches
Mail list logo
