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() {
writeLock.lock();
try {
- if (!localFile.delete() &&
localFile.exists()) {
- log.warn("Failed to locally
delete blob " + localFile.getAbsolutePath());
- } else {
+ try {
+
Files.delete(localFile.toPath());
+ } catch (IOException e) {
+ log.error("Failed to delete
locally blob " + localFile.getAbsolutePath(), e);
+ } catch (Exception e) {
+ log.error("Failed to delete
locally blob " + localFile.getAbsolutePath(), e);
--- End diff --
typo: locally -> local
---
