fix an error

oceanbase · Apr 23, 2024 · 6997eec · 6997eec
1 parent 769a879
commit 6997eec
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java b/server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
@@ -233,8 +233,10 @@ public List<JdbcGeneralResult> doInStatement(Statement statement) throws SQLExce
                             for (SqlExecutionListener listener : sortedListeners) {
                                 long waitTs = System.currentTimeMillis() - startTs;
                                 Long expectedTs = listener.getOnExecutionStartAfterMillis();
-                                if (waitTs > expectedTs || !latch.await(expectedTs - waitTs, TimeUnit.MILLISECONDS)) {
+                                if (!latch.await(expectedTs - waitTs, TimeUnit.MILLISECONDS)) {
                                     listener.onExecutionStartAfter(sqlTuple, context);
+                                } else {
+                                    break;
                                 }
                             }
                             return null;