[SQL][STREAMING][TEST] Follow up to remove Option.contains for Scala 2.10 compatibility
## What changes were proposed in this pull request? Scala 2.10 does not have Option.contains, which broke Scala 2.10 build. ## How was this patch tested? Locally compiled and ran sql/core unit tests in 2.10 Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #15531 from tdas/metrics-flaky-test-fix-1.
This commit is contained in:
parent
7d878cf2da
commit
a9e79a41ee
|
@ -216,7 +216,9 @@ trait StreamTest extends QueryTest with SharedSQLContext with Timeouts {
|
|||
}
|
||||
}
|
||||
|
||||
def isStreamWaitingAt(time: Long): Boolean = synchronized { waitStartTime.contains(time) }
|
||||
def isStreamWaitingAt(time: Long): Boolean = synchronized {
|
||||
waitStartTime == Some(time)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Reference in a new issue