You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by el...@apache.org on 2013/04/23 21:20:40 UTC
svn commit: r1471105 - in /lucene/dev/trunk/solr: CHANGES.txt
core/src/java/org/apache/solr/core/SolrDeletionPolicy.java
Author: elyograg
Date: Tue Apr 23 19:20:39 2013
New Revision: 1471105
URL: http://svn.apache.org/r1471105
Log:
SOLR-4547: Move logging of filenames on commit from INFO to DEBUG.
Modified:
lucene/dev/trunk/solr/CHANGES.txt
lucene/dev/trunk/solr/core/src/java/org/apache/solr/core/SolrDeletionPolicy.java
Modified: lucene/dev/trunk/solr/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/CHANGES.txt?rev=1471105&r1=1471104&r2=1471105&view=diff
==============================================================================
--- lucene/dev/trunk/solr/CHANGES.txt (original)
+++ lucene/dev/trunk/solr/CHANGES.txt Tue Apr 23 19:20:39 2013
@@ -88,6 +88,9 @@ Other Changes
* SOLR-4749: Clean up and refactor CoreContainer code around solr.xml and SolrCore
management. (Mark Miller)
+* SOLR-4547: Move logging of filenames on commit from INFO to DEBUG.
+ (Shawn Heisey, hossman)
+
================== 4.3.0 ==================
Versions of Major Components
Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/core/SolrDeletionPolicy.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/core/SolrDeletionPolicy.java?rev=1471105&r1=1471104&r2=1471105&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/core/SolrDeletionPolicy.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/core/SolrDeletionPolicy.java Tue Apr 23 19:20:39 2013
@@ -73,46 +73,16 @@ public class SolrDeletionPolicy extends
}
}
- static String str(IndexCommit commit) {
- StringBuilder sb = new StringBuilder();
- try {
- sb.append("commit{");
-
- Directory dir = commit.getDirectory();
-
- if (dir instanceof FSDirectory) {
- FSDirectory fsd = (FSDirectory) dir;
- sb.append("dir=").append(fsd.getDirectory());
- } else {
- sb.append("dir=").append(dir);
- }
-
- sb.append(",segFN=").append(commit.getSegmentsFileName());
- sb.append(",generation=").append(commit.getGeneration());
- sb.append(",filenames=").append(commit.getFileNames());
- } catch (Exception e) {
- sb.append(e);
- }
- return sb.toString();
- }
-
- static String str(List commits) {
- StringBuilder sb = new StringBuilder();
- sb.append("num=").append(commits.size());
-
- for (IndexCommit commit : (List<IndexCommit>) commits) {
- sb.append("\n\t");
- sb.append(str(commit));
- }
- return sb.toString();
- }
-
/**
* Internal use for Lucene... do not explicitly call.
*/
@Override
public void onInit(List commits) throws IOException {
- log.info("SolrDeletionPolicy.onInit: commits:" + str(commits));
+ // SOLR-4547: log basic data at INFO, add filenames at DEBUG.
+ log.info("SolrDeletionPolicy.onInit: commits: {}",
+ new CommitsLoggingInfo(commits));
+ log.debug("SolrDeletionPolicy.onInit: commits: {}",
+ new CommitsLoggingDebug(commits));
updateCommits((List<IndexCommit>) commits);
}
@@ -121,10 +91,61 @@ public class SolrDeletionPolicy extends
*/
@Override
public void onCommit(List commits) throws IOException {
- log.info("SolrDeletionPolicy.onCommit: commits:" + str(commits));
+ // SOLR-4547: log basic data at INFO, add filenames at DEBUG.
+ log.info("SolrDeletionPolicy.onCommit: commits: {}",
+ new CommitsLoggingInfo(commits));
+ log.debug("SolrDeletionPolicy.onCommit: commits: {}",
+ new CommitsLoggingDebug(commits));
updateCommits((List<IndexCommit>) commits);
}
+ private static class CommitsLoggingInfo {
+ private List<IndexCommit> commits;
+
+ public CommitsLoggingInfo(List<IndexCommit> commits) {
+ this.commits = commits;
+ }
+
+ public final String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("num=").append(commits.size());
+ for (IndexCommit c : commits) {
+ sb.append("\n\tcommit{");
+ appendDetails(sb, c);
+ sb.append("}");
+ }
+ // add an end brace
+ return sb.toString();
+ }
+
+ protected void appendDetails(StringBuilder sb, IndexCommit c) {
+ Directory dir = c.getDirectory();
+ if (dir instanceof FSDirectory) {
+ FSDirectory fsd = (FSDirectory) dir;
+ sb.append("dir=").append(fsd.getDirectory());
+ } else {
+ sb.append("dir=").append(dir);
+ }
+ sb.append(",segFN=").append(c.getSegmentsFileName());
+ sb.append(",generation=").append(c.getGeneration());
+ }
+ }
+
+ private static class CommitsLoggingDebug extends CommitsLoggingInfo {
+ public CommitsLoggingDebug(List<IndexCommit> commits) {
+ super(commits);
+ }
+
+ protected void appendDetails(StringBuilder sb, IndexCommit c) {
+ super.appendDetails(sb, c);
+ try {
+ sb.append(",filenames=");
+ sb.append(c.getFileNames());
+ } catch (IOException e) {
+ sb.append(e);
+ }
+ }
+ }
private void updateCommits(List<IndexCommit> commits) {
// to be safe, we should only call delete on a commit point passed to us
@@ -135,12 +156,10 @@ public class SolrDeletionPolicy extends
synchronized (this) {
long maxCommitAgeTimeStamp = -1L;
IndexCommit newest = commits.get(commits.size() - 1);
- try {
- log.info("newest commit = " + newest.getGeneration() + newest.getFileNames().toString());
- } catch (IOException e1) {
- throw new RuntimeException();
- }
-
+ // SOLR-4547: Removed the filenames from this log entry because this
+ // method is only called from methods that have just logged them
+ // at DEBUG.
+ log.info("newest commit generation = " + newest.getGeneration());
int singleSegKept = (newest.getSegmentCount() == 1) ? 1 : 0;
int totalKept = 1;