diff --git a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineSQLSegmentBuilderTest.java b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineSQLSegmentBuilderTest.java
index 5c97cb66d7d08..89b409597d5c2 100644
--- a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineSQLSegmentBuilderTest.java
+++ b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineSQLSegmentBuilderTest.java
@@ -50,4 +50,9 @@ void assertGetQualifiedTableNameWithUnsupportedSchema() {
     void assertGetQualifiedTableNameWithSupportedSchema() {
         assertThat(postgreSQLBuilder.getQualifiedTableName("foo_schema", "foo_tbl"), is("foo_schema.foo_tbl"));
     }
+    
+    @Test
+    void assertGetQualifiedTableNameWithSupportedSchemaAndNullSchema() {
+        assertThat(postgreSQLBuilder.getQualifiedTableName(null, "foo_tbl"), is("foo_tbl"));
+    }
 }