fixing bugs in distributed
@@ -159,7 +159,6 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
}
private void convert(ODatabaseDocumentInternal database) {
- ops.clear();
for (ORecordOperationRequest req : operations) {
byte type = req.getType();
if (type == ORecordOperation.LOADED) {
@@ -181,6 +180,7 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
ops.add(op);
} else {
record = ORecordSerializerNetworkV37.INSTANCE.fromStream(req.getRecord(), null, null);
+ ORecordInternal.setRecordSerializer(record, database.getSerializer());
}
}
