retract在什么时候触发呢？是有groupby或者窗口就默认retract吗，还是需要配置？
有几个问题想咨询下大佬： 1.retract在什么时候触发呢？是有groupby或者窗口就默认retract吗，还是需要配置？ 2.如果上游操作有retract，那么不是所有的下游都带有retract性质了？不然下游计算的数据就不准了。 3.sql操作的话，如果上游是有retract的，那下游select然后print,会把DELETE和INSERT这两条记录都print出来？*来自志愿者整理的FLINK邮件归档
写回答
-
1.retract在什么时候触发呢？是有groupby或者窗口就默认retract吗，还是需要配置？
这个是某些算子会有这个行为，比如普通的group by，就会发送retract消息。 另外有一些算子是在某些特定配置下才会有这个行为，比如window operator，在配置了early fire或者late fire的时候。 还有些算子本身不会产生，但是会传递，比如calc算子
2.如果上游操作有retract，那么不是所有的下游都带有retract性质了？不然下游计算的数据就不准了。
这个也不绝对。大部分时候是。 这个取决于这个算子本身是不是会consume retraction，目前我好想没见到有算子会消费retraction，但是不产生retraction的。
3.sql操作的话，如果上游是有retract的，那下游select然后print,会把DELETE和INSERT这两条记录都print出来？
是的。*来自志愿者整理的FLINK邮件归档
2021-12-03 18:45:12赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
