[FLINK-15124] types with precision can't be executed in sql client with blink planner

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.0
• Component/s: Table SQL / Client, Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Kurt Young
• Created: 08/Dec/19 02:10
• Updated: 17/Dec/19 13:30
• Resolved: 12/Dec/19 12:50

Description

I created a table in sql client with blink planner:  

create table t (
    a int,
    b varchar,
    c decimal(10, 5))
with (
    'connector.type' = 'filesystem',
    'format.type' = 'csv',
    'format.derive-schema' = 'true',
    'connector.path' = 'xxxxxxx'
);

The table description looks good:

Flink SQL> describe t; 
root 
  |-- a: INT 
  |-- b: STRING 
  |-- c: DECIMAL(10, 5)

But the select query failed:

Flink SQL> select * from t;
[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.planner.codegen.CodeGenException: Incompatible types of expression and result type. Expression[GeneratedExpression(field$3,isNull$3,,DECIMAL(38, 18),None)] type is [DECIMAL(38, 18)], result type is [DECIMAL(10, 5)]

 

Issue Links

• duplicates: FLINK-15141 Using decimal type in a sink table, the result returns a not match ValidationException
• is related to: FLINK-15217 'java.time.LocalDate' should support for the CSV input format.
• relates to: FLINK-15141 Using decimal type in a sink table, the result returns a not match ValidationException
• supercedes: FLINK-15151 Use new type system in TableSourceUtil.computeIndexMapping of blink planner
• links to: GitHub Pull Request #10518