Remove numerical offset usage #9326
Annotations
4 errors
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2748)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 932 interactions with this mock:
logNotifier.started(
"TestTopic_dbd44684a8_610c2e4_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(I
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2748)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 932 interactions with this mock:
logNotifier.started(
"TestTopic_dbd44684a8_610c2e4_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_dbd44684a8_610c2e4_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(I
|
Loading