Skip to content

Commit da0b527

Browse files
authored
[hotfix] Add isClosed protect for LogFetcher#handleFetchLogException to avoid throw exception if channel close (#1107)
1 parent 7f691b4 commit da0b527

File tree

1 file changed

+4
-0
lines changed
  • fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log

1 file changed

+4
-0
lines changed

fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetcher.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -272,6 +272,10 @@ private void invalidTableOrPartitions(TableOrPartitions tableOrPartitions) {
272272
private void handleFetchLogException(
273273
int destination, TableOrPartitions tableOrPartitionsInFetchRequest, Throwable e) {
274274
try {
275+
if (isClosed) {
276+
return;
277+
}
278+
275279
LOG.error("Failed to fetch log from node {}", destination, e);
276280
// if is invalid metadata exception, we need to clear table bucket meta
277281
// to enable another round of log fetch to request new medata

0 commit comments

Comments
 (0)