aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-24 17:45:09 +0200
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-24 17:45:09 +0200
commita21f9bb32a568e26c46a4af8e953f218206de797 (patch)
tree5f05514831275746ecb31c8d342248fd7deb0b97 /vespa-hadoop
parent150aff6805eaa1b23a72bad7b01b89cee72ea6cf (diff)
Add temporary logging
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java1
1 files changed, 1 insertions, 0 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 9bd285b7cca..cbf2409b87e 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
@@ -46,6 +46,7 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> {
public void write(Object key, Object data) throws IOException {
initializeOnFirstWrite();
String json = data.toString().trim();
+ log.info(json); // TODO(bjorncs) Remove temporary logging of JSON
feeder.feedSingle(json)
.whenComplete((result, error) -> {
if (error != null) {