[controller] use new getRealTimeTopicName API - part-2 (#1386) #786
GitHub Actions / JUnit Test Report
failed
Dec 12, 2024 in 0s
6822 tests run, 6818 passed, 0 skipped, 4 failed.
Annotations
github-actions / JUnit Test Report
SITWithTWiseAndBufferAfterLeaderTest.testResubscribeAfterRoleChange
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
Raw output
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testResubscribeAfterRoleChange$107(StoreIngestionTaskTest.java:4092)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:885)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:778)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testResubscribeAfterRoleChange(StoreIngestionTaskTest.java:4114)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at [email protected]/jdk.internal.misc.Unsafe.unpark(Native Method)
at [email protected]/java.util.concurrent.locks.LockSupport.unpark(LockSupport.java:160)
at [email protected]/java.util.concurrent.locks.AbstractQueuedSynchronizer.unparkSuccessor(AbstractQueuedSynchronizer.java:709)
at [email protected]/java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1305)
at [email protected]/java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:439)
github-actions / JUnit Test Report
SITWithTWiseAndBufferAfterLeaderTest.testResubscribeAfterRoleChange
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
Raw output
org.mockito.exceptions.verification.TooFewActualInvocations:
activeActiveStoreIngestionTask.resubscribeForAllPartitions();
Wanted 4 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
But was 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1543)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:616)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testResubscribeAfterRoleChange$107(StoreIngestionTaskTest.java:4092)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:885)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:778)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testResubscribeAfterRoleChange(StoreIngestionTaskTest.java:4114)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at [email protected]/jdk.internal.misc.Unsafe.unpark(Native Method)
at [email protected]/java.util.concurrent.locks.LockSupport.unpark(LockSupport.java:160)
at [email protected]/java.util.concurrent.locks.AbstractQueuedSynchronizer.unparkSuccessor(AbstractQueuedSynchronizer.java:709)
at [email protected]/java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1305)
at [email protected]/java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:439)
Loading