Hi,

可以配置 table.exec.resource.default-parallelism 为需要的并发。详见文档[1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/config.html#table-exec-resource-default-parallelism

jun su <sujun891...@gmail.com> 于2020年7月27日周一 下午3:50写道:

> hi all,
>
> Flink 目前的blink table planner batch mode
> (读hdfs上的orc文件)只支持StreamTableSource和LookupableTableSource,
> 但是StreamTableSource的并行度默认应该是1 , 底层是ContinuousFileMonitoringFunction ,
> 那么如何能扩大并行度来优化性能呢?
>
> --
> Best,
> Jun Su
>

回复