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

2015-05-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14551942#comment-14551942 ] Fabian Hueske commented on FLINK-1848: -- Hi [~Laurent Tardif], thanks for the

[GitHub] flink pull request: cleaned up readme

2015-05-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/693#issuecomment-103796669 Hi @aertoria, thanks for the PR and welcome to the Flink community! Is it intentional, that your PR only adds are remove empty lines? Talking about future

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

2015-05-20 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14551889#comment-14551889 ] Laurent Tardif commented on FLINK-1848: --- going a bit deepper in the investigation

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

2015-05-20 Thread HilmiYildirim
Github user HilmiYildirim commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30677156 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java

[GitHub] flink pull request: [FLINK-1907] Scala shell

2015-05-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-103803452 I am wondering whether it would be better to put this into `flink-client` instead of `flink-staging`. Its not a huge component, should be easy to maintain, and would

[jira] [Closed] (FLINK-1762) Make Statefulness of a Streaming Function explicit

2015-05-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1762. - Resolution: Fixed Make Statefulness of a Streaming Function explicit

[jira] [Created] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator

2015-05-20 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2054: - Summary: StreamOperator rework removed copy calls when passing output to a chained operator Key: FLINK-2054 URL: https://issues.apache.org/jira/browse/FLINK-2054 Project:

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

2015-05-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2026. --- Resolution: Fixed Fix Version/s: 0.9 Error message in count() only jobs

[jira] [Created] (FLINK-2056) Add guide to create a chainable predictor in docs

2015-05-20 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2056: -- Summary: Add guide to create a chainable predictor in docs Key: FLINK-2056 URL: https://issues.apache.org/jira/browse/FLINK-2056 Project: Flink

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

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

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

2015-05-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/686 --- 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: Implemented TwitterSourceFilter and adapted Tw...

2015-05-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103848061 +1 to merge like this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

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

2015-05-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30691440 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java ---

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

2015-05-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552154#comment-14552154 ] Till Rohrmann commented on FLINK-1731: -- Sure. Maybe we can add in this version a

[GitHub] flink pull request: [FLINK-2052] Fix Serialization warnings in Str...

2015-05-20 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/698 [FLINK-2052] Fix Serialization warnings in Stream Operators You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink

[jira] [Created] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

2015-05-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2058: --- Summary: Hadoop Input Splits do not use proper UserCodeClassloader Key: FLINK-2058 URL: https://issues.apache.org/jira/browse/FLINK-2058 Project: Flink Issue

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

2015-05-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2025. --- Resolution: Implemented Fix Version/s: 0.9 Support booleans in CSV reader

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

2015-05-20 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552113#comment-14552113 ] Alexander Alexandrov commented on FLINK-1731: - [~till.rohrmann] Can we merge

[GitHub] flink pull request: [FLINK-1907] Scala shell

2015-05-20 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-103848414 Hey Fabian. The problem with putting it in the `flink-client` is that the shell only works with Scala-2.10 and is not included for the Scala-2.11 build. As far as I've

[jira] [Assigned] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator

2015-05-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2054: --- Assignee: Aljoscha Krettek StreamOperator rework removed copy calls when passing

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

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

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

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

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

2015-05-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/685 --- 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] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

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

[GitHub] flink pull request: [FLINK-1687] [streaming] Syncing streaming sou...

2015-05-20 Thread szape
Github user szape commented on the pull request: https://github.com/apache/flink/pull/521#issuecomment-103842766 Thank you Robert. Unfortunately, I didn't have much time this week to review the code. As soon as I'm done with the storm compatibility examples, I will be able to

[jira] [Commented] (FLINK-2052) Clear up Serializable warnings in streaming operators

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

[GitHub] flink pull request: Eager print

2015-05-20 Thread nikste
GitHub user nikste opened a pull request: https://github.com/apache/flink/pull/699 Eager print Uses collect in print function now. No need for calling execute() after print(). You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-2057) Remove IOReadableWritable interface from input splits

2015-05-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2057: --- Summary: Remove IOReadableWritable interface from input splits Key: FLINK-2057 URL: https://issues.apache.org/jira/browse/FLINK-2057 Project: Flink Issue

[jira] [Created] (FLINK-2053) Preregister ML types for Kryo serialization

2015-05-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2053: Summary: Preregister ML types for Kryo serialization Key: FLINK-2053 URL: https://issues.apache.org/jira/browse/FLINK-2053 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators

2015-05-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552007#comment-14552007 ] Till Rohrmann commented on FLINK-2050: -- At the moment, I would say keep the model and

[jira] [Commented] (FLINK-1980) Allowing users to decorate input streams

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

[GitHub] flink pull request: [FLINK-1980] allowing users to decorate input ...

2015-05-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/658#issuecomment-103819433 I think the PR is 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 your project does

[GitHub] flink pull request: [FLINK-1687] [streaming] Syncing streaming sou...

2015-05-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/521#discussion_r30683603 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SourceAPITest.scala --- @@ -0,0 +1,22 @@

[jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

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

[jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

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

[jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

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

[GitHub] flink pull request: [FLINK-1687] [streaming] Syncing streaming sou...

2015-05-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/521#discussion_r30683935 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@

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

2015-05-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/685#issuecomment-103800272 LGTM +1 for merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

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

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

2015-05-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552031#comment-14552031 ] Maximilian Michels commented on FLINK-2038: --- +1 that's a much more intriguing

[jira] [Created] (FLINK-2055) Implement Streaming HBaseSink

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2055: - Summary: Implement Streaming HBaseSink Key: FLINK-2055 URL: https://issues.apache.org/jira/browse/FLINK-2055 Project: Flink Issue Type: New Feature

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

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

[GitHub] flink pull request: [FLINK-1687] [streaming] Syncing streaming sou...

2015-05-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/521#issuecomment-103822246 The change looks good in theory but there are some details that need some reworking. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

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

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

2015-05-20 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/681#discussion_r30686981 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala --- @@ -609,6 +612,98 @@ WordSpecLike with Matchers with

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

2015-05-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/681#issuecomment-103833918 Thanks for your feedback. You introduce a separate session ID here. Why not use the JobID as the session ID? This is how the logic in the JobManager (that attaches

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

2015-05-20 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/681#discussion_r30686986 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala --- @@ -609,6 +612,98 @@ WordSpecLike with Matchers with

[jira] [Commented] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

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

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552036#comment-14552036 ] Robert Metzger commented on FLINK-1874: --- The blocker for this issue has been

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

2015-05-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552085#comment-14552085 ] Ufuk Celebi commented on FLINK-2038: I like this more. +1 I am wondering though

[jira] [Commented] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators

2015-05-20 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14551965#comment-14551965 ] Theodore Vasiloudis commented on FLINK-2050: Are we also going with sklearn's

[jira] [Resolved] (FLINK-1986) Group by fails on iterative data streams

2015-05-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1986. --- Resolution: Fixed commit that fixes it: 2d3e69a25e753b2eb825b589fe2550d2b968e161 Group by fails on

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

2015-05-20 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/638 --- 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: [FLINK-1927] [py] Operator distribution rework

2015-05-20 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-103813351 Implementing this in a clean way has become trickier that i initially expected, as such I'll postpone it and close this PR for now. --- If your project is set up for it,

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[GitHub] flink pull request: [FLINK-2059] Changed flink-compiler to flink-o...

2015-05-20 Thread tammymendt
GitHub user tammymendt opened a pull request: https://github.com/apache/flink/pull/701 [FLINK-2059] Changed flink-compiler to flink-optimizer in the pom.xml You can merge this pull request into a Git repository by running: $ git pull https://github.com/tammymendt/flink

[jira] [Commented] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552305#comment-14552305 ] Stephan Ewen commented on FLINK-2060: - +1 We should not use any snapshots (because the

[GitHub] flink pull request: [FLINK-2059] Changed flink-compiler to flink-o...

2015-05-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/701#issuecomment-103886271 Will merge this in my next batch... --- 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-2059) Rename modules flink-compiler to flink-optimizer in pom.xml

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

[jira] [Assigned] (FLINK-2055) Implement Streaming HBaseSink

2015-05-20 Thread Hilmi Yildirim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hilmi Yildirim reassigned FLINK-2055: - Assignee: Hilmi Yildirim Implement Streaming HBaseSink -

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

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

[jira] [Commented] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

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

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

2015-05-20 Thread peedeeX21
GitHub user peedeeX21 opened a pull request: https://github.com/apache/flink/pull/700 [FLINK-1731] [ml] Implementation of Feature K-Means and Test Suite Within the IMPRO-3 warm-up task the implementation of K-Means and corresponding test suite was done. You can merge this pull

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

2015-05-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/678#issuecomment-103862850 Hi @vasia , I will address your comments one by one :) - the addVertices method receives a List of Edges instead of a DataSet of Edges because you need to

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

2015-05-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552257#comment-14552257 ] Aljoscha Krettek commented on FLINK-1962: - [~vanaepi] Are you making progress or

[GitHub] flink pull request: [FLINK-2059] Changed flink-compiler to flink-o...

2015-05-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/701#issuecomment-103870838 Thank you for fixing this. +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

[jira] [Commented] (FLINK-2059) Rename modules flink-compiler to flink-optimizer in pom.xml

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

[jira] [Created] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2060: - Summary: Let maven fail on travis when modules reference to outdated internal dependency Key: FLINK-2060 URL: https://issues.apache.org/jira/browse/FLINK-2060

[jira] [Commented] (FLINK-1980) Allowing users to decorate input streams

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

[GitHub] flink pull request: [FLINK-1980] allowing users to decorate input ...

2015-05-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/658#issuecomment-103883348 Looks good. Will merge this in my next batch... --- 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-1962) Add Gelly Scala API

2015-05-20 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552289#comment-14552289 ] PJ Van Aeken commented on FLINK-1962: - There are no blocking issues at the moment. I

[GitHub] flink pull request: Eager print

2015-05-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/699#issuecomment-103882937 Okay, the issue with print in test cases seems to be fixed in the second commit, that looks good. --- If your project is set up for it, you can reply to this email

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

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552331#comment-14552331 ] Stephan Ewen commented on FLINK-2038: - I am okay with dropping the unified. It is

[GitHub] flink pull request: cleaned up readme

2015-05-20 Thread aertoria
Github user aertoria commented on the pull request: https://github.com/apache/flink/pull/693#issuecomment-103894295 Hey Febian, You may ignore that pull request. I was just demonstrating my friend how to get start contribute a apache projects. We should welcome him Brad to

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

2015-05-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552342#comment-14552342 ] Aljoscha Krettek commented on FLINK-1962: - No worries :D I just didn't want this

[GitHub] flink pull request: cleaned up readme

2015-05-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/693#issuecomment-103895674 Ah OK :-) Would you mind, closing the PR then? Thanks, Fabian --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Created] (FLINK-2062) Fix names of memory segment config parameter

2015-05-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2062: --- Summary: Fix names of memory segment config parameter Key: FLINK-2062 URL: https://issues.apache.org/jira/browse/FLINK-2062 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2059] Changed flink-compiler to flink-o...

2015-05-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/701 --- 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: [FLINK-2061] [core] Fix names of memory size c...

2015-05-20 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/703 [FLINK-2061] [core] Fix names of memory size config parameter This still evaluates the old parameter, if the old one is set and the new one is not set. You can merge this pull request into a

[jira] [Created] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2065: - Summary: Cancelled jobs finish with final state FAILED Key: FLINK-2065 URL: https://issues.apache.org/jira/browse/FLINK-2065 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2065: -- Attachment: failed.tgz I've attached the full yarn log of all the machines. Please note that

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

2015-05-20 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30724769 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java ---

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

2015-05-20 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103963870 Add one more small request to add comments as JavaDoc for the test then it should ready to go. Thanks again for the contribution. --- If your project is set up for

[GitHub] flink pull request: Eager print

2015-05-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/699#issuecomment-103925741 I just noticed this test case: `flink-tests/src/test/scala/org/apache/flink/api/scala/DeltaIterationSanityCheckTest.scala` The programs in this test are

[jira] [Closed] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2058. --- Hadoop Input Splits do not use proper UserCodeClassloader

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

2015-05-20 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30724526 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java ---

[jira] [Commented] (FLINK-2061) CSVReader: quotedStringParsing and includeFields yields ParseException

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

[jira] [Resolved] (FLINK-2057) Remove IOReadableWritable interface from input splits

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2057. - Resolution: Fixed Fixed via f27025bafbe45fbfe8bfd27d06f01258a4ff9f44 Remove IOReadableWritable

[jira] [Resolved] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2058. - Resolution: Fixed Fixed via f27025bafbe45fbfe8bfd27d06f01258a4ff9f44 Hadoop Input Splits do not

[jira] [Closed] (FLINK-2057) Remove IOReadableWritable interface from input splits

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2057. --- Remove IOReadableWritable interface from input splits

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

2015-05-20 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552501#comment-14552501 ] PJ Van Aeken commented on FLINK-1962: - Ok cool. One more thing perhaps, if you could

[jira] [Updated] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2065: -- Description: While running some experiments, I've noticed that jobs sometimes finish in

[jira] [Updated] (FLINK-1612) Add guidelines to avoid duplicate class names and more JavaDoc for new addition

2015-05-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1612: --- Component/s: (was: website) Project Website Add guidelines to avoid duplicate

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

2015-05-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2042: --- Component/s: (was: website) Increase font size for stack figure on website home

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

2015-05-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2038. Resolution: Fixed Fixed in 6f8ca04 Extend headline of website --

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

2015-05-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2038: --- Component/s: (was: website) Project Website Extend headline of website

[jira] [Created] (FLINK-2066) Make delay between execution retries configurable

2015-05-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2066: --- Summary: Make delay between execution retries configurable Key: FLINK-2066 URL: https://issues.apache.org/jira/browse/FLINK-2066 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2066) Make delay between execution retries configurable

2015-05-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2066: Labels: starter (was: ) Make delay between execution retries configurable

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-20 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/704 [FLINK-2050] Introduces new pipelining mechanism for FlinkML This PR introduces the new pipelining mechanism for FlinkML. In order to make pipeline applicable to different input types, the

  1   2   >