Ryan Pelaez created FLINK-40808:
-----------------------------------
Summary: Setting up PyPI for AWS Connector
Key: FLINK-40808
URL: https://issues.apache.org/jira/browse/FLINK-40808
Project: Flink
Issue Type: Improvement
Reporter: Ryan Pelaez
The flink-python module in flink-connector-aws contains Python wrappers for
KinesisStreamsSource, KinesisStreamsSink, and KinesisFirehoseSink. However,
this package is not published to PyPI, preventing PyFlink users from installing
it via pip.
This is blocking PyFlink DataStream applications on Flink 2.x from consuming
Kinesis Data Streams, since:
- The apache-flink PyPI package only wraps the legacy FlinkKinesisConsumer
(SourceFunction-based)
- SourceFunction was removed in Flink 2.0
- The new FLIP-27 based KinesisStreamsSource wrappers exist in this repo but
aren't pip-installable
See related
- https://issues.apache.org/jira/browse/FLINK-38214
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
