探索云世界
问题1：兄弟们 flink 算子间数据传递没有经过序列化和反序列化吗？我怎么感觉还是引用传递啊？
有大佬解释一下吗？我这个demo 理论上map应该只有一个mapName的属性，为什么会加上了keyName的属性。。
问题2：正常keyBy是用来分组的，估计写这块代码的人就没想过你会在keyBy中修改数据，也说明keyBy的那个getKey方法应该就是直接拿的原对象
写回答
回答1：应该是引用类型导致的。
回答2：对，这个可能就是 永远不知道你的用户会搞出什么不一样的操作，但是我现在做的一个需求就是给每个算子添加一些指标属性。正常keyBy后面肯定要接其他处理算子的，拟在后面的算子里面统计不就行了，此回答整理自钉群“【③群】Apache Flink China社区”
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
