[environment-##1426] delete tmp flink-distribute-cache-xxx dir after …

…job is done
DTStack · Dec 2, 2022 · 587dbeb · 587dbeb
1 parent 4b834c5
commit 587dbeb
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/environment/MyLocalStreamEnvironment.java b/chunjun-core/src/main/java/com/dtstack/chunjun/environment/MyLocalStreamEnvironment.java
@@ -41,7 +41,6 @@
 import javax.annotation.Nonnull;
 
 import java.io.File;
-import java.io.FilenameFilter;
 import java.io.IOException;
 import java.net.URL;
 import java.util.Collections;
@@ -123,12 +122,7 @@ private void clearFlinkLocalDsitributeCache(JobGraph jobGraph) throws IOExceptio
  JobID jobID = jobGraph.getJobID();
  File[] flinkTmpDirs =
  osTmpDir.listFiles(
- new FilenameFilter() {
- @Override
- public boolean accept(File dir, String name) {
- return name.startsWith("flink-distributed-cache-" + jobID);
- }
- });
+ (dir, name) -> name.startsWith("flink-distributed-cache-" + jobID));
 
  if (flinkTmpDirs != null && flinkTmpDirs.length > 0) {
  for (File flinkTmpDir : flinkTmpDirs) {