jihoonson opened a new issue #9245: The coordinator doesn't clean up the 
pendingSegments table for a datasource if there is no published segments in the 
datasource
URL: https://github.com/apache/druid/issues/9245
 
 
   ### Affected Version
   
   All versions since 0.12.0
   
   ### Description
   
   `DruidCoordinatorCleanupPendingSegments` checks only the datasources that 
have at least one published segments. See the below code snippet.
   
   ```java
       for (String dataSource : 
params.getUsedSegmentsTimelinesPerDataSource().keySet()) {
         if 
(!params.getCoordinatorDynamicConfig().getDataSourcesToNotKillStalePendingSegmentsIn().contains(dataSource))
 {
           log.info(
               "Killed [%d] pendingSegments created until [%s] for 
dataSource[%s]",
               indexingServiceClient.killPendingSegments(dataSource, 
stalePendingSegmentsCutoffCreationTime),
               stalePendingSegmentsCutoffCreationTime,
               dataSource
           );
         }
       }
   ```
   
   An easy fix would be adding a new class that handles the access to the 
`pendingSegments` table.

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to