python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - amazon-kinesis-analytics

Apache Flink : Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Could not serialize inputs

I have a Flink-1.13 program that reads data from a Kinesis stream containing records with different schemas. My program iterates over all the possible schemas contained into the stream, filters a main...
test-img

nach0

apache-flink

flink-streaming

amazon-kinesis

amazon-kinesis-analytics

Votes: 0

Answers: 0

Flink - DynamoDB source

I'm new working with real-time applications. Currently, I'm using AWS Kinesis/Flink and Scala I have the following architecture: old architecture As you can see I consume a CSV file using CSVTableSour...
test-img

Felipe Jorquera Uribe

scala

amazon-dynamodb

apache-flink

amazon-kinesis-analytics

Votes: 0

Answers: 1

Latest Answer

You could use a RichFlatMapFunction to open DynamoDB client and lookup data from DynamoDB. A sample code is given below. public static class DynamoDBMapper extends RichFlatMapFunction < IN, OUT >...
test-img

naba

Posts

Questions

Blogs

Jobs