haibow commented on a change in pull request #4954: Support schema evolution for consuming segments URL: https://github.com/apache/incubator-pinot/pull/4954#discussion_r369820290
########## File path: pinot-server/src/main/java/org/apache/pinot/server/starter/helix/HelixInstanceDataManager.java ########## @@ -194,7 +198,17 @@ private void reloadSegment(String tableNameWithType, SegmentMetadata segmentMeta File indexDir = segmentMetadata.getIndexDir(); if (indexDir == null) { - LOGGER.info("Skip reloading REALTIME consuming segment: {} in table: {}", segmentName, tableNameWithType); + if (!_instanceDataManagerConfig.shouldReloadConsumingSegment()) { + LOGGER.info("Skip reloading REALTIME consuming segment: {} in table: {}", segmentName, tableNameWithType); + return; + } + LOGGER.info("Try reloading REALTIME consuming segment: {} in table: {}", segmentName, tableNameWithType); + SegmentMetadataImpl segmentMetadataImpl = (SegmentMetadataImpl) segmentMetadata; Review comment: Removed defaultColumnActionMap from the signature. Multiple calls to the same consuming segment is covered. It will always compare the new schema with the original schema (when the segment started consuming), and add the new columns to the new columns map. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org