I guess we need more logic here. At first I also thought that we don't need special treatment of time attributes here. However, if we have a processing-time temporal join we need to materialize all rowtime attributes of both inputs. So this method needs to look at the time attributes defined by the join condition. What do you think?
[ Full content available at: https://github.com/apache/flink/pull/6299 ] This message was relayed via gitbox.apache.org for [email protected]
