You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/07/02 09:43:58 UTC
[iotdb] branch master updated: [IOTDB-3726] Fix concurrent issue of udf management
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new bfbf05a96f [IOTDB-3726] Fix concurrent issue of udf management
bfbf05a96f is described below
commit bfbf05a96f3943384b4299154d6e66915c9ae9db
Author: lancelly <10...@users.noreply.github.com>
AuthorDate: Sat Jul 2 17:43:54 2022 +0800
[IOTDB-3726] Fix concurrent issue of udf management
---
.../iotdb/confignode/client/handlers/FunctionManagementHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FunctionManagementHandler.java b/confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FunctionManagementHandler.java
index 6ec4b4f06f..90a4967e12 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FunctionManagementHandler.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FunctionManagementHandler.java
@@ -44,15 +44,15 @@ public class FunctionManagementHandler implements AsyncMethodCallback<TSStatus>
@Override
public void onComplete(TSStatus response) {
- countDownLatch.countDown();
dataNodeResponseStatus.add(response);
+ countDownLatch.countDown();
}
@Override
public void onError(Exception exception) {
- countDownLatch.countDown();
dataNodeResponseStatus.add(
new TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode())
.setMessage("DataNode[" + ip + ":" + port + "] " + exception.getMessage()));
+ countDownLatch.countDown();
}
}