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.
---