Repository: asterixdb Updated Branches: refs/heads/master 8f378b52e -> 15d9e0299
[ASTERIXDB-1706][RT] Ensure Result Files Are Flushed - user model changes: no - storage format changes: no - interface changes: no Details: - Ensure result files are flushed to disk. Change-Id: I32e77187ed8cb9d7fd17ab83a9e8fb9264f11851 Reviewed-on: https://asterix-gerrit.ics.uci.edu/2319 Sonar-Qube: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> Tested-by: Jenkins <[email protected]> Contrib: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/15d9e029 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/15d9e029 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/15d9e029 Branch: refs/heads/master Commit: 15d9e0299ed60ed7cc43b1b5fdf907513001b7ca Parents: 8f378b5 Author: Murtadha Hubail <[email protected]> Authored: Wed Jan 24 05:22:46 2018 +0300 Committer: Michael Blow <[email protected]> Committed: Tue Jan 23 22:07:50 2018 -0800 ---------------------------------------------------------------------- .../java/org/apache/hyracks/control/nc/dataset/ResultState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/15d9e029/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/dataset/ResultState.java ---------------------------------------------------------------------- diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/dataset/ResultState.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/dataset/ResultState.java index 3e3f06b..afce266 100644 --- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/dataset/ResultState.java +++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/dataset/ResultState.java @@ -127,7 +127,7 @@ public class ResultState implements IStateObject { String fName = FILE_PREFIX + String.valueOf(resultSetPartitionId.getPartition()); fileRef = fileFactory.createUnmanagedWorkspaceFile(fName); writeFileHandle = ioManager.open(fileRef, IIOManager.FileReadWriteMode.READ_WRITE, - IIOManager.FileSyncMode.METADATA_ASYNC_DATA_ASYNC); + IIOManager.FileSyncMode.METADATA_ASYNC_DATA_SYNC); } size += ioManager.syncWrite(writeFileHandle, size, buffer);
