Java 在 Airflow 中找不到命令

Question

您好，您已使用 Linux 子系统在 window 系统中成功安装了气流。

我已经安装了 java 并在环境变量中设置了它的主路径。通常我可以从命令行运行任何 java 程序。

我正在尝试运行 java 使用 airflow 代码的程序。但我收到错误 java command is not found.

下面的代码用于气流。

import airflow
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime
import os
import sys



args = {
  'owner': 'airflow',
  'start_date': datetime(2017, 1, 27),
  'provide_context': True
}
d = datetime(2019, 9, 1)


dag = DAG('usgs', start_date = d, schedule_interval = '@daily', default_args = args)

t_main = BashOperator(
  task_id = 'usgs_fetch',
  dag = dag,
  bash_command = 'java -jar /mnt/D/testProjects/reporting_platform/classes/artifacts/reporting_platform_jar/pp_platform.jar'
  )

请帮忙，我是气流调度器的新手。

Answer 1

您好，我正在回答我的问题，我还必须在 windows 的 linux 子系统上安装 java。

还需要在linux子系统中设置JAVA_HOME。

谢谢

Java 在 Airflow 中找不到命令

Java command not found in Airflow

java

airflow

airflow-scheduler