[hotfix] Make RestServerEndpoint#uploadDir protected

apache · Mar 21, 2018 · 659479f · 659479f
1 parent 719abe3
commit 659479f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
@@ -42,7 +42,6 @@
 import org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler;
 
 import java.io.IOException;
-import java.nio.file.Path;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
@@ -52,8 +51,6 @@
  */
 public class DispatcherRestEndpoint extends WebMonitorEndpoint<DispatcherGateway> {
 
-	private final Path uploadDir;
-
 	private WebMonitorExtension webSubmissionExtension;
 
 	public DispatcherRestEndpoint(
@@ -80,7 +77,6 @@ public DispatcherRestEndpoint(
 			leaderElectionService,
 			fatalErrorHandler);
 
-		uploadDir = endpointConfiguration.getUploadDir();
 		webSubmissionExtension = WebMonitorExtension.empty();
 	}
 

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java
@@ -79,8 +79,9 @@ public abstract class RestServerEndpoint implements AutoCloseableAsync {
 	private final String restBindAddress;
 	private final int restBindPort;
 	private final SSLEngine sslEngine;
-	private final Path uploadDir;
 	private final int maxContentLength;
+
+	protected final Path uploadDir;
 	protected final Map<String, String> responseHeaders;
 
 	private final CompletableFuture<Void> terminationFuture;