| commit | acb2ea80537a8cd5ff7644c2ef1b8c2336e3d0a6 | [log] [tgz] |
|---|---|---|
| author | zentol <chesnay@apache.org> | Thu Jul 05 23:28:47 2018 +0200 |
| committer | zentol <chesnay@apache.org> | Fri Jul 06 12:08:55 2018 +0200 |
| tree | c948ad2518afe77dbe78dfc5dbb23bf30620e6bc | |
| parent | 7c84214701188c29b970825f157011de4a906f2f [diff] |
[FLINK-9769][rest] Clear FileUpload attribute after access This closes #6270.
diff --git 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 index aa87cc5..28c2849 100644 --- 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
@@ -199,7 +199,7 @@ } 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); } }