Hi Philipp,

It sounds this is a bug, can you create a JIRA issue for this problem?

Thanks, vino.

2018-07-23 2:01 GMT+08:00 Philipp Bussche <philipp.bussche@gmail.com>:
Hi there,

when trying to use a KinesisProducer which has both aws.region and
aws.endpoint set I am receiving the following error message:

07/22/2018 19:52:42     Source: EventStream -> (Sink: Unnamed, EventAndVenueMap
-> (Filter, Sink: EventToInventorySink), Sink: ElasticSearchEventsSink)(4/8)
switched to FAILED
java.lang.IllegalArgumentException: Either AWS region ('aws.region') or AWS
endpoint ('aws.region') must be set in the config.
        at
org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtil.validateAwsConfiguration(KinesisConfigUtil.java:248)
        at
org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtil.getValidatedProducerConfiguration(KinesisConfigUtil.java:191)
        at
org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer.open(FlinkKinesisProducer.java:210)

However when I am only using aws.endpoint (since I want to test against a
local Kinesalite instance) I am getting this:

07/22/2018 19:59:42     Source: EventStream -> (Sink: Unnamed, EventAndVenueMap
-> (Filter, Sink: EventToInventorySink), Sink: ElasticSearchEventsSink)(2/8)
switched to FAILED
java.lang.NullPointerException
        at java.util.regex.Matcher.getTextLength(Matcher.java:1283)
        at java.util.regex.Matcher.reset(Matcher.java:309)
        at java.util.regex.Matcher.<init>(Matcher.java:229)
        at java.util.regex.Pattern.matcher(Pattern.java:1093)
        at java.util.regex.Pattern.matches(Pattern.java:1134)
        at
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration.setRegion(KinesisProducerConfiguration.java:1279)

It seems that the KinesisProducer needs the aws.region set but can't have
both set which would mean I can't test against my local instance of
Kinesalite anymore with 1.4.2 ? This was working fine in 1.3.2 as having
both set then wasn't picked up as a problem.

Thanks
Philipp



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/