Jackie-Jiang opened a new pull request, #15764: URL: https://github.com/apache/pinot/pull/15764
Related to #14518 Currently colocated join requires tables on both side have same number of partitions. This PR enhances the worker assignment to allow colocated join with one side having more partitions than the other side, if the following condition is met: - Partition count for the larger side is multiple of smaller side, e.g. 16 vs 4 - Partitions are actually assigned in a way that partitions are colocated, e.g. partition 0, 4, 8, 12 of the larger side are assigned to the same server hosting partition 0 of the smaller side To enable this, explicitly set `partition_size` on the larger side to match the smaller side, e.g. `/*+ tableOptions(partition_size='4') */` Added queries in `ColocatedJoinQuickStart` and verifies the results. TODO: Currently the queries test setup doesn't align with the colocation requirement. Will add test separately -- 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: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org
