Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5160#discussion_r157281403
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@ -191,6 +191,7 @@ public static KinesisProducerConfiguration
getValidatedProducerConfiguration(Pro
}
KinesisProducerConfiguration kpc =
KinesisProducerConfiguration.fromProperties(config);
+
kpc.setRegion(config.getProperty(AWSConfigConstants.AWS_REGION));
--- End diff --
Does this work if the region property is `null`?
---
