在Windows和Apache Toree内核上与Jupyter一起工作，以获得Spark兼容性

我正在尝试安装Apache Toree内核以兼容spark，我遇到了一个奇怪的环境消息。以下是我所遵循的过程:

安装最新Anaconda版本与Jupyter 4.1.0
运行:pip install——pretoree
运行:jupyter toree install——interpreter =PySpark,SparkR,Scala,SQL

只对Scala内核感兴趣，但我安装了所有的解释器。操作系统是windows 7，没有选择使用虚拟机或linux。

这是内核。

使用cygwin来执行run.sh bash脚本。

{
  "language": "scala", 
  "display_name": "Apache Toree - Scala", 
  "env": {
    "__TOREE_SPARK_OPTS__": "", 
    "SPARK_HOME": "C:\CDH\spark", 
    "__TOREE_OPTS__": "", 
    "DEFAULT_INTERPRETER": "Scala", 
    "PYTHONPATH": "C:\CDH\spark\python:C:\CDH\spark\python\lib\py4j-0.8.2.1-src.zip", 
    "PYTHON_EXEC": "python"
  }, 
  "argv": [
    "C:\cygwin64\bin\mintty.exe","-h","always","/bin/bash","-l","-e","C:\ProgramData\jupyter\kernels\apache_toree_scala\bin\run.sh", 
    "--profile", 
    "{connection_file}"
  ]
}

当运行jupyter时，内核出现错误停止:

TypeError: environment can only contain strings

扩展日志:

[E 10:45:56.736 NotebookApp] Failed to run command:
    ['C:\cygwin64\bin\mintty.exe', '-h', 'always', '/bin/bash', '-l', '-e', 'C:\ProgramData\jupyter\kernels\apache_toree_scala\bin\run.sh', '
--profile', 'C:\Users\luis\AppData\Roaming\jupyter\runtime\kernel-e02cac9b-15de-4c69-a8e5-e5b11919e1bc.json']
    with kwargs:
    {'stdin': -1, 'stdout': None, 'cwd': 'C:\Users\luis\Documents', 'stderr': None, 'env': {'TMP': 'C:\Users\luis\AppData\Local\Temp', 'COMPUTERNAME': 'laptop', 'USERDOMAIN': 'HOME', 'SPARK_HOME': u'C:\CDH\spark', 'DEFLOGDIR': 'C:\ProgramData\McAfee\DesktopProtection', 'PSMODULEPATH': 'C:\Windows\system32\WindowsPowerShell\v1.0\Modules\', 'COMMONPROGRAMFILES': 'C:\Program Files\Common Files', 'PROCESSOR_IDENTIFIER':'Intel64 Family 6 Model 45 Stepping 7, GenuineIntel', u'DEFAULT_INTERPRETER': u'Scala', 'PROGRAMFILES': 'C:\Program Files', 'PROCESSOR_REVISION': '2d07', 'SYSTEMROOT': 'C:\Windows', 'PATH': 'C:\Users\luis\AppData\Local\Continuum\Anaconda2\Library\bin;C:\Users\luis\AppData\Local\Continuum\Anaconda2;C:\Users\luis\AppData\Local\Continuum\Anaconda2\Scripts;C:\Users\luis\AppData\Local\Continuum\Anaconda2\Library\bin;C:\Users\luis\AppData\Local\Continuum\Anaconda2\Library\bin;C:\Program Files\Java\jdk1.7.0_76\jre\bin;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.0\;C:\Program Files (x86)\sbt\bin;C:\Users\luis\AppData\Local\Continuum\Anaconda2;C:\Users\luis\AppData\Local\Continuum\Anaconda2\Scripts;C:\Users\luis\AppData\Local\Continuum\Anaconda2\Library\bin', 'PROGRAMFILES(X86)': 'C:\Program Files (x86)', 'WINDOWS_TRACING_FLAGS': '3', 'TK_LIBRARY': 'C:\Users\luis\AppData\Local\Continuum\Anaconda2\tcl\tk8.5', u'__TOREE_SPARK_OPTS__': u'', 'TEMP': 'C:\Users\luis\AppData\Local\Temp', 'COMMONPROGRAMFILES(X86)': 'C:\Program Files (x86)\Common Files', 'PROCESSOR_ARCHITECTURE': 'AMD64', 'TIX_LIBRARY': 'C:\Users\luis\AppData\Local\Continuum\Anaconda2\tcl\tix8.4.3', 'ALLUSERSPROFILE': 'C:\ProgramData', 'LOCALAPPDATA': 'C:\Users\luis\AppData\Local', 'HOMEPATH': '\Users\luis', 'JAVA_HOME': 'C:\Program Files\java\jdk1.7.0_76', 'JPY_INTERRUPT_EVENT': '1056', 'PROGRAMW6432': 'C:\Program Files', 'USERNAME': 'luis', 'LOGONSERVER': '\\S8KROGR2', 'SBT_HOME': 'C:\Program Files (x86)\sbt\', 'JPY_PARENT_PID': '1036', 'PROGRAMDATA': 'C:\ProgramData', u'PYTHONPATH': u'C:\CDH\spark\python:C:\CDH\spark\python\lib\py4j-0.8.2.1-src.zip', 'TCL_LIBRARY': 'C:\Users\luis\AppData\Local\Continuum\Anaconda2\tcl\tcl8.5', 'VSEDEFLOGDIR': 'C:\ProgramData\McAfee\DesktopProtection', 'USERDNSDOMAIN': 'HOME.ES', 'SESSIONNAME': 'RDP-Tcp#0', 'PATHEXT': '.COM;.EXE;.BAT;.CMD;.VBS;.VBE;.JS;.JSE;.WSF;.WSH;.MSC', u'PYTHON_EXEC': u'python', 'CLIENTNAME': 'laptop2', u'__TOREE_OPTS__': u'', 'FP_NO_HOST_CHECK': 'NO', 'WINDIR': 'C:\Windows', 'WINDOWS_TRACING_LOGFILE': 'C:\BVTBin\Tests\installpackage\csilogfile.log', 'HOMEDRIVE': 'C:', 'SYSTEMDRIVE': 'C:', 'COMSPEC': 'C:\Windows\system32\cmd.exe', 'NUMBER_OF_PROCESSORS': '2', 'APPDATA': 'C:\Users\luis\AppData\Roaming', 'PROCESSOR_LEVEL': '6', 'COMMONPROGRAMW6432':    'C:\Program Files\Common Files', 'OS': 'Windows_NT', 'PUBLIC': 'C:\Users\Public', 'IPY_INTERRUPT_EVENT': '1056', 'USERPROFILE': 'C:\Users\luis'}}
[E 10:45:56.744 NotebookApp] Unhandled error in API request
    Traceback (most recent call last):
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesnotebookbasehandlers.py", line 457, in wrapper
        result = yield gen.maybe_future(method(self, *args, **kwargs))
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1008, in run
        value = future.result()
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadoconcurrent.py", line 232, in result
        raise_exc_info(self._exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1014, in run
        yielded = self.gen.throw(*exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesnotebookservicessessionshandlers.py", line 62, in post
        kernel_id=kernel_id))
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1008, in run
        value = future.result()
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadoconcurrent.py", line 232, in result
        raise_exc_info(self._exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1014, in run
        yielded = self.gen.throw(*exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesnotebookservicessessionssessionmanager.py", line 79, in create_session
        kernel_name)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1008, in run
        value = future.result()
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadoconcurrent.py", line 232, in result
        raise_exc_info(self._exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1014, in run
        yielded = self.gen.throw(*exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesnotebookservicessessionssessionmanager.py", line 92, in start_kernel_for_session
        self.kernel_manager.start_kernel(path=kernel_path, kernel_name=kernel_name)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 1008, in run
        value = future.result()
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadoconcurrent.py", line 232, in result
        raise_exc_info(self._exc_info)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagestornadogen.py", line 282, in wrapper
        yielded = next(result)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesnotebookserviceskernelskernelmanager.py", line 87, in start_kernel
        super(MappingKernelManager, self).start_kernel(**kwargs)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesjupyter_clientmultikernelmanager.py", line 110, in start_kernel
        km.start_kernel(**kwargs)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesjupyter_clientmanager.py", line 243, in start_kernel
        **kw)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesjupyter_clientmanager.py", line 189, in _launch_kernel
        return launch_kernel(kernel_cmd, **kw)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsite-packagesjupyter_clientlauncher.py", line 123, in launch_kernel
        proc = Popen(cmd, **kwargs)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsubprocess.py", line 711, in __init__
        errread, errwrite)
      File "C:UsersluisAppDataLocalContinuumAnaconda2libsubprocess.py", line 959, in _execute_child
        startupinfo)
    TypeError: environment can only contain strings
[E 10:45:56.766 NotebookApp] {
      "Origin": "http://localhost:8888",
      "Content-Length": "88",
      "Accept-Language": "es-ES,es;q=0.8",
      "Accept-Encoding": "gzip, deflate",
      "Host": "localhost:8888",
      "Accept": "application/json, text/javascript, */*; q=0.01",
      "User-Agent": "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.101 Safari/537.36",
      "Connection": "keep-alive",
      "X-Requested-With": "XMLHttpRequest",
      "Referer": "http://localhost:8888/notebooks/Untitled3.ipynb?kernel_name=apache_toree_scala",
      "Content-Type": "application/json"
    }
[E 10:45:56.796 NotebookApp] 500 POST /api/sessions (::1) 626.00ms referer=http://localhost:8888/notebooks/Untitled3.ipynb?kernel_name=apache_toree_sc
ala

我已经单独运行了命令:

C:\cygwin64\bin\mintty.exe -h always /bin/bash -l -e C:\ProgramData\jupyter\kernels\apache_toree_scala\bin\run.sh

它起作用了。它只在jupyter服务器执行的上下文中失败。

有人在windows机器上成功运行这个内核吗?

我写了我自己的(粗糙的)运行。使用Spark 2.2.0和toree-assembly-0.2.0.dev1-incubating-SNAPSHOT让它工作。我把我的解决方案贴在了TOREE-399机票上。

运行。命令行如下:

@echo off
set PROG_HOME=%~dp0..
if not defined SPARK_HOME (
  echo SPARK_HOME must be set to the location of a Spark distribution!
  exit 1
)
REM disable randomized hash for string in Python 3.3+
set PYTHONHASHSEED=0
REM The SPARK_OPTS values during installation are stored in __TOREE_SPARK_OPTS__. This allows values to be specified during
REM install, but also during runtime. The runtime options take precedence over the install options.
if not defined SPARK_OPTS (
  set SPARK_OPTS=%__TOREE_SPARK_OPTS__%
) else (
  if "%SPARK_OPTS%" == "" (
    set SPARK_OPTS=%__TOREE_SPARK_OPTS__%
  )
)
if not defined TOREE_OPTS (
  set TOREE_OPTS=%__TOREE_OPTS__%
) else (
  if "%TOREE_OPTS%" == "" (
    set TOREE_OPTS=%__TOREE_OPTS__%
  )
)
echo Starting Spark Kernel with SPARK_HOME=%SPARK_HOME%
REM This doesn't work because the classpath doesn't get set properly, unless you hardcode it in SPARK_SUBMIT_OPTS using forward slashes or double backslashes, but then you can't use the SPARK_HOME and PROG_HOME variables.
REM set SPARK_SUBMIT_OPTS=-cp "%SPARK_HOME%conf;%SPARK_HOME%jars*;%PROG_HOME%libtoree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar" -Dscala.usejavacp=true
REM set TOREE_COMMAND="%SPARK_HOME%binspark-submit.cmd" %SPARK_OPTS% --class org.apache.toree.Main %PROG_HOME%libtoree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar %TOREE_OPTS% %*
REM The two important things that we must do differently on Windows are that we must add toree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar to the classpath, and we must define the java property scala.usejavacp=true.
set TOREE_COMMAND="%JAVA_HOME%binjava" -cp "%SPARK_HOME%conf;%SPARK_HOME%jars*;%PROG_HOME%libtoree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar" -Dscala.usejavacp=true -Xmx1g org.apache.spark.deploy.SparkSubmit %SPARK_OPTS% --class org.apache.toree.Main %PROG_HOME%libtoree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar %TOREE_OPTS% %*
echo.
echo %TOREE_COMMAND%
echo.
%TOREE_COMMAND%

。CMD文件应放在C: ProgramData jupyter 内核 apache_toree_scala bin
此外,您需要编辑内核。要更改的文件夹中的Json
如果你想允许安装额外的对于三个内核，您还应该编辑toreeapp.py以将run.sh更改为run.cmd。
我还没有测试IF语句是否正确工作。我怀疑它们会因为某些参数而阻塞，因为batch缺乏健壮的IF语句。

我有同样的问题使用:python在win10, Anaconda, spark 2.0.2

这是我想到的解决方法:使用conda环境切换来设置环境变量，而不是使用jupyter来设置它们

克隆一个单独的conda环境(http://conda.pydata.org/docs/using/envs.html #创造一个环境)
设置toree所需的环境变量windows (http://conda.pydata.org/docs/using/envs.html)

然后运行jupyter notebook <root dir of notebooks>

您也可以从windows永久地设置这三个变量，并从kernel.json中清空"env"字典"env":{}

我想保持我的环境变量分开使用pyspark

相关内容

最新更新

热门标签：