Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199734399
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java
---
@@ -44,7 +41,7 @@
@Override
protected void configureBuilder(KafkaTableSource.Builder builder) {
super.configureBuilder(builder);
- ((KafkaAvroTableSource.Builder)
builder).forAvroRecordClass(SameFieldsAvroClass.class);
+ ((KafkaAvroTableSource.Builder)
builder).forAvroRecordClass(SchemaRecord.class);
--- End diff --
No, but it simplifies the code base and uses only real-world generated
records for testing.
---
