[jira] [Created] (ZEPPELIN-4128) Zeppelin - unable to stop spark streaming query when awaitTermination is used.

["Srinivasarao Daruna (JIRA)" <ji...@apache.org>]

Srinivasarao Daruna created ZEPPELIN-4128:
---------------------------------------------

             Summary: Zeppelin - unable to stop spark streaming query when awaitTermination is used.
                 Key: ZEPPELIN-4128
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-4128
             Project: Zeppelin
          Issue Type: Bug
    Affects Versions: 0.8.1
            Reporter: Srinivasarao Daruna


When basic spark streaming  example with zeppelin  is executed, its not been possible to stop the paragraph once its started.

cancel/stop the paragraph is not stopping the execution.

Sample code executed in zeppelin paragraph:

import org.apache.spark.sql.functions._
import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder.appName("StructuredNetworkWordCount").getOrCreate()
 
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()

query.awaitTermination()

 

 



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