[controller][common][protocol] Add store-level ULE config for RT topics #449

Annotations

11 errors

clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5436b6f27d_58ae720d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5436b6f27d_58ae720d_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 504482769 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 504482769 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5436b6f27d_58ae720d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770952191828}, Mock for Store, hashCode: 504482769 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5436b6f27d_58ae720d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770952191828} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5436b6f27d_58ae720d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce

clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/RequestBasedMetaRepositoryTest.java#L70