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

[Leonard Xu]

Hi,
看你有两个地方声明hbase的表，

>    |    cf ROW(sex VARCHAR, age INT, created_time TIMESTAMP(3)) 

这种方式应该是ok的，

> users.addColumn("cf", "age", classOf[Array[Byte]])


你这里为什么声明 age 的data type 为什么声明 classOf[Array[Byte]] ？ 是不是忘了修改了？
这里使用 users.addColumn("cf", "age", classOf[Integer]) 应该就行了。

通过DDL 或者 在TableEnvironment 上注册表，使用一个就行了。建议用DDL

祝好