|
29 | 29 | import org.opensearch.test.InternalTestCluster;
|
30 | 30 | import org.opensearch.test.OpenSearchIntegTestCase;
|
31 | 31 | import org.opensearch.test.disruption.NetworkDisruption;
|
| 32 | +import org.opensearch.test.junit.annotations.TestLogging; |
32 | 33 | import org.opensearch.test.transport.MockTransportService;
|
33 | 34 |
|
34 | 35 | import java.io.IOException;
|
@@ -249,6 +250,7 @@ public void testStatsResponseFromLocalNode() {
|
249 | 250 | }
|
250 | 251 | }
|
251 | 252 |
|
| 253 | + @TestLogging(reason = "Getting trace logs from remote store package", value = "org.opensearch.remotestore:TRACE") |
252 | 254 | public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exception {
|
253 | 255 | setup();
|
254 | 256 | // Scenario:
|
@@ -277,6 +279,13 @@ public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exce
|
277 | 279 | .collect(Collectors.toList())
|
278 | 280 | .get(0)
|
279 | 281 | .getSegmentStats();
|
| 282 | + logger.info( |
| 283 | + "Zero state primary stats: {}ms refresh time lag, {}b bytes lag, {}b upload bytes started and {}b upload bytes failed.", |
| 284 | + zeroStatePrimaryStats.refreshTimeLagMs, |
| 285 | + zeroStatePrimaryStats.bytesLag, |
| 286 | + zeroStatePrimaryStats.uploadBytesStarted, |
| 287 | + zeroStatePrimaryStats.uploadBytesFailed |
| 288 | + ); |
280 | 289 | assertTrue(
|
281 | 290 | zeroStatePrimaryStats.totalUploadsStarted == zeroStatePrimaryStats.totalUploadsSucceeded
|
282 | 291 | && zeroStatePrimaryStats.totalUploadsSucceeded == 1
|
@@ -339,6 +348,7 @@ public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exce
|
339 | 348 | }
|
340 | 349 | }
|
341 | 350 |
|
| 351 | + @TestLogging(reason = "Getting trace logs from remote store package", value = "org.opensearch.remotestore:TRACE") |
342 | 352 | public void testDownloadStatsCorrectnessSinglePrimaryMultipleReplicaShards() throws Exception {
|
343 | 353 | setup();
|
344 | 354 | // Scenario:
|
@@ -371,6 +381,13 @@ public void testDownloadStatsCorrectnessSinglePrimaryMultipleReplicaShards() thr
|
371 | 381 | .collect(Collectors.toList())
|
372 | 382 | .get(0)
|
373 | 383 | .getSegmentStats();
|
| 384 | + logger.info( |
| 385 | + "Zero state primary stats: {}ms refresh time lag, {}b bytes lag, {}b upload bytes started and {}b upload bytes failed.", |
| 386 | + zeroStatePrimaryStats.refreshTimeLagMs, |
| 387 | + zeroStatePrimaryStats.bytesLag, |
| 388 | + zeroStatePrimaryStats.uploadBytesStarted, |
| 389 | + zeroStatePrimaryStats.uploadBytesFailed |
| 390 | + ); |
374 | 391 | assertTrue(
|
375 | 392 | zeroStatePrimaryStats.totalUploadsStarted == zeroStatePrimaryStats.totalUploadsSucceeded
|
376 | 393 | && zeroStatePrimaryStats.totalUploadsSucceeded == 1
|
|
0 commit comments