diff --git a/ice/src/main/java/com/altinity/ice/cli/internal/cmd/Insert.java b/ice/src/main/java/com/altinity/ice/cli/internal/cmd/Insert.java index 1e51068..65cec97 100644 --- a/ice/src/main/java/com/altinity/ice/cli/internal/cmd/Insert.java +++ b/ice/src/main/java/com/altinity/ice/cli/internal/cmd/Insert.java @@ -526,7 +526,13 @@ private static List processFile( partitionKey)); } else { // Table isn't partitioned or sorted. Copy as is. - String dstDataFile = dstDataFileSource.get(file); + String dstDataFile; + if (partitionSpec.isPartitioned() && partitionKey != null) { + // File has inferred partition, use partition path + dstDataFile = dstDataFileSource.get(partitionSpec, partitionKey, file); + } else { + dstDataFile = dstDataFileSource.get(file); + } if (checkNotExists.apply(dstDataFile)) { return Collections.emptyList(); }