Unanswered Questions tagged with Amazon Kinesis Data Analytics
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.
According to AWS docs:
*You are charged an hourly rate based on the number of Kinesis Processing Units (KPUs) used to run your applications. A single KPU comprises 1 vCPU compute and 4 GB of memory....
0
answers
0
votes
385
views
asked 11 days agolg...
We'd like to migrate from AWS Managed Apache Flink to our self-hosted Flink cluster on EKS. As part of this, we need to migrate Flink operator states to the new cluster.
From my understanding this...
0
answers
0
votes
368
views
asked a month agolg...
I am working on apache flink application using python API. so it requires jar file to be packaged. I have multiple jar files as dependency. In order to use them, i need to mention them in runtime...
0
answers
0
votes
387
views
asked 2 months agolg...
Hello All,
I m doing one AWS workshop(Data Engineering Immersion Day), as part of workshop, I have to create sql application(legacy), but now AWS deprecated that feature to create new applications. ...
0
answers
0
votes
104
views
asked 9 months agolg...
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
83
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
127
views
asked 2 years agolg...
I'm trying to retrieve 1-week old events from AWS pinpoint and store into S3 bucket via Kinesis Firehose. But I cannot find any documentation for how to retrieve old data.
Can someone please advise...
0
answers
0
votes
97
views
asked 2 years agolg...
Currently I am trying out a KDA + Flink setup and first thing that stops me a little bit is failover strategy. There is only one option for a failover: take savepoint -> destroy cluster -> start new...
0
answers
0
votes
109
views
asked 2 years agolg...
I saw that in Flink 1.15, this was added(https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/ops/state/task_failure_recovery/) but I need to handle the scenario of my source and sink(which...
0
answers
0
votes
288
views
asked 2 years agolg...
Hello,
I am having trouble to properly handle query with tumbling window. My application sends 15 sensor data messages per second to Kinesis Data Stream, which is used as an input stream for Kinesis...
0
answers
0
votes
106
views
asked 2 years agolg...
I followed [this AWS blog post](https://aws.amazon.com/blogs/aws/introducing-amazon-kinesis-data-analytics-studio-quickly-interact-with-streaming-data-using-sql-python-or-scala/) to create KDA app,...
0
answers
1
votes
152
views
asked 2 years agolg...
My application writes text data to a Kinesis Stream using pipe symbol as field separator. I've defined a table in Glue and specified CSV with the | separator. It's defined as a 3 column table and each...
0
answers
0
votes
67
views
asked 2 years agolg...