[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/426#issuecomment-85866221 Cool, thanks. Will have a look shortly. Did you rebase to the latest master? We had a few build issues with the master branch a few days ago. It is a

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-25 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/534#issuecomment-85909585 Hey gyula, What is the problem with the stream writer? And how can I reproduce the record writer broadcast problem? If you give me some instructions to reproduce the

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-25 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/534#discussion_r27100141 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/streamvertex/StreamVertex.java --- @@ -283,16

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1544] [streaming] POJO types added to A...

2015-03-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/517 --- 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-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/530#discussion_r27104700 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -1425,11 +1425,9 @@ public static boolean isClassType(Type t) {

[jira] [Resolved] (FLINK-1544) Extend streaming aggregation tests to include POJOs

2015-03-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1544. --- Resolution: Implemented Fix Version/s: 0.9 Implemented via 597d8b8 Extend streaming

[GitHub] flink pull request: [FLINK-1756] [streaming] Rename Stream Monitor...

2015-03-25 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/531#issuecomment-85951702 Thanks for spotting it, it was my bad. LGTM, 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

[jira] [Commented] (FLINK-1544) Extend streaming aggregation tests to include POJOs

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

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/530#discussion_r27104945 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java --- @@ -1465,7 +1467,9 @@ public static void

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/530#discussion_r27104851 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java --- @@ -525,7 +525,9 @@ protected void run() throws Exception {

[jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

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

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/530#discussion_r27104741 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java --- @@ -35,20 +35,20 @@ * Like

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/530#issuecomment-85954079 +1 This rename makes a lot of sense. Looks good to me apart from the minor comments. --- If your project is set up for it, you can reply to this email and have your reply

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

2015-03-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379653#comment-14379653 ] Timo Walther commented on FLINK-1319: - Thanks for your comments! The analyzer also

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/426#issuecomment-86011099 Oops, I pushed a intermediate commit a8a5c37. I will fix it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Updated] (FLINK-1766) Fix the bug of equals function of FSKey

2015-03-25 Thread Sibao Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1766: -- Issue Type: Improvement (was: Bug) Fix the bug of equals function of FSKey

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-25 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/534#discussion_r27115550 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/streamvertex/StreamVertex.java --- @@ -283,16

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

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

[GitHub] flink pull request: [FLINK-1756] [streaming] Rename Stream Monitor...

2015-03-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/531 --- 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] [Assigned] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

2015-03-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1769: --- Assignee: Aljoscha Krettek Maven deploy is broken (build artifacts are cleaned in

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/426#issuecomment-86011531 Sure, no problem :-) Can I check it now or do you need a bit more time? --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379859#comment-14379859 ] Robert Metzger commented on FLINK-1783: --- To my understanding the new quickstarts are

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[jira] [Assigned] (FLINK-1781) Quickstarts broken due to Scala Version Variables

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1781: - Assignee: Robert Metzger Quickstarts broken due to Scala Version Variables

[GitHub] flink pull request: [FLINK-1650] Configure Netty (akka) to use Slf...

2015-03-25 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/518#issuecomment-86050697 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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/426#issuecomment-86011782 @fhueske You can check it now :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[jira] [Commented] (FLINK-1781) Quickstarts broken due to Scala Version Variables

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379866#comment-14379866 ] Robert Metzger commented on FLINK-1781: --- I'll look into this. Quickstarts broken

[GitHub] flink pull request: [FLINK-1766]Fix the bug of equals function of ...

2015-03-25 Thread matadorhong
Github user matadorhong commented on the pull request: https://github.com/apache/flink/pull/511#issuecomment-86050415 @StephanEwen I have fixed the code style issue and changed the PR to an Improvement one in jira. Finally, great thanks for your help. And I will take more time to

[jira] [Updated] (FLINK-1729) Assess performance of classification algorithms

2015-03-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1729: - Description: In order to validate Flink's classification algorithms (in terms of performance and

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/426#issuecomment-86079595 @chiwanpark excellent job, thanks! Will merge it after a final round of Travis tests passed. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/530#issuecomment-86090016 The documentation also needs to be adapted to use the new interface name. @smarthi If you don't mind I will merge your commit with my remarks addressed. --- If your

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

2015-03-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380041#comment-14380041 ] Fabian Hueske commented on FLINK-1694: -- +1 for the second option with the

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread smarthi
Github user smarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/530#discussion_r27133810 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java --- @@ -35,20 +35,20 @@ * Like

[GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou...

2015-03-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/530 --- 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-1775] BarrierBuffer fix to avoid end of...

2015-03-25 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/534#issuecomment-86140841 Should we merge this anyway? The recordwriter issue seems to be independent from this, and this commit solves some other bugs. --- If your project is set up for it, you

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: Make Expression API available to Java, Rename ...

2015-03-25 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/503#issuecomment-86112294 I fixed @rmetzger's remarks. Still waiting for a solution to the naming issue. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Created] (FLINK-1784) KafkaITCase

2015-03-25 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1784: Summary: KafkaITCase Key: FLINK-1784 URL: https://issues.apache.org/jira/browse/FLINK-1784 Project: Flink Issue Type: Bug Components: Streaming

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-03-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/426 --- 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-1512) Add CsvReader for reading into POJOs.

2015-03-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1512. -- Resolution: Implemented Fix Version/s: 0.9 Implemented in

[GitHub] flink pull request: Fix issue where Windows paths were not recogni...

2015-03-25 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/491#issuecomment-86219748 Thanks, I did that, hopefully the tests will pass now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: Fix issue where Windows paths were not recogni...

2015-03-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/491#issuecomment-86199581 I had a look at the Travis logs and it seems that the build failures are not related to your change. We had a few issues with build stability on the master branch in

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

2015-03-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379764#comment-14379764 ] Timo Walther commented on FLINK-1319: - Is there a reason why Semantic Properties are