You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by GitBox <gi...@apache.org> on 2022/12/23 12:34:17 UTC

[GitHub] [pinot] xiangfu0 opened a new pull request, #10027: Adding a peridical task to automatically remove stale instances

xiangfu0 opened a new pull request, #10027:
URL: https://github.com/apache/pinot/pull/10027

   Instructions:
   1. The PR has to be tagged with at least one of the following labels (*):
      1. `feature`
      2. `bugfix`
      3. `performance`
      4. `ui`
      5. `backward-incompat`
      6. `release-notes` (**)
   2. Remove these instructions before publishing the PR.
    
   (*) Other labels to consider:
   - `testing`
   - `dependencies`
   - `docker`
   - `kubernetes`
   - `observability`
   - `security`
   - `code-style`
   - `extension-point`
   - `refactor`
   - `cleanup`
   
   (**) Use `release-notes` label for scenarios like:
   - New configuration options
   - Deprecation of configurations
   - Signature changes to public methods/interfaces
   - New plugins added or old plugins removed
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] Jackie-Jiang commented on a diff in pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
Jackie-Jiang commented on code in PR #10027:
URL: https://github.com/apache/pinot/pull/10027#discussion_r1060987608


##########
pinot-common/src/main/java/org/apache/pinot/common/metrics/ControllerGauge.java:
##########
@@ -99,9 +99,16 @@ public enum ControllerGauge implements AbstractMetrics.Gauge {
   // Number of Tasks Status
   TASK_STATUS("taskStatus", false),
 
-  // Number of dropped minion instances
+  // Number of dropped stale minion instances
   DROPPED_MINION_INSTANCES("droppedMinionInstances", true),
 
+  // Number of dropped stale broker instances
+  DROPPED_BROKER_INSTANCES("droppedBrokerInstances", true),
+
+  // Number of dropped stale server instances
+  DROPPED_SERVER_INSTANCES("droppedServerInstances", true),
+
+

Review Comment:
   (nit) Remove extra empty line



##########
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/cleanup/StaleInstancesCleanupTask.java:
##########
@@ -34,23 +36,30 @@
 
 
 /**
- * A periodic task to clean up offline Minion instances to not spam Helix.
+ * Automatically removes stale instances from the cluster to not spam Helix.
+ * Stale instance is the instance not in use (not hosting any data or query) and has been in the offline status for more
+ * than the stale instance retention time.
  */
-public class MinionInstancesCleanupTask extends BasePeriodicTask {
-  private static final Logger LOGGER = LoggerFactory.getLogger(MinionInstancesCleanupTask.class);
-  private final static String TASK_NAME = "MinionInstancesCleanupTask";
+public class StaleInstancesCleanupTask extends BasePeriodicTask {
+  private static final Logger LOGGER = LoggerFactory.getLogger(StaleInstancesCleanupTask.class);
+  private final static String TASK_NAME = "StaleInstancesCleanupTask";
+
   protected final PinotHelixResourceManager _pinotHelixResourceManager;
   protected final LeadControllerManager _leadControllerManager;
   protected final ControllerMetrics _controllerMetrics;
+  // This applies to both broker and server instances.
+  private final long _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds;
   private final long _minionInstanceCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds;

Review Comment:
   Deprecate this one?



##########
pinot-controller/src/main/java/org/apache/pinot/controller/ControllerConf.java:
##########
@@ -139,6 +139,14 @@ public static class ControllerPeriodicTasksConf {
         "controller.minion.instances.cleanup.task.minOfflineTimeBeforeDeletionSeconds";
     public static final String MINION_INSTANCES_CLEANUP_TASK_MIN_OFFLINE_TIME_BEFORE_DELETION_PERIOD =
         "controller.minion.instances.cleanup.task.minOfflineTimeBeforeDeletionPeriod";
+
+    public static final String STALE_INSTANCES_CLEANUP_TASK_FREQUENCY_PERIOD =

Review Comment:
   Add `Deprecated` annotation to old minion cleanup configs?



##########
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/cleanup/StaleInstancesCleanupTask.java:
##########
@@ -82,7 +95,47 @@ protected void runTask(Properties periodicTaskProperties) {
             _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_MINION_INSTANCES, 1);
           }
         }
+        continue;
+      }
+
+      // Drop the broker instance if it has been offline for more than a period of this task.
+      if (InstanceTypeUtils.isBroker(offlineInstance) && !brokerInstancesInUse.contains(offlineInstance)) {
+        if (_pinotHelixResourceManager.isInstanceOfflineFor(offlineInstance,
+            _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds)) {
+          LOGGER.info("Dropping broker instance: {}", offlineInstance);
+          PinotResourceManagerResponse response = _pinotHelixResourceManager.dropInstance(offlineInstance);
+          if (response.isSuccessful()) {
+            _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_BROKER_INSTANCES, 1);
+          }
+        }
+        continue;
+      }
+
+      // Drop the server instance if it has been offline for more than a period of this task.
+      if (InstanceTypeUtils.isServer(offlineInstance) && !serverInstancesInUse.contains(offlineInstance)) {
+        if (_pinotHelixResourceManager.isInstanceOfflineFor(offlineInstance,
+            _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds)) {
+          LOGGER.info("Dropping server instance: {}", offlineInstance);
+          PinotResourceManagerResponse response = _pinotHelixResourceManager.dropInstance(offlineInstance);
+          if (response.isSuccessful()) {
+            _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_SERVER_INSTANCES, 1);
+          }
+        }
       }
     }
   }
+
+  private Set<String> getBrokerInstancesInUse() {

Review Comment:
   No need to read all tables. Only need to read the `brokerResource` IS.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] codecov-commenter commented on pull request #10027: Adding a peridical task to automatically remove stale instances

Posted by GitBox <gi...@apache.org>.
codecov-commenter commented on PR #10027:
URL: https://github.com/apache/pinot/pull/10027#issuecomment-1363996012

   # [Codecov](https://codecov.io/gh/apache/pinot/pull/10027?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
   > Merging [#10027](https://codecov.io/gh/apache/pinot/pull/10027?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (bfca15c) into [master](https://codecov.io/gh/apache/pinot/commit/6303fc9940b77358d259607e8328a13c5577773a?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (6303fc9) will **decrease** coverage by `56.82%`.
   > The diff coverage is `63.26%`.
   
   ```diff
   @@              Coverage Diff              @@
   ##             master   #10027       +/-   ##
   =============================================
   - Coverage     70.44%   13.62%   -56.83%     
   + Complexity     5692      176     -5516     
   =============================================
     Files          1994     1940       -54     
     Lines        107462   105069     -2393     
     Branches      16330    16042      -288     
   =============================================
   - Hits          75705    14318    -61387     
   - Misses        26470    89624    +63154     
   + Partials       5287     1127     -4160     
   ```
   
   | Flag | Coverage Δ | |
   |---|---|---|
   | integration1 | `?` | |
   | integration2 | `?` | |
   | unittests1 | `?` | |
   | unittests2 | `13.62% <63.26%> (+0.04%)` | :arrow_up: |
   
   Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#carryforward-flags-in-the-pull-request-comment) to find out more.
   
   | [Impacted Files](https://codecov.io/gh/apache/pinot/pull/10027?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | Coverage Δ | |
   |---|---|---|
   | [...va/org/apache/pinot/controller/ControllerConf.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29udHJvbGxlci9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29udHJvbGxlci9Db250cm9sbGVyQ29uZi5qYXZh) | `55.80% <0.00%> (-3.89%)` | :arrow_down: |
   | [.../helix/core/cleanup/StaleInstancesCleanupTask.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29udHJvbGxlci9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29udHJvbGxlci9oZWxpeC9jb3JlL2NsZWFudXAvU3RhbGVJbnN0YW5jZXNDbGVhbnVwVGFzay5qYXZh) | `76.31% <76.31%> (ø)` | |
   | [...apache/pinot/controller/BaseControllerStarter.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29udHJvbGxlci9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29udHJvbGxlci9CYXNlQ29udHJvbGxlclN0YXJ0ZXIuamF2YQ==) | `78.97% <100.00%> (-3.50%)` | :arrow_down: |
   | [...src/main/java/org/apache/pinot/sql/FilterKind.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29tbW9uL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9waW5vdC9zcWwvRmlsdGVyS2luZC5qYXZh) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [...ain/java/org/apache/pinot/spi/utils/LoopUtils.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3Qtc3BpL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9waW5vdC9zcGkvdXRpbHMvTG9vcFV0aWxzLmphdmE=) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [...ain/java/org/apache/pinot/core/data/table/Key.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29yZS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29yZS9kYXRhL3RhYmxlL0tleS5qYXZh) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [...in/java/org/apache/pinot/spi/utils/BytesUtils.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3Qtc3BpL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9waW5vdC9zcGkvdXRpbHMvQnl0ZXNVdGlscy5qYXZh) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [...n/java/org/apache/pinot/core/data/table/Table.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29yZS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29yZS9kYXRhL3RhYmxlL1RhYmxlLmphdmE=) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [.../java/org/apache/pinot/core/data/table/Record.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29yZS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29yZS9kYXRhL3RhYmxlL1JlY29yZC5qYXZh) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | [.../java/org/apache/pinot/core/util/GroupByUtils.java](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-cGlub3QtY29yZS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcGlub3QvY29yZS91dGlsL0dyb3VwQnlVdGlscy5qYXZh) | `0.00% <0.00%> (-100.00%)` | :arrow_down: |
   | ... and [1570 more](https://codecov.io/gh/apache/pinot/pull/10027/diff?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | |
   
   :mega: We’re building smart automated test selection to slash your CI/CD build times. [Learn more](https://about.codecov.io/iterative-testing/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] xiangfu0 commented on a diff in pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
xiangfu0 commented on code in PR #10027:
URL: https://github.com/apache/pinot/pull/10027#discussion_r1061933761


##########
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/cleanup/StaleInstancesCleanupTask.java:
##########
@@ -34,23 +36,30 @@
 
 
 /**
- * A periodic task to clean up offline Minion instances to not spam Helix.
+ * Automatically removes stale instances from the cluster to not spam Helix.
+ * Stale instance is the instance not in use (not hosting any data or query) and has been in the offline status for more
+ * than the stale instance retention time.
  */
-public class MinionInstancesCleanupTask extends BasePeriodicTask {
-  private static final Logger LOGGER = LoggerFactory.getLogger(MinionInstancesCleanupTask.class);
-  private final static String TASK_NAME = "MinionInstancesCleanupTask";
+public class StaleInstancesCleanupTask extends BasePeriodicTask {
+  private static final Logger LOGGER = LoggerFactory.getLogger(StaleInstancesCleanupTask.class);
+  private final static String TASK_NAME = "StaleInstancesCleanupTask";
+
   protected final PinotHelixResourceManager _pinotHelixResourceManager;
   protected final LeadControllerManager _leadControllerManager;
   protected final ControllerMetrics _controllerMetrics;
+  // This applies to both broker and server instances.
+  private final long _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds;
   private final long _minionInstanceCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds;

Review Comment:
   removed.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] xiangfu0 commented on pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
xiangfu0 commented on PR #10027:
URL: https://github.com/apache/pinot/pull/10027#issuecomment-1371815209

   Updated to https://docs.pinot.apache.org/basics/components/controller#staleinstancescleanuptask


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] Jackie-Jiang commented on pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
Jackie-Jiang commented on PR #10027:
URL: https://github.com/apache/pinot/pull/10027#issuecomment-1371628736

   Please update the PR description with some release note, and also update the pinot doc about the new configs


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] xiangfu0 commented on a diff in pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
xiangfu0 commented on code in PR #10027:
URL: https://github.com/apache/pinot/pull/10027#discussion_r1061933883


##########
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/cleanup/StaleInstancesCleanupTask.java:
##########
@@ -82,7 +95,47 @@ protected void runTask(Properties periodicTaskProperties) {
             _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_MINION_INSTANCES, 1);
           }
         }
+        continue;
+      }
+
+      // Drop the broker instance if it has been offline for more than a period of this task.
+      if (InstanceTypeUtils.isBroker(offlineInstance) && !brokerInstancesInUse.contains(offlineInstance)) {
+        if (_pinotHelixResourceManager.isInstanceOfflineFor(offlineInstance,
+            _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds)) {
+          LOGGER.info("Dropping broker instance: {}", offlineInstance);
+          PinotResourceManagerResponse response = _pinotHelixResourceManager.dropInstance(offlineInstance);
+          if (response.isSuccessful()) {
+            _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_BROKER_INSTANCES, 1);
+          }
+        }
+        continue;
+      }
+
+      // Drop the server instance if it has been offline for more than a period of this task.
+      if (InstanceTypeUtils.isServer(offlineInstance) && !serverInstancesInUse.contains(offlineInstance)) {
+        if (_pinotHelixResourceManager.isInstanceOfflineFor(offlineInstance,
+            _staleInstancesCleanupTaskMinOfflineTimeBeforeDeletionInMilliseconds)) {
+          LOGGER.info("Dropping server instance: {}", offlineInstance);
+          PinotResourceManagerResponse response = _pinotHelixResourceManager.dropInstance(offlineInstance);
+          if (response.isSuccessful()) {
+            _controllerMetrics.addValueToGlobalGauge(ControllerGauge.DROPPED_SERVER_INSTANCES, 1);
+          }
+        }
       }
     }
   }
+
+  private Set<String> getBrokerInstancesInUse() {

Review Comment:
   updated to use brokerResource



##########
pinot-controller/src/main/java/org/apache/pinot/controller/ControllerConf.java:
##########
@@ -139,6 +139,14 @@ public static class ControllerPeriodicTasksConf {
         "controller.minion.instances.cleanup.task.minOfflineTimeBeforeDeletionSeconds";
     public static final String MINION_INSTANCES_CLEANUP_TASK_MIN_OFFLINE_TIME_BEFORE_DELETION_PERIOD =
         "controller.minion.instances.cleanup.task.minOfflineTimeBeforeDeletionPeriod";
+
+    public static final String STALE_INSTANCES_CLEANUP_TASK_FREQUENCY_PERIOD =

Review Comment:
   done



##########
pinot-common/src/main/java/org/apache/pinot/common/metrics/ControllerGauge.java:
##########
@@ -99,9 +99,16 @@ public enum ControllerGauge implements AbstractMetrics.Gauge {
   // Number of Tasks Status
   TASK_STATUS("taskStatus", false),
 
-  // Number of dropped minion instances
+  // Number of dropped stale minion instances
   DROPPED_MINION_INSTANCES("droppedMinionInstances", true),
 
+  // Number of dropped stale broker instances
+  DROPPED_BROKER_INSTANCES("droppedBrokerInstances", true),
+
+  // Number of dropped stale server instances
+  DROPPED_SERVER_INSTANCES("droppedServerInstances", true),
+
+

Review Comment:
   done



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[GitHub] [pinot] xiangfu0 merged pull request #10027: Repurpose MinionInstancesCleanupTask to StaleInstancesCleanupTask to remove stale broker/server instances

Posted by GitBox <gi...@apache.org>.
xiangfu0 merged PR #10027:
URL: https://github.com/apache/pinot/pull/10027


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org