>
>>
>> *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,
>>
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
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
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
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
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
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
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