MINOR: Fix format violations streams scala tests
@mjsax hot fix for streams scala test format violations
Reviewers: Guozhang Wang
@@ -129,7 +129,9 @@ class StreamToTableJoinScalaIntegrationTestBase extends JUnitSuite with StreamTo
// consume and verify result
val consumerConfig = getConsumerConfig()
- IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(consumerConfig, outputTopic, expectedClicksPerRegion.size)
+ IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(consumerConfig,
+ outputTopic,
+ expectedClicksPerRegion.size)
} else {
java.util.Collections.emptyList()
}
