flink on yarn ????????????

flink on yarn ha ??flink1.7.2??hadoop2.8.5 ??5??flinkCPU48G flink?? jobmanager.heap.size: 2048m taskmanager.heap.size: 2048m taskmanager.numberOfTaskSlots: 4 run a job on flink

请教关于Keyed() 方法的问题。

大家好， 先说本人的理解，keyed(..).flatmap(mapFunc()) 其中，每个具体mapFunc处理的数据，应该是相同的key数据。不知理解是否正确。 我的具体情况是 我对数据对校验处理。首先根据设备id (uuid) 分组，然后针对不同分组进行数据校验。 部分代码如下： rowData.filter(legalData _) .map(data => BehaviorComVO(getText(data, "id"), getText(data, "uuid"), getText(data, "session_id"), getText(data,