Liang-Chi Hsieh 19478bdf52 [SPARK-36109][SS][TEST] Check data after adding data to topic in KafkaSourceStressSuite ... ### What changes were proposed in this pull request? This patch proposes to check data after adding data to topic in `KafkaSourceStressSuite`. ### Why are the changes needed? The test logic in `KafkaSourceStressSuite` is not stable. For example, https://github.com/apache/spark/runs/3049244904. Once we add data to a topic and then delete the topic before checking data, the expected answer is different to retrieved data from the sink. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Existing tests. Closes #33311 from viirya/stream-assert. Authored-by: Liang-Chi Hsieh <viirya@gmail.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org> (cherry picked from commit 201566cdd5) Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>		2021-07-13 01:22:06 -07:00
..
src	[SPARK-36109][SS][TEST] Check data after adding data to topic in KafkaSourceStressSuite	2021-07-13 01:22:06 -07:00
pom.xml	[SPARK-35838][BUILD][TESTS] Ensure all modules can be maven test independently in Scala 2.13	2021-06-22 06:31:24 -07:00