You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by sa...@apache.org on 2016/06/17 23:59:51 UTC
[2/4] lucene-solr:branch_5x: SOLR-8866: UpdateLog now throws an error
if it can't serialize a field value (cherry picked from commit a22099a)
SOLR-8866: UpdateLog now throws an error if it can't serialize a field value
(cherry picked from commit a22099a)
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/e04c11f2
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/e04c11f2
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/e04c11f2
Branch: refs/heads/branch_5x
Commit: e04c11f2af087eb2b321a34fa0dd5c4866c02fac
Parents: 3344d21
Author: David Smiley <ds...@apache.org>
Authored: Thu Mar 17 13:22:16 2016 -0400
Committer: Steve Rowe <sa...@apache.org>
Committed: Fri Jun 17 19:58:32 2016 -0400
----------------------------------------------------------------------
.../org/apache/solr/update/TransactionLog.java | 4 +++-
.../test/org/apache/solr/update/TestUpdate.java | 21 ++++++++++++++++++++
.../apache/solr/common/util/JavaBinCodec.java | 4 +++-
3 files changed, 27 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e04c11f2/solr/core/src/java/org/apache/solr/update/TransactionLog.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/update/TransactionLog.java b/solr/core/src/java/org/apache/solr/update/TransactionLog.java
index 6954799..7f0b981 100644
--- a/solr/core/src/java/org/apache/solr/update/TransactionLog.java
+++ b/solr/core/src/java/org/apache/solr/update/TransactionLog.java
@@ -95,7 +95,9 @@ public class TransactionLog implements Closeable {
codec.writeByteArray(br.bytes, br.offset, br.length);
return null;
}
- return o;
+ // Fallback: we have no idea how to serialize this. Be noisy to prevent insidious bugs
+ throw new SolrException(SolrException.ErrorCode.SERVER_ERROR,
+ "TransactionLog doesn't know how to serialize " + o.getClass() + "; try implementing ObjectResolver?");
}
};
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e04c11f2/solr/core/src/test/org/apache/solr/update/TestUpdate.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/update/TestUpdate.java b/solr/core/src/test/org/apache/solr/update/TestUpdate.java
index 381231f..13a2479 100644
--- a/solr/core/src/test/org/apache/solr/update/TestUpdate.java
+++ b/solr/core/src/test/org/apache/solr/update/TestUpdate.java
@@ -18,9 +18,11 @@ package org.apache.solr.update;
import org.apache.solr.SolrTestCaseJ4;
import org.apache.solr.common.SolrException;
+import org.apache.solr.common.SolrInputDocument;
import org.junit.BeforeClass;
import org.junit.Test;
+import java.io.IOException;
import java.util.concurrent.Callable;
public class TestUpdate extends SolrTestCaseJ4 {
@@ -243,4 +245,23 @@ public class TestUpdate extends SolrTestCaseJ4 {
}
+ @Test // SOLR-8866
+ public void testUpdateLogThrowsForUnknownTypes() throws IOException {
+ SolrInputDocument doc = new SolrInputDocument();
+ doc.addField("id", "444");
+ doc.addField("text", new Object());//Object shouldn't be serialized later...
+
+ AddUpdateCommand cmd = new AddUpdateCommand(req());
+ cmd.solrDoc = doc;
+ try {
+ h.getCore().getUpdateHandler().addDoc(cmd); // should throw
+ } catch (SolrException e) {
+ if (e.getMessage().contains("serialize")) {
+ return;//passed test
+ }
+ throw e;
+ }
+ fail();
+ }
+
}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e04c11f2/solr/solrj/src/java/org/apache/solr/common/util/JavaBinCodec.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/common/util/JavaBinCodec.java b/solr/solrj/src/java/org/apache/solr/common/util/JavaBinCodec.java
index 4fc6ea8..7197ed6 100644
--- a/solr/solrj/src/java/org/apache/solr/common/util/JavaBinCodec.java
+++ b/solr/solrj/src/java/org/apache/solr/common/util/JavaBinCodec.java
@@ -207,7 +207,9 @@ public class JavaBinCodec {
if (writeKnownType(tmpVal)) return;
}
}
-
+ // Fallback to do *something*.
+ // note: if the user of this codec doesn't want this (e.g. UpdateLog) it can supply an ObjectResolver that does
+ // something else like throw an exception.
writeVal(val.getClass().getName() + ':' + val.toString());
}