[
https://issues.apache.org/jira/browse/FLINK-40808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40808:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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)
