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 >