是否有机会使用 apache flink 的 jdbc 接收器来限制数据库会话？

Question

我们正在使用jdbc接收器（apache flink），通过它我们可以达到数据库最大会话计数，特别是当我们增加并行度时。

我们的测试表明，如果我们通过将parallelism.default属性设置为大于1来增加默认并行度，我们在数据库上会有更多的非活动会话。当我们进一步增加它时，我们会看到一些异常，因为 jdbc 连接无法再建立。

通过使用不同的parallelism.default属性执行我们的测试，我们遇到了以下行为：

application.parallelism.default = 1 active session / inactive session -> 64/35
application.parallelism.default = 2 active session / inactive session -> 66/70
application.parallelism.default = 3 active session / inactive session -> 63/105
application.parallelism.default = 4 active session / inactive session -> 64/140
application.parallelism.default = 5 active session / inactive session -> 64/175
application.parallelism.default = 6 active session / inactive session -> 64/210
application.parallelism.default = 7 active session / inactive session -> 64/245
application.parallelism.default = 8 active session / inactive session -> 64/280

是否有机会限制jdbc接收器使用的会话？

我们想知道是否有适当的原因来控制我们的 jdbc 接收器使用的非活动会话。

Answer 1

无需更改默认并行度，只需将 JDBC 接收器的并行度设置为 1。这样，工作流程的其余部分就可以以更高的并行度运行（如果需要）。