[KAFKA-7316] Use of filter method in KTable.scala may result in StackOverflowError

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.0.1, 2.1.0
• Component/s: streams
• Labels: scala
• Assignee: Joan Goyeau
• Reporter: Ted Yu
• Created: 21/Aug/18 00:16
• Updated: 31/Oct/18 08:58
• Resolved: 17/Sep/18 16:25

Description

In this thread:

http://search-hadoop.com/m/Kafka/uyzND1dNbYKXzC4F1?subj=Issue+in+Kafka+2+0+0+

Druhin reported seeing StackOverflowError when using filter method from KTable.scala

This can be reproduced with the following change:

diff --git a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala b/streams/streams-scala/src/test/scala
index 3d1bab5..e0a06f2 100644
--- a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala
+++ b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala
@@ -58,6 +58,7 @@ class StreamToTableJoinScalaIntegrationTestImplicitSerdes extends StreamToTableJ
     val userClicksStream: KStream[String, Long] = builder.stream(userClicksTopic)

     val userRegionsTable: KTable[String, String] = builder.table(userRegionsTopic)
+    userRegionsTable.filter { case (_, count) => true }

     // Compute the total per region by summing the individual click counts per region.
     val clicksPerRegion: KTable[String, Long] =

Issue Links

• relates to: KAFKA-7521 [kafka-streams-scala_2.11] Foreach results in StackOverflowError
• links to: GitHub Pull Request #5538
• links to: GitHub Pull Request #5543