flink sql 设置source并行度

在Flink SQL中，设置Source并行度可以通过修改代码来实现。具体来说，可以在构造方法中添加@Nullable Integer parallelism及相关的代码，并在getScanRuntimeProvider()方法的最后返回SourceFunctionProvider.of(kafkaConsumer, false, parallelism)。此外，在copy() / equals() / hashCode()方法内也需要加上parallelism。需要注意的是，由于Flink SQL中的Source有两种并行的标准，因此在实现过程中需要根据具体情况进行调整。