[
https://issues.apache.org/jira/browse/FLINK-12198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantinos Papadopoulos updated FLINK-12198:
----------------------------------------------
Description:
The required modifications will be performed in JDBCInputFormat.class (i.e.,
org.apache.flink.api.java.io.jdbc package) as follows:
* A new Boolean field should be added to enable/disable auto-commit mode.
* The 'openInputFormat' function will be updated to set auto-commit mode if
the aforementioned field has no null value.
* JDBCInputFormatBuilder static class will be modified adding a new function
to set auto-commit mode.
was:
The required modifications will be performed in JDBCInputFormat class (i.e.,
com.iri.aa.etl.jdbc package) as follows:
* A new Boolean field should be added to enable/disable auto-commit mode.
* The 'openInputFormat' function will be updated to set auto-commit mode if
the aforementioned field has no null value.
* JDBCInputFormatBuilder static class will be modified adding a new function
to set auto-commit mode.
> Flink JDBC Connector: Update existing JDBCInputFormat to support setting
> auto-commit mode of DB connection
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-12198
> URL: https://issues.apache.org/jira/browse/FLINK-12198
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / JDBC
> Affects Versions: 1.8.0
> Reporter: Konstantinos Papadopoulos
> Priority: Major
> Original Estimate: 8h
> Remaining Estimate: 8h
>
> The required modifications will be performed in JDBCInputFormat.class (i.e.,
> org.apache.flink.api.java.io.jdbc package) as follows:
> * A new Boolean field should be added to enable/disable auto-commit mode.
> * The 'openInputFormat' function will be updated to set auto-commit mode if
> the aforementioned field has no null value.
> * JDBCInputFormatBuilder static class will be modified adding a new function
> to set auto-commit mode.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
