From dfd617ed964bcdc38a9db0beb6321e39a753ccf1 Mon Sep 17 00:00:00 2001 From: teddy Date: Fri, 23 Jan 2026 17:51:16 +0900 Subject: [PATCH] =?UTF-8?q?soptless=20=EC=A0=81=EC=9A=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/InferenceResultService.java | 16 +++++----------- .../Inference/MapSheetLearnRepositoryImpl.java | 10 +++++----- src/main/resources/application-prod.yml | 1 + 3 files changed, 11 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java b/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java index 62449ebd..a1ed7e9a 100644 --- a/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java +++ b/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java @@ -85,7 +85,6 @@ public class InferenceResultService { @Value("${inference.inference-server-name}") private String inferenceServerName; - @Value("${file.dataset-dir}") private String datasetDir; @@ -522,13 +521,13 @@ public class InferenceResultService { public List getInferenceServerStatusList() { String[] serverNames = inferenceServerName.split(","); - int serveCnt = serverNames.length; + int serveCnt = serverNames.length; List dtoList = inferenceResultCoreService.getInferenceServerStatusList(); int size = dtoList.size(); - List serverStatusList = new ArrayList<>(); + List serverStatusList = new ArrayList<>(); System.out.println("size =" + size); @@ -550,9 +549,8 @@ public class InferenceResultService { String srvNm = serverNames[k]; String srvNmChk = "N"; - Optional matchingDto = dtoList.stream() - .filter(dto -> srvNm.equals(dto.getServerName())) - .findFirst(); + Optional matchingDto = + dtoList.stream().filter(dto -> srvNm.equals(dto.getServerName())).findFirst(); /* int serverChekcCnt = @@ -569,14 +567,10 @@ public class InferenceResultService { dto.setKbmemused(0L); dto.setGpuUtil(0); serverStatusList.add(dto); - } - else - { + } else { serverStatusList.add(matchingDto.get()); } - } - } serverStatusList.sort(Comparator.comparing(InferenceServerStatusDto::getServerName)); diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java index 1e099d78..d6d1d719 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java @@ -152,8 +152,7 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto systemMetricEntity.cpuSystem, systemMetricEntity.memused, systemMetricEntity.kbmemused, - gpuMetricEntity.gpuUtil - )) + gpuMetricEntity.gpuUtil)) .from(systemMetricEntity) .leftJoin(gpuMetricEntity) .on( @@ -161,9 +160,10 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto .timestamp .in(latestGpuIds) .and(gpuMetricEntity.serverName.eq(systemMetricEntity.serverName))) - .where(systemMetricEntity.timestamp.in(latestIds) - //.and(systemMetricEntity.serverName.ne("server2")) - ) // In 절 사용 + .where( + systemMetricEntity.timestamp.in(latestIds) + // .and(systemMetricEntity.serverName.ne("server2")) + ) // In 절 사용 .orderBy(systemMetricEntity.serverName.asc()) .limit(4) .fetch(); diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml index e5aee003..59ceca5d 100644 --- a/src/main/resources/application-prod.yml +++ b/src/main/resources/application-prod.yml @@ -64,6 +64,7 @@ inference: batch-url: http://10.100.0.11:8000/batches geojson-dir: /kamco-nfs/requests/ jar-path: /kamco-nfs/dataset/shp_exporter-1.0.0.jar + inference-server-name: server1,server2,server3,server4 gukyuin: #url: http://localhost:8080