Questions tagged with Amazon Kinesis Data Analytics

I'm running this code in a Zeppelin notebook (via Kinesis Analytics Studio), and it is not printing anything: ``` env.fromElements("a", "b", "c").print() env.execute() ```

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...

Hi, We are exploring with KDA for our streaming data ingestion pipeline for ML purpose. From...

Hello, I have Change Capture Data landing into a S3 bucket. The CDC data is from an AWS RDS. This is my starting point. Now, let's say, I have tables taba, tabb, tabc. I have the 3 folders for each...

Getting the below error SYNTAX_ERROR: line 1:15: Schema ecommerce-raw-apsouth1-84245-dev does not exist This query ran against the "" database, unless qualified by the query. Please post the error...

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...

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...

I have an event processing architecture that's basically KPL Producer -> Kinesis Data Streams(Raw) -> KDA(Flink Aggregation) -> Kinesis Data Streams(Agg) -> Lambda -> Timestream . With a basic setup...

Hello, I'm trying to figure out the best way to output messages to SNS from a Flink Kinesis Analytics application. My understanding is firehose has ~60s of latency, which is not acceptable for this...

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...

Hi, we are using X-Ray for application logs tracing but X-Ray is not able to show case all the logs and after some times it drops off the tracing. Is it some limitations with X-Ray or how we can...

We have several desktop (Win/Mac/Nix) monolithic applications that generate JSON events exposing these events via POST. Currently it is a one way deal, outbound from app to the stream for nothing but...