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)
