File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
clients/da-vinci-client/src/main/java/com/linkedin/davinci Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -564,12 +564,12 @@ public SubscriptionBasedReadOnlyStoreRepository getStoreRepository() {
564564
565565 /**
566566 * Resolves and returns the store object for the given store name.
567- * For user system stores, this returns the SystemStoreAttributes from the parent user store.
568- * For regular stores and shared system stores, this returns the Store object directly.
567+ * For user system stores, it finds the RT name from the SystemStoreAttributes of the parent user store.
568+ * For regular user stores and top level system stores, it finds the RT name from the Store object directly.
569569 */
570570 private String getRealTimeTopicName (String storeName ) {
571571 VeniceSystemStoreType systemStoreType = VeniceSystemStoreType .getSystemStoreType (storeName );
572- if (systemStoreType != null ) {
572+ if (systemStoreType != null && systemStoreType . isStoreZkShared () ) {
573573 // it is a user system store
574574 String userStoreName = VeniceSystemStoreType .extractUserStoreName (storeName );
575575 Store userStore = storeRepository .getStore (userStoreName );
You can’t perform that action at this time.
0 commit comments