fix json mode default value (#123)

apache · Jul 31, 2023 · 8caab6f · 8caab6f
1 parent b1fbc6e
commit 8caab6f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
@@ -114,6 +114,9 @@ public DorisStreamLoad(SparkSettings settings) {
             boolean stripOuterArray = Boolean.parseBoolean(streamLoadProp.getOrDefault("strip_outer_array", "false"));
             if (readJsonByLine && stripOuterArray) {
                 throw new IllegalArgumentException("Only one of options 'read_json_by_line' and 'strip_outer_array' can be set to true");
+            } else if (!readJsonByLine && !stripOuterArray) {
+                LOG.info("set default json mode: strip_outer_array");
+                streamLoadProp.put("strip_outer_array", "true");
             }
         }
         LINE_DELIMITER = escapeString(streamLoadProp.getOrDefault("line_delimiter", "\n"));