[controller] Add OTel metrics to DeferredVersionSwapStats #10439
m-nagarajanVeniceCI-StaticAnalysisAndUnitTests.yml
on: pull_request
Matrix: Clients / UT & CodeCov
Matrix: Controller / UT & CodeCov
Matrix: Integrations / UT & CodeCov
Matrix: Internal / UT & CodeCov
Matrix: Router / UT & CodeCov
Matrix: Server / UT & CodeCov
Matrix: StaticAnalysis
ValidateGradleWrapper
13s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
16 errors
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2600045512; memoryAllocatedAfterInstantiations: 2561908168; memoryAllocatedByInstantiations: -38137344; 3 attempts left.
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2600045512; memoryAllocatedAfterInstantiations: 2561908168; memoryAllocatedByInstantiations: -38137344; 3 attempts left.
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResubscribeAfterRoleChange:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted *at least* 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:783)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResubscribeAfterRoleChange:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted *at least* 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:783)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1764)
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2842)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [InMemoryPubSubPosition{0}] but found [InMemoryPubSubPosition{2}]
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2842)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [InMemoryPubSubPosition{0}] but found [InMemoryPubSubPosition{2}]
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
928 KB |
sha256:b02fd0d5d67187839c4115620cf9e9b095a023fdcd015c721fa3e229907501c1
|
|
|
clients-jdk11
|
3.24 MB |
sha256:f6870c76b9bb089b0020f836573ced4e2f04c26491caaca4c1bd7fc07fbdf165
|
|
|
clients-jdk17
|
3.24 MB |
sha256:e0526dab93f6c9929ab462f06ce7c84f8e543bc833a71c1e7d5a86f67e6d7258
|
|
|
clients-jdk8
|
3.2 MB |
sha256:3f5314be1490e4f8d9723f4c96172e75b5fd28fb58083b8b4ae335ecaa256769
|
|
|
controller-jdk11
|
2.04 MB |
sha256:c0d661ea7dfa5a90b813f54158d2dfedae9d0ceea98f23ece45098bbeea05ae6
|
|
|
controller-jdk17
|
2.03 MB |
sha256:83346237b72548e470ddc02fadfc41d04a691a57acb7126d18568cd6b8b4ae2b
|
|
|
controller-jdk8
|
2.02 MB |
sha256:a9e0d05497eba20afc8315e7718757b2ccb956025871155b1672e41b96fd55c7
|
|
|
integrations-jdk11
|
557 KB |
sha256:6cd7fe3432c5acef2ec3e5e4163db292bc56cd7316dca0306530b4b572c6d668
|
|
|
integrations-jdk17
|
561 KB |
sha256:212b81ee6b911e456783d702e185b51016052141e34e0fb3d0997a10ec191135
|
|
|
integrations-jdk8
|
543 KB |
sha256:b0483b091c871efc24d8050793b9329a9dcebf6aec0e266bafe927d961fbc7a7
|
|
|
internal-jdk11
|
4.33 MB |
sha256:018e770f0350e4d9ea10d8699cc4a76182428db7541d57ebd5a0b01864c03dfd
|
|
|
internal-jdk17
|
4.35 MB |
sha256:725a769dc1257c674d2c2d6bf82d6e7e32f5910722f3a917d486e3a853eae8f8
|
|
|
internal-jdk8
|
4.32 MB |
sha256:00e06bc0ab6af3ca6458e08b07695e81a5bbbe2d3b4023517944da8bad1c3228
|
|
|
router-jdk11
|
763 KB |
sha256:e4c804c7dacdf608dbbd085af7314969ae6feb7cfe957302f4126d0708f20769
|
|
|
router-jdk17
|
773 KB |
sha256:449773e12c3d4eac9d391fad40f962f2e66aa319642c1a33c0dae1eb46f9b30c
|
|
|
router-jdk8
|
756 KB |
sha256:e9f40ddf6e6ab3cd0f7d82d13861a6100e52230d12c731f9f4cadde6d4e8cb16
|
|
|
server-jdk11
|
11.1 MB |
sha256:03da52b248f01d525b1f3b8785c73b670fd1481227f16b698b63d187f69a7f02
|
|
|
server-jdk17
|
11.2 MB |
sha256:1591a6741208bfcd09f6596b81730df1388d2283f86fa688c2084c6a85f0aaf8
|
|
|
server-jdk8
|
10.8 MB |
sha256:d0bd2d4be59dccb8f777616300c6d8237bf019bae61b88344f00ea79e8d30b7e
|
|