Hi， 看起来是你query的 schema 和 table (sink) 的schema 没有对应上，hbase中的数据都是bytes存储，在 flink sql 中一般不需要读取bytes，读取到的数据应该是 FLINK SQL对应的类型，如 int, bigint，string等，方便把你的 SQL 贴下吗？
祝好， Leonard Xu > 在 2020年6月15日，19:55，Zhou Zach <wander...@163.com> 写道： > > > > > > 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]
