[jira] [Updated] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1951: - Priority: Critical (was: Minor) > NullPointerException in DeltaIteration when no ForwardedFileds

[jira] [Resolved] (FLINK-1828) Impossible to output data to an HBase table

2015-04-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1828. -- Resolution: Fixed Fix Version/s: 0.8.2 Fixed in - 0.9 with de573cf5cef3bed6c489af85dba2cc

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-27 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/571#issuecomment-96828941 This PR was split into PR #632 and PR #633 --- 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-1828) Impossible to output data to an HBase table

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

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

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

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/571 --- 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 enabl

[GitHub] flink pull request: Fixed missing call to configure() for Configur...

2015-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/632 --- 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 enabl

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-04-27 Thread Elbehery
Github user Elbehery commented on the pull request: https://github.com/apache/flink/pull/621#issuecomment-96809741 @aljoscha I have run code format from Intellij, I think the problem should be solved now .. I have tried to read the travis build log, but I could not find the

[jira] [Commented] (FLINK-1941) Add documentation for Gelly-GSA

2015-04-27 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514777#comment-14514777 ] Vasia Kalavri commented on FLINK-1941: -- :-) you're way too fast for my current review

[jira] [Commented] (FLINK-1941) Add documentation for Gelly-GSA

2015-04-27 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514772#comment-14514772 ] Andra Lungu commented on FLINK-1941: I believe we should also add documentation for th

[GitHub] flink pull request: [FLINK-1942][gelly] GSA Iteration Configuratio...

2015-04-27 Thread andralungu
GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/635 [FLINK-1942][gelly] GSA Iteration Configuration You can merge this pull request into a Git repository by running: $ git pull https://github.com/andralungu/flink gsaConfig Alternatively you

[jira] [Commented] (FLINK-1942) Add configuration options to Gelly-GSA

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

[jira] [Resolved] (FLINK-1693) Deprecate the Spargel API

2015-04-27 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-1693. -- Resolution: Fixed Fix Version/s: 0.9 > Deprecate the Spargel API > --

[GitHub] flink pull request: FLINK-1693 Add DEPRECATED annotations in Sparg...

2015-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/618 --- 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 enabl

[jira] [Commented] (FLINK-1693) Deprecate the Spargel API

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

[jira] [Commented] (FLINK-1948) Add manual task slot handling for streaming jobs

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

[GitHub] flink pull request: [FLINK-1948] [streaming] Manual task slot shar...

2015-04-27 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/634 [FLINK-1948] [streaming] Manual task slot sharing settings added for stream operators This PR introduces 2 new methods for the streaming operators to give control over the slot sharing settings for t

[GitHub] flink pull request: Addde HBase OutputFormat example (Flink-1828)

2015-04-27 Thread fpompermaier
GitHub user fpompermaier opened a pull request: https://github.com/apache/flink/pull/633 Addde HBase OutputFormat example (Flink-1828) Fixed on top of PR #632, shows how to write data into HBase You can merge this pull request into a Git repository by running: $ git pull https:

[jira] [Created] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-27 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1951: Summary: NullPointerException in DeltaIteration when no ForwardedFileds Key: FLINK-1951 URL: https://issues.apache.org/jira/browse/FLINK-1951 Project: Flink

[jira] [Commented] (FLINK-1924) [Py] Refactor a few minor things

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

[GitHub] flink pull request: [FLINK-1924] Minor Refactoring

2015-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/616 --- 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 enabl

[jira] [Commented] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514232#comment-14514232 ] Robert Metzger commented on FLINK-1950: --- Spark is removing 10%, but at least 384 mb.

[GitHub] flink pull request: Fixed missing call to configure() for Configur...

2015-04-27 Thread fpompermaier
GitHub user fpompermaier opened a pull request: https://github.com/apache/flink/pull/632 Fixed missing call to configure() for Configurable HadoopOutputFormats (Flink-1828) You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpomper

[jira] [Commented] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514215#comment-14514215 ] Stephan Ewen commented on FLINK-1950: - 20% and 30% are both rather random magic number

[jira] [Created] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1950: - Summary: Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants Key: FLINK-1950 URL: https://issues.apache.org/jira/browse/FLINK-1950

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

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

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

2015-04-27 Thread FelixNeutatz
Github user FelixNeutatz commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29148302 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java --- @@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos,

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

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

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29147205 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java --- @@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos, int

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

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

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

2015-04-27 Thread FelixNeutatz
Github user FelixNeutatz commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29145755 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java --- @@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos,

[jira] [Commented] (FLINK-1945) Make python tests less verbose

2015-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514117#comment-14514117 ] Chesnay Schepler commented on FLINK-1945: - There are no print statements, all outp

[jira] [Assigned] (FLINK-1945) Make python tests less verbose

2015-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1945: --- Assignee: Chesnay Schepler > Make python tests less verbose > ---

[jira] [Created] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

2015-04-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1949: - Summary: YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes Key: FLINK-1949 URL: https://issues.apache.org/jira/browse/FLINK-1949 Pr

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

2015-04-27 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/566#issuecomment-96647676 Looks good. I added few minor comments inline. Did you check if the changes should also go into the `ByteParser`? --- If your project is set up for it, you can reply

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

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

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

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

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29144391 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java --- @@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos, int

[jira] [Issue Comment Deleted] (FLINK-1937) Cannot create SparseVector with only one non-zero element.

2015-04-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1937: - Comment: was deleted (was: Hi [~chiwanpark], the problem is that you're giving a tuple of (Int, I

[jira] [Commented] (FLINK-1937) Cannot create SparseVector with only one non-zero element.

2015-04-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514095#comment-14514095 ] Till Rohrmann commented on FLINK-1937: -- Hi [~chiwanpark], the problem is that you're

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29143800 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java --- @@ -42,6 +42,15 @@ public int parseField(byte[] bytes, int startPos, int

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

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

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

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

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

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

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29143814 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java --- @@ -102,6 +111,10 @@ public static final float parseField(byte[] bytes, i

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29143809 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java --- @@ -41,6 +41,15 @@ public int parseField(byte[] bytes, int startPos, int

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29143763 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java --- @@ -103,6 +112,10 @@ public static final double parseField(byte[] bytes,

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

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

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

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r29143622 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java --- @@ -353,6 +354,99 @@ public void testIntegerFieldsl() throws IOExc

[jira] [Assigned] (FLINK-1937) Cannot create SparseVector with only one non-zero element.

2015-04-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1937: Assignee: Till Rohrmann > Cannot create SparseVector with only one non-zero element. >

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

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

[jira] [Commented] (FLINK-1922) Failed task deployment causes NPE on input split assignment

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

[GitHub] flink pull request: [FLINK-1922] Fixes NPE when TM receives a null...

2015-04-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/631 [FLINK-1922] Fixes NPE when TM receives a null input split The ```TaskInputSplitProvider``` did not handle null input splits which are wrapped into a ```NextInputSplit``` message properly. Fixed

[jira] [Assigned] (FLINK-1922) Failed task deployment causes NPE on input split assignment

2015-04-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1922: Assignee: Till Rohrmann > Failed task deployment causes NPE on input split assignment > ---

[jira] [Created] (FLINK-1948) Add manual task slot handling for streaming jobs

2015-04-27 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1948: - Summary: Add manual task slot handling for streaming jobs Key: FLINK-1948 URL: https://issues.apache.org/jira/browse/FLINK-1948 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-1682) Port Record-API based optimizer tests to new Java API

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

[GitHub] flink pull request: [FLINK-1682] Ported optimizer unit tests from ...

2015-04-27 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/627#issuecomment-96631688 Yes, very good point. I replaced the `.print()` statements by `.output(new DiscardingOutputFormat()` as suggested (not only in the ported tests but also some more on t

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

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

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

2015-04-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-96631425 Thank you. I'm trying to find time to review your changes soon. --- 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-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

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

[GitHub] flink pull request: [FLINK-1925] Fixes blocking method submitTask ...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/622#issuecomment-96627457 Looks god modulo some comments. The most critical being the concurrent Map one. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

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

[GitHub] flink pull request: [FLINK-1925] Fixes blocking method submitTask ...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/622#discussion_r29140659 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -795,108 +795,111 @@ extends Actor with ActorLogMessa

[jira] [Commented] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

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

[GitHub] flink pull request: [FLINK-1925] Fixes blocking method submitTask ...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/622#discussion_r29140570 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -137,7 +137,7 @@ extends Actor with ActorLogMessages

[jira] [Commented] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

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

[GitHub] flink pull request: [FLINK-1925] Fixes blocking method submitTask ...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/622#discussion_r29140453 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -345,26 +346,9 @@ public void onComplete(Throwable fai

[jira] [Commented] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

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

[GitHub] flink pull request: [FLINK-1923] Replaces asynchronous logging wit...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/628#issuecomment-96622572 I am curious, why did you rewrite the TaskManager? I thought that one was logging synchronously already. --- If your project is set up for it, you can reply to this e

[jira] [Commented] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

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

[GitHub] flink pull request: [FLINK-1923] Replaces asynchronous logging wit...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/628#discussion_r29140183 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -357,16 +356,6 @@ protected void unregisterTask() {

[jira] [Commented] (FLINK-1911) DataStream and DataSet projection is out of sync

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

[GitHub] flink pull request: [FLINK-1911] [streaming] Streaming projection ...

2015-04-27 Thread szape
GitHub user szape opened a pull request: https://github.com/apache/flink/pull/630 [FLINK-1911] [streaming] Streaming projection without types Since the DataSet projection has been reworked to not require the .types(...) call the Streaming and Batch methods were out of sync. So,

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

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

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

2015-04-27 Thread chiwanpark
GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/629 [FLINK-1933] Add distance measure interface and basic implementation to machine learning library This PR contains following changes: * Add `dot` method and `magnitude` method. * Add `

[jira] [Commented] (FLINK-1924) [Py] Refactor a few minor things

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

[GitHub] flink pull request: [FLINK-1924] Minor Refactoring

2015-04-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/616#issuecomment-96617964 @aljoscha Alright, will merge in a bit. --- 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 no

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

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

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-96599424 Yes, user-facing remains strings which are file paths. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

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

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-04-27 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-96591270 It is not a problem in exposing this to the client as well, I was just unsure if it is necessary. I will add to the client as well to be in sync. Yes, it makes sense to

[GitHub] flink pull request: [FLINK-1682] Ported optimizer unit tests from ...

2015-04-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/627#issuecomment-96580250 Wow, very nice :-) Looks correct from a first glance (I did not thoroughly check everything). One remark: Since `print()` may become an eagerly evaluated comma

[jira] [Commented] (FLINK-1682) Port Record-API based optimizer tests to new Java API

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

[GitHub] flink pull request: [runtime] Bump Netty version to 4.27.Final and...

2015-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/617 --- 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 enabl

[jira] [Commented] (FLINK-1947) Make Avro and Tachyon test logging less verbose

2015-04-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513768#comment-14513768 ] Stephan Ewen commented on FLINK-1947: - You can avoid the sysout logging by using {{Ex

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

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

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-27 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/571#discussion_r29130488 --- Diff: flink-staging/flink-hbase/pom.xml --- @@ -112,6 +112,12 @@ under the License.

[jira] [Commented] (FLINK-1924) [Py] Refactor a few minor things

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

[GitHub] flink pull request: [FLINK-1924] Minor Refactoring

2015-04-27 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/616#issuecomment-96573887 +1, can you merge it @mxm --- 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 t

[jira] [Commented] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

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

[GitHub] flink pull request: [FLINK-1923] Replaces asynchronous logging wit...

2015-04-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/628 [FLINK-1923] Replaces asynchronous logging with synchronous logging in actors Replaces asynchronous logging with synchronous logging in actors. Additionally, all Scala implementations are now u

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

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

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/571#discussion_r29129684 --- Diff: flink-staging/flink-hbase/pom.xml --- @@ -112,6 +112,12 @@ under the License.

[jira] [Commented] (FLINK-1924) [Py] Refactor a few minor things

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

[GitHub] flink pull request: [FLINK-1924] Minor Refactoring

2015-04-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/616#issuecomment-96570629 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 enabled and wis

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-04-27 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/621#issuecomment-96565454 The tests are failing because you use spaces in you code for indentation. Could you please change all indentation to tabs to satisfy the style checker? --- If your proje

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[jira] [Commented] (FLINK-1682) Port Record-API based optimizer tests to new Java API

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

[GitHub] flink pull request: [FLINK-1682] Ported optimizer unit tests from ...

2015-04-27 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/627 [FLINK-1682] Ported optimizer unit tests from Record API to Java API This is a step towards removing the deprecated Record API. You can merge this pull request into a Git repository by running:

  1   2   >