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

Tue, 16 Jun 2020 03:59:15 -0700 

flink sql ??????ROW<`age` INT&gt;??????INT??


streamTableEnv.sqlUpdate(
  """
    |
    |insert into  user_age
    |SELECT rowkey, cast(cf as int) as age
    |FROM
    |  users
    |
    |""".stripMargin)??????????????

回复