[all] Include PubSubMessageHeaders size in ImmutablePubSubMessage heap size estimation #9164
Annotations
10 errors
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_483d566992_6b04c4c3_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 1042 interactions with this mock:
logNotifier.started(
"TestTopic_483d566992_6b04c4c3_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_483d566992_6b04c4c3_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$r
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_83684d5102_5a621e8b_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 818 interactions with this mock:
logNotifier.started(
"TestTopic_83684d5102_5a621e8b_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_83684d5102_5a621e8b_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 941 interactions with this mock:
logNotifier.started(
"TestTopic_4d48c36fc8_53759edd_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d48c36fc8_53759edd_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 1097 interactions with this mock:
logNotifier.started(
"TestTopic_9833d28792_6a5d5b6_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_9833d28792_6a5d5b6_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_846172f774_e437eada_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 710 interactions with this mock:
logNotifier.started(
"TestTopic_846172f774_e437eada_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_846172f774_e437eada_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 908 interactions with this mock:
logNotifier.started(
"TestTopic_4d9032473b_79fe78fe_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4d9032473b_79fe78fe_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 1062 interactions with this mock:
logNotifier.started(
"TestTopic_4ae486592c_df0b8b65_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:204)
logNotifier.progress(
"TestTopic_4ae486592c_df0b8b65_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$r
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L353
java.lang.AssertionError: expected [true] but found [false]
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L497
com.linkedin.venice.exceptions.VeniceException: Subscribe to new topic:_78908715db_6ed0865b_v1 is not successful, error: java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException
|
Loading