diff options
Diffstat (limited to 'vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java')
| -rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java | 1 |
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) { |