This is an automated email from the ASF dual-hosted git repository. xvrl pushed a commit to branch kafka-3.1 in repository https://gitbox.apache.org/repos/asf/druid.git
commit 539ff0479442859dbfad57fffc6b456ab1e03081 Author: Xavier Léauté <[email protected]> AuthorDate: Fri Jan 28 08:24:46 2022 -0800 remove mock calls that were not verified before --- .../lookup/KafkaLookupExtractorFactoryTest.java | 22 ---------------------- 1 file changed, 22 deletions(-) diff --git a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/KafkaLookupExtractorFactoryTest.java b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/KafkaLookupExtractorFactoryTest.java index c2aafaf..8b0a7f1 100644 --- a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/KafkaLookupExtractorFactoryTest.java +++ b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/KafkaLookupExtractorFactoryTest.java @@ -400,12 +400,6 @@ public class KafkaLookupExtractorFactoryTest @Test public void testStartFailsOnMissingConnect() { - EasyMock.expect(cacheManager.createCache()) - .andReturn(cacheHandler) - .once(); - EasyMock.expect(cacheHandler.getCache()).andReturn(new ConcurrentHashMap<>()).once(); - cacheHandler.close(); - PowerMock.replay(cacheManager); final KafkaLookupExtractorFactory factory = new KafkaLookupExtractorFactory( cacheManager, TOPIC, @@ -417,18 +411,11 @@ public class KafkaLookupExtractorFactoryTest () -> factory.start() ); Assert.assertTrue(factory.close()); - PowerMock.verify(cacheManager); } @Test public void testStartFailsOnGroupID() { - EasyMock.expect(cacheManager.createCache()) - .andReturn(cacheHandler) - .once(); - EasyMock.expect(cacheHandler.getCache()).andReturn(new ConcurrentHashMap<>()); - cacheHandler.close(); - PowerMock.replay(cacheManager, cacheHandler); final KafkaLookupExtractorFactory factory = new KafkaLookupExtractorFactory( cacheManager, TOPIC, @@ -440,19 +427,11 @@ public class KafkaLookupExtractorFactoryTest () -> factory.start() ); Assert.assertTrue(factory.close()); - PowerMock.verify(cacheManager); } @Test public void testStartFailsOnAutoOffset() { - EasyMock.expect(cacheManager.createCache()) - .andReturn(cacheHandler) - .once(); - EasyMock.expect(cacheHandler.getCache()).andReturn(new ConcurrentHashMap<>()).once(); - cacheHandler.close(); - EasyMock.expectLastCall(); - PowerMock.replay(cacheManager); final KafkaLookupExtractorFactory factory = new KafkaLookupExtractorFactory( cacheManager, TOPIC, @@ -464,7 +443,6 @@ public class KafkaLookupExtractorFactoryTest () -> factory.start() ); Assert.assertTrue(factory.close()); - PowerMock.verify(cacheManager); } @Test --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
