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.


---

Reply via email to