zhixingheyi-tian

[NSE-1045] Release ColumnarBatch underlying buffer immediately after nativeConvertColumnarToRow converter finish

2

## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) ## How was this patch tested? (Please explain how this patch was tested....

**Is your feature request related to a problem or challenge? Please describe what you are trying to do.** A clear and concise description of what the problem is. Ex. I'm...

[NSE-928] Implement ResultIterator return from one probe output in ColumnarShuffledHashJoinExec

3

…lumnarShuffledHashJoinExec ## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) ## How was this patch tested? (Please explain how this patch was...

[NSE-1015] Implement ResultIterator return from one probe output in ColumnarBroadcastHashJoinExec

3

## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) ## How was this patch tested? (Please explain how this patch was tested....

Follow up Issue #928 . To avoid similar issues, we begin to support batch_size control in output recordbatch for native operators when necessary. - [ ] ColumnarBroadcastHashJoinExec - [ ]...

https://github.com/oap-project/gazelle_plugin/blob/174aad0ffaba4f3f7b665491dd9cfc44853c1528/native-sql-engine/cpp/src/codegen/arrow_compute/ext/array_item_index.h#L25-L33 Here the number of RecordBatch depends on per partition size. It maybe more than 64k，so it is better use uint32_t type. Now when using uint32_t for ArrayItemIndex: array_id, caused...

[DNM] Test optimization for GHA

1

## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) ## How was this patch tested? (Please explain how this patch was tested....

- [ ] Support Array/Struct/Map in ColumnarSortExec - [ ] Support Array/Struct/Map in ColumnarSortMergeJoinExec

[ORC] Count queries without projections encounter Preconditions IllegalStateException issue

2

**Describe the bug** Case: ``` test("count() without group by") { val df = spark.sql("SELECT count(*) as cnt FROM " + "item LIMIT 100") df.explain() df.show() } ``` Error: ``` Caused...

[ORC] Encounter bitmap out of bound issue in evaluateFilter

3

**Describe the bug** When run TPCDS integration testing. Encounter below out of bound issue ``` Caused by: org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1.0 failed...