Apache/lucene
1
0
Fork 0
mirror of https://github.com/apache/lucene.git synced 2025-02-22 10:15:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

SOLR-3911: sync properties files after write so that they are written out before the directory is closed.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1418789 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2012-12-09 00:12:03 +00:00
parent 6a11fd8db6
commit 452a32f314
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
solr/core/src/java/org/apache/solr/handler/SnapPuller.java
View File

@ -110,6 +110,8 @@ import org.slf4j.LoggerFactory;
* @since solr 1.4 * @since solr 1.4
*/ */
public class SnapPuller { public class SnapPuller {
private static final String INDEX_PEROPERTIES = "index.peroperties";
private static final Logger LOG = LoggerFactory.getLogger(SnapPuller.class.getName()); private static final Logger LOG = LoggerFactory.getLogger(SnapPuller.class.getName());
private final String masterUrl; private final String masterUrl;
@ -570,6 +572,7 @@ public class SnapPuller {
OutputStream outFile = new PropertiesOutputStream(out); OutputStream outFile = new PropertiesOutputStream(out);
try { try {
props.store(outFile, "Replication details"); props.store(outFile, "Replication details");
dir.sync(Collections.singleton(REPLICATION_PROPERTIES));
} finally { } finally {
IOUtils.closeQuietly(outFile); IOUtils.closeQuietly(outFile);
} }
@ -863,6 +866,7 @@ public class SnapPuller {
try { try {
os = new PropertiesOutputStream(out); os = new PropertiesOutputStream(out);
p.store(os, "index properties"); p.store(os, "index properties");
dir.sync(Collections.singleton(INDEX_PEROPERTIES));
} catch (Exception e) { } catch (Exception e) {
throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, throw new SolrException(SolrException.ErrorCode.SERVER_ERROR,
"Unable to write index.properties", e); "Unable to write index.properties", e);