kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix format violations streams scala tests (#5402)
Date Fri, 20 Jul 2018 15:20:43 GMT
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 <manikumar.reddy@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 <wangguoz@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] =


Mime
View raw message