diff --git a/src/sql/rewrite/ob_transform_query_push_down.cpp b/src/sql/rewrite/ob_transform_query_push_down.cpp
index 09f4b2a00f..d8a9ebf860 100644
--- a/src/sql/rewrite/ob_transform_query_push_down.cpp
+++ b/src/sql/rewrite/ob_transform_query_push_down.cpp
@@ -462,6 +462,7 @@ int ObTransformQueryPushDown::check_set_op_expr_reference(ObSelectStmt *select_s
   } else {
     ObSEArray<ObRawExpr*, 4> relation_exprs;
     ObSEArray<ObRawExpr*, 4> set_op_exprs;
+    ObSEArray<ObRawExpr*, 4> column_exprs;
     ObBitSet<> selected_set_op_idx;
     ObStmtExprGetter visitor;
     visitor.set_relation_scope();
@@ -470,7 +471,13 @@ int ObTransformQueryPushDown::check_set_op_expr_reference(ObSelectStmt *select_s
       LOG_WARN("failed to get relation exprs", K(ret));
     } else if (OB_FAIL(ObRawExprUtils::extract_set_op_exprs(relation_exprs,
                                                             set_op_exprs))) {
-      LOG_WARN("failed to extract column ids", K(ret));
+      LOG_WARN("failed to extract set op exprs", K(ret));
+    } else if (FALSE_IT(relation_exprs.reuse())) {
+    } else if (OB_FAIL(select_stmt->get_relation_exprs(relation_exprs, visitor))) {
+      LOG_WARN("failed to get relation exprs", K(ret));
+    } else if (OB_FAIL(ObRawExprUtils::extract_column_exprs(relation_exprs,
+                                                            column_exprs))) {
+      LOG_WARN("failed to extract column exprs", K(ret));
     }
     for (int64_t i = 0; OB_SUCC(ret) && i < select_offset.count(); ++i) {
       if (select_offset.at(i) != -1) {
@@ -486,6 +493,15 @@ int ObTransformQueryPushDown::check_set_op_expr_reference(ObSelectStmt *select_s
         is_valid = false;
       }
     }
+    for (int64_t i = 0; OB_SUCC(ret) && is_valid && i < column_exprs.count(); ++i) {
+      ObColumnRefRawExpr *expr = static_cast<ObColumnRefRawExpr*>(column_exprs.at(i));
+      if (OB_ISNULL(expr)) {
+        ret = OB_ERR_UNEXPECTED;
+        LOG_WARN("unexpected null expr", K(ret), KPC(column_exprs.at(i)));
+      } else if (!selected_set_op_idx.has_member(expr->get_column_id() - OB_APP_MIN_COLUMN_ID)) {
+        is_valid = false;
+      }
+    }
   }
   return ret;
 }