[FLINK-13290] HBaseITCase bug using blink-runner: SinkCodeGenerator should not compare row type field names

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Connectors / HBase
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 16/Jul/19 13:53
• Updated: 06/Aug/19 07:22
• Resolved: 02/Aug/19 02:12

Description

Running org.apache.flink.addons.hbase.HBaseSinkITCase using blink planner will encountered this error:

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)

This might because SinkCodeGenerator.scala#L243 compare RowType with field names.

Issue Links

• links to: GitHub Pull Request #9275