[flink-connector-cassandra] branch main updated: [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 main
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git


The following commit(s) were added to refs/heads/main by this push:
     new 1b87943  [FLINK-31805] Avoid non-public APIs
1b87943 is described below

commit 1b8794380b268aad3b74d2b67ded8f59c1f07ea9
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);