You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2025/10/17 05:20:31 UTC
(iotdb) branch try-to-fix-procedure-NPE created (now 7cb03303a34)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch try-to-fix-procedure-NPE
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 7cb03303a34 Update AbstractProcedureScheduler.java
This branch includes the following new commits:
new 7cb03303a34 Update AbstractProcedureScheduler.java
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Update AbstractProcedureScheduler.java
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch try-to-fix-procedure-NPE
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7cb03303a343eefa8087e4aaf57704ded716ad7a
Author: Yongzao <53...@qq.com>
AuthorDate: Fri Oct 17 13:20:20 2025 +0800
Update AbstractProcedureScheduler.java
---
.../confignode/procedure/scheduler/AbstractProcedureScheduler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/AbstractProcedureScheduler.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/AbstractProcedureScheduler.java
index b8e8c5778c4..5a8d53dcb16 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/AbstractProcedureScheduler.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/AbstractProcedureScheduler.java
@@ -78,7 +78,7 @@ public abstract class AbstractProcedureScheduler implements ProcedureScheduler {
@Override
public void addFront(final Procedure procedure) {
- if (procedure.isSuccess()) {
+ if (procedure != null && procedure.isSuccess()) {
LOG.warn("Don't add a successful procedure back to the scheduler, it will be ignored");
return;
}