This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 9ac1abb069a branch-3.1: [fix](test) fix test_multi_table_load_eror
fail #53254 (#53302)
9ac1abb069a is described below
commit 9ac1abb069a65ee3211915a317f77f94fc6382ef
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 15 19:54:41 2025 +0800
branch-3.1: [fix](test) fix test_multi_table_load_eror fail #53254 (#53302)
Cherry-picked from #53254
Co-authored-by: hui lai <[email protected]>
---
.../test_multi_table_load_error.groovy | 24 +---------------------
1 file changed, 1 insertion(+), 23 deletions(-)
diff --git
a/regression-test/suites/load_p0/routine_load/test_multi_table_load_error.groovy
b/regression-test/suites/load_p0/routine_load/test_multi_table_load_error.groovy
index 17a8e5da719..039e734466e 100644
---
a/regression-test/suites/load_p0/routine_load/test_multi_table_load_error.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_multi_table_load_error.groovy
@@ -21,28 +21,6 @@ import org.apache.kafka.clients.producer.ProducerRecord
import org.apache.kafka.clients.producer.ProducerConfig
import org.codehaus.groovy.runtime.IOGroovyMethods
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import org.apache.kafka.clients.admin.AdminClient
-import org.apache.kafka.clients.producer.KafkaProducer
-import org.apache.kafka.clients.producer.ProducerRecord
-import org.apache.kafka.clients.producer.ProducerConfig
-
suite("test_multi_table_load_eror","nonConcurrent") {
def kafkaCsvTpoics = [
"multi_table_csv",
@@ -139,7 +117,7 @@ suite("test_multi_table_load_eror","nonConcurrent") {
def res = sql "show routine load for ${jobName}"
log.info("routine load statistic:
${res[0][14].toString()}".toString())
def json = parseJson(res[0][14])
- if (json.loadedRows.toString() == "0") {
+ if (json.loadedRows.toString() != "0") {
count++
if (count > 60) {
assertEquals(1, 2)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
