skip over value bytes after reading replicated data

2021-09-13 01:26:12 +00:00 · 2017-07-14 12:18:37 +01:00
parent f058c5a9b4
commit abe4297c9e
1 changed files with 1 additions and 1 deletions
@@ -66,7 +66,7 @@ public abstract class ReplicatedInput<K, V, R> implements RemoteOperationContext
            long valueSize = mh.m().valueSizeMarshaller.readSize(replicatedInputBytes);
            long valueOffset = replicatedInputBytes.readPosition();
            Data<V> value = q.wrapValueBytesAsData(replicatedInputBytes, valueOffset, valueSize);
-
+            replicatedInputBytes.readSkip(valueSize);
            s.innerWriteLock.lock();
            mh.m().remoteOperations.put(this, value);
        }