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

fix: Apply offset. (#18957)

Browse Source
This commit is contained in:
Siddhant 2024-12-14 22:30:58 +05:30 committed by GitHub
parent 497b477be3
commit a3cfd8a3f0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java
View File

@ -4152,7 +4152,7 @@ public interface CollectionDAO {
@Bind("eventType") String eventType, @Bind("timestamp") long timestamp); @Bind("eventType") String eventType, @Bind("timestamp") long timestamp);
@SqlQuery( @SqlQuery(
"SELECT json FROM change_event ce where ce.offset > :offset ORDER BY ce.eventTime ASC LIMIT :limit") "SELECT json FROM change_event WHERE offset > :offset ORDER BY offset ASC LIMIT :limit")
List<String> list(@Bind("limit") long limit, @Bind("offset") long offset); List<String> list(@Bind("limit") long limit, @Bind("offset") long offset);
@ConnectionAwareSqlQuery(value = "SELECT MAX(offset) FROM change_event", connectionType = MYSQL) @ConnectionAwareSqlQuery(value = "SELECT MAX(offset) FROM change_event", connectionType = MYSQL)