[FLINK-20321] Get NPE when using AvroDeserializationSchema to deserialize null input

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.5
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Labels: pull-request-available sprint starter
• Assignee: Xue Wang
• Reporter: Shengkai Fang
• Created: 24/Nov/20 12:48
• Updated: 23/Sep/21 18:02
• Resolved: 08/Jan/21 14:32

Description

You can reproduce the bug by adding the code into the AvroDeserializationSchemaTest.
The code follows

@Test
	public void testSpecificRecord2() throws Exception {
		DeserializationSchema<Address> deserializer = AvroDeserializationSchema.forSpecific(Address.class);

		Address deserializedAddress = deserializer.deserialize(null);
		assertEquals(null, deserializedAddress);
	}

Exception stack:

java.lang.NullPointerException
	at org.apache.flink.formats.avro.utils.MutableByteArrayInputStream.setBuffer(MutableByteArrayInputStream.java:43)
	at org.apache.flink.formats.avro.AvroDeserializationSchema.deserialize(AvroDeserializationSchema.java:131)
	at org.apache.flink.formats.avro.AvroDeserializationSchemaTest.testSpecificRecord2(AvroDeserializationSchemaTest.java:69)

Issue Links

• duplicates: FLINK-20459 Handle null message correctly in JSON RowData deserializer
• is related to: FLINK-20121 Test the upsert-kafka Connector
• is related to: FLINK-21889 source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException
• links to: GitHub Pull Request #14539
• links to: GitHub Pull Request #16393
• links to: GitHub Pull Request #16394