You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/04 13:31:16 UTC
[18/19] flink git commit: [FLINK-8697] Rename DummyFlinkKafkaConsumer
in Kinesis tests This closes #5809.
[FLINK-8697] Rename DummyFlinkKafkaConsumer in Kinesis tests This closes #5809.
This closes #5785.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/897dc515
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/897dc515
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/897dc515
Branch: refs/heads/release-1.5
Commit: 897dc515a5b9efbe8df9c8415162145bdea83002
Parents: d7b1257
Author: Bowen Li <bo...@gmail.com>
Authored: Tue Apr 3 13:53:23 2018 -0700
Committer: zentol <ch...@apache.org>
Committed: Wed Apr 4 14:26:54 2018 +0200
----------------------------------------------------------------------
.../connectors/kinesis/internals/KinesisDataFetcherTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/897dc515/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
index 7854d03..ccf39d0 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
@@ -113,7 +113,7 @@ public class KinesisDataFetcherTest extends TestLogger {
// FlinkKinesisConsumer is responsible for setting up the fetcher before it can be run;
// run the consumer until it reaches the point where the fetcher starts to run
- final DummyFlinkKafkaConsumer<String> consumer = new DummyFlinkKafkaConsumer<>(TestUtils.getStandardProperties(), fetcher, 1, 0);
+ final DummyFlinkKinesisConsumer<String> consumer = new DummyFlinkKinesisConsumer<>(TestUtils.getStandardProperties(), fetcher, 1, 0);
CheckedThread consumerThread = new CheckedThread() {
@Override
@@ -171,7 +171,7 @@ public class KinesisDataFetcherTest extends TestLogger {
subscribedStreamsToLastSeenShardIdsUnderTest,
FakeKinesisBehavioursFactory.nonReshardedStreamsBehaviour(streamToShardCount));
- final DummyFlinkKafkaConsumer<String> consumer = new DummyFlinkKafkaConsumer<>(
+ final DummyFlinkKinesisConsumer<String> consumer = new DummyFlinkKinesisConsumer<>(
TestUtils.getStandardProperties(), fetcher, 1, 0);
CheckedThread consumerThread = new CheckedThread() {
@@ -609,7 +609,7 @@ public class KinesisDataFetcherTest extends TestLogger {
assertEquals(streamShardHandle, KinesisDataFetcher.convertToStreamShardHandle(kinesisStreamShard));
}
- private static class DummyFlinkKafkaConsumer<T> extends FlinkKinesisConsumer<T> {
+ private static class DummyFlinkKinesisConsumer<T> extends FlinkKinesisConsumer<T> {
private static final long serialVersionUID = 1L;
private final KinesisDataFetcher<T> fetcher;
@@ -618,7 +618,7 @@ public class KinesisDataFetcherTest extends TestLogger {
private final int subtaskIndex;
@SuppressWarnings("unchecked")
- DummyFlinkKafkaConsumer(
+ DummyFlinkKinesisConsumer(
Properties properties,
KinesisDataFetcher<T> fetcher,
int numParallelSubtasks,