How to use Flink 2.x to run the example

[bgeng777]

Dear maintainers,
I am trying to use flink2.x python api to run the example. But it looks like the pyproject.toml is using Flink1.20 ("confluent-flink-table-api-python-plugin>=1.20.52").
I checked the pypi of confluent, and tried to install python -m pip install cp_pyflink which seems to contain the support of Flink2.x
But it failed to run commands like from pyflink.table.confluent import ConfluentSettings, ConfluentTools

Is there anything wrong in my experiment?

My env:
python 3.10 with following packages:

./venv/bin/python -m pip list
Package                   Version
------------------------- -----------
anaconda-anon-usage       0.4.4
apache-beam               2.61.0
archspec                  0.2.3
async-timeout             5.0.1
attrs                     25.4.0
avro                      1.12.1
avro-python3              1.10.2
boltons                   23.0.0
Brotli                    1.0.9
certifi                   2024.7.4
cffi                      1.16.0
charset-normalizer        3.3.2
cloudpickle               2.2.1
conda                     24.7.1
conda-content-trust       0.2.0
conda-libmamba-solver     24.7.0
conda-package-handling    2.3.0
conda_package_streaming   0.10.0
cp-pyflink                2.1.1.1
cp-pyflink-libraries      2.1.1.1
crcmod                    1.7
cryptography              42.0.5
dill                      0.3.1.1
distro                    1.9.0
dnspython                 2.8.0
docopt                    0.6.2
fastavro                  1.12.1
fasteners                 0.20
find_libpython            0.5.0
frozendict                2.4.2
grpcio                    1.65.5
hdfs                      2.7.3
httplib2                  0.22.0
idna                      3.7
jsonpatch                 1.33
jsonpickle                3.4.2
jsonpointer               2.1
jsonschema                4.26.0
jsonschema-specifications 2025.9.1
libmambapy                1.5.8
menuinst                  2.1.2
numpy                     1.24.4
objsize                   0.6.1
orjson                    3.11.4
packaging                 24.1
pandas                    2.2.3
pemja                     0.4.1
pip                       24.2
platformdirs              3.10.0
pluggy                    1.0.0
proto-plus                1.26.1
protobuf                  5.29.6
py4j                      0.10.9.7
pyarrow                   11.0.0
pyarrow-hotfix            0.7
pycosat                   0.6.6
pycparser                 2.21
pydot                     1.4.2
PyJWT                     2.11.0
pymongo                   4.15.3
pyparsing                 3.2.5
PySocks                   1.7.1
python-dateutil           2.9.0.post0
pytz                      2025.2
PyYAML                    6.0.3
redis                     5.3.1
referencing               0.37.0
regex                     2025.10.23
requests                  2.32.3
rpds-py                   0.30.0
ruamel.yaml               0.18.16
ruamel.yaml.clib          0.2.14
setuptools                72.1.0
six                       1.17.0
sortedcontainers          2.4.0
tqdm                      4.66.4
truststore                0.8.0
typing_extensions         4.15.0
tzdata                    2025.2
urllib3                   2.2.2
wheel                     0.43.0
zstandard                 0.22.0

Thanks.