Use task actions to fetch used segments in MSQ#15284
Merged
cryptoe merged 9 commits intoDec 1, 2023
Merged
Conversation
github-actions
Bot
added
Area - Batch Ingestion
Area - MSQ
Contributor
|
@AmatyaAvadhanula , are more changes pending in this PR? |
Contributor
Author
|
@kfaraz, yes, there are several failing tests which need to be fixed. |
kfaraz
reviewed
Nov 8, 2023
| // If the task is operating with a REPLACE lock, | ||
| // any segment created after the lock was acquired for its interval will not be considered. | ||
| final Collection<DataSegment> publishedUsedSegments = new HashSet<>(); | ||
| for (Interval interval : intervals) { |
Contributor
There was a problem hiding this comment.
Looking at RetrieveSegmentsToReplaceAction and the method IndexerMetadataStorageConnector.retrieveUsedSegmentsAndCreatedDates, I suppose we could just pass a list of intervals to the action rather than firing a separate action for each interval.
This reverts commit 95ab649
cryptoe
marked this pull request as ready for review
November 21, 2023 15:25
kfaraz
approved these changes
Dec 1, 2023
kfaraz
left a comment
kfaraz
left a comment
Contributor
There was a problem hiding this comment.
Minor feedback which can be addressed in a later PR, otherwise LGTM.
| } | ||
| } else if (taskAction instanceof RetrieveSegmentsToReplaceAction) { | ||
| String dataSource = ((RetrieveSegmentsToReplaceAction) taskAction).getDataSource(); | ||
| return (RetType) injector.getInstance(SpecificSegmentsQuerySegmentWalker.class) |
Contributor
There was a problem hiding this comment.
Could you please add a comment here explaining why we need to use the QuerySegmentWalker here instead of how we handle RetrieveUsedSegmentsAction here or how we would respond to the coordinatorClient().fetchUsedSegments() in MSQ tests?
yashdeep97
pushed a commit
to yashdeep97/druid
that referenced
this pull request
Dec 1, 2023
* Use task actions to fetch used segments in MSQ * Fix tests * Fixing tests. * Revert "Fix tests" This reverts commit 95ab649 * Removing conditional check in tests. * Pulling in latest changes. --------- Co-authored-by: cryptoe <[email protected]>
yashdeep97
pushed a commit
to yashdeep97/druid
that referenced
this pull request
Dec 1, 2023
* Use task actions to fetch used segments in MSQ * Fix tests * Fixing tests. * Revert "Fix tests" This reverts commit 95ab649 * Removing conditional check in tests. * Pulling in latest changes. --------- Co-authored-by: cryptoe <[email protected]>
riovic918data
pushed a commit
to riovic918data/druid
that referenced
this pull request
Jun 12, 2026
* Use task actions to fetch used segments in MSQ * Fix tests * Fixing tests. * Revert "Fix tests" This reverts commit 95ab649 * Removing conditional check in tests. * Pulling in latest changes. --------- Co-authored-by: cryptoe <[email protected]>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
4 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
#15220 Introduced a new
RetrieveSegmentsToReplaceaction to be used in the DruidInputSource.This PR lets the MSQ Controller use this action in ControllerImpl#makeDataSegmentTimelineView, to allow a consistent set of segments to be returned, especially with a REPLACE lock.