cisconetgineer created ZEPPELIN-2563:
----------------------------------------
Summary: Paragraph using Spark Structured streaming using Scala
won't stop
Key: ZEPPELIN-2563
URL: https://issues.apache.org/jira/browse/ZEPPELIN-2563
Project: Zeppelin
Issue Type: Bug
Components: zeppelin-interpreter
Affects Versions: 0.7.1
Environment: Centos 7
Reporter: cisconetgineer
Hi,
This issue also happens for spark structured streaming using scala.
This is similar to bug 2156.
1. Paragraph Cancel ( || button ) has no effect.
2. Zeppelin Job view Stop All has no effect
3. Restart Zeppelin stops the note but clicking on run button does not produce
any actions.
Code below
======================
import spark.implicits._
val lines = spark.readStream
.format("socket")
.option("host", "localhost")
.option("port", 9999)
.load()
// Split the lines into words
val words = lines.as[String].flatMap(_.split(" "))
// Generate running word count
val wordCounts = words.groupBy("value").count()
val query = (wordCounts.writeStream
.outputMode("complete")
.format("console")
.start()
.awaitTermination()
)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
