[Minor] Fix Variable initialization (#602)

* Fix Variable intilaliztion * Inline fieldSchema variable
confluentinc · Jan 19, 2018 · 43b2037 · 43b2037
1 parent 09c5da7
commit 43b2037
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/ksql-engine/src/main/java/io/confluent/ksql/planner/plan/AggregateNode.java b/ksql-engine/src/main/java/io/confluent/ksql/planner/plan/AggregateNode.java
@@ -350,15 +350,13 @@ private Schema buildAggregateSchema(final Schema schema,
     }
     for (int aggFunctionVarSuffix = 0;
          aggFunctionVarSuffix < getFunctionList().size(); aggFunctionVarSuffix++) {
-      Schema fieldSchema;
       String udafName = getFunctionList().get(aggFunctionVarSuffix).getName()
           .getSuffix();
       KsqlAggregateFunction aggregateFunction = functionRegistry.getAggregateFunction(udafName,
           getFunctionList()
               .get(aggFunctionVarSuffix).getArguments(), schema);
-      fieldSchema = aggregateFunction.getReturnType();
       schemaBuilder.field(AggregateExpressionRewriter.AGGREGATE_FUNCTION_VARIABLE_PREFIX
-          + aggFunctionVarSuffix, fieldSchema);
+          + aggFunctionVarSuffix, aggregateFunction.getReturnType());
     }
 
     return schemaBuilder.build();