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

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

回复