how to run spark java code in airflow?,"sys.path.append(os.path.join(os.environ['SPARK_HOME'], 'bin'))"