From d779b43e8a9a4129b5c9494bdc47c91ad5673bce Mon Sep 17 00:00:00 2001 From: Panagiotis Garefalakis Date: Thu, 2 Jun 2022 12:21:50 -0700 Subject: [PATCH] fix: ambiguous reference to close issue --- .../io/confluent/ksql/util/PersistentQueryMetadataTest.java | 2 +- .../java/io/confluent/ksql/util/TransientQueryMetadataTest.java | 2 +- .../server/resources/streaming/StreamedQueryResourceTest.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ksqldb-engine/src/test/java/io/confluent/ksql/util/PersistentQueryMetadataTest.java b/ksqldb-engine/src/test/java/io/confluent/ksql/util/PersistentQueryMetadataTest.java index 7076197d5abc..d849ecbc7c81 100644 --- a/ksqldb-engine/src/test/java/io/confluent/ksql/util/PersistentQueryMetadataTest.java +++ b/ksqldb-engine/src/test/java/io/confluent/ksql/util/PersistentQueryMetadataTest.java @@ -214,7 +214,7 @@ public void shouldCloseKafkaStreamsOnStop() { // Then: final InOrder inOrder = inOrder(kafkaStreams); - inOrder.verify(kafkaStreams).close(any()); + inOrder.verify(kafkaStreams).close(any(java.time.Duration.class)); inOrder.verify(kafkaStreams).state(); inOrder.verifyNoMoreInteractions(); } diff --git a/ksqldb-engine/src/test/java/io/confluent/ksql/util/TransientQueryMetadataTest.java b/ksqldb-engine/src/test/java/io/confluent/ksql/util/TransientQueryMetadataTest.java index ae77e0e747cc..9d980799e9b9 100644 --- a/ksqldb-engine/src/test/java/io/confluent/ksql/util/TransientQueryMetadataTest.java +++ b/ksqldb-engine/src/test/java/io/confluent/ksql/util/TransientQueryMetadataTest.java @@ -118,7 +118,7 @@ public void shouldCloseQueueBeforeTopologyToAvoidDeadLock() { // Then: final InOrder inOrder = inOrder(rowQueue, kafkaStreams); inOrder.verify(rowQueue).close(); - inOrder.verify(kafkaStreams).close(any()); + inOrder.verify(kafkaStreams).close(any(java.time.Duration.class)); } @Test diff --git a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/resources/streaming/StreamedQueryResourceTest.java b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/resources/streaming/StreamedQueryResourceTest.java index 1d5f82a96aaa..ce00339ed981 100644 --- a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/resources/streaming/StreamedQueryResourceTest.java +++ b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/resources/streaming/StreamedQueryResourceTest.java @@ -540,7 +540,7 @@ public void shouldStreamRowsCorrectly() throws Throwable { final KafkaStreamsBuilder kafkaStreamsBuilder = mock(KafkaStreamsBuilder.class); when(kafkaStreamsBuilder.build(any(), any())).thenReturn(mockKafkaStreams); MutableBoolean closed = new MutableBoolean(false); - when(mockKafkaStreams.close(any())).thenAnswer(i -> { + when(mockKafkaStreams.close(any(java.time.Duration.class))).thenAnswer(i -> { closed.setValue(true); return true; });