Skip to content

Commit 6f761b5

Browse files
committed
[controller] Skip ERRORed versions when producing snapshots to meta system store
1 parent 53adf35 commit 6f761b5

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7964,6 +7964,9 @@ void setUpMetaStoreAndMayProduceSnapshot(String clusterName, String regularStore
79647964
return;
79657965
}
79667966
for (Version version: versions) {
7967+
if (version.getStatus() == ERROR) {
7968+
continue;
7969+
}
79677970
int versionNumber = version.getNumber();
79687971
String topic = Version.composeKafkaTopic(regularStoreName, versionNumber);
79697972
int partitionCount = version.getPartitionCount();

0 commit comments

Comments
 (0)