[GitHub] flink pull request #2515: [FLINK-4638] Fix exception message for MemorySegme...

2016-09-19 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2515 [FLINK-4638] Fix exception message for MemorySegment You can merge this pull request into a Git repository by running: $ git pull https://github.com/lw-lin/flink fix-msg Alternatively you can

[GitHub] flink pull request #2515: [FLINK-4638] Fix exception message for MemorySegme...

2016-09-19 Thread lw-lin
Github user lw-lin commented on a diff in the pull request: https://github.com/apache/flink/pull/2515#discussion_r79544108 --- Diff: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java --- @@ -161,7 +161,7 @@ } if

[GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2556 [FLINK-4573] Fix potential resource leak due to unclosed RandomAccess… …File in TaskManagerLogHandler -- Thanks for contributing to Apache Flink. Before you open your pull

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2557 [FLINK-3734] Close stream state handles after state restorations Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
Github user lw-lin commented on a diff in the pull request: https://github.com/apache/flink/pull/2557#discussion_r80704455 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -568,8 +568,8 @@ public void setInitialState

[GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un...

2016-09-28 Thread lw-lin
Github user lw-lin commented on a diff in the pull request: https://github.com/apache/flink/pull/2556#discussion_r80947439 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -210,7 +210,17 @@ public void

[GitHub] flink issue #2557: [FLINK-3734] Close stream state handles after state resto...

2016-10-03 Thread lw-lin
Github user lw-lin commented on the issue: https://github.com/apache/flink/pull/2557 Glad to see this issue got fixed along with https://github.com/apache/flink/pull/2512 -- the fix is [this line in StreamTask](https://github.com/apache/flink/blob/master/flink-streaming-java/src/main

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-10-03 Thread lw-lin
Github user lw-lin closed the pull request at: https://github.com/apache/flink/pull/2557 --- 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