Liya Fan created FLINK-13108:
--------------------------------
Summary: Remove duplicated type cast in generated code
Key: FLINK-13108
URL: https://issues.apache.org/jira/browse/FLINK-13108
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Liya Fan
Assignee: Liya Fan
There are duplicated cast operations in the generated code. For example, to run
org.apache.flink.table.runtime.batch.sql.join.JoinITCase#testJoin, the
generated code looks like this:
@Override
public void
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord
element) throws Exception {
org.apache.flink.table.dataformat.BaseRow in1 =
(org.apache.flink.table.dataformat.BaseRow)
(org.apache.flink.table.dataformat.BaseRow)
converter$0.toInternal((org.apache.flink.types.Row) element.getValue());
This issue remove the duplicated type cast.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
