diff --git a/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
index 1298b16..130cab7 100644
--- a/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
@@ -43,7 +43,7 @@ public class ComplianceImportRangeJobConfig extends BaseMultiStepJobConfig<Compl
     private final BatchDateService batchDateService;
     protected String getApiKey() {return "COMPLIANCE_IMPORT_API";}
     protected String getBatchUpdateSql() {
-        return "UPDATE SNP_DATA.BATCH_LAST_EXECUTION SET LAST_SUCCESS_DATE = NOW() WHERE API_KEY = '" + getApiKey() + "'";}
+        return String.format("UPDATE SNP_DATA.BATCH_LAST_EXECUTION SET LAST_SUCCESS_DATE = NOW(), UPDATED_AT = NOW() WHERE API_KEY = '%s'", getApiKey());}
 
     @Override
     protected int getChunkSize() {
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/config/EventImportJobConfig.java b/src/main/java/com/snp/batch/jobs/event/batch/config/EventImportJobConfig.java
index 9da156e..06febda 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/config/EventImportJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/config/EventImportJobConfig.java
@@ -1,6 +1,6 @@
 package com.snp.batch.jobs.event.batch.config;
 
-import com.snp.batch.common.batch.config.BaseJobConfig;
+import com.snp.batch.common.batch.config.BaseMultiStepJobConfig;
 import com.snp.batch.jobs.event.batch.dto.EventDetailDto;
 import com.snp.batch.jobs.event.batch.entity.EventDetailEntity;
 import com.snp.batch.jobs.event.batch.processor.EventDataProcessor;
@@ -10,10 +10,14 @@ import com.snp.batch.service.BatchDateService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.batch.core.Job;
 import org.springframework.batch.core.Step;
+import org.springframework.batch.core.job.builder.JobBuilder;
 import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.core.step.tasklet.Tasklet;
 import org.springframework.batch.item.ItemProcessor;
 import org.springframework.batch.item.ItemReader;
 import org.springframework.batch.item.ItemWriter;
+import org.springframework.batch.repeat.RepeatStatus;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -23,7 +27,7 @@ import org.springframework.web.reactive.function.client.WebClient;
 
 @Slf4j
 @Configuration
-public class EventImportJobConfig extends BaseJobConfig<EventDetailDto, EventDetailEntity> {
+public class EventImportJobConfig extends BaseMultiStepJobConfig<EventDetailDto, EventDetailEntity> {
     private final JdbcTemplate jdbcTemplate;
     private final WebClient maritimeApiWebClient;
 
@@ -32,6 +36,10 @@ public class EventImportJobConfig extends BaseJobConfig<EventDetailDto, EventDet
     private final EventDataWriter eventDataWriter;
     private final BatchDateService batchDateService;
 
+    protected String getApiKey() {return "EVENT_IMPORT_API";}
+    protected String getBatchUpdateSql() {
+        return String.format("UPDATE SNP_DATA.BATCH_LAST_EXECUTION SET LAST_SUCCESS_DATE = NOW(), UPDATED_AT = NOW() WHERE API_KEY = '%s'", getApiKey());}
+
     @Override
     protected int getChunkSize() {
         return 10; // API에서 5000개씩 가져오므로 chunk도 5000으로 설정
@@ -62,6 +70,14 @@ public class EventImportJobConfig extends BaseJobConfig<EventDetailDto, EventDet
         return "eventImportStep";
     }
 
+    @Override
+    protected Job createJobFlow(JobBuilder jobBuilder) {
+        return jobBuilder
+                .start(eventImportStep())
+                .next(eventLastExecutionUpdateStep())
+                .build();
+    }
+
     @Override
     protected ItemReader<EventDetailDto> createReader() {
         return new EventDataReader(maritimeApiWebClient, jdbcTemplate, batchDateService);
@@ -85,4 +101,25 @@ public class EventImportJobConfig extends BaseJobConfig<EventDetailDto, EventDet
         return step();
     }
 
+    /**
+     * 2단계: 모든 스텝 성공 시 배치 실행 로그(날짜) 업데이트
+     */
+    @Bean
+    public Tasklet eventLastExecutionUpdateTasklet() {
+        return (contribution, chunkContext) -> {
+            log.info(">>>>> 모든 스텝 성공: BATCH_LAST_EXECUTION 업데이트 시작");
+
+            jdbcTemplate.execute(getBatchUpdateSql());
+
+            log.info(">>>>> BATCH_LAST_EXECUTION 업데이트 완료");
+            return RepeatStatus.FINISHED;
+        };
+    }
+    @Bean(name = "EventLastExecutionUpdateStep")
+    public Step eventLastExecutionUpdateStep() {
+        return new StepBuilder("EventLastExecutionUpdateStep", jobRepository)
+                .tasklet(eventLastExecutionUpdateTasklet(), transactionManager)
+                .build();
+    }
+
 }
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/reader/EventDataReader.java b/src/main/java/com/snp/batch/jobs/event/batch/reader/EventDataReader.java
index aae9195..c1e0cfd 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/reader/EventDataReader.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/reader/EventDataReader.java
@@ -44,7 +44,7 @@ public class EventDataReader extends BaseApiReader<EventDetailDto> {
     }
 
     protected String getApiKey() {
-        return "EVENT_IMPORT_JOB";
+        return "EVENT_IMPORT_API";
     }
 
     // 배치 처리 상태
@@ -66,7 +66,7 @@ public class EventDataReader extends BaseApiReader<EventDetailDto> {
         log.info("Event API 호출");
         EventResponse response = callEventApiWithBatch();
         // 2-1. Event List 에서 EventID List 추출
-        // TODO: 2-2. Event List 에서 Map<EventId,Map<StartDate,EndDate>> 추출
+        // 2-2. Event List 에서 Map<EventId,Map<StartDate,EndDate>> 추출
         eventIds = extractEventIdList(response);
         log.info("EvnetId List 추출 완료 : {} 개", eventIds.size());
 
@@ -168,11 +168,6 @@ public class EventDataReader extends BaseApiReader<EventDetailDto> {
         int totalBatches = (int) Math.ceil((double) eventIds.size() / batchSize);
         try {
             if (data == null) {
-                // 3. ✨ 배치 성공 시 상태 업데이트 (트랜잭션 커밋 직전에 실행)
-                LocalDate successDate = LocalDate.now(); // 현재 배치 실행 시점의 날짜 (Reader의 toDay와 동일한 값)
-                batchDateService.updateLastSuccessDate(getApiKey(), successDate);
-                log.info("batch_last_execution update 완료 : {}", getApiKey());
-
                 log.info("[{}] 전체 {} 개 배치 처리 완료", getReaderName(), totalBatches);
                 log.info("[{}] 총 {} 개의 Event ID에 대한 API 호출 종료",
                         getReaderName(), eventIds.size());
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
index 5cbe1e0..687f56e 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
@@ -47,7 +47,7 @@ public class EventRepositoryImpl extends BaseJdbcRepository<EventDetailEntity, L
     @Override
     protected String getUpdateSql() {
         return """
-                INSERT INTO snp_data.event_detail (
+                INSERT INTO snp_data.event (
                     Event_ID, Incident_ID, IHSLRorIMOShipNo, Vessel_Name, Vessel_Type,
                     Event_Type, Significance, Headline, Location_Name,
                     Published_Date, Event_Start_Date, Event_End_Date, batch_flag
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventSql.java b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventSql.java
index 02d139d..0b6d1a7 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventSql.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventSql.java
@@ -3,7 +3,7 @@ package com.snp.batch.jobs.event.batch.repository;
 public class EventSql {
     public static String getEventDetailUpdateSql(){
         return """
-               INSERT INTO new_snp.event_detail (
+               INSERT INTO new_snp.event (
                    event_id, incident_id, ihslrorimoshipno, published_date, event_start_date, event_end_date,
                    attempted_boarding, cargo_loading_status_code, casualty_action,
                    casualty_zone, casualty_zone_code, component2, country_code,
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/writer/EventDataWriter.java b/src/main/java/com/snp/batch/jobs/event/batch/writer/EventDataWriter.java
index 936ce48..7185f9c 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/writer/EventDataWriter.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/writer/EventDataWriter.java
@@ -13,7 +13,6 @@ import java.util.List;
 @Component
 public class EventDataWriter extends BaseWriter<EventDetailEntity> {
     private final EventRepository eventRepository;
-    protected String getApiKey() {return "EVENT_IMPORT_JOB";}
     public EventDataWriter(EventRepository eventRepository) {
         super("EventRepository");
         this.eventRepository = eventRepository;
diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
index 7b1d2f0..0086faf 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
@@ -38,7 +38,8 @@ public class RiskImportRangeJobConfig extends BaseMultiStepJobConfig<RiskDto, Ri
 
     protected String getApiKey() {return "RISK_IMPORT_API";}
     protected String getBatchUpdateSql() {
-        return "UPDATE SNP_DATA.BATCH_LAST_EXECUTION SET LAST_SUCCESS_DATE = NOW() WHERE API_KEY = '" + getApiKey() + "'";}
+        return String.format("UPDATE SNP_DATA.BATCH_LAST_EXECUTION SET LAST_SUCCESS_DATE = NOW(), UPDATED_AT = NOW() WHERE API_KEY = '%s'", getApiKey());}
+
 
     @Override
     protected int getChunkSize() {