Matthew Billson created FLINK-5953:
--------------------------------------
Summary: Sample Kinesis Scala code doesn't work
Key: FLINK-5953
URL: https://issues.apache.org/jira/browse/FLINK-5953
Project: Flink
Issue Type: Bug
Components: Documentation
Affects Versions: 1.2.0
Reporter: Matthew Billson
Priority: Minor
In the Scala Kinesis example here:
https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/kinesis.html
we see the following:
val consumerConfig = new Properties();
consumerConfig.put(ConsumerConfigConstants.AWS_REGION, "us-east-1");
consumerConfig.put(ConsumerConfigConstants.AWS_ACCESS_KEY_ID,
"aws_access_key_id");
consumerConfig.put(ConsumerConfigConstants.AWS_SECRET_ACCESS_KEY,
"aws_secret_access_key");
consumerConfig.put(ConsumerConfigConstants.STREAM_INITIAL_POSITION, "LATEST");
but in Scala ConsumerConfigConstants does not inherit the static members of
AWSConfigConstants and so only the 4th line of this actually works.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
