[flink-connector-cassandra] 01/01: [FLINK-31805] Avoid non-public APIs

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch 31805
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git

commit 79bc3ebb3b3909c840fc742f58120841f7857bae
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri Apr 14 10:13:03 2023 +0200

    [FLINK-31805] Avoid non-public APIs
---
 .../source/enumerator/CassandraEnumeratorStateSerializer.java          | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java
 
b/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java
index 3725d47..bb8533b 100644
--- 
a/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java
+++ 
b/flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java
@@ -22,7 +22,6 @@ import 
org.apache.flink.connector.cassandra.source.split.CassandraSplit;
 import 
org.apache.flink.connector.cassandra.source.split.CassandraSplitSerializer;
 import 
org.apache.flink.connector.cassandra.source.utils.BigIntegerSerializationUtils;
 import org.apache.flink.core.io.SimpleVersionedSerializer;
-import org.apache.flink.util.IOUtils;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -87,7 +86,7 @@ public class CassandraEnumeratorStateSerializer
             for (int i = 0; i < splitsToReassignSize; i++) {
                 final int splitSize = objectInputStream.readInt();
                 final byte[] splitBytes = new byte[splitSize];
-                IOUtils.readFully(objectInputStream, splitBytes, 0, splitSize);
+                objectInputStream.readFully(splitBytes);
                 final CassandraSplit split =
                         CassandraSplitSerializer.INSTANCE.deserialize(
                                 CassandraSplitSerializer.CURRENT_VERSION, 
splitBytes);