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

2015-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14597014#comment-14597014 ] ASF GitHub Bot commented on FLINK-1085: --- Github user dabaitu commented on the pull r

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

2015-06-22 Thread dabaitu
Github user dabaitu commented on the pull request: https://github.com/apache/flink/pull/854#issuecomment-114331577 @StephanEwen @fhueske - apologies, I forgot to call collect. A dumb question - why do we need to sort the records before combining them? Should I just call collect on

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

2015-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2262: - Summary: ParameterTool API misnamed function Key: FLINK-2262 URL: https://issues.apache.org/jira/browse/FLINK-2262 Project: Flink Issue Type: Bug Compone

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

2015-06-22 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/802#issuecomment-114252224 Reduce fold and aggregations are being removed from non-grouped DataStream, so we might want to remove that commit. --- If your project is set up for it, you can reply to

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

2015-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596585#comment-14596585 ] ASF GitHub Bot commented on FLINK-2180: --- Github user gyfora commented on the pull re

[jira] [Commented] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec

2015-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596576#comment-14596576 ] ASF GitHub Bot commented on FLINK-2255: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2255] [streaming] Fixed a bug in TopSpe...

2015-06-22 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/857#issuecomment-114250566 Looks good :+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 feature

[GitHub] flink pull request: [FLINK-2261] [streaming] Remove reduce/fold/ag...

2015-06-22 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/860 [FLINK-2261] [streaming] Remove reduce/fold/aggregations from DataStream You can merge this pull request into a Git repository by running: $ git pull https://github.com/gyfora/flink FLINK-2261

[jira] [Commented] (FLINK-2261) Remove reduce/aggregation from DataStream

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

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

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

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

2015-06-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114236910 Moreover, it would be inconsistent IMO with the rest of the typing system. Sometimes interfaces are supported and sometimes not. For the user, this might be confusin

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

2015-06-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114232368 The subtypes of `Writable` are still serialized using the special `Writable` serializer. However, there are situations where you only have a `Writable` type, e.g. fo

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

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

[jira] [Resolved] (FLINK-1319) Add static code analysis for UDFs

2015-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1319. Resolution: Fixed Fix Version/s: 0.10 0.9 Fixed via c854d5260c20b0926c4347

[jira] [Resolved] (FLINK-536) Integrate Static Code Analysis

2015-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-536. --- Resolution: Fixed > Integrate Static Code Analysis > -- > >

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596447#comment-14596447 ] Ufuk Celebi commented on FLINK-1319: Yes, JIRA was down the day I merged the PR. Will

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

2015-06-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596436#comment-14596436 ] Aljoscha Krettek commented on FLINK-2236: - Yes, in the release the RowSerializer i

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114211636 On that front, do you think it's possible to split the online histogram and the decision tree code into two PRs that we can review separately? If the online hist

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596391#comment-14596391 ] Theodore Vasiloudis commented on FLINK-2245: Yup for me the important thing is

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596381#comment-14596381 ] Robert Metzger commented on FLINK-1319: --- I guess we can close this issue? (and FLINK

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

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596378#comment-14596378 ] Theodore Vasiloudis commented on FLINK-2244: It would work differently for eac

[jira] [Updated] (FLINK-1541) GSoC project: Distributed profiling

2015-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1541: -- Assignee: (was: Robert Metzger) > GSoC project: Distributed profiling >

[jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596366#comment-14596366 ] Theodore Vasiloudis commented on FLINK-2186: That's correct, readTextFile is p

[jira] [Created] (FLINK-2261) Remove reduce/aggregation from DataStream

2015-06-22 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2261: - Summary: Remove reduce/aggregation from DataStream Key: FLINK-2261 URL: https://issues.apache.org/jira/browse/FLINK-2261 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2111] Add "terminate" signal to cleanly...

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-114188551 I disagree with the execution graph changes. I took us 6 months to get it stable, and we still discover corner cases. The new state interacts with all other states. U

[jira] [Commented] (FLINK-2111) Add "terminate" signal to cleanly stop streaming jobs

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

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/856#issuecomment-114184385 Here seems to be something with quite some broader implications. This affects the design of aggregations on windows and how they can be pre-aggregated. The w

[jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[jira] [Commented] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec

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

[GitHub] flink pull request: [FLINK-2255] [streaming] Fixed a bug in TopSpe...

2015-06-22 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/857#issuecomment-114184152 Thanks for spotting this, Gabor. 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

[GitHub] flink pull request: New operator state interfaces

2015-06-22 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-114180337 We have added a `KeyedDataStream` type to the API as you can see in the last commit. It is basically a supertype of `GroupDataStream` and represents a `DataStream` w

[GitHub] flink pull request: [streaming] Properly forward rich window funct...

2015-06-22 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/855#issuecomment-114179961 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 enabl

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

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

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

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

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

2015-06-22 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/754#issuecomment-114176855 Addressed @tillrohrmann's comments and rebased on master. @tillrohrmann, should we merge with your upcoming changes or can we merge it before? --- If your project is set up

[GitHub] flink pull request: [streaming] Properly forward rich window funct...

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/855#issuecomment-114177459 Looks good, +1 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 does not have

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

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

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-114176858 I think it will. I will try and add further code for the new webfrontend in the next days, and then open a new pull request that subsumes this one and #297 --- If yo

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

2015-06-22 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114173765 The fundamental idea for a scalable decision tree algorithm is to reduce the number of splits required to be checked at every node. Ideally, we'd check for every v

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596188#comment-14596188 ] Stephan Ewen commented on FLINK-2245: - Ah, sorry, confusion: You were talking about th

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596187#comment-14596187 ] Stephan Ewen commented on FLINK-2245: - I would actually assume that programs with mult

[jira] [Resolved] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis

2015-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2204. Resolution: Fixed > Tez ConnectedComponentsStepITCase fails spuriously on Travis > -

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

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

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

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-114165604 +1 for adding this, looks good! --- 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 n

[jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596116#comment-14596116 ] Stephan Ewen commented on FLINK-2186: - Not sure if we can/want to fix this on the gene

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

2015-06-22 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/859 [FLINK-2235] fix calculation of free memory for local execution The Java runtime may return Long.MAX_VALUE for a call to the maxMemory() method of the Runtime class. In these cases, we simply use the

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

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

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

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596107#comment-14596107 ] Stephan Ewen commented on FLINK-2244: - This is a very generic/broad feature. This woul

[GitHub] flink pull request: New operator state interfaces

2015-06-22 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r32949021 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/PartitionedStreamOperatorState.java --- @@ -0

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

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596102#comment-14596102 ] Stephan Ewen commented on FLINK-2235: - Sounds like a good way to fix this... > Local

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

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596100#comment-14596100 ] Stephan Ewen commented on FLINK-2236: - I think this is fixed in the release, correct?

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

2015-06-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596099#comment-14596099 ] Maximilian Michels commented on FLINK-2235: --- Actually, I think the explanation i

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114154438 Helo @sachingoel0101, I've started reviewing this PR. It would help a lot if you check out these initial comments I made and try to fix similar issues throughout the PR.

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

2015-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/811 --- 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-1727) Add decision tree to machine learning library

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

[jira] [Commented] (FLINK-2230) Add Support for Null-Values in TupleSerializer

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596084#comment-14596084 ] Stephan Ewen commented on FLINK-2230: - There have been many discussions about whether

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

2015-06-22 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/811#issuecomment-114153093 Thanks, merging then. --- 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 featu

[jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596071#comment-14596071 ] Stephan Ewen commented on FLINK-2231: - Exactly, the createTypeInformation macro needs

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

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

[GitHub] flink pull request: [FLINK-2209] Document linking with jars not in...

2015-06-22 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/835#issuecomment-114149626 I do not think that we can expect that every user starts from the quickstart poms, but it is true that a reference to that would have been nicer. I have to admi

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

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596056#comment-14596056 ] Theodore Vasiloudis commented on FLINK-2108: Hello Sachin, could you give us a

[GitHub] flink pull request: [FLINK-2209] Document linking with jars not in...

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/835#issuecomment-114143834 I am a bit confused here. With the quickstart maven projects, fat jar building works without configuring, as it defines proper assembly and share configurations for f

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596054#comment-14596054 ] Stephan Ewen commented on FLINK-2209: - Reopened this, because I think this documentati

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

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

[jira] [Reopened] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-2209: - Assignee: (was: Márton Balassi) > Document how to use TableAPI, Gelly and FlinkML, Streaming

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

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

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

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

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

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

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

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

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32943140 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/tree/Tree.scala --- @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache Software Foun

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32942958 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/tree/Tree.scala --- @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache Software Foun

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

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

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

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

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

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

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

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

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

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-2157: --- Fix Version/s: 0.10 > Create evaluation framework for ML library > ---

[jira] [Updated] (FLINK-2260) Have a complete model evaluation and selection framework for FlinkML

2015-06-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-2260: --- Description: This is an umbrella ticket to keep track on the work on the model evaluat

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

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

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-114135260 Hello @peedeeX21 , most of the failing Travis tests have been fixed in the current master, could you try rebasing this PR and making a forced push to this branch? ---

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

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/823#issuecomment-114134005 Hello @shakir774 , as @sachingoel0101 mentioned you must rebase your current implementation on the current master as the underlying code for FlinkML has changed consider

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

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

[GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a...

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-114132214 Hello, wondering what the status is on this 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 pr

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

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

[jira] [Commented] (FLINK-2097) Add support for JobSessions

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

[GitHub] flink pull request: [FLINK-2097] Implement job session management

2015-06-22 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/858 [FLINK-2097] Implement job session management This is a joint effort by @StephanEwen and me to introduce a session management in Flink. Session are used to keep a copy of the ExecutionGraph in the job m

[jira] [Updated] (FLINK-2251) Implement job session management

2015-06-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2251: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-2250) > Impleme

[jira] [Updated] (FLINK-2097) Add support for JobSessions

2015-06-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2097: -- Issue Type: Sub-task (was: New Feature) Parent: FLINK-2250 > Add support for Jo

[jira] [Closed] (FLINK-2251) Implement job session management

2015-06-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2251. - Resolution: Duplicate > Implement job session management > ---

[jira] [Commented] (FLINK-2111) Add "terminate" signal to cleanly stop streaming jobs

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

[GitHub] flink pull request: [FLINK-2111] Add "terminate" signal to cleanly...

2015-06-22 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-114123970 I agree that extending the state graph is critical. However, IMHO it is the right way to go. I would rather spend more time on getting it right in the first place, than int

[jira] [Created] (FLINK-2260) Have a complete model evaluation and selection framework for FlinkML

2015-06-22 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2260: -- Summary: Have a complete model evaluation and selection framework for FlinkML Key: FLINK-2260 URL: https://issues.apache.org/jira/browse/FLINK-2260 Projec

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

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

[GitHub] flink pull request: [FLINK-2116] [ml] Reusing predict operation fo...

2015-06-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/772#issuecomment-114117337 OK so as I understand it this PR is about splitting the prediction with Vector and LabeledVector input into two functions instead of one as it is now. This allow

[GitHub] flink pull request: [FLINK-2111] Add "terminate" signal to cleanly...

2015-06-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-114109425 I had a look at your code. A lot of it looks good. The one thing I would really like to change is the modification of the execution graph state machine. That

[jira] [Commented] (FLINK-2111) Add "terminate" signal to cleanly stop streaming jobs

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

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

2015-06-22 Thread Mikio Braun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikio Braun reassigned FLINK-2157: -- Assignee: Mikio Braun > Create evaluation framework for ML library > --

[jira] [Created] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

2015-06-22 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2259: -- Summary: Support training Estimators using a (train, validation, test) split of the available data Key: FLINK-2259 URL: https://issues.apache.org/jira/browse/FLINK-225

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

2015-06-22 Thread Mikio Braun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikio Braun reassigned FLINK-2157: -- Assignee: (was: Mikio Braun) > Create evaluation framework for ML library > ---

[jira] [Commented] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis

2015-06-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595910#comment-14595910 ] Stephan Ewen commented on FLINK-2204: - Hmm, looks again like a Tez issue. No Flink c

  1   2   >