This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new e0902c19ff Force FileChannel to commit data to disk (#11625)
e0902c19ff is described below
commit e0902c19ff82969ef0dca26bef5147dad24eee27
Author: Arnav Balyan <[email protected]>
AuthorDate: Mon Sep 25 06:38:23 2023 +0530
Force FileChannel to commit data to disk (#11625)
---
.../local/segment/creator/impl/inv/geospatial/BaseH3IndexCreator.java | 1 +
.../local/segment/creator/impl/inv/json/BaseJsonIndexCreator.java | 1 +
.../pinot/segment/local/startree/v2/builder/StarTreeIndexSeparator.java | 1 +
3 files changed, 3 insertions(+)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/geospatial/BaseH3IndexCreator.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/geospatial/BaseH3IndexCreator.java
index ada362c9f8..42e1882aa1 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/geospatial/BaseH3IndexCreator.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/geospatial/BaseH3IndexCreator.java
@@ -163,6 +163,7 @@ public abstract class BaseH3IndexCreator implements
GeoSpatialIndexCreator {
indexFileChannel);
org.apache.pinot.common.utils.FileUtils.transferBytes(bitmapValueFileChannel,
0, _bitmapValueFile.length(),
indexFileChannel);
+ indexFileChannel.force(true);
}
}
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/json/BaseJsonIndexCreator.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/json/BaseJsonIndexCreator.java
index ec3dc439dd..264bc6044b 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/json/BaseJsonIndexCreator.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/inv/json/BaseJsonIndexCreator.java
@@ -168,6 +168,7 @@ public abstract class BaseJsonIndexCreator implements
JsonIndexCreator {
CleanerUtil.BufferCleaner cleaner = CleanerUtil.getCleaner();
cleaner.freeBuffer(docIdMappingBuffer);
}
+ indexFileChannel.force(true);
}
}
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/startree/v2/builder/StarTreeIndexSeparator.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/startree/v2/builder/StarTreeIndexSeparator.java
index dc475b93fd..a64b939f78 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/startree/v2/builder/StarTreeIndexSeparator.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/startree/v2/builder/StarTreeIndexSeparator.java
@@ -143,6 +143,7 @@ public class StarTreeIndexSeparator implements Closeable {
throws IOException {
try (FileChannel dest = new RandomAccessFile(destFile, "rw").getChannel())
{
org.apache.pinot.common.utils.FileUtils.transferBytes(_indexFileChannel,
value._offset, value._size, dest);
+ dest.force(true);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
