twalthr commented on a change in pull request #6776: [FLINK-9715][table]
Support temporal join with event time
URL: https://github.com/apache/flink/pull/6776#discussion_r225541824
##########
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TemporalRowtimeJoin.scala
##########
@@ -145,22 +146,22 @@ class TemporalRowtimeJoin(
}
override def processElement1(element: StreamRecord[CRow]): Unit = {
- if (!element.getValue.change) {
Review comment:
We should reintroduce the `if` to make sure that exception creation does not
affect runtime. The JVM might be smart here but a `if` branch doesn't harm.
Otherwise an array is created for the arguments.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
