Hi All, I have a Flink streaming Job based on datastream api. My source is Kafka and sink is PostgresDB. For validation, i need to lookup few tables in postgresDB and validate events in Kafka. For this I used the Table API to read the tables required and used broadcast pattern. Now my problem is that since JDBC is a bounded source in Table API, I would like to have an option to somehow rerun the table API fetch. I hoped a job restart would do this, but I think due to checkpointing, it does not rerun the Table API job on job restart. Any idea on how to achieve this ( If at all its possible ) or any alternative.