Skip to content

add more ut

Sign in for the full log view
GitHub Actions / JUnit Test Report failed Nov 21, 2024 in 0s

6778 tests run, 6762 passed, 0 skipped, 16 failed.

Annotations

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6754ad51
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@5a229b96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6b221577
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@249aeb86
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=6, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6754ad51
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@5a229b96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6b221577
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@249aeb86
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=6, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@3429676f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@32bf0026
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@684f26c4
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@9ee6fd1
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@3429676f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@32bf0026
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@684f26c4
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@9ee6fd1
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@66f6ae9a
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@66f6ae9a
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithTWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false) 

org.mockito.exceptions.verification.TooFewActualInvocations: 
hostLevelIngestionStats.recordTotalBytesConsumed(
    <any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2534)
Raw output 
org.mockito.exceptions.verification.TooFewActualInvocations: 
hostLevelIngestionStats.recordTotalBytesConsumed(
    <any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2534)

	at app//com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testRecordLevelMetricForCurrentVersion$35(StoreIngestionTaskTest.java:1389)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:733)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testRecordLevelMetricForCurrentVersion(StoreIngestionTaskTest.java:1382)

Check failure on line 123 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats 

java.lang.AssertionError: expected [1000.0] but found [0.0]
Raw output 
java.lang.AssertionError: expected [1000.0] but found [0.0]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertEqualsImpl(Assert.java:137)
	at org.testng.Assert.assertEquals(Assert.java:118)
	at org.testng.Assert.assertEquals(Assert.java:442)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$4(NativeMetadataRepositoryTest.java:126)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:240)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:225)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:217)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:123)

Check failure on line 65 in clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java

See this annotation in the file changed.

@github-actions 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 app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.$jacocoInit(DatePatternConverter.java)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
	at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
	at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
	at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
	at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
	at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
	at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
	at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
	at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
	at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
	at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
	at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
	at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
	at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6754ad51
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@5a229b96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6b221577
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@249aeb86
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=6, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6754ad51
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@5a229b96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@6b221577
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_741ebadc76_a26eff6d_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$980/0x0000000800821040@249aeb86
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_741ebadc76_a26eff6d_v1",
    2,
    OffsetRecord{localVersionTopicOffset=6, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155537967, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@3429676f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@32bf0026
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@684f26c4
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@9ee6fd1
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85002c61fc_a5691add_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@3429676f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@32bf0026
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610483, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85002c61fc_a5691add_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155610484, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@684f26c4
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85002c61fc_a5691add_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8040@9ee6fd1
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1576)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638101, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$539/0x0000000800692840@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8b6f1cde2d_2be9bdc6_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155638102, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@66f6ae9a
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666106, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155666107, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_91f45a3f4d_44d54fa9_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$543/0x00000008006a8440@66f6ae9a
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF) 

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
Raw output 
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@4848ec67
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@1183e952
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693766, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@6fc42eff
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_9864f5f3d2_105ca834_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$541/0x0000000800692c40@69525c03
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_9864f5f3d2_105ca834_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732155693767, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)

	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$44(StoreIngestionTaskTest.java:1578)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:668)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:632)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1554)

Check failure on line 1 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

SITWithTWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false) 

org.mockito.exceptions.verification.TooFewActualInvocations: 
hostLevelIngestionStats.recordTotalBytesConsumed(
    <any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2534)
Raw output 
org.mockito.exceptions.verification.TooFewActualInvocations: 
hostLevelIngestionStats.recordTotalBytesConsumed(
    <any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2534)

	at app//com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:492)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testRecordLevelMetricForCurrentVersion$35(StoreIngestionTaskTest.java:1389)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:861)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:759)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:733)
	at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testRecordLevelMetricForCurrentVersion(StoreIngestionTaskTest.java:1382)

Check failure on line 123 in clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats 

java.lang.AssertionError: expected [1000.0] but found [0.0]
Raw output 
java.lang.AssertionError: expected [1000.0] but found [0.0]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertEqualsImpl(Assert.java:137)
	at org.testng.Assert.assertEquals(Assert.java:118)
	at org.testng.Assert.assertEquals(Assert.java:442)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$4(NativeMetadataRepositoryTest.java:126)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:240)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:225)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:217)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:123)

Check failure on line 65 in clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java

See this annotation in the file changed.

@github-actions 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 app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.$jacocoInit(DatePatternConverter.java)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
	at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
	at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
	at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
	at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
	at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
	at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
	at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
	at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
	at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
	at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
	at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
	at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
	at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
	at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
	at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
	at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
	at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
	at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
	at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
	at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
View more details on GitHub Actions