This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e905db9 [FLINK-22085][tests] Remove timeouts from
KafkaSourceLegacyITCase
add 33d98e1 [FLINK-19606][table-runtime-blink] Refactor utility class
JoinConditionWithFullFilters from AbstractStreamingJoinOperator
No new revisions were added by this update.
Summary of changes:
.../join/JoinConditionWithNullFilters.java | 66 ++++++++++++++++++++++
.../join/stream/AbstractStreamingJoinOperator.java | 55 +++---------------
2 files changed, 73 insertions(+), 48 deletions(-)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/JoinConditionWithNullFilters.java
