Repository: flink Updated Branches: refs/heads/release-1.5 5896840b1 -> 7763f7f68
[FLINK-8945] [kinesis] Allow customization of KinesisProxy Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7763f7f6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7763f7f6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7763f7f6 Branch: refs/heads/release-1.5 Commit: 7763f7f680fec162e27855f792760bcc3820b799 Parents: 5896840 Author: Kailash HD <[email protected]> Authored: Wed Mar 14 09:20:12 2018 -0700 Committer: Stephan Ewen <[email protected]> Committed: Fri Mar 16 13:52:51 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/7763f7f6/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);
