fixed build issues

Author: Claudenw

kcbq-connector/pom.xml

@@ -42,11 +42,6 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>org.awaitility</groupId>
-            <artifactId>awaitility</artifactId>
-            <scope>test</scope>
-        </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>connect-api</artifactId>

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/BigQuerySinkTaskTest.java

@@ -23,7 +23,6 @@
 
 package com.wepay.kafka.connect.bigquery;
 
-import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertThrows;
@@ -58,7 +57,6 @@
 import com.wepay.kafka.connect.bigquery.write.storage.StorageApiBatchModeHandler;
 import com.wepay.kafka.connect.bigquery.write.storage.StorageWriteApiDefaultStream;
 import java.net.SocketTimeoutException;
-import java.time.Duration;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
@@ -1123,11 +1121,10 @@ public void testStop() {
     testTask.initialize(sinkTaskContext);
     testTask.start(properties);
     testTask.put(Collections.singletonList(spoofSinkRecord(topic)));
-    await().atMost(Duration.ofSeconds(5)).untilAsserted( () -> assertEquals(1, testTask.getTaskThreadsActiveCount()));
-//    assertEquals(1, testTask.getTaskThreadsActiveCount());
+
+    assertEquals(1, testTask.getTaskThreadsActiveCount());
     testTask.stop();
-    await().atMost(Duration.ofSeconds(5)).untilAsserted( () -> assertEquals(0, testTask.getTaskThreadsActiveCount()));
-//    assertEquals(0, testTask.getTaskThreadsActiveCount());
+    assertEquals(0, testTask.getTaskThreadsActiveCount());
     verify(bigQuery, times(1)).insertAll(any(InsertAllRequest.class));
 
     assertThrows(

pom.xml

@@ -62,7 +62,6 @@
 
         <main.dir>${project.basedir}</main.dir>
         <skip.unit.tests>${maven.test.skip}</skip.unit.tests>
-        <awaitility.version>4.2.1</awaitility.version>
     </properties>
 
     <name>kafka-connect-bigquery-parent</name>
@@ -125,12 +124,6 @@
 
     <dependencyManagement>
         <dependencies>
-            <dependency>
-                <groupId>org.awaitility</groupId>
-                <artifactId>awaitility</artifactId>
-                <version>${awaitility.version}</version>
-                <scope>test</scope>
-            </dependency>
             <dependency>
                 <groupId>com.google.cloud</groupId>
                 <artifactId>libraries-bom</artifactId>