[AMORO-2921] Adapt LookupSource interface in Flink 1.15

apache / amoro

Apache Amoro (incubating) is a Lakehouse management system built on open data lake formats.

https://amoro.apache.org/

Apache License 2.0

748 stars 261 forks source link

[AMORO-2921] Adapt LookupSource interface in Flink 1.15 #2923

Closed zhoujinsong closed 2 weeks ago

zhoujinsong commented 3 weeks ago

Why are the changes needed?

Close #2921.

Brief change log

Adapt LookupSource interface in Flink 1.15

How was this patch tested?

[ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible
[ ] Add screenshots for manual tests if appropriate
[x] Run test locally before making a pull request

Documentation

Does this pull request introduce a new feature? (no)
If yes, how is the feature documented? (not applicable)

czy006 commented 2 weeks ago

LookupSource interface is after 1.17 have it

zhoujinsong commented 2 weeks ago

LookupSource interface is after 1.17 have it

In fact, LookupFunction was introduced after version 1.16 to implement LookupSource. However, in versions prior to 1.15, since it did not exist, some special adaptations were required.

zhoujinsong commented 2 weeks ago

Thanks for the review! @czy006