This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7b7c604 [hotfix][conf] Correct config option reference in
resourcemanager.standalone.start-up-time
add ef78c2e [hotfix][connectors/jdbc] Rename JdbcOutputFormat to
JdbcRowOutputFormat
add 2702691 [hotfix][connectors/jdbc] Merge Batching and Abstract into
JdbcOutputFormat
add f2f2524 [hotfix][connectors/jdbc] Rename
JdbcDynamicOutputFormatBuilder to JdbcOutputFormatBuilder
add d502353 [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC
sink
No new revisions were added by this update.
Summary of changes:
...cOutputFormat.java => JdbcRowOutputFormat.java} | 18 +++---
.../org/apache/flink/connector/jdbc/JdbcSink.java | 17 ++---
.../jdbc/internal/AbstractJdbcOutputFormat.java | 72 ----------------------
.../jdbc/internal/GenericJdbcSinkFunction.java | 14 ++++-
...hingOutputFormat.java => JdbcOutputFormat.java} | 66 ++++++++++++++++----
.../jdbc/internal/TableJdbcUpsertOutputFormat.java | 3 +-
.../connector/jdbc/table/JdbcDynamicTableSink.java | 2 +-
...atBuilder.java => JdbcOutputFormatBuilder.java} | 30 +++++----
.../connector/jdbc/table/JdbcUpsertTableSink.java | 11 ++--
.../connector/jdbc/xa/JdbcXaSinkFunction.java | 36 ++++++-----
.../flink/connector/jdbc/JdbcDataTestBase.java | 4 +-
.../apache/flink/connector/jdbc/JdbcITCase.java | 66 ++++++++++++++++++++
...ormatTest.java => JdbcRowOutputFormatTest.java} | 26 ++++----
.../flink/connector/jdbc/JdbcTestFixture.java | 30 +++++++--
.../connector/jdbc/internal/JdbcFullTest.java | 12 ++--
.../jdbc/internal/JdbcTableOutputFormatTest.java | 2 +-
.../jdbc/table/JdbcAppendOnlyWriterTest.java | 6 +-
...utFormatTest.java => JdbcOutputFormatTest.java} | 26 ++++----
.../connector/jdbc/xa/JdbcXaSinkTestBase.java | 25 ++++----
flink-python/pyflink/datastream/connectors.py | 2 +-
20 files changed, 262 insertions(+), 206 deletions(-)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{JdbcOutputFormat.java
=> JdbcRowOutputFormat.java} (91%)
delete mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/AbstractJdbcOutputFormat.java
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/{JdbcBatchingOutputFormat.java
=> JdbcOutputFormat.java} (86%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/{JdbcDynamicOutputFormatBuilder.java
=> JdbcOutputFormatBuilder.java} (91%)
rename
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{JdbcOutputFormatTest.java
=> JdbcRowOutputFormatTest.java} (94%)
rename
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/{JdbcDynamicOutputFormatTest.java
=> JdbcOutputFormatTest.java} (96%)
