You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/01/29 06:10:15 UTC
[iotdb] branch fix_simple_confignode_consensus updated (c5e8ec4c1d -> 19833a7e54)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch fix_simple_confignode_consensus
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c5e8ec4c1d [IOTDB-5432] Use freemarker to generate eventWindow and eventWindowManager
add ca84f2f904 [IOTDB-5425] Consolidate all ConfigNodeClient to be managed by clientManager (#8891)
add 6629816b25 fix win CI
add 5aaa80a37d [IOTDB-5431] Fix concurrent bug caused by using synchronizedSet() in DriverScheduler
add 1dec87939a Use gitbox thrift url instead of github to avoid download issue in China
add b9f209f69a Add AR function in Operators-Functions/Machine-Learning
new 19833a7e54 add logWriter.close() for ConfigNodeRegionStateMachine
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.
Summary of changes:
.github/workflows/main-win.yml | 47 +---
.../statemachine/ConfigNodeRegionStateMachine.java | 1 +
.../Operators-Functions/Machine-Learning.md | 84 ++++++
.../Operators-Functions/Machine-Learning.md | 85 ++++++
.../apache/iotdb/libudf/it/dlearn/DLearnIT.java | 311 +++++++++++++++++++++
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 131 +++++++++
.../apache/iotdb/commons/client/ClientManager.java | 13 +-
pom.xml | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 +--
.../db/mpp/execution/schedule/DriverScheduler.java | 22 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 28 +-
.../db/service/DataNodeServerCommandLine.java | 17 +-
.../iotdb/db/service/RegionMigrateService.java | 14 +-
site/src/main/.vuepress/config.js | 6 +-
14 files changed, 691 insertions(+), 110 deletions(-)
create mode 100644 docs/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 integration-test/src/test/java/org/apache/iotdb/libudf/it/dlearn/DLearnIT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dlearn/UDTFAR.java
[iotdb] 01/01: add logWriter.close() for ConfigNodeRegionStateMachine
Posted by ca...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch fix_simple_confignode_consensus
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 19833a7e54f0ab3322b0c4da3681616266e136e3
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Sun Jan 29 14:10:01 2023 +0800
add logWriter.close() for ConfigNodeRegionStateMachine
---
.../confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
index 74c5ed5784..db16cb9c83 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
@@ -297,6 +297,7 @@ public class ConfigNodeRegionStateMachine
// The method logWriter.write will execute flip() firstly, so we must make position==limit
buffer.position(buffer.limit());
logWriter.write(buffer);
+ logWriter.close();
endIndex = endIndex + 1;
File tmpLogFile = new File(PROGRESS_FILE_PATH + endIndex);
Files.move(logFile.toPath(), tmpLogFile.toPath(), StandardCopyOption.ATOMIC_MOVE);