Hello, I have implemented a custom source that reads tables in parallel, with each split corresponding to a table and custom source implementation can be found here - https://github.com/adasari/mastering-flink/blob/main/app/src/main/java/org/example/paralleljdbc/DatabaseSource.java
However, it seems the source splits are not being scheduled and data is not being read from the tables. Can someone help me identify the issue in the implementation? Thanks
