[inlong] branch master updated: [INLONG-7311][Sort] Fix Doris StreamLoad unable to archive dirtydata (#7312)

[zirui]

This is an automated email from the ASF dual-hosted git repository.

zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 9556f4be8 [INLONG-7311][Sort] Fix Doris StreamLoad unable to archive 
dirtydata (#7312)
9556f4be8 is described below

commit 9556f4be81d321e70ba91ff874350056063665f7
Author: Yizhou Yang <32808678+yizhou-y...@users.noreply.github.com>
AuthorDate: Fri Feb 3 10:32:32 2023 +0800

    [INLONG-7311][Sort] Fix Doris StreamLoad unable to archive dirtydata (#7312)
---
 .../apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
index 93e68370a..84f573334 100644
--- 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
+++ 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
@@ -685,7 +685,7 @@ public class DorisDynamicSchemaOutputFormat<T> extends 
RichOutputFormat<T> {
         } catch (Exception e) {
             LOG.error(String.format("Flush table: %s error", tableIdentifier), 
e);
             // Makesure it is a dirty data
-            if (respContent != null && 
StringUtils.isNotBlank(respContent.getErrorURL())) {
+            if (respContent == null || 
StringUtils.isNotBlank(respContent.getErrorURL())) {
                 flushExceptionMap.put(tableIdentifier, e);
                 errorNum.getAndAdd(values.size());
                 for (Object value : values) {