纱线中的流动燧石

Question

我正在用纱线运行Flink（1.4.2）。我正在使用Flink纱线客户端将作业提交给纱线集群。

假设我有一个有4个插槽的TM，我部署了一个并行度为4、有2个容器的flink作业—1个JM和1个TM。每个并行实例将部署在TM中的每个任务槽中（每个槽运行的整个作业管道）。

我的作业进行连接（非键控流上的SQL时间窗口连接），并缓冲最后3小时的数据。根据Flink docs的说法，在不同的任务槽中运行的独立线程共享数据集和数据结构，从而减少了每个任务的开销

我的问题是运行在不同任务槽中的这些线程是否会共享为连接而缓冲的数据。所有数据在这些线程之间共享。

编辑

示例查询-

<代码>选择R.order\U id，S.order。restaurant\u id FROM awz\U s3\U stream1 R Internal JOIN awz\U s3\U stream2 S ON CAST（R.order\u id AS VARCHAR）=S.order\u id和R.proctime介于S.proctime-间隔“2”小时和S.proctime间隔“2”小时之间，按跃点分组（S.proctime，间隔“2”分钟，间隔“1”小时），S.订单。餐厅id




Answer 1

每个任务都将接收自己的输入数据分离分区。在同一TaskManager上运行的任务共享的是服务和控制数据结构，如网络堆栈、网络连接、RPCendpoint、分布式组件之间的心跳等。