avoided to run database sync from message executor
@@ -863,6 +863,7 @@ public class ODistributedDatabaseImpl implements ODistributedDatabase {
if (parsing) {
while (operationsRunnig.get() != 0) {
try {
+
Thread.sleep(300);
} catch (InterruptedException e) {
break;
@@ -900,7 +901,11 @@ public class ODistributedDatabaseImpl implements ODistributedDatabase {
List<OTransactionId> res = sequenceManager.checkSelfStatus(status);
res.removeAll(this.inQueue);
if (!res.isEmpty()) {
+ Orient.instance()
+ .submit(
+ () -> {
manager.installDatabase(false, databaseName, true, true);
+ });
}
}
