summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-15 17:26:30 +0200
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-16 13:08:32 +0200
commit5696b08dd6e956c4b4cb4c29e63999d3a974dca5 (patch)
treea577874c765729ee733421116d40bb5d574b1bbb /vespa-hadoop
parent335bb432c5befa014f8616ffa07328e46f52aba1 (diff)
Report exceptional feed failures as FeedException.
Change signature of ResultCallback to use FeedException. Rename 'JsonParseException' => 'OperationParseException'. Add exception for response/result parse failure.
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java
index 15b3d2e9d7d..0b64f8ae4cd 100644
--- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java
+++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java
@@ -6,7 +6,7 @@ import ai.vespa.feed.client.DryrunResult;
import ai.vespa.feed.client.FeedClient;
import ai.vespa.feed.client.FeedClientBuilder;
import ai.vespa.feed.client.JsonFeeder;
-import ai.vespa.feed.client.JsonParseException;
+import ai.vespa.feed.client.OperationParseException;
import ai.vespa.feed.client.OperationParameters;
import ai.vespa.feed.client.OperationStats;
import ai.vespa.feed.client.Result;
@@ -54,7 +54,7 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> {
feeder.feedSingle(json)
.whenComplete((result, error) -> {
if (error != null) {
- if (error instanceof JsonParseException) {
+ if (error instanceof OperationParseException) {
counters.incrementDocumentsSkipped(1);
} else {
String msg = "Failed to feed single document: " + error;