Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.12.0
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)
Attachments
Issue Links
- duplicates
-
FLINK-20459 Handle null message correctly in JSON RowData deserializer
-
- Closed
-
- is related to
-
FLINK-20121 Test the upsert-kafka Connector
-
- Closed
-
-
FLINK-21889 source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException
-
- Closed
-
- links to
(1 links to)