this.listener

dnhatn · dnhatn · commit 81550f34d971 · 2026-01-06T08:02:52.000-08:00
diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java
@@ -262,7 +262,7 @@ public void addRemoteSink(
                 fetchExecutor.execute(new ActionRunnable<>(refs.acquire()) {
                     @Override
                     protected void doRun() {
-                        var fetcher = new RemoteSinkFetcher(remoteSink, failFast, onPageFetched, listener);
+                        var fetcher = new RemoteSinkFetcher(remoteSink, failFast, onPageFetched, this.listener);
                         fetcher.fetchPage();
                     }
 
@@ -272,7 +272,7 @@ public void onFailure(Exception e) {
                             aborted = true;
                         }
                         buffer.waitForReading().listener().onResponse(null); // resume the Driver if it is being blocked on reading
-                        remoteSink.close(listener);
+                        remoteSink.close(this.listener);
                     }
                 });
             }

Original file line number	Diff line number	Diff line change
`@@ -262,7 +262,7 @@ public void addRemoteSink(`
`262`	`262`	`fetchExecutor.execute(new ActionRunnable<>(refs.acquire()) {`
`263`	`263`	`@Override`
`264`	`264`	`protected void doRun() {`
`265`		`- var fetcher = new RemoteSinkFetcher(remoteSink, failFast, onPageFetched, listener);`
	`265`	`+ var fetcher = new RemoteSinkFetcher(remoteSink, failFast, onPageFetched, this.listener);`
`266`	`266`	`fetcher.fetchPage();`
`267`	`267`	`}`
`268`	`268`
`@@ -272,7 +272,7 @@ public void onFailure(Exception e) {`
`272`	`272`	`aborted = true;`
`273`	`273`	`}`
`274`	`274`	`buffer.waitForReading().listener().onResponse(null); // resume the Driver if it is being blocked on reading`
`275`		`- remoteSink.close(listener);`
	`275`	`+ remoteSink.close(this.listener);`
`276`	`276`	`}`
`277`	`277`	`});`
`278`	`278`	`}`