Hey all.  Hopefully this is an easy question.  I'm porting my JDBC postgres
sink from 1.10 to 1.12

I'm using:
* StreamTableEnvironment
* JdbcUpsertTableSink

What I'm having difficulty with is how to register the sink with the
streaming table environment.

In 1.10:

    tableEnv.registerTableSink(
>       s"${interval}_maalka_jdbc_output_table",
>       jdbcTableSink)


This method doesn't exist in 1.12, what is the equivalent?

Thanks!
Clay

Reply via email to