zsxwing commented on a change in pull request #27732: [SPARK-30984][SS]Add UI
test for Structured Streaming UI
URL: https://github.com/apache/spark/pull/27732#discussion_r385556396
##########
File path:
sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryListener.scala
##########
@@ -82,15 +82,15 @@ object StreamingQueryListener {
* @param id A unique query id that persists across restarts. See
`StreamingQuery.id()`.
* @param runId A query id that is unique for every start/restart. See
`StreamingQuery.runId()`.
* @param name User-specified name of the query, null if not specified.
- * @param submissionTime The timestamp to start a query.
+ * @param timestamp The timestamp to start a query.
* @since 2.1.0
*/
@Evolving
class QueryStartedEvent private[sql](
val id: UUID,
val runId: UUID,
val name: String,
- val submissionTime: Long) extends Event
+ val timestamp: String) extends Event
Review comment:
Change this to `string` type to be consistent with timestamps in
`StreamingQueryProgress`.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
