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.
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
54
views
asked 4 days 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
369
views
asked a month 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
88
views
asked 8 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
75
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
112
views
asked a year 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
82
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
93
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
281
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
99
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
143
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
61
views
asked 2 years agolg...
We are trying to run a Query on AWS Kinesis, and use autoscaling.
We found that if user specified the Parallelism option in AWS Kinesis configuration, AWS Kinesis will apply the specified parallelism...
0
answers
0
votes
55
views
asked 2 years agolg...
- 1
- 12 / page