You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@amaterasu.apache.org by ya...@apache.org on 2019/05/06 02:40:43 UTC

[incubator-amaterasu] 27/36: Installing action requirements inside the driver and shipping them to the executors

This is an automated email from the ASF dual-hosted git repository.

yaniv pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-amaterasu.git

commit 59c4c1ca96379725cc08916dad28ac4d0f1879b7
Merge: 886541c 2e7904d
Author: Nadav Har Tzvi <na...@apache.org>
AuthorDate: Sat Apr 27 12:28:27 2019 +0300

    Installing action requirements inside the driver and shipping them to the executors

 .../dispatcher/runners/providers/PySparkRunnerProvider.scala     | 9 +++++++--
 sdk_python/amaterasu/pyspark/runtime.py                          | 1 -
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --cc sdk_python/amaterasu/pyspark/runtime.py
index c51382d,da69205..a8fbe3c
--- a/sdk_python/amaterasu/pyspark/runtime.py
+++ b/sdk_python/amaterasu/pyspark/runtime.py
@@@ -18,8 -18,6 +18,7 @@@ from pyspark import SparkContext, Spark
  from pyspark.sql import SparkSession, DataFrame
  from amaterasu.base import BaseAmaContextBuilder, LoaderAmaContext
  from .datasets import DatasetManager
 +from pip._internal import main as pip_main
- import zipfile
  import os
  import sys