(pinot) branch master updated: Deprecates AllowConsumptionDuringCommit config (#15452)

[jackie]

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 156105931d Deprecates AllowConsumptionDuringCommit config (#15452)
156105931d is described below

commit 156105931d41fad744068e4d4b85ce6ab70ac94b
Author: NOOB <43700604+noob-se...@users.noreply.github.com>
AuthorDate: Tue Apr 8 06:07:45 2025 +0530

    Deprecates AllowConsumptionDuringCommit config (#15452)
---
 .../src/main/java/org/apache/pinot/spi/config/table/DedupConfig.java  | 4 ++++
 .../src/main/java/org/apache/pinot/spi/config/table/UpsertConfig.java | 4 ++++
 2 files changed, 8 insertions(+)

diff --git 
a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/DedupConfig.java 
b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/DedupConfig.java
index b3dc13f420..165d9dad97 100644
--- a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/DedupConfig.java
+++ b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/DedupConfig.java
@@ -47,6 +47,8 @@ public class DedupConfig extends BaseJsonConfig {
   @JsonPropertyDescription("Whether to preload segments for fast dedup 
metadata recovery")
   private boolean _enablePreload;
 
+  /// @deprecated use {@link 
org.apache.pinot.spi.config.table.ingestion.ParallelSegmentConsumptionPolicy)} 
instead.
+  @Deprecated
   @JsonPropertyDescription("Whether to pause dedup table's partition 
consumption during commit")
   private boolean _allowDedupConsumptionDuringCommit;
 
@@ -104,10 +106,12 @@ public class DedupConfig extends BaseJsonConfig {
     _enablePreload = enablePreload;
   }
 
+  @Deprecated
   public boolean isAllowDedupConsumptionDuringCommit() {
     return _allowDedupConsumptionDuringCommit;
   }
 
+  @Deprecated
   public void setAllowDedupConsumptionDuringCommit(boolean 
allowDedupConsumptionDuringCommit) {
     _allowDedupConsumptionDuringCommit = allowDedupConsumptionDuringCommit;
   }
diff --git 
a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/UpsertConfig.java 
b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/UpsertConfig.java
index ea8195a70e..a77de822dd 100644
--- 
a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/UpsertConfig.java
+++ 
b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/UpsertConfig.java
@@ -101,6 +101,8 @@ public class UpsertConfig extends BaseJsonConfig {
   @JsonPropertyDescription("Whether to drop out-of-order record")
   private boolean _dropOutOfOrderRecord;
 
+  /// @deprecated use {@link 
org.apache.pinot.spi.config.table.ingestion.ParallelSegmentConsumptionPolicy)} 
instead.
+  @Deprecated
   @JsonPropertyDescription("Whether to pause partial upsert table's partition 
consumption during commit")
   private boolean _allowPartialUpsertConsumptionDuringCommit;
 
@@ -301,10 +303,12 @@ public class UpsertConfig extends BaseJsonConfig {
     _metadataManagerConfigs = metadataManagerConfigs;
   }
 
+  @Deprecated
   public void setAllowPartialUpsertConsumptionDuringCommit(boolean 
allowPartialUpsertConsumptionDuringCommit) {
     _allowPartialUpsertConsumptionDuringCommit = 
allowPartialUpsertConsumptionDuringCommit;
   }
 
+  @Deprecated
   public boolean isAllowPartialUpsertConsumptionDuringCommit() {
     return _allowPartialUpsertConsumptionDuringCommit;
   }


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