diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/CaseInsensitiveQualifiedTable.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/CaseInsensitiveQualifiedTable.java
index d22be4eaefbd1..cdc1954e6687b 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/CaseInsensitiveQualifiedTable.java
+++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/CaseInsensitiveQualifiedTable.java
@@ -41,6 +41,6 @@ public CaseInsensitiveQualifiedTable(final String schemaName, final String table
     
     @Override
     public String toString() {
-        return null == schemaName ? tableName.toString() : String.join(".", schemaName.toString(), tableName.toString());
+        return null == schemaName.toString() ? tableName.toString() : String.join(".", schemaName.toString(), tableName.toString());
     }
 }