Hi,
The exception is thrown by Postgres.
I'd start investigating there what the problem is.
Maybe you need to tweak your Postgres configuration, but it might also be
that the Flink connector needs to be differently configured.
If the necessary config option is missing, it would be good to add.
H
Hi Soheil,
what is your actual question? Did the application eventually finish or does
it keep restarting?
In general, communication with external systems may fail from time to time.
Only if it persists, we would explore it. If it is very rare, a restart
should already help.
Best,
Arvid
On Thu
Hi,
I have a peace of Flink Streaming code that reads data from files and
inserts them into the PostgreSQL table. After inserting 6 to 11 million
records, I got the following errors:
*Caused by: java.lang.RuntimeException: Execution of JDBC statement failed.
at
org.apache.fli