擅长:python、mysql、java
<p>这应该对你有帮助</p>
<p>一种解决方案是将pyspark shell添加到shell环境变量pyspark_SUBMIT_ARGS:</p>
<pre><code>export PYSPARK_SUBMIT_ARGS="--master local[2] pyspark-shell"
</code></pre>
<p>python/pyspark/java_gateway.py中有一个更改,如果用户设置了pyspark_SUBMIT_ARGS变量,则该更改要求pyspark_SUBMIT_ARGS包含pyspark shell。</p>