[
https://issues.apache.org/jira/browse/FLINK-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-16541:
--------------------------------
Description:
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{color:#FF0000}*d*{color}". 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}
was:
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}
> 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
> Priority: Major
>
> 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{color:#FF0000}*d*{color}". 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)
