yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-29 00:53:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove and read alert on sync offset (#19862)

Browse Source 
(cherry picked from commit fce358eaa2c154acabcce851aa22dc783c30d5dc)
This commit is contained in:
Mohit Yadav 2025-02-18 18:36:58 +05:30 committed by mohitdeuex
parent b7611081a4
commit aac55afaa7
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EventSubscriptionRepository.java
View File

@ -115,7 +115,7 @@ public class EventSubscriptionRepository extends EntityRepository<EventSubscript
} }
public EventSubscriptionOffset syncEventSubscriptionOffset(String eventSubscriptionName) { public EventSubscriptionOffset syncEventSubscriptionOffset(String eventSubscriptionName) {
EventSubscription eventSubscription = getByName(null, eventSubscriptionName, getFields("id")); EventSubscription eventSubscription = getByName(null, eventSubscriptionName, getFields("*"));
long latestOffset = daoCollection.changeEventDAO().getLatestOffset(); long latestOffset = daoCollection.changeEventDAO().getLatestOffset();
long currentTime = System.currentTimeMillis(); long currentTime = System.currentTimeMillis();
// Upsert Offset // Upsert Offset
@ -133,6 +133,7 @@ public class EventSubscriptionRepository extends EntityRepository<EventSubscript
"eventSubscriptionOffset", "eventSubscriptionOffset",
JsonUtils.pojoToJson(eventSubscriptionOffset)); JsonUtils.pojoToJson(eventSubscriptionOffset));
EventSubscriptionScheduler.getInstance().updateEventSubscription(eventSubscription);
return eventSubscriptionOffset; return eventSubscriptionOffset;
} }