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 70f505f028 Bugfixing, don't remove timestmap index during server
restart. (#8705)
70f505f028 is described below
commit 70f505f028201392527e9aa805d157aae95e8bd8
Author: Xiang Fu <[email protected]>
AuthorDate: Mon May 16 16:15:17 2022 -0700
Bugfixing, don't remove timestmap index during server restart. (#8705)
---
.../java/org/apache/pinot/core/data/manager/BaseTableDataManager.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java
index 58bd98836a..6276db12c0 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java
@@ -55,6 +55,7 @@ import
org.apache.pinot.segment.local.segment.index.loader.IndexLoadingConfig;
import org.apache.pinot.segment.local.segment.index.loader.LoaderUtils;
import org.apache.pinot.segment.spi.ImmutableSegment;
import org.apache.pinot.segment.spi.SegmentMetadata;
+import org.apache.pinot.segment.spi.creator.SegmentGeneratorConfig;
import org.apache.pinot.segment.spi.index.metadata.SegmentMetadataImpl;
import org.apache.pinot.segment.spi.loader.SegmentDirectoryLoader;
import org.apache.pinot.segment.spi.loader.SegmentDirectoryLoaderContext;
@@ -527,6 +528,9 @@ public abstract class BaseTableDataManager implements
TableDataManager {
recoverReloadFailureQuietly(_tableNameWithType, segmentName, indexDir);
Schema schema = ZKMetadataProvider.getTableSchema(_propertyStore,
_tableNameWithType);
+ schema = SegmentGeneratorConfig.updateSchemaWithTimestampIndexes(schema,
+
SegmentGeneratorConfig.extractTimestampIndexConfigsFromTableConfig(indexLoadingConfig.getTableConfig()));
+
// Creates the SegmentDirectory object to access the segment metadata.
// The metadata is null if the segment doesn't exist yet.
SegmentDirectory segmentDirectory =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
