[controller] AdminConsumptionTask fix around timed out or cancelled AdminExecutionTasks #3993
Annotations
4 errors and 1 warning
|
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_57f22aeac3_2de2a47_v1",
1,
LongEqualOrGreaterThanMatcher(lowerBound=3),
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:26)
However, there were exactly 4 interactions with this mock:
logNotifier.started(
"TestTopic_57f22aeac3_2de2a47_v1",
2
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_57f22aeac3_2de2a47_v1",
2,
3L
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:205)
logNotifier.error(
"TestTopic_57f22aeac3_2de2a47_v1",
2,
"fatal data validation problem for replica: TestTopic_57f22aeac3_2de2a47_v1-2. Incoming record topic-partition: TestTopic_57f22aeac3_2de2a47_v1-2 offset: 4. Consumption will be halted.",
com.linkedin.venice.exceptions.validation.CorruptDataException: CORRUPT data detected for producer GUID: fc7678acc5804e3f97ea89fc00919631; message type: CONTROL_MESSAGE (END_OF_SEGMENT); partition: 2; previous successful offset (in same segment): 3; incoming offset: 4; previous segment: 0; incoming segment: 0; previous sequence number: 2; incoming sequence number: 2; consumer record timestamp: 1736995821246 (Thu Jan 16 02:50:21 UTC 2025); producer timestamp: 1736995821224 (Thu Jan 16 02:50:21 UTC 2025); leader metadata's upstream offset: -1; leader metadata's host name: fv-az1680-739; aggregates: {}; debugInfo: {JDK major version: 8, path: /home/runner/work/venice/venice/clients/da-vinci-client, host: fv-az1680-739, pid: 2326, user: runner}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportError$18(IngestionNotificationDispatcher.java:305)
logNotifier.started(
"TestTopic_57f22aeac3_2de2a47_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L133
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
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_57f22aeac3_2de2a47_v1",
1,
LongEqualOrGreaterThanMatcher(lowerBound=3),
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:26)
However, there were exactly 4 interactions with this mock:
logNotifier.started(
"TestTopic_57f22aeac3_2de2a47_v1",
2
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_57f22aeac3_2de2a47_v1",
2,
3L
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:205)
logNotifier.error(
"TestTopic_57f22aeac3_2de2a47_v1",
2,
"fatal data validation problem for replica: TestTopic_57f22aeac3_2de2a47_v1-2. Incoming record topic-partition: TestTopic_57f22aeac3_2de2a47_v1-2 offset: 4. Consumption will be halted.",
com.linkedin.venice.exceptions.validation.CorruptDataException: CORRUPT data detected for producer GUID: fc7678acc5804e3f97ea89fc00919631; message type: CONTROL_MESSAGE (END_OF_SEGMENT); partition: 2; previous successful offset (in same segment): 3; incoming offset: 4; previous segment: 0; incoming segment: 0; previous sequence number: 2; incoming sequence number: 2; consumer record timestamp: 1736995821246 (Thu Jan 16 02:50:21 UTC 2025); producer timestamp: 1736995821224 (Thu Jan 16 02:50:21 UTC 2025); leader metadata's upstream offset: -1; leader metadata's host name: fv-az1680-739; aggregates: {}; debugInfo: {JDK major version: 8, path: /home/runner/work/venice/venice/clients/da-vinci-client, host: fv-az1680-739, pid: 2326, user: runner}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportError$18(IngestionNotificationDispatcher.java:305)
logNotifier.started(
"TestTopic_57f22aeac3_2de2a47_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L133
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|
Loading