getRuntimeContext().getAttemptNumber() is not founded in flink 2.1

[sd4324530]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

0.8.0 (latest release)

Please describe the bug 🐞

getAttemptNumber() is not founded in flink 2.1

Solution

The current code is compatible with Flink version 1.18. Newer versions can replace it with: getRuntimeContext().getTaskInfo().getAttemptNumber().
We should need to adapt it for Flink 1.19 and above.

Are you willing to submit a PR?

• I'm willing to submit a PR!

[sd4324530]

@loserwang1024 I will submit my PR here as soon as possible.

[loserwang1024]

@sd4324530 Thanks a lot, an adapter for flink common and flink 1.18 is enough.