yujun777 commented on code in PR #69778:
URL: https://github.com/apache/doris/pull/69778#discussion_r4407993399
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/NormalizeOlapTableStreamScan.java:
##########
@@ -390,6 +391,22 @@ private Plan
makeTableStreamScan(LogicalOlapTableStreamScan scan, CascadesContex
List<Long> historicalPartitionIds =
streamWrapper.filterHistoryPartitionIds(scan.getSelectedPartitionIds());
List<Long> incrementalPartitionIds =
streamWrapper.filterIncrementalPartitionIds(scan.getSelectedPartitionIds());
+ if (cascadesContext.getStatementContext().isIvmMTMVRewrite()) {
+ // A partition with no consumption baseline -- added after the
stream was created, or still empty when
Review Comment:
这个感觉不是IVM 专有的，IVM 只是用Stream 功能，如果有BUG，这里对非IVM也是适用的。 read from stream
本来就应该那些没有offset的新分区
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
