[jira] [Updated] (FLINK-1622) Add GroupReducePartial Operator

2015-03-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1622: -- Labels: Local (was: ) Add GroupReducePartial Operator ---

[jira] [Updated] (FLINK-1622) Add GroupReducePartial Operator

2015-03-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1622: -- Component/s: Local Runtime Add GroupReducePartial Operator ---

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367506#comment-14367506 ] ASF GitHub Bot commented on FLINK-1739: --- Github user StephanEwen commented on the

[jira] [Updated] (FLINK-1622) Add GroupReducePartial Operator

2015-03-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1622: -- Labels: (was: Local) Add GroupReducePartial Operator ---

[jira] [Commented] (FLINK-1669) Streaming tests for recovery with distributed process failure

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367505#comment-14367505 ] ASF GitHub Bot commented on FLINK-1669: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/499#issuecomment-83065881 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

[GitHub] flink pull request: [FLINK-1669] [wip] Test for streaming recovery...

2015-03-18 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/496#issuecomment-83065828 I would not suspect that as the batch is using the same config on paper. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Assigned] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paris Carbone reassigned FLINK-1740: Assignee: Paris Carbone StreamExecutionEnvironment is not respecting the

[jira] [Resolved] (FLINK-1622) Add GroupReducePartial Operator

2015-03-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1622. --- Resolution: Implemented Fix Version/s: 0.9 Add GroupReducePartial Operator

[jira] [Resolved] (FLINK-1621) Create a generalized combine function

2015-03-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1621. --- Resolution: Fixed Assignee: Maximilian Michels Resolved by implementing a

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367559#comment-14367559 ] ASF GitHub Bot commented on FLINK-1679: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

2015-03-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/488#issuecomment-83102692 With 236 files, that is hard to assess... That is a point, in general, with humongous pull requests that touch 10 projects at the same time. I would

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367568#comment-14367568 ] ASF GitHub Bot commented on FLINK-1679: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-1709) Add support for programs with slot count exceeding parallelism

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367578#comment-14367578 ] ASF GitHub Bot commented on FLINK-1709: --- Github user StephanEwen commented on the

[jira] [Created] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-03-18 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-1741: -- Summary: Add Jaccard Similarity Metric Example Key: FLINK-1741 URL: https://issues.apache.org/jira/browse/FLINK-1741 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-1738) Add mean centering transformation to machine learning library

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1738: - Issue Type: New Feature (was: Improvement) Add mean centering transformation to machine

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

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1732: - Issue Type: New Feature (was: Improvement) Add Gaussian mixture model to machine learning

[jira] [Updated] (FLINK-1727) Add decision tree to machine learning library

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1727: - Issue Type: New Feature (was: Improvement) Add decision tree to machine learning library

[jira] [Updated] (FLINK-1737) Add statistical whitening transformation to machine learning library

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1737: - Issue Type: New Feature (was: Improvement) Add statistical whitening transformation to machine

[jira] [Updated] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1719: - Issue Type: New Feature (was: Improvement) Add naive Bayes classification algorithm to machine

[jira] [Updated] (FLINK-1717) Add support to read libSVM and SVMLight input files

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1717: - Issue Type: New Feature (was: Improvement) Add support to read libSVM and SVMLight input files

[jira] [Updated] (FLINK-1723) Add cross validation for parameter selection and validation

2015-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1723: - Issue Type: New Feature (was: Improvement) Add cross validation for parameter selection and

[jira] [Assigned] (FLINK-1701) Serialization problems with TestStreamEnvironment

2015-03-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1701: -- Assignee: Péter Szabó Serialization problems with TestStreamEnvironment

[jira] [Closed] (FLINK-1701) Serialization problems with TestStreamEnvironment

2015-03-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó closed FLINK-1701. -- Resolution: Fixed Anonymous inner classes are serializable only if the enclosing class is serilizable.

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/501#discussion_r26704861 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java --- @@ -276,7 +276,7 @@ public void

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/501#discussion_r26704856 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java --- @@ -58,7 +58,7 @@ */ public class

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367847#comment-14367847 ] ASF GitHub Bot commented on FLINK-1740: --- Github user hsaputra commented on a diff in

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367846#comment-14367846 ] ASF GitHub Bot commented on FLINK-1740: --- Github user hsaputra commented on a diff in

[jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-03-18 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367867#comment-14367867 ] Alexander Alexandrov commented on FLINK-1741: - I think we had some similar

[jira] [Created] (FLINK-1743) Add multinomial logistic regression to machine learning library

2015-03-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1743: Summary: Add multinomial logistic regression to machine learning library Key: FLINK-1743 URL: https://issues.apache.org/jira/browse/FLINK-1743 Project: Flink

[jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-03-18 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367883#comment-14367883 ] Andra Lungu commented on FLINK-1741: Hi Alex, Thanks for the tip! I'd like to

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

2015-03-18 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14368071#comment-14368071 ] Henry Saputra commented on FLINK-1744: -- Simple grep in the source code repo: {code}

[jira] [Updated] (FLINK-1688) Add socket sink

2015-03-18 Thread Miguel Angel Fernandez Diaz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Angel Fernandez Diaz updated FLINK-1688: --- Attachment: improvement.patch Added text to the documentation.

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-18 Thread matadorhong
Github user matadorhong commented on the pull request: https://github.com/apache/flink/pull/499#issuecomment-83238963 Have modified the port range of TaskManager in [0, 65535] --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14368248#comment-14368248 ] ASF GitHub Bot commented on FLINK-1739: --- Github user matadorhong commented on the

[jira] [Closed] (FLINK-1734) Insufficient memory allocation in Gelly

2015-03-18 Thread Robert Waury (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Waury closed FLINK-1734. --- Resolution: Not a Problem Bug in user code caused the problem (see mailing list) Insufficient

[jira] [Created] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

2015-03-18 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-1744: Summary: Change the reference of slaves to workers to match the description of the system Key: FLINK-1744 URL: https://issues.apache.org/jira/browse/FLINK-1744

[GitHub] flink pull request: Flink 1740

2015-03-18 Thread senorcarbone
GitHub user senorcarbone opened a pull request: https://github.com/apache/flink/pull/501 Flink 1740 We now use the config parameter for numberofExecutionRetries on the generated job graph. Also piggypacked a minor fix for a compilation error that currently occurs in

[GitHub] flink pull request: [FLINK-1622][java-api][scala-api] add a GroupC...

2015-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/466 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request: Improvements to Kafka Source/Sink some bugfi...

2015-03-18 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26686592 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/pom.xml --- @@ -46,9 +53,13 @@ under the License. dependency

[jira] [Assigned] (FLINK-1622) Add GroupReducePartial Operator

2015-03-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-1622: - Assignee: Maximilian Michels Add GroupReducePartial Operator

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

2015-03-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/488#issuecomment-83100904 Are we sure that this is breaking no existing API. No method on DataSet or any descendant of it has been renamed? Also not on other user facing types? --- If your

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/499#discussion_r26690147 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1274,9 +1274,10 @@ object TaskManager {

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367570#comment-14367570 ] ASF GitHub Bot commented on FLINK-1679: --- Github user StephanEwen commented on the

[jira] [Created] (FLINK-1742) Sample data points for MultipleLinearRegression to support proper SGD

2015-03-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1742: Summary: Sample data points for MultipleLinearRegression to support proper SGD Key: FLINK-1742 URL: https://issues.apache.org/jira/browse/FLINK-1742 Project: Flink

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367666#comment-14367666 ] ASF GitHub Bot commented on FLINK-1739: --- Github user matadorhong commented on a diff

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367993#comment-14367993 ] ASF GitHub Bot commented on FLINK-1740: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83197775 Indeed, cool. Good to know --- 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

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14368001#comment-14368001 ] ASF GitHub Bot commented on FLINK-1740: --- Github user senorcarbone commented on the

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367799#comment-14367799 ] ASF GitHub Bot commented on FLINK-1739: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-18 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/499#issuecomment-83150196 +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 project does not have this feature

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367905#comment-14367905 ] Márton Balassi commented on FLINK-1740: --- That is actually a good question whether we

[jira] [Commented] (FLINK-1669) Streaming tests for recovery with distributed process failure

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367962#comment-14367962 ] ASF GitHub Bot commented on FLINK-1669: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83193360 Added a comment to the JIRA issue, but the suggestion make sense, @senorcarbone. Let me add a bit of doc and merge this. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367978#comment-14367978 ] ASF GitHub Bot commented on FLINK-1740: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread senorcarbone
Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/501#discussion_r26711053 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java --- @@ -58,7 +58,7 @@ */ public class

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83196555 Thanks @mbalassi! If you merge can you remove the quickfix (2872308)? It looks like @hsaputra pushed it already --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-1669] [wip] Test for streaming recovery...

2015-03-18 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/496#issuecomment-83186250 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

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367986#comment-14367986 ] ASF GitHub Bot commented on FLINK-1740: --- Github user senorcarbone commented on a

[GitHub] flink pull request: FLINK-1740

2015-03-18 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83196855 Sure, rebasing to master does that. --- 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

<    1   2