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 d005b47 commit ab06138
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -186,12 +186,13 @@ public Promise<ConnectorInfo, RuntimeException> findConnectorInfoAsync(
final Pair<ConnectorKeyRange, PromiseImpl<ConnectorInfo, RuntimeException>> cacheEntry =
Pair.of(keyRange, PromiseImpl.<ConnectorInfo, RuntimeException> create());

rangePromiseCacheList.add(cacheEntry);
cacheEntry.getValue().thenOnResultOrException(new Runnable() {
public void run() {
rangePromiseCacheList.remove(cacheEntry);
}
});
rangePromiseCacheList.add(cacheEntry);


for (Map.Entry<ConnectorKey, ConnectorEntry<V>> entry : managedConnectorInfos
.entrySet()) {
Expand Down

0 comments on commit ab06138

Please sign in to comment.