Skip to content

Commit a5bf16f

Browse files
committed
Support '=' in table names, storing parquet files in folders containing a = character.
1 parent 6d3b909 commit a5bf16f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dqops/src/main/java/com/dqops/data/storage/HivePartitionPathUtility.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -64,15 +64,15 @@ public static String makeHivePartitionPath(ParquetPartitionId partitionId) {
6464

6565
stringBuilder.append(ParquetPartitioningKeys.CONNECTION);
6666
stringBuilder.append('=');
67-
String encodedConnection = URLEncoder.encode(connectionName, StandardCharsets.UTF_8);
67+
String encodedConnection = FileNameSanitizer.encodeForFileSystem(connectionName);
6868
stringBuilder.append(encodedConnection);
6969
stringBuilder.append('/');
7070

7171
PhysicalTableName tableName = partitionId.getTableName();
7272
if (tableName != null) {
7373
stringBuilder.append(ParquetPartitioningKeys.SCHEMA_TABLE);
7474
stringBuilder.append('=');
75-
String encodedTable = URLEncoder.encode(tableName.toString(), StandardCharsets.UTF_8);
75+
String encodedTable = FileNameSanitizer.encodeForFileSystem(tableName.toString());
7676
stringBuilder.append(encodedTable);
7777
stringBuilder.append('/');
7878
}

0 commit comments

Comments
 (0)