Skip to content

Commit

Permalink
Add build.yml fix range cache
Browse files Browse the repository at this point in the history
  • Loading branch information
vharseko committed Mar 13, 2024
1 parent 575ec2e commit 07bf8e1
Showing 1 changed file with 6 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -100,10 +100,12 @@ protected void doClose() {
}
managedConnectorInfos.clear();
for (Pair<ConnectorKeyRange, PromiseImpl<ConnectorInfo, RuntimeException>> entry : rangePromiseCacheList) {
entry.getValue()
.handleException(
new IllegalStateException(
"ManagedAsyncConnectorInfoManager is shutting down!"));
if (!entry.getValue().isDone()) {
entry.getValue()
.handleException(
new IllegalStateException(
"ManagedAsyncConnectorInfoManager is shutting down!"));
}
}
rangePromiseCacheList.clear();
}
Expand Down

0 comments on commit 07bf8e1

Please sign in to comment.