Matt Pouttu-clarke created FLINK-7035:
-----------------------------------------
Summary: Flink Kinesis connector forces hard coding the AWS Region
Key: FLINK-7035
URL: https://issues.apache.org/jira/browse/FLINK-7035
Project: Flink
Issue Type: Bug
Components: Kinesis Connector
Affects Versions: 1.3.1, 1.2.0
Environment: All AWS Amazon Linux nodes (including EMR) and AWS Lambda
functions.
Reporter: Matt Pouttu-clarke
Hard coding the region frequently causes cross-region network access which can
in the worst cases could cause brown-out of AWS services and nodes, violation
of availability requirements per region, security and compliance issues, and
extremely poor performance for the end user's jobs. All AWS nodes and services
are aware of the region they are running in, please see:
https://aws.amazon.com/blogs/developer/determining-an-applications-current-region/
Need to change the following line of code to use Regions.getCurrentRegion()
rather than throwing an exception. Also, code examples should be changed to
reflect correct practices.
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java#L174
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
