This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 722d1e42873 Change the default settings to DISALLOW_ALWAYS for a
dropOutOfOrderRecord tables as well (#17671)
722d1e42873 is described below
commit 722d1e42873e0059893709e7d0a430855ff2d1de
Author: Chaitanya Deepthi <[email protected]>
AuthorDate: Mon Feb 9 13:58:08 2026 -0800
Change the default settings to DISALLOW_ALWAYS for a dropOutOfOrderRecord
tables as well (#17671)
---
.../pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
index 5f4fdc22138..b7122ccff35 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
@@ -1877,8 +1877,9 @@ public class RealtimeSegmentDataManager extends
SegmentDataManager {
// TODO: Revisit the non-pauseless handling
if (_partitionUpsertMetadataManager != null) {
UpsertContext upsertContext =
_partitionUpsertMetadataManager.getContext();
- if (upsertContext.isAllowPartialUpsertConsumptionDuringCommit()
- || upsertContext.getUpsertMode() != UpsertConfig.Mode.PARTIAL) {
+ if (upsertContext.isAllowPartialUpsertConsumptionDuringCommit() || (
+ upsertContext.getUpsertMode() != UpsertConfig.Mode.PARTIAL &&
!upsertContext.isDropOutOfOrderRecord()
+ && upsertContext.getOutOfOrderRecordColumn() == null)) {
return ParallelSegmentConsumptionPolicy.ALLOW_ALWAYS;
}
return pauseless ?
ParallelSegmentConsumptionPolicy.ALLOW_DURING_BUILD_ONLY
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
