database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-05 16:15:50 +03:00
Code Activity

fix(joblist,sorting): columnstore_orderby_threads for subquery (#3079)

Browse Source
This commit is contained in:
Leonid Fedorov
2024-07-31 17:50:18 +04:00
parent 546be21ef9
commit 848f5bf162
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dbcon/joblist/subquerytransformer.cpp
View File

@@ -82,7 +82,7 @@ SJSTEP& SubQueryTransformer::makeSubQueryStep(execplan::CalpontSelectExecutionPl
if (fOutJobInfo->trace) if (fOutJobInfo->trace)
cout << (*csep) << endl; cout << (*csep) << endl;
// Setup job info, job list and error status relation. // Setup job info, job list and error status relation.
fSubJobInfo = new JobInfo(fOutJobInfo->rm); fSubJobInfo = new JobInfo(fOutJobInfo->rm);
fSubJobInfo->sessionId = fOutJobInfo->sessionId; fSubJobInfo->sessionId = fOutJobInfo->sessionId;
fSubJobInfo->txnId = fOutJobInfo->txnId; fSubJobInfo->txnId = fOutJobInfo->txnId;
@@ -119,6 +119,8 @@ SJSTEP& SubQueryTransformer::makeSubQueryStep(execplan::CalpontSelectExecutionPl
fSubJobInfo->partitionSize = fOutJobInfo->partitionSize; fSubJobInfo->partitionSize = fOutJobInfo->partitionSize;
fSubJobInfo->umMemLimit = fOutJobInfo->umMemLimit; fSubJobInfo->umMemLimit = fOutJobInfo->umMemLimit;
fSubJobInfo->isDML = fOutJobInfo->isDML; fSubJobInfo->isDML = fOutJobInfo->isDML;
fSubJobInfo->orderByThreads = csep->orderByThreads();
// Update v-table's alias. // Update v-table's alias.
fVtable.name("$sub"); fVtable.name("$sub");