Avihai Berkovitz created FLINK-6044:
---------------------------------------

             Summary: TypeSerializerSerializationProxy.read() doesn't verify 
the read buffer length
                 Key: FLINK-6044
                 URL: https://issues.apache.org/jira/browse/FLINK-6044
             Project: Flink
          Issue Type: Bug
          Components: Type Serialization System
    Affects Versions: 1.2.0
         Environment: Ubuntu server 12.04.5 64 bit
java version "1.8.0_111"
Java(TM) SE Runtime Environment (build 1.8.0_111-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.111-b14, mixed mode)
            Reporter: Avihai Berkovitz
            Priority: Critical


The read() method of TypeSerializerSerializationProxy creates a buffers and 
tries to fill it by calling the read() method of the given DataInputView, but 
never checks the return value. The actual size read from the stream might be 
smaller than the buffer size, and the rest of the buffer is filled with zeroes, 
causing the deserialization to fail.
It happened to me using a RocksDB state backend backed by S3. The setup was 
done according to 
https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/aws.html#s3-simple-storage-service
 and everything worked correctly until I upgraded to Flink 1.2.0.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to