[jira] [Created] (FLINK-13108) Remove duplicated type cast in generated code

[Shang Yuanchun (Jira)]

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)