From 87749b93c9b05574737cd96b4a37ed1b71a74031 Mon Sep 17 00:00:00 2001
From: Cristian <me@cristian.io>
Date: Mon, 18 Dec 2017 15:56:03 -0800
Subject: [PATCH] [hotfix] Fix typo in TestableKinesisDataFetcher

This closes #5178
---
 .../kinesis/testutils/TestableKinesisDataFetcher.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java
index d111546c138..5d7626210f5 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java
@@ -53,7 +53,7 @@ public class TestableKinesisDataFetcher extends KinesisDataFetcher<String> {
 			List<String> fakeStreams,
 			Properties fakeConfiguration,
 			int fakeTotalCountOfSubtasks,
-			int fakeTndexOfThisSubtask,
+			int fakeIndexOfThisSubtask,
 			AtomicReference<Throwable> thrownErrorUnderTest,
 			LinkedList<KinesisStreamShardState> subscribedShardsStateUnderTest,
 			HashMap<String, String> subscribedStreamsToLastDiscoveredShardIdsStateUnderTest,
@@ -61,7 +61,7 @@ public class TestableKinesisDataFetcher extends KinesisDataFetcher<String> {
 		super(fakeStreams,
 			getMockedSourceContext(),
 			fakeCheckpointLock,
-			getMockedRuntimeContext(fakeTotalCountOfSubtasks, fakeTndexOfThisSubtask),
+			getMockedRuntimeContext(fakeTotalCountOfSubtasks, fakeIndexOfThisSubtask),
 			fakeConfiguration,
 			new KinesisDeserializationSchemaWrapper<>(new SimpleStringSchema()),
 			thrownErrorUnderTest,
@@ -105,7 +105,7 @@ public class TestableKinesisDataFetcher extends KinesisDataFetcher<String> {
 		return Mockito.mock(SourceFunction.SourceContext.class);
 	}
 
-	private static RuntimeContext getMockedRuntimeContext(final int fakeTotalCountOfSubtasks, final int fakeTndexOfThisSubtask) {
+	private static RuntimeContext getMockedRuntimeContext(final int fakeTotalCountOfSubtasks, final int fakeIndexOfThisSubtask) {
 		RuntimeContext mockedRuntimeContext = Mockito.mock(RuntimeContext.class);
 
 		Mockito.when(mockedRuntimeContext.getNumberOfParallelSubtasks()).thenAnswer(new Answer<Integer>() {
@@ -118,7 +118,7 @@ public class TestableKinesisDataFetcher extends KinesisDataFetcher<String> {
 		Mockito.when(mockedRuntimeContext.getIndexOfThisSubtask()).thenAnswer(new Answer<Integer>() {
 			@Override
 			public Integer answer(InvocationOnMock invocationOnMock) throws Throwable {
-				return fakeTndexOfThisSubtask;
+				return fakeIndexOfThisSubtask;
 			}
 		});
 
@@ -132,7 +132,7 @@ public class TestableKinesisDataFetcher extends KinesisDataFetcher<String> {
 		Mockito.when(mockedRuntimeContext.getTaskNameWithSubtasks()).thenAnswer(new Answer<String>() {
 			@Override
 			public String answer(InvocationOnMock invocationOnMock) throws Throwable {
-				return "Fake Task (" + fakeTndexOfThisSubtask + "/" + fakeTotalCountOfSubtasks + ")";
+				return "Fake Task (" + fakeIndexOfThisSubtask + "/" + fakeTotalCountOfSubtasks + ")";
 			}
 		});
 
-- 
GitLab