This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 3194bac382a [opt](jdbc catalog) Refine the jdbc_connector close logic
and actively clear the jvm occupied by jdbcexecutor (#32300) (#32528)
3194bac382a is described below
commit 3194bac382a0f2403283b4c865dbd1303e793a64
Author: zy-kkk <[email protected]>
AuthorDate: Wed Mar 20 22:40:20 2024 +0800
[opt](jdbc catalog) Refine the jdbc_connector close logic and actively
clear the jvm occupied by jdbcexecutor (#32300) (#32528)
pick #32300
---
be/src/vec/exec/vjdbc_connector.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/vec/exec/vjdbc_connector.cpp
b/be/src/vec/exec/vjdbc_connector.cpp
index 23602e52d6d..9b98627db94 100644
--- a/be/src/vec/exec/vjdbc_connector.cpp
+++ b/be/src/vec/exec/vjdbc_connector.cpp
@@ -100,12 +100,12 @@ Status JdbcConnector::close() {
}
JNIEnv* env = nullptr;
RETURN_IF_ERROR(JniUtil::GetJNIEnv(&env));
+ env->CallNonvirtualVoidMethod(_executor_obj, _executor_clazz,
_executor_close_id);
env->DeleteGlobalRef(_executor_clazz);
DELETE_BASIC_JAVA_CLAZZ_REF(object)
DELETE_BASIC_JAVA_CLAZZ_REF(string)
DELETE_BASIC_JAVA_CLAZZ_REF(list)
#undef DELETE_BASIC_JAVA_CLAZZ_REF
- env->CallNonvirtualVoidMethod(_executor_obj, _executor_clazz,
_executor_close_id);
RETURN_IF_ERROR(JniUtil::GetJniExceptionMsg(env));
env->DeleteGlobalRef(_executor_obj);
return Status::OK();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
