Flink 并发参数设置：并行度和线程池详解

Flink\u7684\u5e76\u540c\u53c2\u6570\u6307\u7684\u662f\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\u548c\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\u3002\n\n\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\u6307\u7684\u662f\u540c\u65f6\u6267\u884c\u7684\u4efb\u52a1\u6570\uff0c\u53ef\u4ee5\u901a\u8fc7\u8bbe\u7f6e\u201csetParallelism()\u201d\u65b9\u6cd5\u6765\u6307\u5b9a\uff0c\u9ed8\u8ba4\u503c\u4e3a1\u3002\n\n\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\u6307\u7684\u662f\u4efb\u52a1\u6267\u884c\u6240\u4f7f\u7528\u7684\u7ebf\u7a0b\u6570\uff0c\u53ef\u4ee5\u901a\u8fc7\u8bbe\u7f6e\u201ctaskmanager.numberOfTaskSlots\u201d\u53c2\u6570\u6765\u6307\u5b9a\uff0c\u9ed8\u8ba4\u503c\u4e3a1\u3002\u8be5\u53c2\u6570\u51b3\u5b9a\u4e86\u4efb\u52a1\u7684\u6700\u5927\u5e76\u884c\u5ea6\u3002\n\n\u5728Flink\u4e2d\uff0c\u4efb\u52a1\u5e76\u884c\u5ea6\u548c\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\u662f\u76f8\u4e92\u5173\u8054\u7684\u3002\u4e00\u4e2a\u4efb\u52a1\u5e76\u884c\u5ea6\u4e3aN\u7684\u4f5c\u4e1a\uff0c\u9700\u8981\u81f3\u5c11N\u4e2aTask Slot\u6765\u6267\u884c\uff0c\u5982\u679cTask Slot\u7684\u6570\u91cf\u5c0f\u4e8e\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\uff0c\u5c31\u4f1a\u51fa\u73b0\u8d44\u6e90\u4e0d\u8db3\u7684\u60c5\u51b5\u3002\u53e6\u5916\uff0c\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\u4e5f\u4f1a\u5f71\u54cd\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\u3002\u5982\u679c\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\u5c0f\u4e8e\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\uff0c\u90a3\u4e48\u4efb\u52a1\u7684\u6267\u884c\u5c31\u4f1a\u53d7\u5230\u9650\u5236\uff0c\u65e0\u6cd5\u5145\u5206\u5229\u7528\u8d44\u6e90\u3002\n\n\u6240\u4ee5\uff0c\u5728\u8bbe\u7f6eFlink\u7684\u5e76\u540c\u53c2\u6570\u65f6\uff0c\u9700\u8981\u7efc\u5408\u8003\u8651\u4efb\u52a1\u7684\u5e76\u884c\u5ea6\u548c\u7ebf\u7a0b\u6c60\u7684\u5927\u5c0f\uff0c\u4ee5\u5145\u5206\u53d1\u6325Flink\u7684\u5e76\u884c\u8ba1\u7b97\u80fd\u529b\u3002