[shardingsphere] branch master updated: Remove reconnect when exception caught at MySQLClient (#25052)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng 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 0ad45b523bf Remove reconnect when exception caught at MySQLClient 
(#25052)
0ad45b523bf is described below

commit 0ad45b523bf6f4a10fa1f668221de0883890eae9
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Fri Apr 7 17:35:22 2023 +0800

    Remove reconnect when exception caught at MySQLClient (#25052)
---
 .../data/pipeline/mysql/ingest/client/MySQLClient.java               | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

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 e84d5d8a842..c5a0dac580f 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
@@ -308,6 +308,7 @@ public final class MySQLClient {
         
         @Override
         public void channelInactive(final ChannelHandlerContext ctx) {
+            log.warn("MySQL binlog channel inactive");
             if (!running) {
                 return;
             }
@@ -319,10 +320,6 @@ public final class MySQLClient {
             String fileName = null == lastBinlogEvent ? null : 
lastBinlogEvent.getFileName();
             Long position = null == lastBinlogEvent ? null : 
lastBinlogEvent.getPosition();
             log.error("MySQLBinlogEventHandler protocol resolution error, file 
name:{}, position:{}", fileName, position, cause);
-            if (!running) {
-                return;
-            }
-            reconnect();
         }
         
         private void reconnect() {