From abe87fa3f42c02afb02ed73192e9829592b32285 Mon Sep 17 00:00:00 2001
From: tyrantlucifer <tyrantlucifer@gmail.com>
Date: Thu, 1 Dec 2022 23:20:26 +0800
Subject: [PATCH] [Improve][Connector-V2][File] Fix the partition directory

---
 .../seatunnel/file/sink/writer/AbstractWriteStrategy.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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<String, List<String>> 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();