You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Consistent data push protocol APIs are available via controller REST APIs such as startReplaceSegments, endReplaceSegments, and revertReplaceSegments. However, previously, ingestion jobs are not wired to use this feature.
Introduce a new boolean consistentDataPush in TableConfig->ingestionConfig->batchIngestionConfig that when enabled, supports batch ingestion in REFRESH mode to run in consistent data push mode.
Consistent push goal: supports atomic switching (on broker level) between data snapshots and eliminate the time period where the query is getting computed from inconsistent data mixed from existing and new data. Moreover, we aim to provide an easy way to rollback to the previous data in case of the bad data push.
Improve test coverage for pinot-batch-ingestion-standalone jobs to cover SegmentMetadataPushJobRunner, SegmentTarPushJobRunner and SegmentUriPushJobRunner.
Refactor the common logics out of all pushJobRunner(s) into a new abstract class BaseSegmentPushJobRunner.
Main change on enabling consistent data push on ingestion jobs.
The text was updated successfully, but these errors were encountered:
One challenge to solve here is the segment name conflict. Currently the reason why batch replace cannot be enabled for REFRESH mode is because the segment will have the same name, thus directly replace the existing segment. cc @snleee
yuanbenson
changed the title
Enable Consistent Data Push on Ingestion Jobs for REFRESH use case
Enable Consistent Data Push on Ingestion Jobs for REFRESH use case (standalone only)
Sep 7, 2022
Consistent data push protocol APIs are available via controller REST APIs such as
startReplaceSegments
,endReplaceSegments
, andrevertReplaceSegments
. However, previously, ingestion jobs are not wired to use this feature.Introduce a new boolean
consistentDataPush
inTableConfig->ingestionConfig->batchIngestionConfig
that when enabled, supports batch ingestion in REFRESH mode to run in consistent data push mode.Consistent push goal: supports atomic switching (on broker level) between data snapshots and eliminate the time period where the query is getting computed from inconsistent data mixed from existing and new data. Moreover, we aim to provide an easy way to rollback to the previous data in case of the bad data push.
See #7813 for more details.
Some tasks breakdown associated with this issue:
SegmentMetadataPushJobRunner
,SegmentTarPushJobRunner
andSegmentUriPushJobRunner
.BaseSegmentPushJobRunner
.The text was updated successfully, but these errors were encountered: