This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/correctMetric-1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d1ff27129d5c7d140171fa9c1595da96028d1b7b Author: JackieTien97 <[email protected]> AuthorDate: Tue Sep 23 11:37:41 2025 +0800 [To dev/1.3] Fix Metric name --- .../db/queryengine/execution/fragment/FragmentInstanceManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceManager.java index 5cb43d86bc0..9a2657101e7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceManager.java @@ -189,7 +189,6 @@ public class FragmentInstanceManager { instance.isExplainAnalyze(), exchangeManager); } catch (Throwable t) { - clearFIRelatedResources(instanceId); // deal with if (t instanceof IllegalStateException && TOO_MANY_CONCURRENT_QUERIES_ERROR_MSG.equals(t.getMessage())) { @@ -202,6 +201,7 @@ public class FragmentInstanceManager { logger.warn("error when create FragmentInstanceExecution.", t); stateMachine.failed(t); } + clearFIRelatedResources(instanceId); return null; } }); @@ -280,7 +280,6 @@ public class FragmentInstanceManager { false, exchangeManager); } catch (Throwable t) { - clearFIRelatedResources(instanceId); // deal with if (t instanceof IllegalStateException && TOO_MANY_CONCURRENT_QUERIES_ERROR_MSG.equals(t.getMessage())) { @@ -293,6 +292,7 @@ public class FragmentInstanceManager { logger.warn("Execute error caused by ", t); stateMachine.failed(t); } + clearFIRelatedResources(instanceId); return null; } });
