rciea
>
>
>
> *From: *Dylan Forciea
> *Date: *Monday, December 7, 2020 at 5:33 PM
> *To: *"user@flink.apache.org"
> *Subject: *Re: Batch loading into postgres database
>
>
>
> As a follow up – I’m trying to follow the approach I outlined be
the series of steps that I went through, if
anybody has any suggestions!
Thanks,
Dylan Forciea
From: Dylan Forciea
Date: Monday, December 7, 2020 at 5:33 PM
To: "user@flink.apache.org"
Subject: Re: Batch loading into postgres database
As a follow up – I’m trying to follow the
As a follow up – I’m trying to follow the approach I outlined below, and I’m
having trouble figuring out how to perform the step of doing the delete/insert
after the job is complete.
I’ve tried adding a job listener, like so, but that doesn’t seem to ever get
fired off:
val statementSet =
