This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d3c4472 [hotfix][tests] Replace mock ConsumerRecords with
ConsumerRecords.empty
d3c4472 is described below
commit d3c4472d3992ebcc906c0c9b5770244716b4c5cf
Author: tison <[email protected]>
AuthorDate: Sun Apr 28 01:00:38 2019 +0800
[hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty
---
.../flink/streaming/connectors/kafka/internal/HandoverTest.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java
b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java
index 5bd4aff..1ec740d 100644
---
a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java
+++
b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java
@@ -31,7 +31,6 @@ import java.util.concurrent.TimeoutException;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
-import static org.mockito.Mockito.mock;
/**
* Tests for the {@link Handover} between Kafka Consumer Thread and the
fetcher's main thread.
@@ -285,9 +284,8 @@ public class HandoverTest {
producer.sync();
}
- @SuppressWarnings("unchecked")
private static ConsumerRecords<byte[], byte[]> createTestRecords() {
- return mock(ConsumerRecords.class);
+ return ConsumerRecords.empty();
}
//
------------------------------------------------------------------------
