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": {}
      }
    }
    ```


---

Reply via email to