We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4ff1276 commit 2b3e9e8Copy full SHA for 2b3e9e8
1 file changed
ice/src/main/java/com/altinity/ice/cli/internal/cmd/Insert.java
@@ -526,7 +526,13 @@ private static List<DataFile> processFile(
526
partitionKey));
527
} else {
528
// Table isn't partitioned or sorted. Copy as is.
529
- String dstDataFile = dstDataFileSource.get(file);
+ String dstDataFile;
530
+ if (partitionSpec.isPartitioned() && partitionKey != null) {
531
+ // File has inferred partition, use partition path
532
+ dstDataFile = dstDataFileSource.get(partitionSpec, partitionKey, file);
533
+ } else {
534
+ dstDataFile = dstDataFileSource.get(file);
535
+ }
536
if (checkNotExists.apply(dstDataFile)) {
537
return Collections.emptyList();
538
}
0 commit comments