请问老师，这种自定义source读取mysql数据如何做到实时读取呢，每次都是读完表里的存量数据，程序就退出了，那样是没办法做到实时读取增量吗？

如果在run()方法中，添加一个 private boolean flag = true;如下图，这样只会循环读已经读过的

@Override
    public void run(SourceContext<Student> ctx) throws Exception {
    while (flag){
        ResultSet rs = psmt.executeQuery();
        while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");
            ctx.collect(new Student(id, name, age));
            Thread.sleep(2000);
        }
      }
    }