@@ -174,7 +174,7 @@ void testTeragrep() {
174174
175175 this .streamingTestUtil .performDPLTest (q , this .testFile , res -> {
176176 List <Row > sourcetypeCol = res .select ("sourcetype" ).distinct ().collectAsList ();
177- Assertions .assertEquals (9 , res .count ());
177+ Assertions .assertEquals (10 , res .count ());
178178 Assertions .assertEquals (1 , sourcetypeCol .size ());
179179 Assertions .assertEquals ("teragrep version" , sourcetypeCol .get (0 ).get (0 ).toString ());
180180
@@ -189,7 +189,7 @@ void testTeragrep() {
189189 Assertions .assertTrue (r .getAs (0 ).toString ().contains ("version:" ));
190190 executedLoops ++;
191191 }
192- Assertions .assertEquals (9 , executedLoops );
192+ Assertions .assertEquals (10 , executedLoops );
193193 });
194194 }
195195
@@ -203,7 +203,7 @@ void testTeragrepSystemVersionWithoutDataset() {
203203
204204 this .streamingTestUtil .performDPLTest (q , this .testFile , res -> {
205205 List <Row > sourcetypeCol = res .select ("sourcetype" ).distinct ().collectAsList ();
206- Assertions .assertEquals (9 , res .count ());
206+ Assertions .assertEquals (10 , res .count ());
207207 Assertions .assertEquals (1 , sourcetypeCol .size ());
208208 Assertions .assertEquals ("teragrep version" , sourcetypeCol .get (0 ).get (0 ).toString ());
209209
@@ -218,7 +218,7 @@ void testTeragrepSystemVersionWithoutDataset() {
218218 Assertions .assertTrue (r .getAs (0 ).toString ().contains ("version:" ));
219219 executedLoops ++;
220220 }
221- Assertions .assertEquals (9 , executedLoops );
221+ Assertions .assertEquals (10 , executedLoops );
222222 });
223223 }
224224
0 commit comments