We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc52393 commit 5bdd75dCopy full SHA for 5bdd75d
core/trino-main/src/main/java/io/trino/operator/project/PageProcessor.java
@@ -320,8 +320,9 @@ private ProcessBatchResult processBatch(int batchSize)
320
blocks[i] = previouslyComputedResults[i].getRegion(0, batchSize);
321
}
322
else {
323
+ SourcePage inputChannelsSourcePage = projection.getInputChannels().getInputChannels(page);
324
expressionProfiler.start();
- Block result = projection.project(session, projection.getInputChannels().getInputChannels(page), positionsBatch);
325
+ Block result = projection.project(session, inputChannelsSourcePage, positionsBatch);
326
long projectionTimeNanos = expressionProfiler.stop(positionsBatch.size());
327
metrics.recordProjectionTime(projectionTimeNanos);
328
0 commit comments