Skip to content

Commit 917ecdd

Browse files
committed
Update expected compressed bulk request sizes in integration tests
The addition of resolvedScriptParameters field to SerializedJsonImpl and SerializedJsonNode increases the Java object serialization size, which affects compressed bulk request size estimation. Signed-off-by: Dinu John <86094133+dinujoh@users.noreply.github.com>
1 parent 9eef437 commit 917ecdd

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

  • data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch

data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -529,7 +529,7 @@ void testOutputRawSpanDefault(final boolean estimateBulkSizeUsingCompression,
529529
.add(OpenSearchSink.BULKREQUEST_SIZE_BYTES).toString());
530530
assertThat(bulkRequestSizeBytesMetrics.size(), equalTo(3));
531531
assertThat(bulkRequestSizeBytesMetrics.get(0).getValue(), closeTo(1.0, 0));
532-
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 799.0 : 2058.0;
532+
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 830.0 : 2058.0;
533533
assertThat(bulkRequestSizeBytesMetrics.get(1).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
534534
assertThat(bulkRequestSizeBytesMetrics.get(2).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
535535
}
@@ -615,7 +615,7 @@ void testOutputRawSpanWithDLQ(final boolean estimateBulkSizeUsingCompression,
615615
.add(OpenSearchSink.BULKREQUEST_SIZE_BYTES).toString());
616616
assertThat(bulkRequestSizeBytesMetrics.size(), equalTo(3));
617617
assertThat(bulkRequestSizeBytesMetrics.get(0).getValue(), closeTo(1.0, 0));
618-
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 1085.0 : 2072.0;
618+
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 1114.0 : 2072.0;
619619
assertThat(bulkRequestSizeBytesMetrics.get(1).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
620620
assertThat(bulkRequestSizeBytesMetrics.get(2).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
621621

@@ -677,7 +677,7 @@ void testOutputServiceMapDefault(final boolean estimateBulkSizeUsingCompression,
677677
.add(OpenSearchSink.BULKREQUEST_SIZE_BYTES).toString());
678678
assertThat(bulkRequestSizeBytesMetrics.size(), equalTo(3));
679679
assertThat(bulkRequestSizeBytesMetrics.get(0).getValue(), closeTo(1.0, 0));
680-
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 376.0 : 265.0;
680+
final double expectedBulkRequestSizeBytes = isRequestCompressionEnabled && estimateBulkSizeUsingCompression ? 410.0 : 265.0;
681681
assertThat(bulkRequestSizeBytesMetrics.get(1).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
682682
assertThat(bulkRequestSizeBytesMetrics.get(2).getValue(), closeTo(expectedBulkRequestSizeBytes, 0));
683683

0 commit comments

Comments
 (0)