flink如何禁止source并行度大于1

Question

最近写flink遇到个问题，代码逻辑很简单，就是flink从clickhouse读取数据，然后简单转换存入es，但是并行度遇到个问题，我在提交时候指定并行度为12，然后souce端的并行度也成为了12，与后续map等算子直接合并了，就导致source只有一个solt在工作，然后后面的map也只有一个solt，其他的都finish了，如图

如果我手动把source并行度设为1，就需要再手动把map设为12，这样确实可以解决问题，如图

但是这样就导致并行度写死了，以后资源分配调整都挺费劲的，我想知道为什么会这样，还有其他解决办法吗。

附上clickhouse的souce代码

batchEnv.createInput(JdbcInputFormat.buildJdbcInputFormat()
                .setDBUrl(String.format("jdbc:clickhouse://%s:%s/%s?%s",
                        dbConfigProperties.getHost()
                        , dbConfigProperties.getPort()
                        , dbConfigProperties.getBDName()
                        , "socket_timeout=240000000"))
                .setDrivername(dbConfigProperties.getDriver())
                .setUsername(dbConfigProperties.getUserName())
                .setPassword(dbConfigProperties.getPassword())
                .setQuery(sql)
                .setRowTypeInfo(rowTypeInfo)
                .finish()
        ).setParallelism(1);

```

Answer 1

flink批处理，不是流处理