Skip to content

Commit a7e549a

Browse files
committed
add unit tests for s3 enrich processor
Signed-off-by: Xun Zhang <xunzh@amazon.com>
1 parent a781b13 commit a7e549a

6 files changed

Lines changed: 1145 additions & 1 deletion

File tree

data-prepper-plugins/s3-enrich-processor/src/main/java/org/opensearch/dataprepper/plugins/s3_enrich/processor/s3source/S3ObjectWorker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ private void doProcessObject(final S3ObjectReference s3ObjectReference) throws E
9292
try {
9393
Event event = record.getData();
9494

95-
String correlationValue = event.getJsonNode().get(s3EnricherProcessorConfig.getCorrelationKey()).asText();
95+
String correlationValue = event.getJsonNode().get(s3EnricherProcessorConfig.getCorrelationKeys().get(0)).asText();
9696

9797
event.getMetadata().setExternalOriginationTime(originationTime);
9898
event.getEventHandle().setExternalOriginationTime(originationTime);

0 commit comments

Comments
 (0)