You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/07/20 15:20:43 UTC
[kafka] branch trunk updated: MINOR: Fix format violations streams
scala tests (#5402)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9089fb2 MINOR: Fix format violations streams scala tests (#5402)
9089fb2 is described below
commit 9089fb2d8255b9ea08e083c39c1ec3fe37d78082
Author: Manikumar Reddy O <ma...@gmail.com>
AuthorDate: Fri Jul 20 20:50:36 2018 +0530
MINOR: Fix format violations streams scala tests (#5402)
@guozhangwang @mjsax hot fix for streams scala test format violations
Reviewers: Guozhang Wang <wa...@gmail.com>
---
.../scala/StreamToTableJoinScalaIntegrationTestBase.scala | 10 ++++++----
...treamToTableJoinWithIncompleteMetadataIntegrationTest.scala | 2 +-
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestBase.scala b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestBase.scala
index 78ed591..32ad793 100644
--- a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestBase.scala
+++ b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestBase.scala
@@ -103,9 +103,9 @@ class StreamToTableJoinScalaIntegrationTestBase extends JUnitSuite with StreamTo
}
def produceNConsume(userClicksTopic: String,
- userRegionsTopic: String,
- outputTopic: String,
- waitTillRecordsReceived: Boolean = true): java.util.List[KeyValue[String, Long]] = {
+ userRegionsTopic: String,
+ outputTopic: String,
+ waitTillRecordsReceived: Boolean = true): java.util.List[KeyValue[String, Long]] = {
import collection.JavaConverters._
@@ -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()
}
diff --git a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinWithIncompleteMetadataIntegrationTest.scala b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinWithIncompleteMetadataIntegrationTest.scala
index f5a098b..3bf5977 100644
--- a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinWithIncompleteMetadataIntegrationTest.scala
+++ b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinWithIncompleteMetadataIntegrationTest.scala
@@ -52,7 +52,7 @@ class StreamToTableJoinWithIncompleteMetadataIntegrationTest extends StreamToTab
val userClicksStream: KStream[String, Long] = builder.stream(userClicksTopic)
- val userRegionsTable: KTable[String, String] = builder.table(userRegionsTopic+"1")
+ val userRegionsTable: KTable[String, String] = builder.table(userRegionsTopic + "1")
// Compute the total per region by summing the individual click counts per region.
val clicksPerRegion: KTable[String, Long] =