Hi All,
We are trying to switch to blink table planner in HBase connector, which found the following error: Running org.apache.flink.addons.hbase.HBaseSinkITCase Formatting using clusterid: testClusterID Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 28.042 sec <<< FAILURE! - in org.apache.flink.addons.hbase.HBaseSinkITCase testTableSink(org.apache.flink.addons.hbase.HBaseSinkITCase) Time elapsed: 2.431 sec <<< ERROR! org.apache.flink.table.api.TableException: Result field 'family1' does not match requested type. Requested: Row(col1: Integer); Actual: Row(EXPR$0: Integer) at org.apache.flink.addons.hbase.HBaseSinkITCase.testTableSink(HBaseSinkITCase.java:140) The original flink table planner executed successfully. Thanks, Kaka Chen
