FranMorilloAWS

[SUPPORT] How to do Schema Evolution with Apache Flink DataStream API when doing CDC?

5

I have an Apache Flink application, that is consuming directly from a database using Flink CDC Connectors, however, I am not able to find any documentation on how to manage...

[SUPPORT] Inconsistent Checkpoint Size in Flink Applications with MoR

14

I have an Apache Flink Application that leverages RockDB and incremental checkpoint, but it seems that every time a compaction task occurs, the checkpoint size of the application during that...

Pinot not loading segments to deep storage, and deletes segments in tmp folders

1

Hi, I am using a Kinesis Consumer, and once the segments reaches number of rows, Pinot is not creating any new segments as well as not being able to upload...

Marquez doesnt create Dataset and Job with Flink Start Event

1

I am trying to use OpenLineage with Amazon Managed Service for Apache Flink. I receive Start Event in Marquez, but it doesnt create the datasets or the job ion the...

[FLINK-29549]- Flink Glue Catalog integration

6

## Purpose of the change *For example: Implements the Table API for the Kinesis Source.* ## Verifying this change Please make sure both new and modified tests in this PR...

## Purpose of the change *For example: modify the Java Kinesis Sink to provide the stream ARN* ## Verifying this change Please test your changes both running locally, in the...