[7/7] flink git commit: [FLINK-8656] [flip6] Add modify CLI command to rescale Flink jobs

2018-02-23 Thread trohrmann
[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

[4/7] flink git commit: [FLINK-8629] [flip6] Allow JobMaster to rescale jobs

2018-02-23 Thread trohrmann
[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

[2/7] flink git commit: [FLINK-8633] [flip6] Expose rescaling of jobs via the Dispatcher

2018-02-23 Thread trohrmann
[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

[1/7] flink git commit: [hotfix] Fix checkstyle violations in ExecutionGraph

2018-02-23 Thread trohrmann
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/

[3/7] flink git commit: [FLINK-8627] Introduce new JobStatus#SUSPENDING to ExecutionGraph

2018-02-23 Thread trohrmann
[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

[5/7] flink git commit: [FLINK-8634] [rest] Introduce job rescaling REST handler

2018-02-23 Thread trohrmann
[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

[6/7] flink git commit: [FLINK-8635] [rest] Register rescaling handlers at web endpoint

2018-02-23 Thread trohrmann
[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

flink git commit: [FLINK-8679][State Backends] Ensure that RocksDBKeyedBackend.getKeys() filters keys by namespace

2018-02-23 Thread srichter
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

flink git commit: [FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState in Kinesis connector.

2018-02-23 Thread tzulitai
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

flink git commit: [FLINK-8754][flip6] Make TaskManagerInfo implement Serializable

2018-02-23 Thread trohrmann
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

flink git commit: [hotfix] [formats] Dependency and code clean-up

2018-02-23 Thread twalthr
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

flink git commit: [hotfix] [sql-client] Use hard-coded Scala version

2018-02-23 Thread twalthr
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

flink-web git commit: [hotfix] Update quickstarts to Flink 1.4.1

2018-02-23 Thread twalthr
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.

flink git commit: [hotfix] Update docs version to Flink 1.4.1

2018-02-23 Thread twalthr
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