命令:/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 抛出异常:java.lang.IllegalArgumentException:应该只有一个 jar
应用模式不支持pyflink吗?