diff --git a/code/Streaming-Chapter_21_Structured_Streaming_Basics.scala b/code/Streaming-Chapter_21_Structured_Streaming_Basics.scala
index 45b23d6..0bab95e 100644
--- a/code/Streaming-Chapter_21_Structured_Streaming_Basics.scala
+++ b/code/Streaming-Chapter_21_Structured_Streaming_Basics.scala
@@ -146,7 +146,7 @@ val socketDF = spark.readStream.format("socket")
 
 // COMMAND ----------
 
-activityCounts.format("console").write()
+activityCounts.writeStream.format("console").start()
 
 
 // COMMAND ----------