This is an automated email from the ASF dual-hosted git repository.
yuqi1129 pushed a change to branch me/fix-entity-change-log-poller-11736
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from 262b6991a0 [#11736] improvement(core): Address review comments on
EntityChangeLogPoller
add 2792e1cb56 [#11736] improvement(core): Replace poll lag with
created_at watermark + overlap window
No new revisions were added by this update.
Summary of changes:
.../fileset/TestFilesetCatalogOperations.java | 4 +-
.../catalog/kafka/TestKafkaCatalogOperations.java | 4 +-
.../generic/TestGenericCatalogOperations.java | 4 +-
.../catalog/model/TestModelCatalogOperations.java | 4 +-
.../cache/it/AbstractEntityStorageBenchmark.java | 4 +-
.../main/java/org/apache/gravitino/Configs.java | 25 ++++---
.../storage/relational/EntityChangeLogPoller.java | 87 ++++++++++++----------
.../storage/relational/RelationalEntityStore.java | 2 +-
.../relational/mapper/EntityChangeLogMapper.java | 8 +-
.../mapper/EntityChangeLogSQLProviderFactory.java | 10 +--
.../base/EntityChangeLogBaseSQLProvider.java | 43 ++++++-----
.../EntityChangeLogPostgreSQLProvider.java | 15 ----
.../authorization/TestAccessControlManager.java | 4 +-
.../gravitino/authorization/TestOwnerManager.java | 4 +-
.../gravitino/hook/TestFilesetHookDispatcher.java | 4 +-
.../gravitino/hook/TestTableHookDispatcher.java | 4 +-
.../apache/gravitino/policy/TestPolicyManager.java | 4 +-
.../gravitino/stats/TestStatisticManager.java | 4 +-
.../storage/AbstractEntityStorageTest.java | 4 +-
.../relational/TestEntityChangeLogPoller.java | 43 ++++++-----
.../provider/base/TestEntityChangeLogMapper.java | 66 +++++++++++-----
.../service/TestEntityChangeLogService.java | 80 ++++++++++----------
.../relational/service/TestTableMetaService.java | 20 ++---
.../org/apache/gravitino/tag/TestTagManager.java | 4 +-
docs/gravitino-server-config.md | 2 +-
.../jcasbin/TestJcasbinAuthorizer.java | 2 +-
26 files changed, 237 insertions(+), 218 deletions(-)
