[FLINK-29445] When the decimal table column field is printed，program is error

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Affects Version/s: 1.12.0
• Component/s: Table SQL / API, Table SQL / Runtime
• Labels: flink table-api

Environment

<flink.version>1.12.0</flink.version>

flink-table-api-java-bridge_2.11

flink-table-planner_2.11

flink-streaming-scala_2.11

• Assignee: Unassigned
• Reporter: liuzhiyong
• Created: 28/Sep/22 08:14
• Updated: 30/Sep/22 01:55
• Resolved: 30/Sep/22 01:55

Description

runtime is java

error code：

tEnv.executeSql("select `openScore` from demo").print();

openScore field is BigDecimal

error log is:

Exception in thread "main" java.lang.ClassCastException: org.apache.flink.table.types.logical.LegacyTypeInformationType cannot be cast to org.apache.flink.table.types.logical.DecimalType
    at org.apache.flink.table.utils.PrintUtils.columnWidthsByType(PrintUtils.java:264)
    at org.apache.flink.table.utils.PrintUtils.printAsTableauForm(PrintUtils.java:127)
    at org.apache.flink.table.api.internal.TableResultImpl.print(TableResultImpl.java:149)
    at com.mask.maintest.TestTableEnv.main(TestTableEnv.java:74)

 

source code position:

class : PrintUtils 

line: 177

len = ((DecimalType)type).getPrecision() + 2;