minor

dianfu · Apr 25, 2024 · 0d9d592 · 0d9d592
1 parent 127a521
commit 0d9d592
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-python/src/main/java/org/apache/flink/python/util/PythonDependencyUtils.java b/flink-python/src/main/java/org/apache/flink/python/util/PythonDependencyUtils.java
@@ -353,7 +353,7 @@ private void removeCachedFilesByPrefix(String prefix) {
             final List<String> cachedFiles =
                     config.getOptional(PipelineOptions.CACHED_FILES).orElse(new ArrayList<>())
                             .stream()
-                            .map(m -> Tuple2.of(ConfigurationUtils.parseMap(m), m))
+                            .map(m -> Tuple2.of(ConfigurationUtils.parseStringToMap(m), m))
                             .filter(
                                     t ->
                                             t.f0.get("name") != null