diff --git a/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java b/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java index 896d311d2d854..eac0781e3cdce 100644 --- a/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java +++ b/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java @@ -133,8 +133,6 @@ private enum State private final TableExecuteContext tableExecuteContext; private final boolean outputRowCount; - private final Supplier tableFinishInfoSupplier; - public TableFinishOperator( OperatorContext operatorContext, TableFinisher tableFinisher, @@ -150,9 +148,8 @@ public TableFinishOperator( this.descriptor = requireNonNull(descriptor, "descriptor is null"); this.statisticsCpuTimerEnabled = statisticsCpuTimerEnabled; this.tableExecuteContext = requireNonNull(tableExecuteContext, "tableExecuteContext is null"); - this.tableFinishInfoSupplier = createTableFinishInfoSupplier(outputMetadata, statisticsTiming); this.outputRowCount = outputRowCount; - operatorContext.setInfoSupplier(tableFinishInfoSupplier); + operatorContext.setInfoSupplier(createTableFinishInfoSupplier(outputMetadata, statisticsTiming)); } @Override