You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Steve Bistline <sr...@gmail.com> on 2018/11/09 13:00:57 UTC
ProvisionedThroughputExceededException
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))