下面的sql 执行的时候报 下面的错误CREATE TABLE  target (
    jnlno VARCHAR,
--     taskid char(9),
--     hit char(4)
   taskid VARCHAR,
    hit VARCHAR
) 
insert into  target select  a.jnlno,'111111qeq','false' from loginevent a

Exception in thread "main" org.apache.flink.table.api.ValidationException: Type 
STRING of table field 'hit' does not match with the physical type CHAR(4) of 
the 'EXPR$2' field of the TableSink consumed type.

Flink 版本 1.10
  怎么解决呢?Flink sql的 string char 不兼容?
sql应该怎么写合适呢?

Reply via email to