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 index c40420d8..3708c551 100644 --- 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"));