I am trying to use the Kinesis Connector and getting the following error message. I am not getting any data at all because of this. I have a native KCL client running in parallel and it is receiving data fine.
Any thoughts?
flink-sbistl919-taskexecutor-0-CACSVML-15736.log:2018-11-09
07:46:11,579 WARN org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy - Got recoverable
SdkClientException. Backing off for 258 millis (Rate exceeded for shard shardId-000000000000
in stream CSV under account 496346111546. (Service: AmazonKinesis; Status Code:
400; Error Code: ProvisionedThroughputExceededException; Request ID:
e1c0caa4-8c4c-7738-b59f-4977bc762cf3))
flink-sbistl919-taskexecutor-0-CACSVML-15736.log:2018-11-09
07:46:16,844 WARN org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy - Got recoverable
SdkClientException. Backing off for 203 millis (Rate exceeded for shard
shardId-000000000001 in stream CSV under account 496346111546. (Service:
AmazonKinesis; Status Code: 400; Error Code:
ProvisionedThroughputExceededException; Request ID:
f7d22c26-96f6-c547-a38d-affe493cd2e1))
Locked
