This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new a12b760b74 Amend schema to add timestamp index during segment
reloading (#8679)
a12b760b74 is described below
commit a12b760b74b7ac9e1b30a8fe990e6c30a35e1275
Author: Xiang Fu <[email protected]>
AuthorDate: Tue May 10 21:31:09 2022 -0700
Amend schema to add timestamp index during segment reloading (#8679)
---
.../segment/local/indexsegment/immutable/ImmutableSegmentLoader.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/immutable/ImmutableSegmentLoader.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/immutable/ImmutableSegmentLoader.java
index b26e4b727a..b9968c85c0 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/immutable/ImmutableSegmentLoader.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/immutable/ImmutableSegmentLoader.java
@@ -161,6 +161,8 @@ public class ImmutableSegmentLoader {
// Remove columns not in schema from the metadata
Map<String, ColumnMetadata> columnMetadataMap =
segmentMetadata.getColumnMetadataMap();
if (schema != null) {
+ schema = SegmentGeneratorConfig.updateSchemaWithTimestampIndexes(schema,
+
SegmentGeneratorConfig.extractTimestampIndexConfigsFromTableConfig(indexLoadingConfig.getTableConfig()));
Set<String> columnsInMetadata = new
HashSet<>(columnMetadataMap.keySet());
columnsInMetadata.removeIf(schema::hasColumn);
if (!columnsInMetadata.isEmpty()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
