diff options
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java')
-rw-r--r-- | vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java index d8b69bd4a85..2b67df00e12 100644 --- a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java @@ -80,8 +80,13 @@ public abstract class Feeder { while (!sender.isAborted()) { try { FeedOperation op = reader.read(); - if (createIfNonExistent && op.getDocumentUpdate() != null) { - op.getDocumentUpdate().setCreateIfNonExistent(true); + if (createIfNonExistent) { + if (op.getDocumentUpdate() != null) { + op.getDocumentUpdate().setCreateIfNonExistent(true); + } + if (op.getDocumentPut() != null) { + op.getDocumentPut().setCreateIfNonExistent(true); + } } if (op.getType() == FeedOperation.Type.INVALID) break; // Done feeding sender.sendOperation(op); |