src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java

@@ -12,18 +12,18 @@ import java.util.List;
 
 /**
  * Risk 상세 데이터 수집을 위한 IMO 목록 조회 Tasklet.
- * std_snp_svc.tb_ship_risk_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
+ * std_snp_data.tb_ship_default_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
  * JobExecutionContext에 저장.
  */
 @Slf4j
 public class RiskDetailImoFetchTasklet implements Tasklet {
 
     private final JdbcTemplate jdbcTemplate;
-    private final String serviceSchema;
+    private final String targetSchema;
 
-    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String serviceSchema) {
+    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String targetSchema) {
         this.jdbcTemplate = jdbcTemplate;
-        this.serviceSchema = serviceSchema;
+        this.targetSchema = targetSchema;
     }
 
     @Override
@@ -32,8 +32,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
                 .getStepExecution().getJobExecution();
 
         String sql = String.format(
-                "SELECT DISTINCT imo_no FROM %s.tb_ship_risk_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
-                serviceSchema);
+                "SELECT DISTINCT imo_no FROM %s.tb_ship_default_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
+                targetSchema);
 
         List<String> imoNumbers = jdbcTemplate.queryForList(sql, String.class);
 
@@ -42,8 +42,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
             jobExecution.getExecutionContext().putString("allImoNumbers", String.join(",", imoNumbers));
         }
 
-        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_risk_info)",
-                imoNumbers.size(), serviceSchema);
+        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_default_info)",
+                imoNumbers.size(), targetSchema);
 
         return RepeatStatus.FINISHED;
     }

src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java

@@ -47,9 +47,6 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
     @Value("${app.batch.target-schema.name}")
     private String targetSchema;
 
-    @Value("${app.batch.service-schema.name}")
-    private String serviceSchema;
-
     @Value("${app.batch.risk-detail.partition-count:4}")
     private int partitionCount;
 
@@ -94,7 +91,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Override
     protected int getChunkSize() {
-        return 100;
+        return 5000;
     }
 
     // ========================================
@@ -119,7 +116,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Bean
     public Tasklet riskDetailImoFetchTasklet() {
-        return new RiskDetailImoFetchTasklet(jdbcTemplate, serviceSchema);
+        return new RiskDetailImoFetchTasklet(jdbcTemplate, targetSchema);
     }
 
     @Bean(name = "RiskDetailImoFetchStep")