Repository: flink
Updated Branches:
refs/heads/master 4a8e94403 -> 28ff5a3c9
[hotfix] Fix restart strategy class loading by using not lower cased class name
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28ff5a3c
Tree: ht
Repository: flink
Updated Branches:
refs/heads/flip-6 3cda59339 -> 2a61e74b9
[FLINK-4580] [rpc] Report rpc invocation exceptions to the caller
This closes #2526.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2a61e74b
Tr
Repository: flink
Updated Branches:
refs/heads/flip-6 2a61e74b9 -> 93775cef6
[FLINK-4687] [rpc] Add getAddress to RpcService
This closes #2551.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93775cef
Tree: http://git-wip
[FLINK-4690] Replace SlotAllocationFuture with flink's own future
This closes #2552.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b88f1a7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b88f1a7
Diff: http://git-w
[FLINK-4361] Introduce Flink's own future abstraction
Flink's future abstraction whose API is similar to Java 8's CompletableFuture.
That's in order to ease a future transition to this class once we ditch Java 7.
The current set of operations comprises:
- isDone to check the completion of the fut
Repository: flink
Updated Branches:
refs/heads/master 6e123d287 -> 84672c22f
[FLINK-4690] Use direct executor to run slot allocation future handler
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84672c22
Tree: http://git-
Repository: flink
Updated Branches:
refs/heads/master 84672c22f -> f1b5b35f5
[FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate
MetricRegistry parameters
In order to decouple the MetricRegistry object instantiation from the global
configuration
the MetricRegistryConfiguration
[hotfix] Remove unused imports from SlotRequestRegistered/Rejected and
ResourceSlot
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/078dacee
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/078dacee
Diff: http://git-wi
http://git-wip-us.apache.org/repos/asf/flink/blob/171cfd30/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/SlotManagerTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemana
[hotfix] Add self rpc gateway registration to TestingSerialRpcService
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ab566ebf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ab566ebf
Diff: http://git-wip-us.apache.org
[FLINK-4403] [rpc] Use relative classloader for proxies, rather than system
class loader.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8dedf1d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8dedf1d
Diff: http://
[FLINK-4516] leader election of resourcemanager
- add serial rpc service
- add a special rpcService implementation which directly executes the
asynchronous calls serially one by one, it is just for testcase
- Change ResourceManagerLeaderContender code and TestingSerialRpcService code
- override s
[hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails
fast when endpoint is unreachable.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/073f6089
Tree: http://git-wip-us.apache.org/repos/asf/flink/tre
[FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be
reusable
This closes #2520
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b955465f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b955465f
[FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages
This PR introduces an eager serialization for remote rpc invocation messages.
That way it is possible to check whether the message is serializable and
whether it exceeds the maximum allowed akka frame size. If either of these
cons
[FLINK-4580] [rpc] Report rpc invocation exceptions to the caller
This closes #2526.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb501fb4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb501fb4
Diff: http://git-w
[FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance
This commit extends the RpcCompletenessTest such that it can now check for
inherited
remote procedure calls. All methods defined at the RpcGateway are considered
native.
This means that they need no RpcEndpoint counterpa
[FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as
protected
Give main thread execution context into the
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/156f0ff5
[FLINK-4355] [cluster management] Implement TaskManager side of registration at
ResourceManager.
This closes #2353
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2738709c
Tree: http://git-wip-us.apache.org/repos/asf/flink/t
http://git-wip-us.apache.org/repos/asf/flink/blob/171cfd30/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskE
[FLINK-4535] rebase and refine
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ceac4831
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ceac4831
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ceac4831
Branch:
[FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members
This closes #2351
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/675bf2aa
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/675bf2aa
Diff:
[FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not
reachable
This PR introduces a RpcConnectionException which is thrown if the rpc endpoint
is not reachable when calling RpcService.connect.
This closes #2405.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Com
Repository: flink
Updated Branches:
refs/heads/flip-6 ed5c83dc2 -> b955465ff (forced update)
http://git-wip-us.apache.org/repos/asf/flink/blob/da8fae2e/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerGateway.java
--
http://git-wip-us.apache.org/repos/asf/flink/blob/171cfd30/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecut
[hotfix] fix ResourceManagerGateway
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c59c8b3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c59c8b3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7c59c8b3
Br
[FLINK-4687] [rpc] Add getAddress to RpcService
This closes #2551.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8419ec0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8419ec0
Diff: http://git-wip-us.apache.org/r
[FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies
This PR introduces a generic AkkaRpcActor which receives rpc calls as a
RpcInvocation message. The RpcInvocation message is generated by the
AkkaInvocationHandler which gets them from automatically generated Java Proxies.
Add document
[FLINK-4434] [rpc] Add a testing RPC service.
This closes #2394.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f73a935
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9f73a935
Diff: http://git-wip-us.apache.org/rep
[FLINK-4392] [rpc] Make RPC Service thread-safe
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d881403b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d881403b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/
[hotfix] Remove RecoveryMode from JobMaster
The recovery mode is not used any more by the latest CheckpointCoordinator.
All difference in recovery logic between high-availability and
non-high-availability
is encapsulated in the HighAvailabilityServices.
Project: http://git-wip-us.apache.org/re
[FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint
This closes #2360
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d31e6314
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d31e6314
Diff: http://git-wip-u
[FLINK-4537] rebase and refine
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2fbfe071
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2fbfe071
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2fbfe071
Branch:
http://git-wip-us.apache.org/repos/asf/flink/blob/103e44c1/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSeria
[FLINK-4346] [rpc] Add new RPC abstraction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da8fae2e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da8fae2e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/da8fa
[FLINK-4373] [cluster management] Introduce SlotID, AllocationID,
ResourceProfile
[FLINK-4373] [cluster management] address comments
This closes #2370.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d17afc1c
Tree: http://g
[FLINK-4537] [cluster management] ResourceManager registration with JobManager
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/deb80226
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/deb80226
Diff: http://git-wip-us.a
[FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job
submission & setting up the ExecutionGraph
This closes #2480
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d9c4814c
Tree: http://git-wip-us.apache.org/r
[FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of
the rpc package
The TaskExecutor, the JobMaster and the ResourceManager were still contained in
the rpc
package. With this commit, they will be moved out of this package. Now they are
contained
in dedicated packages o
http://git-wip-us.apache.org/repos/asf/flink/blob/171cfd30/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequest.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/
[FLINK-4355] [cluster management] Add tests for the TaskManager ->
ResourceManager registration.
This closes #2395.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a957cd7
Tree: http://git-wip-us.apache.org/repos/asf/flink/
[FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its
executor
This closes #2531.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6159f56a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6159f
[hotfix] [clustermgnt] Set pending registration properly in
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86f2fa31
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/86f2fa31
Dif
http://git-wip-us.apache.org/repos/asf/flink/blob/9e6ff60e/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpc
[FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol
- associates JobMasters with JobID instead of InstanceID
- adds TaskExecutorGateway to slot
- adds SlotManager as RM constructor parameter
- adds LeaderRetrievalListener to SlotManager to keep track of the leader id
- tests the inte
[FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started
This PR allows the AkkaRpcActor to stash messages until the corresponding
RcpEndpoint
has been started. When receiving a Processing.START message, the AkkaRpcActor
unstashes all messages and starts processing rpcs. When re
[FLINK-4363] Implement TaskManager basic startup of all components in java
This closes #2400
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75a68843
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/75a68843
Diff: http
[FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters
Adapt related components to the changes in HighAvailabilityServices
Add comments for getJobMasterElectionService in HighAvailabilityServices
This closes #2377.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
[FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction
This closes #2530.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/103e44c1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/103e44c1
Diff: ht
[FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's
main thread
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0d5b7b8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f0d5b7b8
Diff: http://
[FLINK-4414] [cluster] Add getAddress method to RpcGateway
The RpcGateway.getAddress method allows to retrieve the fully qualified address
of the
associated RpcEndpoint.
This closes #2392.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf
http://git-wip-us.apache.org/repos/asf/flink/blob/53287755/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/SlotManagerTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemana
[hotfix] [taskmanager] Fixes TaskManager component creation at startup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f9e2dc05
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f9e2dc05
Diff: http://git-wip-us.apache.or
[FLINK-4535] [cluster management] resourceManager process the registration from
TaskExecutor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e4957f8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0e4957f8
Diff: http
[hotfix] Add methods defined in the gateway to the ResourceManager and
TaskExecutor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a5a2b13
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a5a2b13
Diff: http://git-wi
[FLINK-4347][cluster management] Implement SlotManager core
This closes #2388
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/278f6092
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/278f6092
Diff: http://git-wip-us.a
http://git-wip-us.apache.org/repos/asf/flink/blob/171cfd30/flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/SlotManagerTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/clusterfram
Repository: flink
Updated Branches:
refs/heads/flip-6 b955465ff -> 5513fe61d
[FLINK-4505] [cluster mngt] Implement TaskManager component's startup
The TaskManagerRunner now contains the startup logic for the TaskManager's
components.
Project: http://git-wip-us.apache.org/repos/asf/flink/rep
[FLINK-4505] [cluster mngt] Separate TaskManager service configuration from
TaskManagerConfiguration; Implement TaskManagerRunner
Refactors the startup logic so that is easier to reuse.
This closes #2461.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apac
http://git-wip-us.apache.org/repos/asf/flink/blob/5513fe61/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerRunner.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Ta
Repository: flink
Updated Branches:
refs/heads/flip-6 387663094 -> cf1e875d7
[hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf1e875d
Tree: ht
[FLINK-4711] Let the Task trigger partition state requests and handle their
responses
This PR makes changes the partition state check in a way that the Task is now
responsible
for triggering the state check instead of the SingleInputGate. Furthermore, the
operation
returns a future containing t
Repository: flink
Updated Branches:
refs/heads/master 7758571ae -> 477d1c5d4
http://git-wip-us.apache.org/repos/asf/flink/blob/477d1c5d/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
---
Repository: flink
Updated Branches:
refs/heads/flip-6 cf1e875d7 -> 626e67276
[FLINK-4406] [cluster management] Implement job master registration at resource
manager
[FLINK-4406] [cluster management] Skip new connection if new resource manager's
address and leader id are both not changing
[F
Repository: flink
Updated Branches:
refs/heads/flip-6 626e67276 -> 96a5cb2dc
[FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper
[FLINK-4657] Implement a few rpc calls for JobMaster
[FLINK-4657][cluster management] Address review comments
[FLINK-4657][cluster management] Throw
[FLINK-4406] [cluster management] Implement job master registration at resource
manager
[FLINK-4406] [cluster management] Skip new connection if new resource manager's
address and leader id are both not changing
[FLINK-4406] [cluster management] Verify registration response with leader id
This
[FLINK-4505] [cluster mngt] Implement TaskManager component's startup
The TaskManagerRunner now contains the startup logic for the TaskManager's
components.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/60b2fb75
Tree: http
[FLINK-4355] [cluster management] Implement TaskManager side of registration at
ResourceManager.
This closes #2353
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24eab760
Tree: http://git-wip-us.apache.org/repos/asf/flink/t
[hotfix] [clustermgnt] Set pending registration properly in
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39a36994
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/39a36994
Dif
Repository: flink
Updated Branches:
refs/heads/flip-6 96a5cb2dc -> f7cfc1bb6 (forced update)
[FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's
main thread
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/fli
[FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job
submission & setting up the ExecutionGraph
This closes #2480
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9816484e
Tree: http://git-wip-us.apache.org/r
[FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper
[FLINK-4657] Implement a few rpc calls for JobMaster
[FLINK-4657][cluster management] Address review comments
[FLINK-4657][cluster management] Throw exception when error occurred when
request input split
Project: http://git-wi
[FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as
protected
Give main thread execution context into the
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e114d13b
http://git-wip-us.apache.org/repos/asf/flink/blob/2400f7dd/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskE
[FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses
This closes #2561
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be43f6ff
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be43f6ff
Diff:
[hotfix] Add methods defined in the gateway to the ResourceManager and
TaskExecutor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/125bda03
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/125bda03
Diff: http://git-wi
[FLINK-4580] [rpc] Report rpc invocation exceptions to the caller
This closes #2526.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf1dd48c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf1dd48c
Diff: http://git-w
http://git-wip-us.apache.org/repos/asf/flink/blob/e5894877/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/SlotManagerTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemana
[FLINK-4392] [rpc] Make RPC Service thread-safe
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29fadada
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29fadada
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/
[hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails
fast when endpoint is unreachable.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/18f26e0e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tre
[FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters
Adapt related components to the changes in HighAvailabilityServices
Add comments for getJobMasterElectionService in HighAvailabilityServices
This closes #2377.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
[hotfix] Add self rpc gateway registration to TestingSerialRpcService
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73618057
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/73618057
Diff: http://git-wip-us.apache.org
http://git-wip-us.apache.org/repos/asf/flink/blob/2400f7dd/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecut
[FLINK-4347][cluster management] Implement SlotManager core
This closes #2388
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c9f9d42
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c9f9d42
Diff: http://git-wip-us.a
[FLINK-4606] Integrate the new ResourceManager with the existed
FlinkResourceManager
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6bace895
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6bace895
Diff: http://git-
[FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of
the rpc package
The TaskExecutor, the JobMaster and the ResourceManager were still contained in
the rpc
package. With this commit, they will be moved out of this package. Now they are
contained
in dedicated packages o
[FLINK-4535] rebase and refine
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b051d7c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3b051d7c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3b051d7c
Branch:
[hotfix] Remove unused imports from SlotRequestRegistered/Rejected and
ResourceSlot
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9bd91a64
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9bd91a64
Diff: http://git-wi
[FLINK-4355] [cluster management] Add tests for the TaskManager ->
ResourceManager registration.
This closes #2395.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7aa4dba6
Tree: http://git-wip-us.apache.org/repos/asf/flink/
[FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol
- associates JobMasters with JobID instead of InstanceID
- adds TaskExecutorGateway to slot
- adds SlotManager as RM constructor parameter
- adds LeaderRetrievalListener to SlotManager to keep track of the leader id
- tests the inte
[hotfix] fix ResourceManagerGateway
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4fe734a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a4fe734a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a4fe734a
Br
http://git-wip-us.apache.org/repos/asf/flink/blob/f5ab959b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerRunner.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Ta
http://git-wip-us.apache.org/repos/asf/flink/blob/88a05f5b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSeria
[FLINK-4505] [cluster mngt] Separate TaskManager service configuration from
TaskManagerConfiguration; Implement TaskManagerRunner
Refactors the startup logic so that is easier to reuse.
This closes #2461.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apac
[FLINK-4687] [rpc] Add getAddress to RpcService
This closes #2551.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d9fcf4d0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d9fcf4d0
Diff: http://git-wip-us.apache.org/r
[FLINK-4414] [cluster] Add getAddress method to RpcGateway
The RpcGateway.getAddress method allows to retrieve the fully qualified address
of the
associated RpcEndpoint.
This closes #2392.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf
[FLINK-4606] integrate features of old ResourceManager
This closes #2540
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eebe2c38
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eebe2c38
Diff: http://git-wip-us.apache
http://git-wip-us.apache.org/repos/asf/flink/blob/2400f7dd/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/SlotManagerTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemana
[hotfix] [taskmanager] Fixes TaskManager component creation at startup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a17c106c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a17c106c
Diff: http://git-wip-us.apache.or
[FLINK-4537] [cluster management] ResourceManager registration with JobManager
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0501df5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f0501df5
Diff: http://git-wip-us.a
1 - 100 of 5116 matches
Mail list logo
