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