fix NPE

Apache9 · Apache9 · commit e0cd899f71ee · 2024-11-12T22:32:53.000+08:00
diff --git a/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutput.java b/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutput.java
@@ -387,7 +387,7 @@ private void setupReceiver(int timeoutMs) {
     this.state = State.STREAMING;
     setupReceiver(conf.getInt(DFS_CLIENT_SOCKET_TIMEOUT_KEY, READ_TIMEOUT));
     this.streamSlowMonitor = streamSlowMonitor;
-    this.dummyStream = FanOutOneBlockAsyncDFSOutputHelper.createDummyDFSOutputStream(null, client,
+    this.dummyStream = FanOutOneBlockAsyncDFSOutputHelper.createDummyDFSOutputStream(this, client,
       src, stat, createFlags, summer);
   }
 

Original file line number	Diff line number	Diff line change
`@@ -387,7 +387,7 @@ private void setupReceiver(int timeoutMs) {`
`387`	`387`	`this.state = State.STREAMING;`
`388`	`388`	`setupReceiver(conf.getInt(DFS_CLIENT_SOCKET_TIMEOUT_KEY, READ_TIMEOUT));`
`389`	`389`	`this.streamSlowMonitor = streamSlowMonitor;`
`390`		`- this.dummyStream = FanOutOneBlockAsyncDFSOutputHelper.createDummyDFSOutputStream(null, client,`
	`390`	`+ this.dummyStream = FanOutOneBlockAsyncDFSOutputHelper.createDummyDFSOutputStream(this, client,`
`391`	`391`	`src, stat, createFlags, summer);`
`392`	`392`	`}`
`393`	`393`