libai created ZEPPELIN-3470:
-------------------------------

             Summary: ambari2.6.1 use zeppelin0.7.3 error
                 Key: ZEPPELIN-3470
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-3470
             Project: Zeppelin
          Issue Type: Bug
          Components: Core
    Affects Versions: 0.7.3
         Environment: centos7.3 

ambari2.6.1+hdp2.6.3

 

please tell me resolve......online wait....
            Reporter: libai
             Fix For: 0.7.3


%spark.spark
import org.apache.commons.io.IOUtils
import java.net.URL
import java.nio.charset.Charset

// Zeppelin creates and injects sc (SparkContext) and sqlContext (HiveContext 
or SqlContext)
// So you don't need create them manually

// load bank data
val bankText = sc.parallelize(
 IOUtils.toString(
 new URL("https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv";),
 Charset.forName("utf8")).split("\n"))

case class Bank(age: Integer, job: String, marital: String, education: String, 
balance: Integer)

val bank = bankText.map(s => s.split(";")).filter(s => s(0) != "\"age\"").map(
 s => Bank(s(0).toInt, 
 s(1).replaceAll("\"", ""),
 s(2).replaceAll("\"", ""),
 s(3).replaceAll("\"", ""),
 s(5).replaceAll("\"", "").toInt
 )
).toDF()
bank.registerTempTable("bank")

up is script

----------------------------------------------------

down is error 
spark.spark interpreter not found
org.apache.zeppelin.interpreter.InterpreterException: spark.spark interpreter 
not found at 
org.apache.zeppelin.interpreter.InterpreterFactory.getInterpreter(InterpreterFactory.java:416)
 at org.apache.zeppelin.notebook.Note.run(Note.java:617) at 
org.apache.zeppelin.socket.NotebookServer.persistAndExecuteSingleParagraph(NotebookServer.java:1650)
 at 
org.apache.zeppelin.socket.NotebookServer.runAllParagraphs(NotebookServer.java:1597)
 at 
org.apache.zeppelin.socket.NotebookServer.onMessage(NotebookServer.java:269) at 
org.apache.zeppelin.socket.NotebookSocket.onWebSocketText(NotebookSocket.java:59)
 at 
org.eclipse.jetty.websocket.common.events.JettyListenerEventDriver.onTextMessage(JettyListenerEventDriver.java:128)
 at 
org.eclipse.jetty.websocket.common.message.SimpleTextMessage.messageComplete(SimpleTextMessage.java:69)
 at 
org.eclipse.jetty.websocket.common.events.AbstractEventDriver.appendMessage(AbstractEventDriver.java:65)
 at 
org.eclipse.jetty.websocket.common.events.JettyListenerEventDriver.onTextFrame(JettyListenerEventDriver.java:122)
 at 
org.eclipse.jetty.websocket.common.events.AbstractEventDriver.incomingFrame(AbstractEventDriver.java:161)
 at 
org.eclipse.jetty.websocket.common.WebSocketSession.incomingFrame(WebSocketSession.java:309)
 at 
org.eclipse.jetty.websocket.common.extensions.ExtensionStack.incomingFrame(ExtensionStack.java:214)
 at org.eclipse.jetty.websocket.common.Parser.notifyFrame(Parser.java:220) at 
org.eclipse.jetty.websocket.common.Parser.parse(Parser.java:258) at 
org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.readParse(AbstractWebSocketConnection.java:632)
 at 
org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:480)
 at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544) 
at 
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635)
 at 
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555) 
at java.lang.Thread.run(Thread.java:748)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to