Repository: flink Updated Branches: refs/heads/master c71f7e1ba -> cb60fd29e
[FLINK-8945] [kinesis] Allow customization of KinesisProxy This closes #5698 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb60fd29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb60fd29 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cb60fd29 Branch: refs/heads/master Commit: cb60fd29e7e46f8015587e9be7ad88f2368fe85a Parents: c71f7e1 Author: Kailash HD <[email protected]> Authored: Wed Mar 14 09:20:12 2018 -0700 Committer: Stephan Ewen <[email protected]> Committed: Fri Mar 16 13:51:45 2018 +0100 ---------------------------------------------------------------------- .../flink/streaming/connectors/kinesis/proxy/KinesisProxy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cb60fd29/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java index da81a65..057e18d 100644 --- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java +++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java @@ -122,7 +122,7 @@ public class KinesisProxy implements KinesisProxyInterface { * * @param configProps configuration properties containing AWS credential and AWS region info */ - private KinesisProxy(Properties configProps) { + protected KinesisProxy(Properties configProps) { checkNotNull(configProps); this.kinesisClient = AWSUtil.createKinesisClient(configProps);
