(dolphinscheduler) branch dev updated: [Fix-17668] [jdbc-registry] Aim to purge history registry data change events older than N hours, but actually purge events within N hours (#17669)

[zihaoxiang]

This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 941343dc7d [Fix-17668] [jdbc-registry] Aim to purge history registry 
data change events older than N hours, but actually purge events within N hours 
(#17669)
941343dc7d is described below

commit 941343dc7d678ddc1fdc112c2993f0bc2e3781ad
Author: qiong-zhou <zhouqiong...@gmail.com>
AuthorDate: Wed Nov 12 16:19:28 2025 +0800

    [Fix-17668] [jdbc-registry] Aim to purge history registry data change 
events older than N hours, but actually purge events within N hours (#17669)
---
 .../plugin/registry/jdbc/mapper/JdbcRegistryDataChangeEventMapper.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/mapper/JdbcRegistryDataChangeEventMapper.java
 
b/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/mapper/JdbcRegistryDataChangeEventMapper.java
index 46d15aa0ef..750121c27f 100644
--- 
a/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/mapper/JdbcRegistryDataChangeEventMapper.java
+++ 
b/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/mapper/JdbcRegistryDataChangeEventMapper.java
@@ -36,6 +36,6 @@ public interface JdbcRegistryDataChangeEventMapper extends 
BaseMapper<JdbcRegist
     @Select("select * from t_ds_jdbc_registry_data_change_event where id > 
#{id} order by id asc limit 1000")
     List<JdbcRegistryDataChangeEvent> 
selectJdbcRegistryDataChangeEventWhereIdAfter(@Param("id") long id);
 
-    @Delete("delete from t_ds_jdbc_registry_data_change_event where 
create_time > #{createTime}")
+    @Delete("delete from t_ds_jdbc_registry_data_change_event where 
create_time < #{createTime}")
     void 
deleteJdbcRegistryDataChangeEventBeforeCreateTime(@Param("createTime") Date 
createTime);
 }