commit 00c4040dabca263da663f730c2f0519d02f72be0
author Maksim Timonin <timoninmaxim@apache.org> Wed Apr 12 19:16:27 2023 +0300
committer GitHub <noreply@github.com> Wed Apr 12 19:16:27 2023 +0300
tree 4bf26b1235c2709b37a3f3251793875d1aadfae5
parent 1a2d00870870909416e80af6f0ec16c658cfa21d
parent 3959d6afca84e074ff2e4d7b55a0f65f89fb8c4d

IGNITE-18532 Fix runners join loop waits for the excess thread

modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java

diff --git a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
index a8d28e1..27de527 100644
--- a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
+++ b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
@@ -179,8 +179,8 @@
         }
 
         try {
-            for (int i = 0; i < threadCnt + 1; i++)
-                runners.get(i).join();
+            for (Thread run: runners)
+                run.join();
         }
         catch (InterruptedException e) {
             stopped.set(true);