This is an automated email from the ASF dual-hosted git repository.
ankitsultana pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new b00dbfec1b8 [bugfix] Fixing the TableType val passed for unavailable
segments in physical optimizer (#16660)
b00dbfec1b8 is described below
commit b00dbfec1b8f0e880d05f7b57960b74e68e1bfac
Author: Shaurya Chaturvedi <[email protected]>
AuthorDate: Fri Aug 22 09:26:18 2025 -0700
[bugfix] Fixing the TableType val passed for unavailable segments in
physical optimizer (#16660)
Co-authored-by: Shaurya Chaturvedi <[email protected]>
---
.../planner/physical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/v2/opt/rules/LeafStageWorkerAssignmentRule.java
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/v2/opt/rules/LeafStageWorkerAssignmentRule.java
index b4bd796c900..10bb8cd161a 100644
---
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/v2/opt/rules/LeafStageWorkerAssignmentRule.java
+++
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/v2/opt/rules/LeafStageWorkerAssignmentRule.java
@@ -174,7 +174,7 @@ public class LeafStageWorkerAssignmentRule extends
PRelOptRule {
}
if (!routingTable.getUnavailableSegments().isEmpty()) {
// Set unavailable segments in context, keyed by PRelNode ID.
-
segmentUnavailableMap.put(TableNameBuilder.forType(TableType.valueOf(tableName)).tableNameWithType(tableName),
+
segmentUnavailableMap.put(TableNameBuilder.forType(TableType.valueOf(tableType)).tableNameWithType(tableName),
new HashSet<>(routingTable.getUnavailableSegments()));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
