|
2 | 2 |
|
3 | 3 | Examples showing how to include Python libraries in your PyFlink application.
|
4 | 4 |
|
5 |
| -* Flink version: 1.19 |
| 5 | +* Flink version: 1.20 |
6 | 6 | * Flink API: Table API & SQL
|
7 | 7 | * Flink Connectors: Kinesis Connector
|
8 | 8 | * Language: Python
|
@@ -33,12 +33,12 @@ The output is sent to a Kinesis Data Stream.
|
33 | 33 | #### Development and build environment requirements
|
34 | 34 |
|
35 | 35 | * Python 3.11
|
36 |
| -* PyFlink library: `apache-flink==1.19.1` + any libraries defined in `requirements.txt` |
| 36 | +* PyFlink library: `apache-flink==1.20.0` + any libraries defined in `requirements.txt` |
37 | 37 | * Java JDK 11+ and Maven
|
38 | 38 |
|
39 |
| -> ⚠️ As of 2024-06-27, the Flink Python library 1.19.x may fail installing on Python 3.12. |
| 39 | +> ⚠️ The Flink Python library 1.20.0 may fail installing on Python 3.12. |
40 | 40 | > We recommend using Python 3.11 for development, the same Python version used by Amazon Managed Service for Apache Flink
|
41 |
| -> runtime 1.19. |
| 41 | +> runtime 1.20. |
42 | 42 |
|
43 | 43 | > JDK and Maven are uses to download and package any required Flink dependencies, e.g. connectors, and
|
44 | 44 | to package the application as `.zip` file, for deployment to Amazon Managed Service for Apache Flink.
|
@@ -89,14 +89,14 @@ In addition to these configuration properties, when running a PyFlink applicatio
|
89 | 89 | > We recommend to use Virtual Environments or any equivalent tool to create isolated environment
|
90 | 90 |
|
91 | 91 | To run the application locally, from the command line or in your IDE, you need to install the following Python dependencies:
|
92 |
| -* `apache-flink==1.19.1` |
| 92 | +* `apache-flink==1.20.0` |
93 | 93 | * Any requirements defined in `requirements.txt`
|
94 | 94 |
|
95 | 95 | Assuming you use `virtualenv` and you have it installed already:
|
96 | 96 |
|
97 | 97 | 1. Create the Virtual Environment in the project directory: `virtualenv venv`
|
98 | 98 | 2. Activate the Virtual Environment you just created: `source venv/bin/activate`
|
99 |
| -3. Install PyFlink library: `pip install apache-flink==1.19.1` |
| 99 | +3. Install PyFlink library: `pip install apache-flink==1.20.0` |
100 | 100 | 4. Install other dependencies from `requirements.txt`: `pip install -r requirements.txt`
|
101 | 101 |
|
102 | 102 |
|
|
0 commit comments