Re: Flink JDBC: Disable auto-commit mode

2019-04-15 Thread Rong Rong
> >> >> *From:* Papadopoulos, Konstantinos >> >> *Sent:* Δευτέρα, 15 Απριλίου 2019 12:30 μμ >> *To:* Fabian Hueske >> *Cc:* Rong Rong ; user >> *Subject:* RE: Flink JDBC: Disable auto-commit mode >> >> >> >> Hi Fabian, >>

Re: Flink JDBC: Disable auto-commit mode

2019-04-15 Thread Fabian Hueske
se/FLINK-12198 > > > > Best, > > Konstantinos > > > > *From:* Papadopoulos, Konstantinos > > *Sent:* Δευτέρα, 15 Απριλίου 2019 12:30 μμ > *To:* Fabian Hueske > *Cc:* Rong Rong ; user > *Subject:* RE: Flink JDBC: Disable auto-commit mode > > > > Hi F

RE: Flink JDBC: Disable auto-commit mode

2019-04-15 Thread Papadopoulos, Konstantinos
de.com>> Cc: Rong Rong mailto:walter...@gmail.com>>; user mailto:user@flink.apache.org>> Subject: Re: Flink JDBC: Disable auto-commit mode Hi Konstantinos, This sounds like a useful extension to me. Would you like to create a Jira issue and contribute the improvement? In the mea

RE: Flink JDBC: Disable auto-commit mode

2019-04-15 Thread Papadopoulos, Konstantinos
Hi Fabian, Glad to hear that you agree for such an improvement. Of course, I can handle it. Best, Konstantinos From: Fabian Hueske Sent: Δευτέρα, 15 Απριλίου 2019 11:56 πμ To: Papadopoulos, Konstantinos Cc: Rong Rong ; user Subject: Re: Flink JDBC: Disable auto-commit mode Hi Konstantinos

Re: Flink JDBC: Disable auto-commit mode

2019-04-15 Thread Fabian Hueske
tch) to achieve our purpose. > > > > Thanks, > > Konstantinos > > > > *From:* Rong Rong > *Sent:* Παρασκευή, 12 Απριλίου 2019 6:50 μμ > *To:* Papadopoulos, Konstantinos > > *Cc:* user > *Subject:* Re: Flink JDBC: Disable auto-commit mode > > > > Hi Kons

RE: Flink JDBC: Disable auto-commit mode

2019-04-14 Thread Papadopoulos, Konstantinos
To: Papadopoulos, Konstantinos Cc: user Subject: Re: Flink JDBC: Disable auto-commit mode Hi Konstantinos, Seems like setting for auto commit is not directly possible in the current JDBCInputFormatBuilder. However there's a way to specify the fetch size [1] for your DB round-trip, do

Re: Flink JDBC: Disable auto-commit mode

2019-04-12 Thread Rong Rong
Hi Konstantinos, Seems like setting for auto commit is not directly possible in the current JDBCInputFormatBuilder. However there's a way to specify the fetch size [1] for your DB round-trip, doesn't that resolve your issue? Similarly in JDBCOutputFormat, a batching mode was also used to stash up

Flink JDBC: Disable auto-commit mode

2019-04-12 Thread Papadopoulos, Konstantinos
Hi all, We are facing an issue when trying to integrate PostgreSQL with Flink JDBC. When you establish a connection to the PostgreSQL database, it is in auto-commit mode. It means that each SQL statement is treated as a transaction and is automatically committed, but this functionality results