Hi Nadia You don't need to call `Env.execute("Flink CDC Job");` because the job will be submitted after executing `Result.executeInsert("mysql_table");`.
Best, Feng On Mon, Nov 18, 2024 at 12:05 PM Nadia Mujeeb <nadiamujeeb...@gmail.com> wrote: > > So my task is to set up a Apache flink in my Linux Ubuntu wherein I should > be having two data bases as postgress and MySQL . > The 2 data bases should be connected in such a way that any change or > update in my postgres database should I immediately reflect in my SQL > database. > > But this is error I'm encountering while running my flink job. Pls help > sir.. >