flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 王双利 <all...@163.com>
Subject flink sql string char 不兼容?
Date Tue, 21 Apr 2020 10:20:49 GMT
下面的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应该怎么写合适呢?
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message