diff options
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java index 1c7edf34fe0..32cdbf9af5c 100644 --- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java +++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java @@ -163,8 +163,9 @@ public class VespaDocumentOperation extends EvalFunc<String> { if (op == Operation.UPDATE && createIfNonExistent) { writeField("create", true, DataType.BOOLEAN, g, properties, schema, op, 0); } - String testSetCondition = properties.getProperty(TESTSET_CONDITION); - if (testSetCondition != null) { + String testSetConditionTemplate = properties.getProperty(TESTSET_CONDITION); + if (testSetConditionTemplate != null) { + String testSetCondition = TupleTools.toString(fields, testSetConditionTemplate); writeField(TESTSET_CONDITION, testSetCondition, DataType.CHARARRAY, g, properties, schema, op, 0); } if (op != Operation.REMOVE) { |