git

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/app/service/TaskApplicationService.java

@@ -311,6 +311,7 @@ public class TaskApplicationService {
                             csvName = split;
                             String linuxFile = linuxPath + split;
                             String minioPathCsv = taskPath + split;
+                            log.info("下载minio文件:{},path:{}", minioPathCsv, linuxFile);
                             MinioUtil.downloadToFile(minioClient, bucketName, minioPathCsv, linuxFile);
                         }
                     }
@@ -391,7 +392,6 @@ public class TaskApplicationService {
                 multiSimulationProjectParam.setProjectStatus(MultiSimulationStatusEnum.COMPLETED_STATUS.getProjectStatus());
                 multiSimulationProjectMapper.updateMultiSimulationProjectStatus(multiSimulationProjectParam);
                 // 删除kafka topic
-                // todo 暂时不删除
                 KafkaUtil.deleteTopic(kafkaAdminClient, projectId);
                 //6 删除项目 pod 启动文件
                 FileUtil.deleteFileBySubstring(multiPodYamlDirectory, projectId);