diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CopyIntoInfo.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CopyIntoInfo.java
index a97149569b6c83..f0fc2630500b07 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CopyIntoInfo.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CopyIntoInfo.java
@@ -266,7 +266,10 @@ public void doValidate(String user, String db, boolean checkAuth) throws Analysi
                     analyzer, context, cascadesContext);
         }
 
-        dataDescProperties.put(FileFormatProperties.PROP_COMPRESS_TYPE, copyIntoProperties.getCompression());
+        String compression = copyIntoProperties.getCompression();
+        if (compression != null) {
+            dataDescProperties.put(FileFormatProperties.PROP_COMPRESS_TYPE, compression);
+        }
         dataDescription = new DataDescription(tableName.getTbl(), null, Lists.newArrayList(filePath),
             copyFromDesc.getFileColumns(), separator, fileFormatStr, null, false,
             legacyColumnMappingList, legacyFileFilterExpr, null, LoadTask.MergeType.APPEND, null,