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

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611544#comment-14611544 ] ASF GitHub Bot commented on FLINK-1085: --- Github user dabaitu commented on a diff in

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

2015-07-01 Thread dabaitu
Github user dabaitu commented on a diff in the pull request: https://github.com/apache/flink/pull/854#discussion_r33749843 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/CombineTaskTest.java --- @@ -92,7 +92,35 @@ public void testCombineTask() {

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

2015-07-01 Thread dabaitu
Github user dabaitu commented on a diff in the pull request: https://github.com/apache/flink/pull/854#discussion_r33749807 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java --- @@ -170,7 +171,14 @@ public void run() throws Excep

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

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611542#comment-14611542 ] ASF GitHub Bot commented on FLINK-1085: --- Github user dabaitu commented on a diff in

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

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611454#comment-14611454 ] ASF GitHub Bot commented on FLINK-1085: --- Github user dabaitu commented on a diff in

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

2015-07-01 Thread dabaitu
Github user dabaitu commented on a diff in the pull request: https://github.com/apache/flink/pull/854#discussion_r33746632 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java --- @@ -170,7 +171,12 @@ public void run() throws Excep

[GitHub] flink pull request: [FLINK-2272] [ml] [docs] Move vision and roadm...

2015-07-01 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/864#issuecomment-117860517 Good. +1 for 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 thi

[jira] [Commented] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611240#comment-14611240 ] ASF GitHub Bot commented on FLINK-2272: --- Github user chiwanpark commented on the pul

[jira] [Commented] (FLINK-2307) Drop Java 6 support

2015-07-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611026#comment-14611026 ] Matthias J. Sax commented on FLINK-2307: This change should also update Storm depe

[jira] [Updated] (FLINK-2310) Add an Adamic-Adar Similarity example

2015-07-01 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-2310: --- Assignee: Shivani Ghatge > Add an Adamic-Adar Similarity example > ---

[jira] [Created] (FLINK-2310) Add an Adamic-Adar Similarity example

2015-07-01 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2310: -- Summary: Add an Adamic-Adar Similarity example Key: FLINK-2310 URL: https://issues.apache.org/jira/browse/FLINK-2310 Project: Flink Issue Type: Task Co

[jira] [Commented] (FLINK-2309) Use static code analysis to replace selector functions with field accesses.

2015-07-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610929#comment-14610929 ] Fabian Hueske commented on FLINK-2309: -- This is a very nice idea! Key selector funct

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610786#comment-14610786 ] ASF GitHub Bot commented on FLINK-1520: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-01 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-117787551 Nice and rebased. +1 --- 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

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610780#comment-14610780 ] ASF GitHub Bot commented on FLINK-2141: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-01 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/877#issuecomment-117785914 LGTM :) @vasia ? --- 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 fe

[jira] [Created] (FLINK-2309) Use static code analysis to replace selector functions with field accesses.

2015-07-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2309: --- Summary: Use static code analysis to replace selector functions with field accesses. Key: FLINK-2309 URL: https://issues.apache.org/jira/browse/FLINK-2309 Project: Flin

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610556#comment-14610556 ] ASF GitHub Bot commented on FLINK-1731: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

2015-07-01 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-117731195 @peedeeX21 , try this link: https://github.com/sachingoel0101/flink/compare/clustering_initializations...peedeeX21:feature_kmeans I had a lot of trouble getting

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

2015-07-01 Thread Shivani Ghatge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610527#comment-14610527 ] Shivani Ghatge commented on FLINK-2093: --- Thank you :) > Add a difference method to

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-01 Thread shghatge
Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/877#issuecomment-117730019 Updated PR. --- 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 en

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610553#comment-14610553 ] ASF GitHub Bot commented on FLINK-1731: --- Github user peedeeX21 commented on the pull

[jira] [Resolved] (FLINK-2158) NullPointerException in DateSerializer.

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2158. - Resolution: Fixed Fix Version/s: 0.10 Fixed in 4e9e0d6839ba1a817432169bf6ed7b777e3096d6 >

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610550#comment-14610550 ] ASF GitHub Bot commented on FLINK-2141: --- Github user shghatge commented on the pull

[GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

2015-07-01 Thread peedeeX21
Github user peedeeX21 commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-117730349 @sachingoel0101 me creating a pull request for your repo would be the best. But for some reason I can't choose your repo as base fork. --- If your project is set up f

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610529#comment-14610529 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on the pull

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-01 Thread shghatge
Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-117728162 Updated PR --- 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 ena

[jira] [Closed] (FLINK-2158) NullPointerException in DateSerializer.

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2158. --- > NullPointerException in DateSerializer. > --- > > Ke

[jira] [Resolved] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2308. - Resolution: Fixed Fixed in f5c1768aa730fb6be74c0ebf480675acb1488d4f > Improve error messages on b

[jira] [Closed] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2308. --- > Improve error messages on broken user-defined serialization > --

[jira] [Resolved] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2275. - Resolution: Fixed Fix Version/s: 0.10 Fixed in a137321acfce02d62ce48e03b5de37c388152d28 Th

[jira] [Commented] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610516#comment-14610516 ] ASF GitHub Bot commented on FLINK-2275: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2158) NullPointerException in DateSerializer.

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610517#comment-14610517 ] ASF GitHub Bot commented on FLINK-2158: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2275. --- > Migrate test from package 'org.apache.flink.test.javaApiOperators' > ---

[GitHub] flink pull request: [FLINK-2158] Add support for null to the DateS...

2015-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/780 --- 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] flink pull request: [FLINK-2275] Migrate test from package 'org.ap...

2015-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/866 --- 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] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

2015-07-01 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-117723450 @thvasilo , how do I merge this PR into mine? Maybe @peedeeX21 can create a pull request to my branch at https://github.com/sachingoel0101/flink/tree/clustering_in

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610506#comment-14610506 ] ASF GitHub Bot commented on FLINK-1731: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610503#comment-14610503 ] ASF GitHub Bot commented on FLINK-2131: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

2015-07-01 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-117722491 @thvasilo , right now, there aren't other features in the library which need sampling. Perhaps it isn't a good idea to file a separate feature request. But, if nee

[jira] [Commented] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610440#comment-14610440 ] Stephan Ewen commented on FLINK-2308: - Have a very simple patch coming up that only ca

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610436#comment-14610436 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

2015-07-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33688371 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -141,6 +144,25 @@ public boolean isClosureCleanerEnabled() {

[jira] [Commented] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610433#comment-14610433 ] Ufuk Celebi commented on FLINK-2308: +1 > Improve error messages on broken user-defin

[jira] [Updated] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2308: --- Fix Version/s: 0.10 > Improve error messages on broken user-defined serialization > --

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610428#comment-14610428 ] ASF GitHub Bot commented on FLINK-1967: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

2015-07-01 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33687769 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -141,6 +144,25 @@ public boolean isClosureCleanerEnabled() {

[jira] [Resolved] (FLINK-2303) Add count method to GroupedDataStream

2015-07-01 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann resolved FLINK-2303. -- Resolution: Not A Problem > Add count method to GroupedDataStream >

[jira] [Commented] (FLINK-2303) Add count method to GroupedDataStream

2015-07-01 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610412#comment-14610412 ] Gábor Hermann commented on FLINK-2303: -- Okay, I will mark it as not an issue. > Add

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610400#comment-14610400 ] ASF GitHub Bot commented on FLINK-1967: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

2015-07-01 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/879 [FLINK-1967] Introduce (Event)time in Streaming (This PR consists of other commits because of bugs discovered while writing tests for the new feature and existing features.) This is the fir

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-01 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/871#issuecomment-117700685 Copying from the JIRA: Turns out it's more complicated to have a score function that is available for chained Predictors as well. If score is defined as

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610390#comment-14610390 ] ASF GitHub Bot commented on FLINK-2157: --- Github user thvasilo commented on the pull

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

2015-07-01 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610382#comment-14610382 ] Theodore Vasiloudis commented on FLINK-2108: Turns out it's more complicated t

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

2015-07-01 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608336#comment-14608336 ] Theodore Vasiloudis edited comment on FLINK-2108 at 7/1/15 2:32 PM:

[jira] [Created] (FLINK-2308) Improve error messages on broken user-defined serialization

2015-07-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2308: --- Summary: Improve error messages on broken user-defined serialization Key: FLINK-2308 URL: https://issues.apache.org/jira/browse/FLINK-2308 Project: Flink Issu

[jira] [Commented] (FLINK-2158) NullPointerException in DateSerializer.

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610287#comment-14610287 ] ASF GitHub Bot commented on FLINK-2158: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2158] Add support for null to the DateS...

2015-07-01 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/780#issuecomment-117686427 Will merge this... --- 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

[GitHub] flink pull request: [FLINK-2275] Migrate test from package 'org.ap...

2015-07-01 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/866#issuecomment-117684978 Looks good, let me merge this... --- 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

[jira] [Commented] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610281#comment-14610281 ] ASF GitHub Bot commented on FLINK-2275: --- Github user StephanEwen commented on the pu

[jira] [Resolved] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2298. --- Resolution: Fixed Fix Version/s: 0.9.1 0.10 Fixed for 0.10 in http:/

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610231#comment-14610231 ] ASF GitHub Bot commented on FLINK-2298: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/876 --- 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

[jira] [Commented] (FLINK-2303) Add count method to GroupedDataStream

2015-07-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610215#comment-14610215 ] Aljoscha Krettek commented on FLINK-2303: - -1 We are having the discussion right n

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610200#comment-14610200 ] ASF GitHub Bot commented on FLINK-2298: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/876#issuecomment-117663964 :+1: Thanks :) --- 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 enab

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610197#comment-14610197 ] ASF GitHub Bot commented on FLINK-2298: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/876#issuecomment-117662372 Which comment? I added a test also for the short variant. Merging this ... --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2176) Add support for ProgramDesctiption interface in clients

2015-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610143#comment-14610143 ] Robert Metzger commented on FLINK-2176: --- Thx for closing. I forgot that because I ha

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610068#comment-14610068 ] ASF GitHub Bot commented on FLINK-2304: --- GitHub user mjsax opened a pull request:

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

2015-07-01 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/878 [FLINK-2304] Add named attribute access to Storm compatibility layer - extended FlinkTuple to enable named attribute access - extended BoltWrapper for user defined input schema - extended

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610057#comment-14610057 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

2015-07-01 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/875#issuecomment-117649187 Close and re-open in new branch to link to JIRA. --- 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

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610058#comment-14610058 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax closed the pull request a

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

2015-07-01 Thread mjsax
Github user mjsax closed the pull request at: https://github.com/apache/flink/pull/875 --- 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 enable

[jira] [Closed] (FLINK-2176) Add support for ProgramDesctiption interface in clients

2015-07-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2176. -- Resolution: Fixed Resolved by https://github.com/apache/flink/pull/707 See https://issues.apache

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

2015-07-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2175. -- Resolution: Fixed Resolved by https://github.com/apache/flink/pull/707 > Allow multiple jobs in

[GitHub] flink pull request: [FLINK-2138] Added custom partitioning to Data...

2015-07-01 Thread gaborhermann
Github user gaborhermann commented on the pull request: https://github.com/apache/flink/pull/872#issuecomment-117644273 Sorry. * updated the docs (custom partitioning was also missing in the Scala batch API docs) * added IT case tests (also for the other stream partitioning met

[jira] [Commented] (FLINK-2138) PartitionCustom for streaming

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610043#comment-14610043 ] ASF GitHub Bot commented on FLINK-2138: --- Github user gaborhermann commented on the p

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/876#issuecomment-117630964 Looks good except for the test case comment I made. --- 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] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610013#comment-14610013 ] ASF GitHub Bot commented on FLINK-2298: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609997#comment-14609997 ] ASF GitHub Bot commented on FLINK-2298: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/876#discussion_r33671148 --- Diff: flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -121,6 +121,7 @@ public void testDetachedMode() {

[jira] [Commented] (FLINK-1991) Return Table as DataSet

2015-07-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609964#comment-14609964 ] Timo Walther commented on FLINK-1991: - +1 I was also looking for this feature and coul

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609950#comment-14609950 ] ASF GitHub Bot commented on FLINK-2298: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/876#issuecomment-117613418 Thx for the good PR, Robert :) +1 LGTM --- 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 projec

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

2015-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/707 --- 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

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

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609930#comment-14609930 ] ASF GitHub Bot commented on FLINK-2175: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-2307) Drop Java 6 support

2015-07-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2307: - Summary: Drop Java 6 support Key: FLINK-2307 URL: https://issues.apache.org/jira/browse/FLINK-2307 Project: Flink Issue Type: Improvement Compone

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609875#comment-14609875 ] ASF GitHub Bot commented on FLINK-2298: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/876#issuecomment-117581828 I've addressed your concerns and updated the PR. --- 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-2297] [ml] Add threshold setting for SV...

2015-07-01 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/874#issuecomment-117574076 After discussing with, we decided that one parameter determining the value of the threshold _and_ whether we output the thresholded values or not is ambiguous.

[jira] [Commented] (FLINK-2297) Add threshold setting for SVM binary predictions

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609856#comment-14609856 ] ASF GitHub Bot commented on FLINK-2297: --- Github user thvasilo commented on the pull

[GitHub] flink pull request: [FLINK-2297] [ml] Add threshold setting for SV...

2015-07-01 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/874#discussion_r33663520 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/SVM.scala --- @@ -242,8 +275,21 @@ object SVM{ } }

[jira] [Commented] (FLINK-2297) Add threshold setting for SVM binary predictions

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609840#comment-14609840 ] ASF GitHub Bot commented on FLINK-2297: --- Github user thvasilo commented on a diff in

[jira] [Created] (FLINK-2306) Add support for named streams in Storm compatibility layer

2015-07-01 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2306: -- Summary: Add support for named streams in Storm compatibility layer Key: FLINK-2306 URL: https://issues.apache.org/jira/browse/FLINK-2306 Project: Flink

[GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio...

2015-07-01 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/876#discussion_r33662529 --- Diff: docs/setup/yarn_setup.md --- @@ -100,11 +100,13 @@ Usage: -D Dynamic properties -d,--detached

[jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609825#comment-14609825 ] ASF GitHub Bot commented on FLINK-2298: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-2297) Add threshold setting for SVM binary predictions

2015-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609822#comment-14609822 ] ASF GitHub Bot commented on FLINK-2297: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: [FLINK-2297] [ml] Add threshold setting for SV...

2015-07-01 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/874#discussion_r33662458 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala --- @@ -121,7 +121,7 @@ object Predictor { in

  1   2   >