flink sql 怎样将从hbase中取出的BYTES类型转换成Int

Mon, 15 Jun 2020 04:57:02 -0700 



Exception in thread "main" org.apache.flink.table.api.ValidationException: 
Field types of query result and registered TableSink 
default_catalog.default_database.user_cnt do not match.
Query schema: [time: STRING, age: BYTES]
Sink schema: [time: STRING, sum_age: INT]





















					回复