Skip to content

Commit

Permalink
Update SchemaExecutionVisitor.java
Browse files Browse the repository at this point in the history
  • Loading branch information
Caideyipi committed Sep 26, 2024
1 parent 574bbd1 commit 0c90ef8
Showing 1 changed file with 12 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -315,6 +315,18 @@ private void executeInternalCreateAlignedTimeSeries(
encodingList.remove(index);
compressionTypeList.remove(index);

// If with merge is set, the lists are deep copied and need to be altered here.
// We still remove the element from the original list to help cascading pipe transfer
// schema.
// If this exception is thrown, the measurements, data types, etc. must be unchanged.
// Thus, the index for the copied lists are identical to that in the original lists.
if (withMerge) {
createAlignedTimeSeriesPlan.getMeasurements().remove(index);
createAlignedTimeSeriesPlan.getDataTypes().remove(index);
createAlignedTimeSeriesPlan.getEncodings().remove(index);
createAlignedTimeSeriesPlan.getCompressors().remove(index);
}

if (measurementList.isEmpty()) {
shouldRetry = false;
}
Expand Down

0 comments on commit 0c90ef8

Please sign in to comment.