Re: PostgreSQL JDBC connection drops after inserting some records

2020-01-28 Thread Fabian Hueske
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

Re: PostgreSQL JDBC connection drops after inserting some records

2020-01-28 Thread Arvid Heise
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

PostgreSQL JDBC connection drops after inserting some records

2020-01-23 Thread Soheil Pourbafrani
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