File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -174,8 +174,8 @@ case class HashAggregateExec(
174
174
}
175
175
}
176
176
177
- // The variables used as aggregation buffer. Only used in codegen for aggregation without keys.
178
- @ transient private var bufVars : Seq [ExprCode ] = _
177
+ // The variables used as aggregation buffer. Only used for aggregation without keys.
178
+ private var bufVars : Seq [ExprCode ] = _
179
179
180
180
private def doProduceWithoutKeys (ctx : CodegenContext ): String = {
181
181
val initAgg = ctx.addMutableState(CodeGenerator .JAVA_BOOLEAN , " initAgg" )
@@ -238,8 +238,6 @@ case class HashAggregateExec(
238
238
| }
239
239
""" .stripMargin)
240
240
241
- bufVars = null // explicitly null this field out to allow the referent to be GC'd sooner
242
-
243
241
val numOutput = metricTerm(ctx, " numOutputRows" )
244
242
val aggTime = metricTerm(ctx, " aggTime" )
245
243
val beforeAgg = ctx.freshName(" beforeAgg" )
You can’t perform that action at this time.
0 commit comments