private void parseAll() {

        // Prepare CacheZones for each cluster and task
        Map<String, Map<String, String>> newMd5Map = new ConcurrentHashMap<>();
        Map<String, Map<String, CacheZoneConfig>> newConfigMap = new ConcurrentHashMap<>();

        streamSinkMap.forEach((sortClusterName, task2SinkList) -> {
            // prepare the new config and md5
            Map<String, CacheZoneConfig> task2Config = new ConcurrentHashMap<>();
            Map<String, String> task2Md5 = new ConcurrentHashMap<>();

            task2SinkList.forEach((taskName, sinkList) -> {
                try {
                    CacheZoneConfig cacheZoneConfig =
                            CacheZoneConfig.builder()
                                    .sortClusterName(sortClusterName)
                                    .sortTaskId(taskName)
                                    .build();
                    Map<String, CacheZone> cacheZoneMap =
                            this.parseCacheZones(sortClusterName, sinkList);
                    cacheZoneConfig.setCacheZones(cacheZoneMap);

                    // prepare md5
                    String jsonStr = GSON.toJson(cacheZoneConfig);
                    String md5 = DigestUtils.md5Hex(jsonStr);
                    task2Config.put(taskName, cacheZoneConfig);
                    task2Md5.put(taskName, md5);
                } catch (Throwable t) {
                    LOGGER.warn("failed to parse sort source config of sortCluster={}, task={}",
                            sortClusterName, taskName, t);
                }
            });
            newConfigMap.put(sortClusterName, task2Config);
            newMd5Map.put(sortClusterName, task2Md5);

        });
        sortSourceConfigMap = newConfigMap;
        sortSourceMd5Map = newMd5Map;
        sortClusters = null;
        mqClusters = null;
        groupInfos = null;
        allStreams = null;
        backupClusterTag = null;
        backupGroupMqResource = null;
        backupStreamMqResource = null;
        streamSinkMap = null;
    }
key 1: cluster name, key 2: task name, value : source config
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java