'application mode not support pyflink on yarn
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?
Solution 1:[1]
It is not supported in <1.13 and was supposedly fixed in Flink 1.14.4. Sad.
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|---|
| Solution 1 | dz902 |