[Improve][Connector-V2][File] Fix the partition directory

apache · Dec 3, 2022 · da9df36 · da9df36
1 parent 2f0258d
commit da9df36
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ava/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java b/...ava/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();