為什麼我的瀏覽器屏幕上我得到這個錯誤,
<類型的異常。異常的>:Java網關進程退出之前發送司機港口參數數量= (“Java網關進程退出之前發送司機端口號的,)消息= ' Java網關進程退出之前發送司機端口號的
因為,
# !python / Python27 /打印”的content - type: text / html;utf - 8字符集=“打印#啟用調試進口cgitb cgitb.enable()導入操作係統導入係統#路徑火花源文件夾操作係統。環境(' SPARK_HOME '] = " C: \ Apache \ spark-1.4.1”# Append pyspark to Python Path sys.path.append("C:\Apache\spark-1.4.1\python") from pyspark import SparkContext from pyspark import SparkConf from pyspark.sql import SQLContext print ("Successfully imported Spark Modules") # Initialize SparkContext sc = SparkContext('local') words = sc.parallelize(["scala","java","hadoop","spark","akka"]) print words.count() sc.stop()
我在Windows7多。我的版本是spark-1.4.1-bin-hadoop2.6火花。tgz——prebuild haddop 2.6及以後。
任何想法如何我可以修複它嗎?
這是一個工作示例wsgi上運行,
導入操作係統導入係統 火花源文件夾的路徑年代。環境(' SPARK_HOME '] = " C: \ Apache \ spark-1.4.1”
附加pyspark Python路徑ys.path.append (“C: \ Apache \ spark-1.4.1 \ python”)
從進口SparkContext pyspark pyspark進口SparkConf pyspark。sql進口SQLContext
這是我們的應用程序對象。它可以是任何名稱,除了使用mod_wsgi時,一定是“應用程序”def應用程序(圍住,start_response):
#初始化SparkContext sc = SparkContext(當地的)單詞= sc.parallelize ([“scala”、“java”、“hadoop”、“火花”," akka "])數= words.count() #打印計數sc.stop () response_body =“成功導入模塊和火花總的話:”+ str(計數)# HTTP響應代碼和消息狀態= ' 200 OK”#這是HTTP頭所期望的客戶端。#他們必須包裹的元組對列表:#(標題名稱,標題值)。response_headers =[(“內容類型”、“文本/普通”),(內容長度,str (len (response_body)))) #送到服務器使用提供的函數start_response(地位、response_headers) #返回響應的身體。#注意到它是包裹在一個列表雖然可能有任何iterable。返回(response_body) < / pre >