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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
