Fixed PulsarAvroTableSinkTest

apache · Jan 4, 2019 · cee76bc · cee76bc
1 parent bfb9bd7
commit cee76bc
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/...k/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarAvroTableSinkTest.java b/...k/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarAvroTableSinkTest.java
@@ -92,7 +92,6 @@ private PulsarAvroTableSink spySink() throws Exception {
                 Mockito.anyString(),
                 Mockito.anyString(),
                 Mockito.any(SerializationSchema.class),
-                Mockito.any(PowerMockito.class),
                 Mockito.any(PulsarKeyExtractor.class)
         ).thenReturn(producer);
         Whitebox.setInternalState(sink, "fieldNames", fieldNames);

diff --git a/...k/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarJsonTableSinkTest.java b/...k/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarJsonTableSinkTest.java
@@ -86,7 +86,6 @@ private PulsarJsonTableSink spySink() throws Exception {
                 Mockito.anyString(),
                 Mockito.anyString(),
                 Mockito.any(SerializationSchema.class),
-                Mockito.any(PowerMockito.class),
                 Mockito.any(PulsarKeyExtractor.class)
         ).thenReturn(producer);
         Whitebox.setInternalState(sink, "fieldNames", fieldNames);