Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6188

Some setParallelism() methods can't cope with default parallelism

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.2.1, 1.3.0
    • Fix Version/s: None
    • Component/s: DataStream API
    • Labels:
      None

      Description

      Recent changes done for FLINK-5808 move default parallelism manifestation from eager to lazy, that is, the parallelism of operations that don't have an explicit parallelism is only set when generating the JobGraph. Some setParallelism() calls, such as SingleOutputStreamOperator.setParallelism() cannot deal with the fact that the parallelism of an operation might be -1 (which indicates that it should take the default parallelism when generating the JobGraph).

      We should either revert the changes that fixed another user-facing bug for version 1.2.1 or fix the methods.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated: