[SPARK-22873] Init lastReportTimestamp with system current time when start() called in AsyncEventQueue

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 2.2.1
• Component/s: Spark Core
• Labels: newbie
• Flags: Patch
• Assignee: Unassigned
• Reporter: wuyi
• Due: 22/Dec/17
• Created: 22/Dec/17 06:22
• Updated: 28/Jan/18 21:48
• Resolved: 28/Jan/18 21:48

Description

   if (droppedEventsCounter.compareAndSet(droppedCount, 0)) {
      val prevLastReportTimestamp = lastReportTimestamp
      lastReportTimestamp = System.currentTimeMillis()
      val previous = new java.util.Date(prevLastReportTimestamp)
      logWarning(s"Dropped $droppedEvents events from $name since $previous.")
   }

First time we log previous date, it would be "Thu Jan 01 08:00:00 CST 1970" because of lastReportTimestamp was inited by 0L. Although there is no mistake in theory, AsyncEventQueue's starting time seems better.

Issue Links

• links to: [Github] Pull Request #20053 (Ngone51)