[shardingsphere] branch master updated: Remove timeout limit with unregister PostgreSQLBinaryStatementRegistry (#10188)

[ouyangwen]

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

ouyangwen 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 0e86726  Remove timeout limit with unregister 
PostgreSQLBinaryStatementRegistry (#10188)
0e86726 is described below

commit 0e86726248fb404efa286b0889f7d4cd3c99db10
Author: Liang Zhang <terrym...@163.com>
AuthorDate: Sun Apr 25 15:23:55 2021 +0800

    Remove timeout limit with unregister PostgreSQLBinaryStatementRegistry 
(#10188)
---
 .../proxy/frontend/postgresql/PostgreSQLFrontendEngine.java            | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/PostgreSQLFrontendEngine.java
 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/PostgreSQLFrontendEngine.java
index 5ca3d7e..33f6e88 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/PostgreSQLFrontendEngine.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/PostgreSQLFrontendEngine.java
@@ -51,8 +51,7 @@ public final class PostgreSQLFrontendEngine implements 
DatabaseProtocolFrontendE
     }
     
     private void waitingForFinish(final BackendConnection backendConnection) {
-        int tryTimes = 0;
-        while (backendConnection.getRunningTaskCount().get() > 0 && tryTimes++ 
< 3) {
+        while (backendConnection.getRunningTaskCount().get() > 0) {
             try {
                 Thread.sleep(500L);
             } catch (final InterruptedException ex) {