This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 051377051d9 fix varchar length for array<varchar> (#25601)
051377051d9 is described below
commit 051377051d96d255b7d8c23cff5bc7d31f4808ee
Author: amory <[email protected]>
AuthorDate: Wed Oct 18 22:10:43 2023 +0800
fix varchar length for array<varchar> (#25601)
---
fe/fe-core/src/main/java/org/apache/doris/analysis/TypeDef.java | 3 ---
.../load_p0/stream_load/test_stream_load_properties.groovy | 9 ++++++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/TypeDef.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/TypeDef.java
index 9c80ee01ab1..199bb8a7917 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/TypeDef.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/TypeDef.java
@@ -177,9 +177,6 @@ public class TypeDef implements ParseNode {
parent.getPrimitiveType() + " unsupported sub-type: " +
child.toSql());
}
- if (child.getPrimitiveType().isStringType() && !child.isLengthSet()) {
- child.setLength(1);
- }
analyze(child);
}
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
index 930df507243..3d7ca2e9e92 100644
---
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
+++
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
@@ -124,11 +124,11 @@ suite("test_stream_load_properties", "p0") {
"basic_array_data_by_line.json",
]
- def loadedRows = [12,12,12,12,8,8,15]
+ def loadedRows = [12,12,12,12,15,15,15]
def jsonLoadedRows = [20,20,20,20,18,18,18]
- def filteredRows = [8,8,8,8,12,12,5]
+ def filteredRows = [8,8,8,8,5,5,5]
def maxFilterRatio = [0.4,0.4,0.4,0.4,0.6,0.6,0.6]
@@ -271,6 +271,8 @@ suite("test_stream_load_properties", "p0") {
file errorFiles[i]
time 10000 // limit inflight 10s
+ log.info("Stream load table==============: ${table}".toString())
+ log.info("Stream load i==============: ${i}".toString())
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
@@ -793,7 +795,8 @@ suite("test_stream_load_properties", "p0") {
if (exception != null) {
throw exception
}
- log.info("Stream load result: ${result}".toString())
+ log.info(" ===== ${table} with json ${i} Stream load
result: ${result}".toString())
+ //log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
assertEquals("success", json.Status.toLowerCase())
assertEquals(jsonLoadedRows[i], json.NumberTotalRows)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
