From d4dc0a68dec9f0f0325f9def51e4ea1328fb3fa8 Mon Sep 17 00:00:00 2001 From: Vinay Krishna Pudyodu Date: Mon, 8 Dec 2025 16:11:05 -0800 Subject: [PATCH] Added logs for reconstructPushedDownRelNodeTree Signed-off-by: Vinay Krishna Pudyodu --- .../storage/scan/context/PushDownContext.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/opensearch/src/main/java/org/opensearch/sql/opensearch/storage/scan/context/PushDownContext.java b/opensearch/src/main/java/org/opensearch/sql/opensearch/storage/scan/context/PushDownContext.java index b18bdacfa9c..f309b7c5800 100644 --- a/opensearch/src/main/java/org/opensearch/sql/opensearch/storage/scan/context/PushDownContext.java +++ b/opensearch/src/main/java/org/opensearch/sql/opensearch/storage/scan/context/PushDownContext.java @@ -165,14 +165,21 @@ public RelNode reconstructPushedDownRelNodeTree(RelNode logicalIndexScan) { RelNode current = logicalIndexScan; List pushDownOperations = new ArrayList<>(this); + LOGGER.info("Starting reconstruction with {} operations", pushDownOperations.size()); for (int i = 0; i < pushDownOperations.size(); i++) { - RelNode storedRelNode = pushDownOperations.get(i).relNode(); + PushDownOperation op = pushDownOperations.get(i); + LOGGER.info("Operation {}: type={}, digest={}", i, op.type(), op.digest()); + RelNode storedRelNode = op.relNode(); if (storedRelNode != null) { + LOGGER.info(" Stored RelNode: {}", storedRelNode); RelNode before = current; current = replaceInput(storedRelNode, current); - LOGGER.info("{} being added as input to {}", before, current); + LOGGER.info(" {} being added as input to {}", before, current); + } else { + LOGGER.info(" No RelNode stored for this operation"); } } + LOGGER.info("Final reconstructed tree\n: {}", current); return current; }