Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.10.0
Description
Document of table.exec.shuffle-mode is incorrect. Currently the document states that
Sets exec shuffle mode. Only batch or pipeline can be set.
But "pipeline" is incorrect, the correct configuration is "pipelined". Using pipeline instead of pipelined will throw the following exception.
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)
Attachments
Issue Links
- links to