fix ci fail

maochongxin · maochongxin · commit e279303b7329 · 2024-11-02T18:29:22.000+08:00
diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java
@@ -620,6 +620,8 @@ protected Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> handleException(
                     client.calculateContinuousFailure(tableName, e.getMessage());
                     throw e;
                 }
+            } else {
+                throw e;
             }
         }
         return iterator; // Return the original iterator if no changes are made  

Original file line number	Diff line number	Diff line change
`@@ -620,6 +620,8 @@ protected Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> handleException(`
`620`	`620`	`client.calculateContinuousFailure(tableName, e.getMessage());`
`621`	`621`	`throw e;`
`622`	`622`	`}`
	`623`	`+ } else {`
	`624`	`+ throw e;`
`623`	`625`	`}`
`624`	`626`	`}`
`625`	`627`	`return iterator; // Return the original iterator if no changes are made`