Update previous nits to pass unit tests

apache · Mar 14, 2022 · 5072901 · 5072901
1 parent d8895c8
commit 5072901
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...rc/main/java/org/apache/pinot/segment/local/recordtransformer/ComplexTypeTransformer.java b/...rc/main/java/org/apache/pinot/segment/local/recordtransformer/ComplexTypeTransformer.java
@@ -25,7 +25,6 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;
 import javax.annotation.Nullable;
 import org.apache.pinot.common.function.scalar.JsonFunctions;
 import org.apache.pinot.spi.config.table.TableConfig;
@@ -301,7 +300,7 @@ protected void renamePrefixes(GenericRow record) {
     if (_prefixesToRename.isEmpty()) {
       return;
     }
-    Set<String> fields = record.getFieldToValueMap().keySet();
+    List<String> fields = new ArrayList<>(record.getFieldToValueMap().keySet());
     for (Map.Entry<String, String> entry : _prefixesToRename.entrySet()) {
       for (String field : fields) {
         String prefix = entry.getKey();

diff --git a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/TableConfigUtils.java b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/TableConfigUtils.java
@@ -358,7 +358,7 @@ public static void validateIngestionConfig(TableConfig tableConfig, @Nullable Sc
         if (MapUtils.isNotEmpty(prefixesToRename)) {
           for (String prefix : prefixesToRename.keySet()) {
             for (String field : fieldNames) {
-              Preconditions.checkState(field.startsWith(prefix),
+              Preconditions.checkState(!field.startsWith(prefix),
                       "Fields in the schema may not begin with any prefix specified in the prefixesToRename"
                               + " config. Name conflict with field: " + field + " and prefix: " + prefix);
             }