[iotdb] branch Fsync-2 updated: fsync for TriggerInfo and UDFInfo

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch Fsync-2
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/Fsync-2 by this push:
     new 7a865ab5745 fsync for TriggerInfo and UDFInfo
7a865ab5745 is described below

commit 7a865ab574513f75f8146180f8c347fd4b547f89
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Thu Oct 26 16:32:26 2023 +0800

    fsync for TriggerInfo and UDFInfo
---
 .../main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java | 2 ++
 .../src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java | 3 +++
 2 files changed, 5 insertions(+)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
index 4ad86745de7..85014ba3f16 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
@@ -254,6 +254,8 @@ public class TriggerInfo implements SnapshotProcessor {
 
       triggerTable.serializeTriggerTable(fileOutputStream);
 
+      // fsync
+      fileOutputStream.getFD().sync();
       return true;
     } finally {
       releaseTriggerTableLock();
diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
index bb121e71df1..5ab8172d742 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
@@ -201,6 +201,9 @@ public class UDFInfo implements SnapshotProcessor {
 
       udfTable.serializeUDFTable(fileOutputStream);
 
+      // fsync
+      fileOutputStream.getFD().sync();
+
       return true;
     } finally {
       releaseUDFTableLock();