[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

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

[jira] [Resolved] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1820. -- Resolution: Fixed Resolved with ea23f28c449a1a11e509ca62a36f770a6940d40a Thanks for the fix!

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/685#issuecomment-103389217 This PR needs also to be rebased on the current master because the `ParserTestBase` has been extended. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550001#comment-14550001 ] ASF GitHub Bot commented on FLINK-2025: --- Github user fhueske commented on the pull

[jira] [Commented] (FLINK-2003) Building on some encrypted filesystems leads to File name too long error

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550014#comment-14550014 ] ASF GitHub Bot commented on FLINK-2003: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: [FLINK-2003] Building on some encrypted filesy...

2015-05-19 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/690#discussion_r30577392 --- Diff: flink-yarn/pom.xml --- @@ -113,6 +113,10 @@ under the License. jvmArg-Xms128m/jvmArg

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1985: - Reporter: Matthias J. Sax (was: Aljoscha Krettek) Streaming does not correctly forward

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14549995#comment-14549995 ] ASF GitHub Bot commented on FLINK-1820: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550035#comment-14550035 ] Stephan Ewen commented on FLINK-2040: - Funny, I just saw the same thing...

[jira] [Commented] (FLINK-2003) Building on some encrypted filesystems leads to File name too long error

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

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550093#comment-14550093 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1523] vertex-centric iteration extensio...

2015-05-19 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/680#issuecomment-103411372 Thanks for the review @andralungu! I rebased again because of the iteration configuration changes. If no objections, I would like merge this tonight. --- If your

[jira] [Commented] (FLINK-2034) Add vision and roadmap for ML library to docs

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550113#comment-14550113 ] Till Rohrmann commented on FLINK-2034: -- Will do it. Add vision and roadmap for ML

[jira] [Commented] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550038#comment-14550038 ] Stephan Ewen commented on FLINK-2040: - The cause is the following: It may be (very

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550040#comment-14550040 ] Fabian Hueske commented on FLINK-2026: -- That might be counter-intuitive for users who

[GitHub] flink pull request: [FLINK-2003] Building on some encrypted filesy...

2015-05-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/690#issuecomment-103400415 Yeah, I think that this may impact the compatibility of our code with other code. A better approach would be IMHO to try and reduce the length of the

[jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550058#comment-14550058 ] Stephan Ewen commented on FLINK-2042: - I would like to increase the entire figure,

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550056#comment-14550056 ] Stephan Ewen commented on FLINK-2026: - +1 for a good error message. I agree with

[jira] [Assigned] (FLINK-2009) Time-Based Windows fail with Chaining Disabled

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2009: --- Assignee: Aljoscha Krettek Time-Based Windows fail with Chaining Disabled

[jira] [Commented] (FLINK-2038) Extend headline of website

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550066#comment-14550066 ] Stephan Ewen commented on FLINK-2038: - How about making the scalable part of the

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550068#comment-14550068 ] Robert Metzger commented on FLINK-2036: --- No, this is still an open issue. I am

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-19 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/682#discussion_r30580847 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -543,6 +542,144 @@ public void disableAutoTypeRegistration() {

[jira] [Closed] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2040. --- TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

[GitHub] flink pull request: [FLINK-2034] [docs] Add vision and roadmap for...

2015-05-19 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/688#issuecomment-103413605 Pinging @tillrohrmann to take a look. --- 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

[jira] [Commented] (FLINK-2034) Add vision and roadmap for ML library to docs

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550112#comment-14550112 ] ASF GitHub Bot commented on FLINK-2034: --- Github user thvasilo commented on the pull

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread Sebastian Schelter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550017#comment-14550017 ] Sebastian Schelter commented on FLINK-2026: --- Wouldn't it be best to simply

[jira] [Created] (FLINK-2042) Increase font size for stack figure on website home

2015-05-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2042: Summary: Increase font size for stack figure on website home Key: FLINK-2042 URL: https://issues.apache.org/jira/browse/FLINK-2042 Project: Flink Issue

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550062#comment-14550062 ] Aljoscha Krettek commented on FLINK-2036: - [~rmetzger] This should be resolved

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1985: Reporter: Aljoscha Krettek (was: Matthias J. Sax) Streaming does not correctly forward

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1985: Assignee: Matthias J. Sax (was: Aljoscha Krettek) Streaming does not correctly forward

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

2015-05-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550076#comment-14550076 ] Márton Balassi commented on FLINK-2036: --- You can submit multiple different

[jira] [Commented] (FLINK-2003) Building on some encrypted filesystems leads to File name too long error

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550129#comment-14550129 ] ASF GitHub Bot commented on FLINK-2003: --- Github user thvasilo commented on the pull

[GitHub] flink pull request: [FLINK-2003] Building on some encrypted filesy...

2015-05-19 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/690#issuecomment-103417077 So @rmetzger, where do you think the note should go? In the project documentation or the How to contribute section of the project website? --- If your project is set

[GitHub] flink pull request: Hits

2015-05-19 Thread JavidMayar
GitHub user JavidMayar opened a pull request: https://github.com/apache/flink/pull/694 Hits You can merge this pull request into a Git repository by running: $ git pull https://github.com/JavidMayar/flink HITS Alternatively you can review and apply these changes as the patch

[GitHub] flink pull request: Hits

2015-05-19 Thread JavidMayar
Github user JavidMayar closed the pull request at: https://github.com/apache/flink/pull/694 --- 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

[jira] [Updated] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2043: -- Component/s: Examples Change the KMeansDataGenerator to allow passing a custom path

[jira] [Created] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
Ahamd Javid created FLINK-2044: -- Summary: Implementation of Gelly Algorithm HITS Key: FLINK-2044 URL: https://issues.apache.org/jira/browse/FLINK-2044 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2045: -- Issue Type: Bug (was: Improvement) JobManager webinterface is unresponsive with many

[jira] [Updated] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Component/s: (was: Java API) Implementation of Gelly Algorithm HITS

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550184#comment-14550184 ] Till Rohrmann commented on FLINK-1807: -- Yes, let's keep this issue open until we have

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550201#comment-14550201 ] Stephan Ewen commented on FLINK-1952: - I cannot reproduce this error any more with

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550215#comment-14550215 ] Robert Metzger commented on FLINK-1952: --- Thank you for looking into the issue. Lets

[jira] [Updated] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java Implementation of Gelly

[jira] [Created] (FLINK-2046) Quickstarts are missing on the new Website

2015-05-19 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2046: --- Summary: Quickstarts are missing on the new Website Key: FLINK-2046 URL: https://issues.apache.org/jira/browse/FLINK-2046 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550260#comment-14550260 ] Ahamd Javid commented on FLINK-2044: We are two Students part of the DIMA Big data

[jira] [Comment Edited] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550260#comment-14550260 ] Ahamd Javid edited comment on FLINK-2044 at 5/19/15 11:38 AM: --

[jira] [Issue Comment Deleted] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Comment: was deleted (was: .) Implementation of Gelly Algorithm HITS

[jira] [Comment Edited] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550280#comment-14550280 ] Ahamd Javid edited comment on FLINK-2044 at 5/19/15 11:43 AM: --

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-19 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-103457498 Done. Remove changes in ExecutionConfig. Adopted JUnit test. Rebased on current master. Travis is green. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550311#comment-14550311 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: Implemented the class TwitterFilterSource

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/687#issuecomment-103460862 I do another Pull Request --- 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

[GitHub] flink pull request: Implemented the class TwitterFilterSource

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim closed the pull request at: https://github.com/apache/flink/pull/687 --- 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

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/685#discussion_r30592154 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java --- @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550321#comment-14550321 ] ASF GitHub Bot commented on FLINK-2025: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550322#comment-14550322 ] ASF GitHub Bot commented on FLINK-2025: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/685#discussion_r30592160 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java --- @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/685#issuecomment-103461860 - Rebased to current master. - Now comparing on byte array instead of creating a String object. - All checks are performed case-insensitive. --- If your project is

[jira] [Created] (FLINK-2047) Rename CoCoA to SVM

2015-05-19 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2047: -- Summary: Rename CoCoA to SVM Key: FLINK-2047 URL: https://issues.apache.org/jira/browse/FLINK-2047 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

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

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-19 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30592697 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/optimization/GradientDescentITSuite.scala --- @@ -205,6 +190,61 @@ class

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/686#issuecomment-103463683 Pull request updated. --- 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-2026) Error message in count() only jobs

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

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2015-05-19 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14551753#comment-14551753 ] Raghav Chalapathy commented on FLINK-1733: -- Hi Till Let me go through the paper

[GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/

2015-05-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/691#issuecomment-103471022 I think this is a hacky fix. Sounds like the right approach is to have a python cli frontend that does not expect a jar file. --- If your project is set up

[jira] [Commented] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550446#comment-14550446 ] Robert Metzger commented on FLINK-2048: --- Hi [~HilmiYildirim], I gave you Contributor

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103498471 Thank you for working on the issue. I'll soon review your changes in detail. From what I saw by scrolling over it, it looks very good (with log messages and

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103499923 It is possible to implement an integration test. For example, I can track a term and then I has to check if all tweets contain the term. If you want I can

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550364#comment-14550364 ] Stephan Ewen commented on FLINK-1952: - Okay, I am able to reproduce it locally with a

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Labels: ML (was: ) Implement an online histogram with Merging and equalization features

[jira] [Created] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Hilmi Yildirim (JIRA)
Hilmi Yildirim created FLINK-2048: - Summary: Enhance Twitter Stream support Key: FLINK-2048 URL: https://issues.apache.org/jira/browse/FLINK-2048 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550385#comment-14550385 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on a diff in

[jira] [Commented] (FLINK-2007) Initial data point in Delta function needs to be serializable

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550482#comment-14550482 ] ASF GitHub Bot commented on FLINK-2007: --- GitHub user mbalassi opened a pull request:

[GitHub] flink pull request: [FLINK-2007] [streaming] Proper Delta policy s...

2015-05-19 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/697 [FLINK-2007] [streaming] Proper Delta policy serialization The initial value passed to the Delta policy has to be serialized to be transferred to the cluster. This change adds the standard Flink

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Priority: Minor (was: Major) Implement an online histogram with Merging and equalization

[jira] [Updated] (FLINK-2046) Quickstarts are missing on the new Website

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2046: -- Component/s: Quickstarts Quickstarts are missing on the new Website

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-19 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550382#comment-14550382 ] Laurent Tardif commented on FLINK-1848: --- There also a little issue in the test that

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550425#comment-14550425 ] ASF GitHub Bot commented on FLINK-1745: --- GitHub user chiwanpark opened a pull

[GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne...

2015-05-19 Thread chiwanpark
GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/696 [FLINK-1745] [ml] [WIP] Add exact k-nearest-neighbours algorithm to machine learning library This PR is not final but work in progress. You can see detail description in

[jira] [Updated] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2048: -- Assignee: Hilmi Yildirim Enhance Twitter Stream support --

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/686#discussion_r30592879 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java --- @@ -914,7 +917,15 @@ public JavaPlan createProgramPlan(String jobName)

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550340#comment-14550340 ] ASF GitHub Bot commented on FLINK-2026: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-1999) TF-IDF transformer

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550448#comment-14550448 ] Till Rohrmann commented on FLINK-1999: -- You probably have to apply a similar trick as

[jira] [Updated] (FLINK-1733) Add PCA to machine learning library

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Priority: Minor (was: Major) Add PCA to machine learning library

[jira] [Updated] (FLINK-1733) Add PCA to machine learning library

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Description: Dimension reduction is a crucial prerequisite for many data analysis tasks.

[jira] [Updated] (FLINK-1733) Add PCA to machine learning library

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Description: Dimension reduction is a crucial prerequisite for many data analysis tasks.

[jira] [Created] (FLINK-2049) KafkaSink sporadically fails to send message

2015-05-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2049: - Summary: KafkaSink sporadically fails to send message Key: FLINK-2049 URL: https://issues.apache.org/jira/browse/FLINK-2049 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/686#issuecomment-103470201 Looks good, modulo the commas. +1 to merge after fixing this. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

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

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550549#comment-14550549 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha closed the pull

[jira] [Closed] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1977. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in

[jira] [Closed] (FLINK-2009) Time-Based Windows fail with Chaining Disabled

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2009. --- Resolution: Fixed Fixed in

[jira] [Commented] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550568#comment-14550568 ] Alexander Alexandrov commented on FLINK-2044: - The [feature branch can be

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Assignee: Sachin Goel Implement an online histogram with Merging and equalization features

[jira] [Updated] (FLINK-2035) Update 0.9 roadmap with ML issues

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2035: - Fix Version/s: 0.9 Update 0.9 roadmap with ML issues -

[jira] [Closed] (FLINK-1971) Add user function type to StreamOperator

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1971. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Updated] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1992: - Fix Version/s: 0.9 Add convergence criterion to SGD optimizer

[jira] [Updated] (FLINK-2034) Add vision and roadmap for ML library to docs

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2034: - Fix Version/s: 0.9 Add vision and roadmap for ML library to docs

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-19 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-103530579 Manually merged --- 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-1977) Rework Stream Operators to always be push based

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550548#comment-14550548 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha commented on the pull

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Summary: Implementation of Gelly HITS Algorithm (was: Implementation of Gelly Algorithm HITS)

  1   2   >