diff --git a/sql/core/src/main/scala/org/apache/spark/sql/util/ContinuousQueryListener.scala b/sql/core/src/main/scala/org/apache/spark/sql/util/ContinuousQueryListener.scala
index 73c78d1b62bbce32ecddb07bb981fc806c746a14..2c5358cbd72cb4b0b100a84de2a9a60b8278000c 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/util/ContinuousQueryListener.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/util/ContinuousQueryListener.scala
@@ -32,9 +32,9 @@ abstract class ContinuousQueryListener {
   /**
    * Called when a query is started.
    * @note This is called synchronously with
-   *       [[org.apache.spark.sql.DataFrameWriter `DataFrameWriter.stream()`]],
-   *       that is, `onQueryStart` will be called on all listeners before `DataFrameWriter.stream()`
-   *       returns the corresponding [[ContinuousQuery]].
+   *       [[org.apache.spark.sql.DataFrameWriter `DataFrameWriter.startStream()`]],
+   *       that is, `onQueryStart` will be called on all listeners before
+   *       `DataFrameWriter.startStream()` returns the corresponding [[ContinuousQuery]].
    */
   def onQueryStarted(queryStarted: QueryStarted)