Github user kailashhd commented on a diff in the pull request:
https://github.com/apache/flink/pull/5992#discussion_r188481158
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java
---
@@ -97,8 +228,7 @@ public void testClientConfigOverride() {
AmazonKinesis kinesisClient = Whitebox.getInternalState(proxy,
"kinesisClient");
ClientConfiguration clientConfiguration =
Whitebox.getInternalState(kinesisClient,
- "clientConfiguration");
+ "clientConfiguration");
assertEquals(9999, clientConfiguration.getSocketTimeout());
}
-
--- End diff --
Done. Sorry for the inconvenience.
---
