Unanswered Questions tagged with Amazon Kinesis
Content language: English
Select up to 5 tags to filter
Sort by most recent
Browse through the questions and answers listed below or filter and sort to narrow down your results.
Hi, I'm trying to figure out if Typescript is supported in Kinesis Data Analytics using Beam. I found this tutorial that uses Java, Flink, &...
0
answers
0
votes
80
views
asked a year agolg...
When calling /joinStorageSession I get a response of {"message":"An internal failure has occurred !"} and a 500 status code on about half of requests. The other requests work as expected. This occurs...
0
answers
0
votes
109
views
asked a year agolg...
The SendSdpOffer documentation states that a viewer can only send an offer to the master. That seems to indicate a single channel cannot be used to create a meeting room of more than 2 participants....
0
answers
0
votes
65
views
asked a year agolg...
Hi there,
I've installed the stream manager via pip, also installed the stream manager component via AWS console and everything looks healthy. I am trying to run these samples from github:...
0
answers
0
votes
140
views
asked a year agolg...
**Please investigate as a matter of urgency**
With regard to the hadoop client classes, there is an incompatibility in the jars loaded from the `/opt/flink/lib` directory. To reproduce the bug,...
0
answers
0
votes
122
views
asked 2 years agolg...
I am trying to use firehose and stream the CloudWatch log to private network (not AWS) HEC. In this case we need to open firewall between two component, as i know firehose is regional based which i...
0
answers
0
votes
58
views
asked 2 years agolg...
What is the AWS recommended way for using Kinesis as a Source with Apache Spark Structured Streaming if running Spark jobs on EMR (not AWS Glue).
There is a [third party open source connector...
0
answers
0
votes
122
views
asked 2 years agolg...
how to you mange application state when using KCL.
I create a simple application which will save my application state on efs when creating checkpoint, but the state is per shard. it willnot work when...
0
answers
0
votes
91
views
asked 2 years agolg...
Error:
HIVE_PARTITION_SCHEMA_MISMATCH: There is a mismatch between the table and partition schemas. The types are incompatible and cannot be coerced. The column 'isfallbackkey' in table...
0
answers
0
votes
199
views
asked 2 years agolg...
In the documentation (https://docs.aws.amazon.com/firehose/latest/dev/controlling-access.html ), there are 2 set of IPs for us to whitelist when using Splunk or RedShift as Kinesis Data Firehose...
0
answers
0
votes
96
views
asked 2 years agolg...
I am using KCL 1.14.8 for Java. My Kinesis only have one shard, and I put a record into Kinesis every 30 seconds. For each record, the RecordProcessor will process it, processing each record may take...
0
answers
0
votes
109
views
asked 2 years agolg...
I am hoping to create a stream of messages, and the stream will be defined by providing an S3 bucket + prefix, and will stream:
1. a list of all existing objects at the given prefix
2. new objects...
0
answers
0
votes
130
views
asked 2 years agolg...