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!