[FLINK-9769][rest] Clear FileUpload attribute after access

This closes #6270.

[FLINK-9769][rest] Clear FileUpload attribute after access
This closes #6270.
ac543210 · zentol · b346961a · ac543210
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java ...java/org/apache/flink/runtime/rest/FileUploadHandler.java +1 -1

未找到文件。
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
@@ -188,7 +188,7 @@ public class FileUploadHandler extends SimpleChannelInboundHandler<HttpObject> {
 	}

 	public static FileUploads getMultipartFileUploads(ChannelHandlerContext ctx) {
-		return Optional.ofNullable(ctx.channel().attr(UPLOADED_FILES).get())
+		return Optional.ofNullable(ctx.channel().attr(UPLOADED_FILES).getAndRemove())
 			.orElse(FileUploads.EMPTY);
 	}
 }