Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5777
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r195370225
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r195369853
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r195369715
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r17396
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r177736130
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5777
[FLINK-7897] Consider using nio.Files for file deletion in
TransientBlobCleanupTask
## What is the purpose of the change
*This pull request use `nio.Files.delete` method to make the delete
