Hi Kaka,
Thanks for reporting this. We didn't cover integrate tests for connectors
yet because of FLINK-13276. We will cover that after FLINK-13276 is fixed.
The problem you raised might because we misused `LogicalType.equals` which
will checks field names as well.
I have created an issue (FLINK-13290) to track this problem.
Best,
Jark
On Tue, 16 Jul 2019 at 17:35, kaka chen <kaka11.c...@gmail.com> wrote:
> I am looking this issue, the related codes which throw errors are:
>
> SinkCodeGenerator:: validateFieldType()
>
> ...
>
> // Tuple/Case class/Row type requested
> case tt: TupleTypeInfoBase[_] =>
> fieldTypes.zipWithIndex foreach {
> case (fieldTypeInfo: GenericTypeInfo[_], i) =>
> val requestedTypeInfo = tt.getTypeAt(i)
> if (!requestedTypeInfo.isInstanceOf[GenericTypeInfo[Object]]) {
> throw new TableException(
> s"Result field '${fieldNames(i)}' does not match requested
> type. " +
> s"Requested: $requestedTypeInfo; Actual:
> $fieldTypeInfo")
> }
> case (fieldTypeInfo, i) =>
> val requestedTypeInfo = tt.getTypeAt(i)
> validateFieldType(requestedTypeInfo)
> * if (fromTypeInfoToLogicalType(fieldTypeInfo) !=*
> * fromTypeInfoToLogicalType(requestedTypeInfo) &&*
> * !requestedTypeInfo.isInstanceOf[GenericTypeInfo[Object]])
> {*
> * val fieldNames = tt.getFieldNames*
> * throw new TableException(s"Result field '${fieldNames(i)}'
> does not match requested" +*
> * s" type. Requested: $requestedTypeInfo; Actual:
> $fieldTypeInfo")*
> * }*
> }
> ...
>
> Thanks,
> Frank
>
> kaka chen <kaka11.c...@gmail.com> 于2019年7月16日周二 下午5:23写道：
>
> > 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
> >
>
