[jira] [Created] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect

Shang Yuanchun (Jira)
Caizhi Weng created FLINK-16541:
-----------------------------------

             Summary: Document of table.exec.shuffle-mode is incorrect
                 Key: FLINK-16541
                 URL: https://issues.apache.org/jira/browse/FLINK-16541
             Project: Flink
          Issue Type: Bug
          Components: Documentation
    Affects Versions: 1.10.0
            Reporter: Caizhi Weng


Document of table.exec.shuffle-mode is incorrect. Currently the document states that
{code:java}
Sets exec shuffle mode. Only batch or pipeline can be set.
{code}
But "pipeline" is incorrect, the correct configuration is "pipeline*d*". Using pipeline instead of pipelined will throw the following exception.
{code:java}
java.lang.IllegalArgumentException: table.exec.shuffle-mode can only be set to BATCH or PIPELINED
        at org.apache.flink.table.planner.utils.ExecutorUtils.isShuffleModeAllBatch(ExecutorUtils.java:98)
        at org.apache.flink.table.planner.utils.ExecutorUtils.setBatchProperties(ExecutorUtils.java:69)
        at org.apache.flink.table.planner.delegation.BatchExecutor.getStreamGraph(BatchExecutor.java:50)
        at com.ververica.flink.table.gateway.context.ExecutionContext.createPipeline(ExecutionContext.java:272)
        at com.ververica.flink.table.gateway.operation.SelectOperation.executeQueryInternal(SelectOperation.java:246){code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)