flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [2/2] flink git commit: [FLINK-7135] [flip-6] Pass in proper configuration to Dispatcher component
Date Wed, 26 Jul 2017 16:28:29 GMT
[FLINK-7135] [flip-6] Pass in proper configuration to Dispatcher component

This closes #4286.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e19a0da
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e19a0da
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5e19a0da

Branch: refs/heads/master
Commit: 5e19a0da63d578dd0638cba9b112076eed530fa8
Parents: e08ebce
Author: Till Rohrmann <trohrmann@apache.org>
Authored: Wed Jul 26 12:02:19 2017 +0200
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Wed Jul 26 18:03:17 2017 +0200

----------------------------------------------------------------------
 .../apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/5e19a0da/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java
index 02a5e4a..4c7df1b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java
@@ -60,6 +60,7 @@ public abstract class SessionClusterEntrypoint extends ClusterEntrypoint
{
 			this);
 
 		dispatcher = createDispatcher(
+			configuration,
 			rpcService,
 			highAvailabilityServices,
 			blobServer,
@@ -106,6 +107,7 @@ public abstract class SessionClusterEntrypoint extends ClusterEntrypoint
{
 	}
 
 	protected Dispatcher createDispatcher(
+		Configuration configuration,
 		RpcService rpcService,
 		HighAvailabilityServices highAvailabilityServices,
 		BlobServer blobServer,
@@ -117,6 +119,7 @@ public abstract class SessionClusterEntrypoint extends ClusterEntrypoint
{
 		return new StandaloneDispatcher(
 			rpcService,
 			Dispatcher.DISPATCHER_NAME,
+			configuration,
 			highAvailabilityServices,
 			blobServer,
 			heartbeatServices,


Mime
View raw message