UBarney

> 在解决图8的问题是，论文中提到了这么一个解决方案： > > > Raft handles this by having each leader commit a blank no-op entry into the log at the start of its term. > > 在新选举出一个leader后，该leader会立即发送一个该term的“空Log”。当该空log被大多数服务器复制提交后，可认为该log之前的log已经全部被提交。 >...

take

> limiting the the intermediate result to ~1 batch size is enough to keep the performance. Do you mean we should also limit num_row of [`left_side, right_side`](https://github.com/apache/datafusion/blob/69dfe6c499d39563f4e6d9835fcdf3793f7d98c8/datafusion/physical-plan/src/joins/nested_loop_join.rs#L986) to 1 batch...

> By joining only one left row with the right batch at a time? However when `right_side_ordered == True` we need maintains right_side order. https://github.com/apache/datafusion/blob/69dfe6c499d39563f4e6d9835fcdf3793f7d98c8/datafusion/physical-plan/src/joins/nested_loop_join.rs#L727-L728 Perhaps we can "Process the...

> I plan to implement "Limit intermediate_batch Size During Filtering" and "Yield Partial Batches on Demand" first, and then I will work on "Process the Cartesian Product Incrementally". https://github.com/apache/datafusion/pull/16443