Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6026
@twalthr Thanks for the comment. I've commited a new version as per your
suggestion. Particularly, I agree that TypeInfomation should always be derived
from the 'avroRecrodClass', but the constructor of AvroRowDeserializationSchema
only takes argument as type 'Class<? extends SpecificRecord>'. In this version
I've changed the argument as 'Class<? extends SpecificRecordBase>' and fixed
relevant test cases accordingly. This version of fix has passed relevant unit
tests and my local integration tests.
---
