[jira] [Created] (FLINK-5953) Sample Kinesis Scala code doesn't work

[Shang Yuanchun (Jira)]

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)