Hi Joe,
there was a follow-up issue, FLINK-23450, which was only fixed for 1.13.3
(not yet released) which I think is what you're seeing?
Best
Ingo
On Fri, Aug 6, 2021, 21:17 Joseph Lorenzini wrote:
> Hi all,
>
>
>
> I am on flink 1.13.2. I set up create table like so:
>
>
>
> CREATE TABLE le
Hi all,
I am on flink 1.13.2. I set up create table like so:
CREATE TABLE lead_buffer (
`id` INT NOT NULL,
`state` STRING NOT NULL,
PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
'connector'= 'kafka',
'topic' = 'buffer',
'format'= 'debezium-avro-confluent',
'debeziu
