This is an automated email from the ASF dual-hosted git repository.

rongr 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 5253c37088 default enable metadata manager for colocated join 
quickstart (#11579)
5253c37088 is described below

commit 5253c37088f32fb6f90161dfb6e78b4458fec8a7
Author: Rong Rong <[email protected]>
AuthorDate: Tue Sep 12 20:16:03 2023 -0700

    default enable metadata manager for colocated join quickstart (#11579)
    
    colocated join quickstart didn't enable partition metadata manager, this 
enables it.
    
    Co-authored-by: Rong Rong <[email protected]>
---
 .../org/apache/pinot/tools/ColocatedJoinEngineQuickStart.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/pinot-tools/src/main/java/org/apache/pinot/tools/ColocatedJoinEngineQuickStart.java
 
b/pinot-tools/src/main/java/org/apache/pinot/tools/ColocatedJoinEngineQuickStart.java
index 0241168b81..c9d8b42e45 100644
--- 
a/pinot-tools/src/main/java/org/apache/pinot/tools/ColocatedJoinEngineQuickStart.java
+++ 
b/pinot-tools/src/main/java/org/apache/pinot/tools/ColocatedJoinEngineQuickStart.java
@@ -21,7 +21,10 @@ package org.apache.pinot.tools;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
+import org.apache.pinot.spi.utils.CommonConstants;
 import org.apache.pinot.tools.admin.PinotAdministrator;
 
 
@@ -36,6 +39,13 @@ public class ColocatedJoinEngineQuickStart extends 
MultistageEngineQuickStart {
     return Collections.singletonList(QUICKSTART_IDENTIFIER);
   }
 
+  @Override
+  public Map<String, Object> getConfigOverrides() {
+    Map<String, Object> overrides = new HashMap<>(super.getConfigOverrides());
+    
overrides.put(CommonConstants.Broker.CONFIG_OF_ENABLE_PARTITION_METADATA_MANAGER,
 "true");
+    return overrides;
+  }
+
   @Override
   public String[] getDefaultBatchTableDirectories() {
     return COLOCATED_JOIN_DIRECTORIES;


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to