You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by su...@apache.org on 2022/10/12 07:52:16 UTC
[shardingsphere] branch master updated: Adjust order of DatabaseRuleConfiguration (#21522)
This is an automated email from the ASF dual-hosted git repository.
sunnianjun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 248b7eab75d Adjust order of DatabaseRuleConfiguration (#21522)
248b7eab75d is described below
commit 248b7eab75d9525c2633d075bd4dc197f73d2e17
Author: Zhengqiang Duan <du...@apache.org>
AuthorDate: Wed Oct 12 15:52:03 2022 +0800
Adjust order of DatabaseRuleConfiguration (#21522)
---
.../shardingsphere/dbdiscovery/constant/DatabaseDiscoveryOrder.java | 2 +-
.../readwritesplitting/constant/ReadwriteSplittingOrder.java | 2 +-
.../java/org/apache/shardingsphere/shadow/constant/ShadowOrder.java | 2 +-
.../shardingsphere/data/pipeline/mysql/ingest/client/MySQLClient.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/features/db-discovery/core/src/main/java/org/apache/shardingsphere/dbdiscovery/constant/DatabaseDiscoveryOrder.java b/features/db-discovery/core/src/main/java/org/apache/shardingsphere/dbdiscovery/constant/DatabaseDiscoveryOrder.java
index b97c9fb6246..5ae5fe25d38 100644
--- a/features/db-discovery/core/src/main/java/org/apache/shardingsphere/dbdiscovery/constant/DatabaseDiscoveryOrder.java
+++ b/features/db-discovery/core/src/main/java/org/apache/shardingsphere/dbdiscovery/constant/DatabaseDiscoveryOrder.java
@@ -29,7 +29,7 @@ public final class DatabaseDiscoveryOrder {
/**
* Database discovery order.
*/
- public static final int ORDER = 30;
+ public static final int ORDER = 40;
/**
* Algorithm provider database discovery order.
diff --git a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/constant/ReadwriteSplittingOrder.java b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/constant/ReadwriteSplittingOrder.java
index 0a7ff1226fe..dc0916b3462 100644
--- a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/constant/ReadwriteSplittingOrder.java
+++ b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/constant/ReadwriteSplittingOrder.java
@@ -29,7 +29,7 @@ public final class ReadwriteSplittingOrder {
/**
* Readwrite-splitting order.
*/
- public static final int ORDER = 20;
+ public static final int ORDER = 30;
/**
* Algorithm provider readwrite-splitting order.
diff --git a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/constant/ShadowOrder.java b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/constant/ShadowOrder.java
index e6bd70a1cdf..a02cf7690aa 100644
--- a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/constant/ShadowOrder.java
+++ b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/constant/ShadowOrder.java
@@ -29,7 +29,7 @@ public final class ShadowOrder {
/**
* Shadow order.
*/
- public static final int ORDER = 40;
+ public static final int ORDER = 50;
/**
* Algorithm provider shadow order.
diff --git a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/MySQLClient.java b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/MySQLClient.java
index d532995c150..3df3d068be7 100644
--- a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/MySQLClient.java
+++ b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/MySQLClient.java
@@ -298,7 +298,7 @@ public final class MySQLClient {
log.error("MySQLBinlogEventHandler protocol resolution error, file name:{}, position:{}", fileName, position, cause);
reconnect();
}
-
+
private void reconnect() {
if (reconnectTimes.get() > 3) {
log.warn("exceeds the maximum number of retry times, last binlog event:{}", lastBinlogEvent);