nsivabalan commented on code in PR #12529:
URL: https://github.com/apache/hudi/pull/12529#discussion_r1894046063
##########
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java:
##########
@@ -477,7 +482,16 @@ private void initializeFromFilesystem(String
initializationTime, List<MetadataPa
HoodieData<HoodieRecord> records =
fileGroupCountAndRecordsPair.getValue();
bulkCommit(instantTimeForPartition, partitionName, records,
fileGroupCount);
metadataMetaClient.reloadActiveTimeline();
-
+ if (partitionType == COLUMN_STATS) {
+ // initialize Col Stats
+ // if col stats, lets also update list of columns indexed if changed.
+ updateColumnsToIndexWithColStats(columnsToIndex);
Review Comment:
just that, if initialization succeeded, but before applying the commit of
interest if job crashed. we don't want to miss the index defn update.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
