application mode not support pyflink on yarn

Viewed 87

command: /space/flink/bin/flink run-application -t yarn-application -Dyarn.application.name=kafka-hive --pyFiles /space/testAirflow/airflow/dags/ -py /space/testAirflow/airflow/dags/chloe/kafka_to_hive_1.py

flink throw a Exception : java.lang.IllegalArgumentException: Should only have one jar

Does application mode not support pyflink?

1 Answers
Related