We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b403181 commit 544e04fCopy full SHA for 544e04f
server/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteFetch.java
@@ -163,7 +163,8 @@ public void onComplete() {
163
164
CompletableFuture<RemoteLogReadResult> remoteFetchResult = remoteFetchResults.get(tp);
165
if (remoteFetchInfos.containsKey(tp)
166
- && remoteFetchResult.isDone() && result.error() == Errors.NONE
+ && remoteFetchResult.isDone()
167
+ && result.error() == Errors.NONE
168
&& result.info().delayedRemoteStorageFetch.isPresent()) {
169
170
if (remoteFetchResult.get().error().isPresent()) {
0 commit comments