diff --git a/ClusterOperator/Backlog.js b/ClusterOperator/Backlog.js index 261cc9b..20ef363 100644 --- a/ClusterOperator/Backlog.js +++ b/ClusterOperator/Backlog.js @@ -127,7 +127,7 @@ class BackLog { } else { let setSession = false; if (query.toLowerCase().startsWith('create')) { - setSession = true; + setSession = false; } if (connId === false) { if (setSession) await this.UserDBClient.query("SET SESSION sql_mode='IGNORE_SPACE,NO_ZERO_IN_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION'", false, fullQuery); diff --git a/ClusterOperator/Operator.js b/ClusterOperator/Operator.js index bb3d77c..d14dcba 100644 --- a/ClusterOperator/Operator.js +++ b/ClusterOperator/Operator.js @@ -509,7 +509,7 @@ class Operator { let masterSN = BackLog.sequenceNumber + 1; let copyBuffer = false; while (BackLog.sequenceNumber < masterSN && !copyBuffer) { - const index = BackLog.sequenceNumber; + const index = BackLog.sequenceNumber + 1; const response = await fluxAPI.getBackLog(index, this.masterWSConn); masterSN = response.sequenceNumber; const percent = Math.round((index / masterSN) * 1000);