This is an automated email from the ASF dual-hosted git repository.
manishswaminathan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 9ca8a870da Bump com.diffplug.spotless:spotless-maven-plugin from
2.44.2 to 2.44.3 (#15106)
add 49f0ebae53 Decouple tracking and storage in MinionEventObserver using
MinionTaskObserverStorageManager (#15044)
No new revisions were added by this update.
Summary of changes:
.../minion/tasks/TestEventObserverFactory.java | 14 ++
.../org/apache/pinot/minion/BaseMinionStarter.java | 26 ++-
.../java/org/apache/pinot/minion/MinionConf.java | 1 +
.../event/BaseMinionProgressObserverFactory.java | 13 +-
.../minion/event/DefaultMinionEventObserver.java | 12 ++
.../event/DefaultMinionEventObserverFactory.java | 6 +
.../DefaultMinionTaskObserverStorageManager.java | 95 +++++++++++
.../minion/event/EventObserverFactoryRegistry.java | 8 +-
.../pinot/minion/event/MinionEventObserver.java | 15 ++
.../minion/event/MinionEventObserverFactory.java | 7 +
.../pinot/minion/event/MinionEventObservers.java | 4 +-
.../pinot/minion/event/MinionProgressObserver.java | 117 ++++++++------
.../org/apache/pinot/minion/MinionTestUtils.java | 56 +++++++
.../resources/PinotTaskProgressResourceTest.java | 16 +-
.../minion/event/MinionEventObserversTest.java | 19 ++-
.../minion/event/MinionProgressObserverTest.java | 42 +++--
.../plugin/minion/tasks/MinionTaskTestUtils.java | 24 ++-
.../mergerollup/MergeRollupTaskExecutorTest.java | 6 +-
.../minion/tasks/purge/PurgeTaskExecutorTest.java | 4 +-
.../RealtimeToOfflineSegmentsTaskExecutorTest.java | 18 +--
.../spi/tasks/MinionTaskBaseObserverStats.java | 176 +++++++++++++++++++++
.../tasks/MinionTaskObserverStorageManager.java | 25 ++-
.../spi/tasks/MinionTaskBaseObserverStatsTest.java | 91 +++++++++++
23 files changed, 670 insertions(+), 125 deletions(-)
create mode 100644
pinot-minion/src/main/java/org/apache/pinot/minion/event/DefaultMinionTaskObserverStorageManager.java
create mode 100644
pinot-minion/src/test/java/org/apache/pinot/minion/MinionTestUtils.java
copy
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/BrokerData.java
=>
pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/test/java/org/apache/pinot/plugin/minion/tasks/MinionTaskTestUtils.java
(61%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/tasks/MinionTaskBaseObserverStats.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/SchedulerGroupFactory.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/tasks/MinionTaskObserverStorageManager.java
(59%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/tasks/MinionTaskBaseObserverStatsTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
