parallel-processing - Flink CPU 配置

Flink 官方文档指出，对于 cpu 中的每个核心，您必须分配 1 个插槽并同时将并行度水平提高 1 个。

我的一个自定义运算符需要超过 1 个 CPU 用于计算（这就是它在 Heron 中的工作方式）。我系统的cpu是2.5。但是 Flink 只使用了 1 个 cpu。你知道我怎样才能配置 Flink 以使用更多的 CPU，只有 1 个插槽？

标签： parallel-processingapache-flinkflink-streaming

“每个核心一个插槽”只是一个经验法则。没有什么可以强制执行此操作。

每个子任务（操作员链的一个实例）都是单线程的，但是任务管理器中的插槽以及机器或容器中的任务管理器将使用它们可用的所有资源。