This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch
maintain-pool-selection-for-minimizeDataMovement
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit 97ab0b7d4599fba3b85129982ed7132eeaf9ecf0
Author: Jialiang Li <j...@linkedin.com>
AuthorDate: Tue Nov 14 21:59:59 2023 -0800
Update
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/instance/InstancePartitionSelector.java
Co-authored-by: Xiaotian (Jackie) Jiang
<17555551+jackie-ji...@users.noreply.github.com>
---
.../helix/core/assignment/instance/InstancePartitionSelector.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/instance/InstancePartitionSelector.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/instance/InstancePartitionSelector.java
index 5f92db2426..335070b003 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/instance/InstancePartitionSelector.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/instance/InstancePartitionSelector.java
@@ -36,7 +36,9 @@ abstract class InstancePartitionSelector {
_replicaGroupPartitionConfig = replicaGroupPartitionConfig;
_tableNameWithType = tableNameWithType;
_existingInstancePartitions = existingInstancePartitions;
- _minimizeDataMovement = minimizeDataMovement;
+ // For backward compatibility, enable minimize data movement when it is
enabled in top level or instance
+ // partition selector level.
+ _minimizeDataMovement = minimizeDataMovement ||
replicaGroupPartitionConfig.isMinimizeDataMovement();
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
