2017-08-24 2 views
0

Ich habe einen Cron-Job, der alle zwei Minuten aufgerufen wird Der Zweck dieses Jobs ist es, auf neue Anfrage zu prüfen und einen Funken Job auszulösen. Cron Job -> ruft eine Shell-Skript -> ruft Funken einreichenpyspark Automatisierung mit Cron Job

source /etc/hadoop/conf/hadoop-env.sh 
source /etc/spark/conf/spark-env.sh 
spark-submit --executor-memory 2g --num-executors 1 --packages com.databricks:spark-csv_2.10:1.5.0 \ 
            --py-files <some egg files location> \ 
            <python main script> \ 
            <configuration file> <Input Parameters> 

Beim manuellen trigered, das Skript funktioniert gut, aber wenn man durch cron ausgelöst geht es in ein totes Schloss versucht Funken Kontext zu erhalten.

Jeder Körper jemand haben Hinweise für mich zu diesem Thema?

+0

Verwendung 'http: // airbnb.io/projects/airflow /', 'cron' ist unzuverlässig –

+0

Wie haben Sie den Cron Job konfiguriert? – MedAli

+0

@MedAli: Ich benutze Crontab -e, und dann in die Anweisung */2 * * * * sh /path/script.sh – Garfield

Antwort