[GitHub] flink pull request: FLINK-3197: InputStream not closed in BinaryIn...

2016-01-07 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/1494 FLINK-3197: InputStream not closed in BinaryInputFormat#createStatistics You can merge this pull request into a Git repository by running: $ git pull https://github.com/ajaybhat/flink

[GitHub] flink pull request: [FLINK-2125][streaming] Delimiter change from ...

2016-01-07 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/1491 [FLINK-2125][streaming] Delimiter change from char to string You can merge this pull request into a Git repository by running: $ git pull https://github.com/ajaybhat/flink char_buffer

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

2016-01-06 Thread ajaybhat
Github user ajaybhat commented on the pull request: https://github.com/apache/flink/pull/1486#issuecomment-169543630 The build has failed, but the failure seems unrelated to this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

2016-01-06 Thread ajaybhat
Github user ajaybhat commented on the pull request: https://github.com/apache/flink/pull/1486#issuecomment-169292981 Hi @chiwanpark > Could you re-implement DummyRecordWriter to make tests fast? Its because I saw many tests creating temporary files that I used the s

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

2016-01-06 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/1486 [FLINK-2445] Add tests for HadoopOutputFormats You can merge this pull request into a Git repository by running: $ git pull https://github.com/ajaybhat/flink test-fix Alternatively you can

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-05-25 Thread ajaybhat
Github user ajaybhat commented on a diff in the pull request: https://github.com/apache/flink/pull/720#discussion_r30982636 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -150,6 +150,14 @@ public void testMerged

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-05-24 Thread ajaybhat
Github user ajaybhat commented on a diff in the pull request: https://github.com/apache/flink/pull/720#discussion_r30963563 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -150,6 +150,14 @@ public void testMerged

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-05-24 Thread ajaybhat
Github user ajaybhat commented on the pull request: https://github.com/apache/flink/pull/720#issuecomment-105028293 > please do not merge my commit on the delta policies as it is already in. I don't know how that happened. As usual I just committed, rebased from ma

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-05-23 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/720 FLINK-2018 Add ParameterUtil.fromGenericOptionsParser() Pls review and comment You can merge this pull request into a Git repository by running: $ git pull https://github.com/ajaybhat/flink

[GitHub] flink pull request: [FLINK-1165] No createCollectionsEnvironment i...

2015-01-19 Thread ajaybhat
Github user ajaybhat commented on the pull request: https://github.com/apache/flink/pull/320#issuecomment-70484376 Fixed the typos. --- 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

[GitHub] flink pull request: [FLINK-1165] No createCollectionsEnvironment i...

2015-01-19 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/320 [FLINK-1165] No createCollectionsEnvironment in Java API This commit adds a new method to ExecutionEnvironment to create a CollectionEnvironment, and applies the method to cases where a

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-14 Thread ajaybhat
Github user ajaybhat commented on the pull request: https://github.com/apache/flink/pull/296#issuecomment-70046292 Thanks for the comments. Do you think the new message is better? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: [FLINK-1228] Add REST Interface to JobManager

2015-01-10 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/297 [FLINK-1228] Add REST Interface to JobManager Hi, For the [REST interface] (https://issues.apache.org/jira/browse/FLINK-1228) I'd like to start off with the JobManagerInfoSe

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-10 Thread ajaybhat
GitHub user ajaybhat opened a pull request: https://github.com/apache/flink/pull/296 [FLINK-1183] Generate gentle notification message when Flink is started with Java 6 I've closed the [previous PR ] (https://github.com/apache/flink/pull/277) in favor of this new one. Pls r

[GitHub] flink pull request: FLINK-1183 Generate gentle notification messag...

2015-01-10 Thread ajaybhat
Github user ajaybhat closed the pull request at: https://github.com/apache/flink/pull/277 --- 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