diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java index f914a2223cb..a3c5e45c9e6 100644 --- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java +++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java @@ -165,8 +165,7 @@ public Map> generatorPartitionDir(SeaTunnelRow seaTunnelRow for (int i = 0; i < partitionFieldsIndexInRow.size(); i++) { stringBuilder.append(partitionFieldList.get(i)) .append("=") - .append(seaTunnelRow.getFields()[partitionFieldsIndexInRow.get(i)]) - .append(File.separator); + .append(seaTunnelRow.getFields()[partitionFieldsIndexInRow.get(i)]); vals.add(seaTunnelRow.getFields()[partitionFieldsIndexInRow.get(i)].toString()); } partitionDir = stringBuilder.toString();