diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-15 17:26:30 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-16 13:08:32 +0200 |
commit | 5696b08dd6e956c4b4cb4c29e63999d3a974dca5 (patch) | |
tree | a577874c765729ee733421116d40bb5d574b1bbb /vespa-hadoop | |
parent | 335bb432c5befa014f8616ffa07328e46f52aba1 (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.java | 4 |
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; |