?????? flink sql ????????ROW??????????INT

??hbase??hbase ---- ??:"Leonard Xu"

?????? flink sql ????????ROW??????????INT

??.?? offset (0) + length (4) exceed the capacity of the array: 2 ?? hbaseint?? ??users.addColumn("cf", "age", classOf[Integer]) ?? ??int??IntegerInteger??int

flink sql ????????ROW??????????INT

flink sql??HBase??ROWROW??INT select cast(cf as Int) cf from hbase_table ??