Support Flink 2.1

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Currently ,Flink has been moved forward to flink 2.0. Fluss can aslo support it.

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!

[MehulBatra]

@loserwang1024 If you'd like to collaborate or need help breaking down this feature into smaller tasks and getting them done, I'd be happy to pair up or assist wherever required!

[loserwang1024]

@MehulBatra I would be grateful if you can help review this pr and try it in flink 2.x.

[SteNicholas]

@loserwang1024, why do you conclude that I searched in the issues and found nothing similar?

[loserwang1024]

@loserwang1024, why do you conclude that I searched in the issues and found nothing similar?

Sorry, my mistake for ignoring your issue created before.
At the begining, I want to support flink 2.1 because the release announcement[1] is done. But I found that the jar of 2.1 is still not ready. Thus I still waiting for this, and this pr is a temporary pr for test, and will use flink 2.1 later. The module name is still fluss-flink-2.1

[1] https://cwiki.apache.org/confluence/display/FLINK/2.1+Release

[loserwang1024]

@SteNicholas I want to support 2.1 because I want to support delta join which is not included in 2.0

[wuchong]

Let's continue to review and move forward with #651 first. Flink 2.1 is expected to be released one month later.

[wuchong]

this has been implemented in #1176