Hi Clay, I am not a Table API expert but let me try to answer your question:
With FLINK-17748 [1] the community removed the registerTableSink in favour of the connect API. The connect API has been deprecated [2] because it was not well maintained. Now the recommended way for specifying sinks is to use Flink's DDL [3]. Unfortunately, I couldn't find an easy example on how to use the DDL. Maybe Timo or Jark can point you towards a good guide on how to register your jdbc table sink. [1] https://issues.apache.org/jira/browse/FLINK-17748 [2] https://issues.apache.org/jira/browse/FLINK-18416 [3] https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sourceSinks.html Cheers, Till On Tue, Feb 16, 2021 at 4:42 PM Clay Teeter <clay.tee...@maalka.com> wrote: > 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 > >
