[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370246#comment-16370246
]
ASF GitHub Bot commented on FLINK-8656:
---------------------------------------
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5487
After rescaling `SocketWindowWordCount`, the parallelism exposed by the
REST API remains unchanged.
Steps to reproduce:
Start netcat.
```
nc -l 9001
```
Submit job with parallelism 1.
```
bin/flink run -p1 examples/streaming/SocketWindowWordCount.jar --port 9001
```
Re-scale to parallelism 10.
```
bin/flink modify 4f9e368f973be3780b75e49e50168fcc -p 10
```
Check parallelism:
```
curl localhost:9065/jobs/4f9e368f973be3780b75e49e50168fcc/config | jq .
{
"jid": "4f9e368f973be3780b75e49e50168fcc",
"name": "Socket Window WordCount",
"execution-config": {
"execution-mode": "PIPELINED",
"restart-strategy": "default",
"job-parallelism": 1,
"object-reuse-mode": false,
"user-config": {}
}
}
```
> Add CLI command for rescaling
> -----------------------------
>
> Key: FLINK-8656
> URL: https://issues.apache.org/jira/browse/FLINK-8656
> Project: Flink
> Issue Type: New Feature
> Components: Client
> Affects Versions: 1.5.0
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Priority: Major
> Labels: flip-6
> Fix For: 1.5.0
>
>
> The REST rescaling calls should be made accessible via the {{CliFrontend}}.
> In order to do that I propose to add a {{modify}} command to the
> {{CliFrontend}} to which we can pass a new parallelism.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
