[jira] [Created] (FLINK-12453) StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator

[Shang Yuanchun (Jira)]

Jingsong Lee created FLINK-12453:
------------------------------------

             Summary: StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator
                 Key: FLINK-12453
                 URL: https://issues.apache.org/jira/browse/FLINK-12453
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
            Reporter: Jingsong Lee
            Assignee: Jark Wu


In generateAggsHandler: 

val generator = new AggsHandlerCodeGenerator(
  CodeGeneratorContext(config),
  relBuilder,
  FlinkTypeFactory.toInternalRowType(inputRowType).getFieldTypes,
  needRetract = false,
  config.getNullCheck,
  inputFieldCopy)

but AggsHandlerCodeGenerator args is:

class AggsHandlerCodeGenerator(
  ctx: CodeGeneratorContext,
  relBuilder: RelBuilder,
  inputFieldTypes: Seq[InternalType],
  needRetract: Boolean,
  copyInputField: Boolean,
  needAccumulate: Boolean = true)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)