[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

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

[GitHub] flink pull request: [FLINK-1637] Reduce number of files in uberjar...

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/450#issuecomment-77117018 According to this discussion: https://issues.apache.org/jira/browse/SPARK-1520 Jars build by java 6 can have more than 65k entries. If thats the case, we could als

[jira] [Created] (FLINK-1641) Make projection operator chainable

2015-03-04 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1641: - Summary: Make projection operator chainable Key: FLINK-1641 URL: https://issues.apache.org/jira/browse/FLINK-1641 Project: Flink Issue Type: Improvement

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

2015-03-04 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/426#discussion_r25760453 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java --- @@ -235,8 +252,21 @@ public OUT readRecord(OUT reuse, byte[] bytes,

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

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346626#comment-14346626 ] ASF GitHub Bot commented on FLINK-1512: --- Github user chiwanpark commented on a diff

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77125258 Hey Vasia, 1. I think the tests shouldn't print to stdout, but use the logger for test output. 2. The exceptions were wrong-fully logged for cancelled/failed task.

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

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

[jira] [Assigned] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis

2015-03-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1601: Assignee: Robert Metzger > Sometimes the YARNSessionFIFOITCase fails on Travis > --

[jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis

2015-03-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346660#comment-14346660 ] Till Rohrmann commented on FLINK-1601: -- It happened again, but this time with another

[jira] [Created] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase

2015-03-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1642: Summary: Flakey YARNSessionCapacitySchedulerITCase Key: FLINK-1642 URL: https://issues.apache.org/jira/browse/FLINK-1642 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-03-04 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-77127742 Thanks, I have two last requests, sorry for that. Could you rename flink-generic to flink-language-binding-generic? The problem is, that the package name is now f

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346680#comment-14346680 ] ASF GitHub Bot commented on FLINK-1616: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346681#comment-14346681 ] ASF GitHub Bot commented on FLINK-1616: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/451#discussion_r25763642 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -601,452 +482,295 @@ public int compare(ExecutionGraph o1, Executio

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/451#discussion_r25763670 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -601,452 +482,295 @@ public int compare(ExecutionGraph o1, Executio

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77131171 The two last build profiles are probably failing because the tests are checking on the output of the CLI frontend. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/451#discussion_r25765068 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/messages/JobManagerMessages.scala --- @@ -19,11 +19,14 @@ package org.apache.flink.r

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346697#comment-14346697 ] ASF GitHub Bot commented on FLINK-1616: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77132462 Except for the YARN test cases which fail, 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 yo

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77134702 The `-h` command is not working for the actions (tested with info and run) ``` [root@sandbox flink-yarn-0.9-SNAPSHOT]# ./bin/flink info -h 10:28:01,440 WAR

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77135314 The YARN application master doesn't start anymore with the following exception: ``` 10:31:01,526 ERROR org.apache.flink.yarn.ApplicationMaster$

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[jira] [Created] (FLINK-1643) Detect tumbling policies where trigger and eviction match

2015-03-04 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1643: - Summary: Detect tumbling policies where trigger and eviction match Key: FLINK-1643 URL: https://issues.apache.org/jira/browse/FLINK-1643 Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-03-04 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-77140113 and here i thought i was being clever by swapping to built-in functions. addressed both issues. --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[jira] [Created] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method

2015-03-04 Thread Jonathan Hasenburg (JIRA)
Jonathan Hasenburg created FLINK-1644: - Summary: WebClient dies when no ExecutionEnvironment in main method Key: FLINK-1644 URL: https://issues.apache.org/jira/browse/FLINK-1644 Project: Flink

[GitHub] flink pull request: [FLINK-999] Configurability of LocalExecutor

2015-03-04 Thread jkirsch
Github user jkirsch closed the pull request at: https://github.com/apache/flink/pull/448 --- 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 enab

[jira] [Commented] (FLINK-999) Configurability of LocalExecutor

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346806#comment-14346806 ] ASF GitHub Bot commented on FLINK-999: -- Github user jkirsch closed the pull request at

[jira] [Commented] (FLINK-999) Configurability of LocalExecutor

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346807#comment-14346807 ] ASF GitHub Bot commented on FLINK-999: -- Github user jkirsch commented on the pull requ

[GitHub] flink pull request: [FLINK-999] Configurability of LocalExecutor

2015-03-04 Thread jkirsch
Github user jkirsch commented on the pull request: https://github.com/apache/flink/pull/448#issuecomment-77144749 #427 is a better approach --- 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 thi

[jira] [Updated] (FLINK-1628) Strange behavior of "where" function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1628: - Priority: Critical (was: Major) > Strange behavior of "where" function during a join > --

[jira] [Assigned] (FLINK-1628) Strange behavior of "where" function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1628: Assignee: Fabian Hueske > Strange behavior of "where" function during a join >

[GitHub] flink pull request: Streaming cancellation + exception handling re...

2015-03-04 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/449#issuecomment-77150831 Code looks good, testing usage right now. I checked the quickstarts for API changes no need to change stuff there. I think some documentation is needed on the beh

[jira] [Updated] (FLINK-1628) Strange behavior of "where" function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1628: - Component/s: Optimizer > Strange behavior of "where" function during a join >

[jira] [Created] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming

2015-03-04 Thread JIRA
Márton Balassi created FLINK-1645: - Summary: Move StreamingClassloaderITCase to flink-streaming Key: FLINK-1645 URL: https://issues.apache.org/jira/browse/FLINK-1645 Project: Flink Issue Type

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77156490 Thanks, I addressed your comments. Seems to work now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] flink pull request: [FLINK-1637] Reduce number of files in uberjar...

2015-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/450#issuecomment-77157047 Makes sense, +1 for building the releases with openjdk6 (half of the code is compiled by the Scala Compiler anyways) --- If your project is set up for it, you can rep

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

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

[jira] [Closed] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

2015-03-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1162. - Resolution: Fixed Fix Version/s: 0.9 Fixed with Kryo. I suspect there is no test for it. >

[jira] [Created] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception

2015-03-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1646: - Summary: Add name of required configuration value into the "Insufficient number of network buffers" exception Key: FLINK-1646 URL: https://issues.apache.org/jira/browse/FLINK-16

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

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

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-04 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77163740 Thanks Ufuk! @andralungu, could you please change the test to use the logger? @uce, regarding the exceptions output, I see this after having rebased on the latest mas

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77164833 Thank you. I'll try it again on my YARN setup later today. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Closed] (FLINK-839) Add GroupReduceFunction and CoGroupFunction with separate Key

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-839. --- Resolution: Duplicate Duplicate of FLINK-553 and FLINK-1272 > Add GroupReduceFunction and CoGroupFunct

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[jira] [Reopened] (FLINK-1577) Misleading error messages when cancelling tasks

2015-03-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-1577: Assignee: Ufuk Celebi I think I've only fixed half of the issue. Both [~vkalavri] and [~bamrabi]

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

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

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77165497 Thanks, Vasia! :) It still seems to be a problem. I've re-opened the [corresponding issue](https://issues.apache.org/jira/browse/FLINK-1577) and will fix it. In any case, noth

[GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl...

2015-03-04 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/429#issuecomment-77166964 This looks good! Thanks @andralungu for catching the bug ^^ I'll merge it later. --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

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

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/453 [FLINK-1640] Remove tailing slash from paths. - Remove tailing slash from paths. - Add tests for Path and FileOutputFormat. Tailing slashes were previously not removed from paths which

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[jira] [Created] (FLINK-1647) Push master documentation (latest) to Flink website

2015-03-04 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-1647: Summary: Push master documentation (latest) to Flink website Key: FLINK-1647 URL: https://issues.apache.org/jira/browse/FLINK-1647 Project: Flink Issue Type:

[jira] [Closed] (FLINK-1647) Push master documentation (latest) to Flink website

2015-03-04 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels closed FLINK-1647. -- Resolution: Fixed Done :) http://flink.apache.org/ Under Documentation -> Current Snapshot -> 0.9 >

[jira] [Commented] (FLINK-1647) Push master documentation (latest) to Flink website

2015-03-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347066#comment-14347066 ] Henry Saputra commented on FLINK-1647: -- That was quick =P LOL > Push master document

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77194681 Allright. I was able to start a YARN session from the frontend. Also the `-h` is working now. --- If your project is set up for it, you can reply to this email and ha

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[jira] [Resolved] (FLINK-1627) Netty channel connect deadlock

2015-03-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1627. Resolution: Fixed Fixed in 0333109. It was not a connect deadlock, but the network I/O thread was b

[jira] [Created] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots

2015-03-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1648: --- Summary: Add a mode where the system automatically sets the parallelism to the available task slots Key: FLINK-1648 URL: https://issues.apache.org/jira/browse/FLINK-1648

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/451 --- 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-1616) Action "list -r" gives IOException when there are running jobs

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/451#issuecomment-77206172 Manually merged in 5385e48d94a2df81c8fd6102a889cf42dd93fe2f --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

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

[jira] [Resolved] (FLINK-1616) Action "list -r" gives IOException when there are running jobs

2015-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1616. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed in 5385e48d94a2d

[jira] [Resolved] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception

2015-03-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1646. Resolution: Fixed Fixed in 9c0d634. > Add name of required configuration value into the "Insufficie

[GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch)

2015-03-04 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/410 --- 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-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception

2015-03-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-1646: -- Assignee: Ufuk Celebi > Add name of required configuration value into the "Insufficient number

[GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch)

2015-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/410#issuecomment-77205854 Manually merged into `release-0.8` in a6f9f9939ca03026baeefb3bd0876b90068b7682 --- If your project is set up for it, you can reply to this email and have your reply a

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/453#discussion_r25795767 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/io/FileOutputFormatTest.java --- @@ -44,7 +44,7 @@ public void testCreateNoneParallelLocalFS() {

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-03-04 Thread Adnan Khan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347239#comment-14347239 ] Adnan Khan commented on FLINK-1388: --- So I've made changes according to the suggestions y

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/453#discussion_r25795975 --- Diff: flink-core/src/test/java/org/apache/flink/core/fs/PathTest.java --- @@ -23,6 +23,152 @@ import static org.junit.Assert.*; public class Pa

[jira] [Commented] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

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

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/453#discussion_r25796503 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java --- @@ -217,7 +211,17 @@ public Path(String pathString) { *the path string

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[GitHub] flink pull request: [FLINK-1605] Bundle all hadoop dependencies an...

2015-03-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/454 [FLINK-1605] Bundle all hadoop dependencies and shade guava away I don't have a working eclipse setup right now, so I didn't test this change with eclipse. I would be very interested in som

[jira] [Commented] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception

2015-03-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347297#comment-14347297 ] Henry Saputra commented on FLINK-1646: -- That was super quick =P > Add name of requir

[jira] [Updated] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-03-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-1602: - Assignee: Max Michels > Remove 0.6-incubating from Flink website SVN > ---

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-03-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347318#comment-14347318 ] Henry Saputra commented on FLINK-1602: -- [~maxmichaels], seemed like you already took

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-03-04 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347324#comment-14347324 ] Max Michels commented on FLINK-1602: Yes, I took care of it. The old docs are deleted

[jira] [Resolved] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-03-04 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels resolved FLINK-1602. Resolution: Fixed > Remove 0.6-incubating from Flink website SVN > -

[jira] [Closed] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-03-04 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels closed FLINK-1602. -- > Remove 0.6-incubating from Flink website SVN > > >

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/453#issuecomment-77218259 :+1: Looks good to me. I've tried it out locally. Nice that you added tests :) My inline comments regarding the tests are very general and don't really need be addre

[GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths.

2015-03-04 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/453#discussion_r25801300 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java --- @@ -217,7 +211,17 @@ public Path(String pathString) { *the path stri

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

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

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347396#comment-14347396 ] ASF GitHub Bot commented on FLINK-1587: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-04 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77224411 Hi @uce! I am using a data set's print() method in that particular test suite. I tried several mixes and matches with the logger but none were successful.

[jira] [Created] (FLINK-1649) Give a good error message when a user program emits a null record

2015-03-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1649: --- Summary: Give a good error message when a user program emits a null record Key: FLINK-1649 URL: https://issues.apache.org/jira/browse/FLINK-1649 Project: Flink

[jira] [Created] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1650: --- Summary: Suppress Akka's Netty Shutdown Errors through the log config Key: FLINK-1650 URL: https://issues.apache.org/jira/browse/FLINK-1650 Project: Flink Iss

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347450#comment-14347450 ] Stephan Ewen commented on FLINK-1650: - The logged error is below. Setting the log leve

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347461#comment-14347461 ] ASF GitHub Bot commented on FLINK-1650: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request: [FLINK-1650] [logging] Suppress wrong netty wa...

2015-03-04 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/455 [FLINK-1650] [logging] Suppress wrong netty warnings on akka shutdown You can merge this pull request into a Git repository by running: $ git pull https://github.com/StephanEwen/incubator-f

[jira] [Commented] (FLINK-1649) Give a good error message when a user program emits a null record

2015-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14347465#comment-14347465 ] ASF GitHub Bot commented on FLINK-1649: --- GitHub user StephanEwen opened a pull reque

  1   2   >