[FLINK-8656] [flip6] Add modify CLI command to rescale Flink jobs
Jobs can now be rescaled by calling flink modify -p .
Internally, the CliFrontend will send the corresponding REST call and poll
for status updates.
This closes #5487.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
C
[FLINK-8629] [flip6] Allow JobMaster to rescale jobs
This commit adds the functionality to rescale a job or parts of it to
the JobMaster. In order to rescale a job, the JobMaster does the following:
1. Take a savepoint
2. Create a rescaled ExecutionGraph from the JobGraph
3. Initialize it with the
[FLINK-8633] [flip6] Expose rescaling of jobs via the Dispatcher
This commit exposes the JobMaster#rescaleJob via the Dispatcher. This will
allow it to call this functionality from a REST handler.
This closes #5452.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-w
Repository: flink
Updated Branches:
refs/heads/master 519639c64 -> 0651876ae
[hotfix] Fix checkstyle violations in ExecutionGraph
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e8d6f397
Tree: http://git-wip-us.apache.org/
[FLINK-8627] Introduce new JobStatus#SUSPENDING to ExecutionGraph
The new JobStatus#SUSPENDING says that an ExecutionGraph has been suspended but
its
clean up has not been done yet. Only after all Executions have been canceled,
the
ExecutionGraph will enter the SUSPENDED state and complete the t
[FLINK-8634] [rest] Introduce job rescaling REST handler
Add rescaling REST handler as a sub class of the
AbstractAsynchronousOperationHandlers.
This closes #5451.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06acdc19
Tre
[FLINK-8635] [rest] Register rescaling handlers at web endpoint
This closes #5454.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e840979
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e840979
Diff: http://git-wip
Repository: flink
Updated Branches:
refs/heads/master 0651876ae -> eeac022f0
[FLINK-8679][State Backends] Ensure that RocksDBKeyedBackend.getKeys() filters
keys by namespace
This closes #5518.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master eeac022f0 -> e75481cc6
[FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState in
Kinesis connector.
This closes #5480.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master e75481cc6 -> 461d66eb4
[FLINK-8754][flip6] Make TaskManagerInfo implement Serializable
This closes #5566.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/461d66eb
Tree
Repository: flink
Updated Branches:
refs/heads/master 461d66eb4 -> 1b1c00286
[hotfix] [formats] Dependency and code clean-up
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1b1c0028
Tree: http://git-wip-us.apache.org/repos
Repository: flink
Updated Branches:
refs/heads/master 1b1c00286 -> af3ea8103
[hotfix] [sql-client] Use hard-coded Scala version
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af3ea810
Tree: http://git-wip-us.apache.org/re
Repository: flink-web
Updated Branches:
refs/heads/asf-site 6c1ec7b82 -> 155a1d0f6
[hotfix] Update quickstarts to Flink 1.4.1
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/155a1d0f
Tree: http://git-wip-us.apache.
Repository: flink
Updated Branches:
refs/heads/release-1.4 f06ec38f2 -> 0d89a1c9f
[hotfix] Update docs version to Flink 1.4.1
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0d89a1c9
Tree: http://git-wip-us.apache.org/repo
14 matches
Mail list logo