All Content tagged with Amazon Managed Service for Apache Flink

Build and run fully managed Apache Flink applications.

Content language: English

Select tags to filter
Sort by most recent
62 results
I am unable to run successfully the "Getting Started" python example of AWS Managed Flink from the archive https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples.git on AWS....
1
answers
0
votes
92
views
asked a month ago
I have a use case with * 60 MB/sec data volume * Near real time use cases of AI/Data science as downstream applications should be supported * It's not a ultra-low latency use case, even 60 seconds of...
1
answers
0
votes
66
views
asked a month ago
I have enabled **automatic system rollbacks** for an Apache Flink 1.20 application on Managed Service for Apache Flink, but it doesn't seem to trigger. I deployed a new version with state changes, so...
1
answers
0
votes
52
views
asked 2 months ago
Below is an improved version of your message with added clarity and structure: --- Hello, I'm encountering an issue with my PyFlink processing pipeline that uses side output. The pipeline works cor...
1
answers
0
votes
99
views
asked 2 months ago
Hello! I have a system design / architecture problem. Context: The ultimate goal is to ingest battery data from an MQTT broker -> process this data to keep track of each data points state (charging,...
1
answers
0
votes
111
views
asked 3 months ago
I am using Kinesis Studio Notebooks currently, with Zeppelin version 1.15.2 and very happy with this function. I can build app and deploy to Kinesis app after that. However, the currently Zeppelin ver...
1
answers
0
votes
63
views
asked 4 months ago
This article aims to explore an innovative architectural approach that combines real-time data streaming with generative AI, specifically Retrieval Augmented Generation (RAG), to create a cutting-edge...
Don't miss us live on [Twitch.tv](https://bit.ly/4anH9WR) on Monday, November 25th to learn how you can Build Next-Gen Data Platforms using Apache Iceberg.
I have a simple python code of Flink. I am consuming the data from the kafka and then sinking it to opensearch. I have used state and timers for this which is working fine in my local machine. I am ...
1
answers
0
votes
347
views
asked 6 months ago
I have an Apache Flink application for 1.19 runtime with S3 integration. I use flink-s3-fs-hadoop-1.19.1.jar for sending files to S3. JVM version 11. Flink version 1.19 However, on starting this app ...
1
answers
0
votes
121
views
asked 7 months ago
When performing a checkpoint in flink, I get the following error AccessDenied: 27ee2b74c7eed5431eb45d1ab715fefe-991518841123-1727835091122/: User: arn:aws:sts::607606922030:assumed-role/AWSKinesisAnal...
5
answers
0
votes
745
views
asked 7 months ago
Is there a way to hide sensitive runtime properties in AWS Managed Apache Flink (Amazon Kinesis Data Analytics)? They are currently displayed in plain text in the AWS console. Flink supposedly support...
1
answers
0
votes
136
views
asked 8 months ago