batch nlj 右表存在 limit 下压导致正确性问题

obclient> set _nlj_batching_enabled = 0;
Query OK, 0 rows affected

obclient> SELECT /*+ PARALLEL(2) leading(t23 view2) use_NL(VIEW2) SEMI_TO_INNER(view1)*/count(*) from t24 where exists (SELECT * FROM T24 T24_6144151 WHERE T24_6144151.C8 = T24.C8);
+----------+
| COUNT(*) |
+----------+
|    19978 |
+----------+

obclient> set _nlj_batching_enabled = 1;
Query OK, 0 rows affected

obclient> SELECT /*+ PARALLEL(2) leading(t23 view2) use_NL(VIEW2) SEMI_TO_INNER(view1)*/count(*) from t24 where exists (SELECT * FROM T24 T24_6144151 WHERE T24_6144151.C8 = T24.C8);
+----------+
| COUNT(*) |
+----------+
|       20 |
+----------+

obclient>explain SELECT /*+ PARALLEL(2) leading(t23 view2) use_NL(VIEW2) SEMI_TO_INNER(view1)*/count(*) from t24 where exists (SELECT * FROM T24 T24_6144151 WHERE T24_6144151.C8 = T24.C8);
***************************** 1.row *****************************
Query Plan: =====================================================
|ID|OPERATOR         |NAME|EST. ROWS|COST |
-------------------------------------------
|0 |SCALAR GROUP BY  |    |1        |936590|
|1 | NESTED-LOOP JOIN|    |19779    |935890|
|2 |  TABLE SCAN     |XY_T   |19978 |7747  |
|3 |  SUBPLAN SCAN   |VIEW2   |1    |46    |
|4 |   DISTRIBUTED TABLE SCAN|T24_6144151   |1    |46    |
==============================================================

Outputs & filters:
---------------------------------------------
  0 - output([T_FUN_COUNT(*)]),filter(nil),
     group(nil),agg_func([T_FUN_COUNT(*)])
  1 - output(nil),filter(nil),
     conds(nil),nl_params_([XY_T.CB])
  2 - output([XY_T.CB]),filter(nil),
     access([XY_T.CB]),partitions(p0)
  3 - output(nil),filter(nil),
     access([nil])
  4 - output(T24_6144151.CB),filter(nil),
     access([GROUP_ID],[T24_6144151.CB]),partitions(p0),
     limit(1),offset(nil)