Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199778602 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -148,25 +148,26 @@ public AvroRowDeserializationSchema(Class<? extends SpecificRecord> recordClazz) public AvroRowDeserializationSchema(String avroSchemaString) { Preconditions.checkNotNull(avroSchemaString, "Avro schema must not be null."); recordClazz = null; - typeInfo = AvroSchemaConverter.convert(avroSchemaString); + final TypeInformation<?> typeInfo = AvroSchemaConverter.convertToTypeInfo(avroSchemaString); + // check for a schema that describes a record + if (!(typeInfo instanceof RowTypeInfo)) { + throw new IllegalArgumentException("Row type information expected."); --- End diff -- `Preconditions.checkArgument`?
---