Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Amazon EMR es compatible con las versiones 6.15.0 y superiores de EKS. PyFlink Si ya tiene un PyFlink script, puede realizar una de las siguientes acciones:
-
Cree una imagen personalizada con el PyFlink script incluido.
-
Cargue su script en una ubicación de Amazon S3
Si aún no tiene un script, puede usar el siguiente ejemplo para lanzar un PyFlink trabajo. En este ejemplo se recupera el script de S3. Si utiliza una imagen personalizada con el script ya incluido en la imagen, debe actualizar la ruta del script a la ubicación donde guardó dicho script. Si el script está en una ubicación S3, Amazon EMR en EKS recuperará el script y lo colocará en el directorio /opt/flink/usrlib/ del contenedor Flink.
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
name: python-example
spec:
flinkVersion: v1_17
flinkConfiguration:
taskmanager.numberOfTaskSlots: "1"
executionRoleArn: job-execution-role
emrReleaseLabel: "emr-6.15.0-flink-latest"
jobManager:
highAvailabilityEnabled: false
replicas: 1
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
job:
jarURI: s3://S3 bucket with your script/pyflink-script.py
entryClass: "org.apache.flink.client.python.PythonDriver"
args: ["-py", "/opt/flink/usrlib/pyflink-script.py"]
parallelism: 1
upgradeMode: stateless