Skip to content

Commit a2f6c76

Browse files
committed
Fix script to use filtered document when document filters are active
Pass filteredJsonNode instead of jsonNode to scriptManager.buildScript so that params.doc in the script reflects the post-filter document, consistent with how builder.document() and builder.upsert() use the filtered version. Signed-off-by: Dinu John <86094133+dinujoh@users.noreply.github.com>
1 parent d8bfbec commit a2f6c76

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkOperationFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ private BulkOperation createUpdateOperation(final String action,
113113
.version(version);
114114

115115
if (scriptManager.isScriptEnabled()) {
116-
builder.script(scriptManager.buildScript(jsonNode, document.getResolvedScriptParameters().orElse(null)));
116+
builder.script(scriptManager.buildScript(filteredJsonNode, document.getResolvedScriptParameters().orElse(null)));
117117
if (isUpsert) {
118118
builder.upsert(filteredJsonNode);
119119
builder.scriptedUpsert(true);

0 commit comments

Comments
 (0)