[jira] [Commented] (FLINK-1732) Add Gaussian mixture model to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14598532#comment-14598532 ] ASF GitHub Bot commented on FLINK-1732: --- Github user shakir774 commented on the pull

[GitHub] flink pull request: FLINK-1732 Gaussian Mixture Model for Flink-ml...

Github user shakir774 commented on the pull request: https://github.com/apache/flink/pull/823#issuecomment-114666761 @thvasilo as we are busy with our next task of IMPRO-3.SS15 for the semester, once we finished with it, I will rebase it according to the new pipeline mechanism. ---

[GitHub] flink pull request: FLINK-2125

Github user hczerpak commented on the pull request: https://github.com/apache/flink/pull/862#issuecomment-114659058 mvn verify went successful with 0 errors but my travis ci doesn't finish everything correctly. Still don't have solution for that --- If your project is set up for it,

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14598488#comment-14598488 ] ASF GitHub Bot commented on FLINK-2125: --- Github user hczerpak commented on the pull

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14598483#comment-14598483 ] ASF GitHub Bot commented on FLINK-2125: --- GitHub user hczerpak opened a pull request:

[GitHub] flink pull request: FLINK-2125

GitHub user hczerpak opened a pull request: https://github.com/apache/flink/pull/862 FLINK-2125 Attempt to complete task https://issues.apache.org/jira/browse/FLINK-2125 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hczerpak/fli

[jira] [Commented] (FLINK-2198) BlobManager tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597888#comment-14597888 ] Sachin Goel commented on FLINK-2198: As far as I could figure out, windows doesn't all

[jira] [Commented] (FLINK-2116) Make pipeline extension require less coding

[ https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597836#comment-14597836 ] Sachin Goel commented on FLINK-2116: It would make sense to have three functions: pre

[jira] [Commented] (FLINK-2108) Add score function for Predictors

[ https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597818#comment-14597818 ] Sachin Goel commented on FLINK-2108: Hi Theodore, if you've started working on this, g

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33050123 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/OnlineHistogram.scala --- @@ -0,0 +1,81 @@ +/* + * Licensed to the Apa

[jira] [Updated] (FLINK-2264) Migrate integration tests for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2264: - Assignee: Samia Khalid > Migrate integration tests for Gelly > ---

[jira] [Created] (FLINK-2264) Migrate integration tests for Gelly

Vasia Kalavri created FLINK-2264: Summary: Migrate integration tests for Gelly Key: FLINK-2264 URL: https://issues.apache.org/jira/browse/FLINK-2264 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33047408 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/CategoricalHistogram.scala --- @@ -0,0 +1,173 @@ +/* + * Licensed to the Apa

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33046983 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/OnlineHistogram.scala --- @@ -0,0 +1,81 @@ +/* + * Licensed to the Apache So

[GitHub] flink pull request: [FLINK-2180] [streaming] Iteration test fix

Github user gaborhermann commented on the pull request: https://github.com/apache/flink/pull/802#issuecomment-114525454 Thanks for the heads up, I removed the aggregation test. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597731#comment-14597731 ] ASF GitHub Bot commented on FLINK-2180: --- Github user gaborhermann commented on the p

[GitHub] flink pull request: [Flink-1727][ml]Decision tree[WIP]

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r33046001 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to

[GitHub] flink pull request: implement a simple session management

Github user mxm closed the pull request at: https://github.com/apache/flink/pull/681 --- 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 enabled

[GitHub] flink pull request: implement a simple session management

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/681#issuecomment-114517003 Closing this in favor of the new pull request #858. --- 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 pr

[jira] [Closed] (FLINK-2262) ParameterTool API misnamed function

[ https://issues.apache.org/jira/browse/FLINK-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2262. - Resolution: Fixed Assignee: Maximilian Michels > ParameterTool API misnamed function

[jira] [Commented] (FLINK-2262) ParameterTool API misnamed function

[ https://issues.apache.org/jira/browse/FLINK-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597665#comment-14597665 ] Maximilian Michels commented on FLINK-2262: --- [~greghogan] It was pointed out to

[jira] [Updated] (FLINK-2262) ParameterTool API misnamed function

[ https://issues.apache.org/jira/browse/FLINK-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2262: -- Fix Version/s: 0.9.1 > ParameterTool API misnamed function > ---

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

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

[GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114501534 I don't think Kryo is handling classes implementing `Writable` in a special way. It should be trivial to add a special Kryo serializer for it (see also https://githu

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r33037235 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long getSizeOfFreeHeapMemor

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597614#comment-14597614 ] ASF GitHub Bot commented on FLINK-2235: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597603#comment-14597603 ] ASF GitHub Bot commented on FLINK-2235: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r33036711 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long getSizeOfFreeHeapMemor

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r33036608 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long getSizeOfFreeHeapMemor

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597602#comment-14597602 ] ASF GitHub Bot commented on FLINK-2235: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114481973 Hey @tillrohrmann , Sorry for the incredibly late reply. The last weeks have been very hectic. Nevertheless, I'd like to properly finish and polish this i

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597594#comment-14597594 ] ASF GitHub Bot commented on FLINK-2152: --- Github user andralungu commented on the pul

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597568#comment-14597568 ] Matthias J. Sax commented on FLINK-2032: I will take care of the tests in package

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597561#comment-14597561 ] Maximilian Michels commented on FLINK-2032: --- Hi [~vkalavri], I think it is a goo

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597555#comment-14597555 ] ASF GitHub Bot commented on FLINK-1962: --- Github user PieterJanVanAeken commented on

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

Github user PieterJanVanAeken commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-114468380 Hi, Thanks all for the comments. Unfortunately, I will be gone until the 13th of July so I will not be able to resolve these issues until then. They are

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-114426618 Oh, one more thing :) In order to make this work in Eclipse, I had to add a few lines to the pom.xml. Basically, I copied the `` block from the streaming-scala proje

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-114412170 ExecutionEnvironment.scala, UnionOperator.java and Graph.java have a lot of whitespace/formatting changes. This makes it hard to see the actual changes to functionality.

[jira] [Commented] (FLINK-2244) Add ability to start and stop persistent IaaS cluster

[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597372#comment-14597372 ] Maximilian Michels commented on FLINK-2244: --- I think [~tvas] suggests that we sh

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-114420568 Thanks @aljoscha for reminding me... This slipped my mind for a sec. I agree that the methods should have Scaladoc (this should be straightforward to add star

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/818#issuecomment-114430160 Hi @shghatge! Thank you for the quick update. Apart from my minor comment, this looks good now :) --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/818#discussion_r33026720 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -1234,6 +1248,17 @@ public void coGroup(Iterable> edge, Iterable> edg

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/861 [Flink-2030][ml]Online Histogram: Discrete and Categorical This implements the Online Histograms for both categorical and continuous data. For continuous data, we emulate a continuous probabil

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114410824 Thank you Sachin, I'll try to review 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] flink pull request: [FLINK-1962] Add Gelly Scala API

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-114422736 Hey, I also checked this over the weekend! (and realized how rusty my Scala has gotten :-S) I agree with both of you on the scaladocs, docs and formatti

[GitHub] flink pull request: [FLINK-2175] Allow multiple jobs in single jar...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-114409476 Travis failed in flink-tachyon (what happens regularly). My travis passed https://travis-ci.org/mjsax/flink/builds/67863816 Should be ready to get merged. --- If your

[GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114424839 Ah, okay. I was not aware that they are handled by a special writable serializer (that is subclass aware) and that still uses the writable logic. Is it s special kryo

[jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features

[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597370#comment-14597370 ] Theodore Vasiloudis commented on FLINK-2030: Hello Sachin, I'm reopening this,

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

[ https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597425#comment-14597425 ] ASF GitHub Bot commented on FLINK-2194: --- Github user StephanEwen commented on the pu

[jira] [Created] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries

Márton Balassi created FLINK-2263: - Summary: ExecutionGraph uses Thread.sleep to delay execution retries Key: FLINK-2263 URL: https://issues.apache.org/jira/browse/FLINK-2263 Project: Flink

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597426#comment-14597426 ] ASF GitHub Bot commented on FLINK-1962: --- Github user vasia commented on the pull req

[jira] [Updated] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2236: -- Fix Version/s: 0.9.1 > RowSerializer and CaseClassComparator are not in sync regarding N

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597434#comment-14597434 ] ASF GitHub Bot commented on FLINK-2093: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597436#comment-14597436 ] ASF GitHub Bot commented on FLINK-2093: --- Github user vasia commented on the pull req

[jira] [Reopened] (FLINK-2030) Implement an online histogram with Merging and equalization features

[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis reopened FLINK-2030: > Implement an online histogram with Merging and equalization features > ---

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597415#comment-14597415 ] ASF GitHub Bot commented on FLINK-1962: --- Github user vasia commented on the pull req

[jira] [Commented] (FLINK-2175) Allow multiple jobs in single jar file

[ https://issues.apache.org/jira/browse/FLINK-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597358#comment-14597358 ] ASF GitHub Bot commented on FLINK-2175: --- Github user mjsax commented on the pull req

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597407#comment-14597407 ] ASF GitHub Bot commented on FLINK-1962: --- Github user andralungu commented on the pul

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

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

[jira] [Commented] (FLINK-2262) ParameterTool API misnamed function

[ https://issues.apache.org/jira/browse/FLINK-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597449#comment-14597449 ] Maximilian Michels commented on FLINK-2262: --- Hi [~greghogan]! Could you open a p

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597403#comment-14597403 ] Vasia Kalavri commented on FLINK-2032: -- Hi there, I am working with a new contributor

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597445#comment-14597445 ] Maximilian Michels commented on FLINK-2236: --- This still needs to be fixed on the

[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-tabpanel&focusedCommentId=14597355#comment-14597355 ] ASF GitHub Bot commented on FLINK-1727: --- GitHub user sachingoel0101 opened a pull re

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597349#comment-14597349 ] ASF GitHub Bot commented on FLINK-2235: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r33020328 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long getSizeOfFreeHeapMemor

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r33019549 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long getSizeOfFreeHeapMemor

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597339#comment-14597339 ] ASF GitHub Bot commented on FLINK-2235: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

[ https://issues.apache.org/jira/browse/FLINK-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597336#comment-14597336 ] Till Rohrmann commented on FLINK-2197: -- I haven't found a good solution for this prob

[jira] [Updated] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

[ https://issues.apache.org/jira/browse/FLINK-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2197: - Description: If one uses the the Scala batch and streaming API from within the same program and im

[jira] [Commented] (FLINK-2214) ALS predict and empiricalRisk function can cause hash join function to exceed maximum number of recursions

[ https://issues.apache.org/jira/browse/FLINK-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597327#comment-14597327 ] ASF GitHub Bot commented on FLINK-2214: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-2214] [ml] Fixes prediction join operat...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/844#issuecomment-114403301 It's not a problem with the joins of the loop but instead with the single join of the empirical risk and prediction calculation. --- If your project is set up for i

[GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/854#issuecomment-114396094 The combiner partially sorts the records, to group subsequences in order to combine (reduce) them. If a record does not fit into a fresh sort buffer, then we

[jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver

[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597304#comment-14597304 ] ASF GitHub Bot commented on FLINK-1085: --- Github user StephanEwen commented on the pu