Github user tdas commented on a diff in the pull request:

    https://github.com/apache/spark/pull/20382#discussion_r167128044
  
    --- Diff: 
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/socket.scala
 ---
    @@ -164,54 +213,43 @@ class TextSocketSource(host: String, port: Int, 
includeTimestamp: Boolean, sqlCo
         }
       }
     
    -  override def toString: String = s"TextSocketSource[host: $host, port: 
$port]"
    +  override def toString: String = s"TextSocketMicroBatchReader[host: 
$host, port: $port]"
    --- End diff --
    
    This shows up in the StreamingQueryProgressEvent as description, so it may 
be better to have it as "TextSocket[..."


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to