[jira] [Created] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes

["Ferenc Csaky (Jira)" <ji...@apache.org>]

Ferenc Csaky created FLINK-38952:
------------------------------------

             Summary: Adapt PyFlink AWS connector code to the current Java class changes
                 Key: FLINK-38952
                 URL: https://issues.apache.org/jira/browse/FLINK-38952
             Project: Flink
          Issue Type: Improvement
            Reporter: Ferenc Csaky
             Fix For: aws-connector-6.0.0


Currently the Python test CI fails with:
{code}
TypeError: Could not found the Java class 'org.apache.flink.streaming.connectors.kinesis.serialization.KinesisDeserializationSchemaWrapper'.
{code}
The cause for this is the Python code is lagging behind and they are not in sync with the current Java classes on main.

We need to update the Java class references in both {{kinesys.py}} and {{test_kinesys.py}}.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)