Skip to content

Commit 0716022

Browse files
Handle IndexBuildInProgress exception in InboundSink
1 parent 9eb18a6 commit 0716022

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

src/java/org/apache/cassandra/net/InboundSink.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
2323
import java.util.function.Predicate;
2424

25+
import org.apache.cassandra.index.IndexBuildInProgressException;
2526
import org.apache.cassandra.index.sai.utils.AbortedOperationException;
2627
import org.slf4j.LoggerFactory;
2728

@@ -105,12 +106,20 @@ public void accept(Message<?> message)
105106
if (t instanceof AbortedOperationException)
106107
return;
107108

108-
if (t instanceof TombstoneOverwhelmingException || t instanceof IndexNotAvailableException)
109+
if (t instanceof TombstoneOverwhelmingException ||
110+
t instanceof IndexNotAvailableException ||
111+
t instanceof IndexBuildInProgressException)
112+
{
109113
noSpamLogger.error(t.getMessage());
114+
}
110115
else if (t instanceof RuntimeException)
116+
{
111117
throw (RuntimeException) t;
118+
}
112119
else
120+
{
113121
throw new RuntimeException(t);
122+
}
114123
}
115124
}
116125

0 commit comments

Comments
 (0)