We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d69180f commit 787c45cCopy full SHA for 787c45c
clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java
@@ -2368,7 +2368,7 @@ protected void processCommonConsumerAction(ConsumerAction consumerAction) throws
2368
* {@link #kafkaDataValidationService}, we would like to drain all the buffered messages before cleaning up those
2369
* two variables to avoid the race condition.
2370
*/
2371
- if (consumerAction.isHelixTriggeredAction()) {
+ if (isDaVinciClient() || consumerAction.isHelixTriggeredAction()) {
2372
partitionConsumptionStateMap.remove(partition);
2373
LOGGER.info(
2374
"Removing tracking of replica: {} from storage utilization manager as this UNSUBSCRIBE is helix triggered action",
0 commit comments