You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2018/06/22 09:34:30 UTC
[2/6] flink git commit: [FLINK-8945] [kinesis] Allow customization of
KinesisProxy
[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/2ff1279b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ff1279b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2ff1279b
Branch: refs/heads/release-1.4
Commit: 2ff1279bf63555b238670e66f3e0785b0214e00a
Parents: 6ef1e9e
Author: Kailash HD <kd...@lyft.com>
Authored: Wed Mar 14 09:20:12 2018 -0700
Committer: Thomas Weise <th...@apache.org>
Committed: Sun Jun 17 20:59:01 2018 +0200
----------------------------------------------------------------------
.../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/2ff1279b/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 89e9f04..9c7a2da 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
@@ -120,7 +120,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);