Re: Re: flink sql read hbase sink mysql data type not match

Tue, 16 Jun 2020 04:57:14 -0700 

不能直接cast，ROW类型是一个复合类型，要获取其中的某个字段，可以用`.`来获取。
比如你现在这个场景，就是 SELECT rowkey, cf.age FROM users

Zhou Zach <is...@foxmail.com> 于2020年6月16日周二 下午6:59写道：

> flink sql 怎么将ROW<`age` INT&gt;转换成INT啊
>
>
> streamTableEnv.sqlUpdate(
>   """
>     |
>     |insert into  user_age
>     |SELECT rowkey, cast(cf as int) as age
>     |FROM
>     |  users
>     |
>     |""".stripMargin)这样尝试报错了

回复