This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3e862a3 [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer add de7cccc [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem. No new revisions were added by this update. Summary of changes: docs/content.zh/docs/connectors/table/jdbc.md | 126 ++++++-- docs/content.zh/docs/dev/table/catalogs.md | 2 +- docs/content/docs/connectors/table/jdbc.md | 92 ++++-- docs/content/docs/dev/table/catalogs.md | 2 +- .../jdbc/catalog/AbstractJdbcCatalog.java | 133 +++++++- .../connector/jdbc/catalog/JdbcCatalogUtils.java | 3 + .../flink/connector/jdbc/catalog/MySqlCatalog.java | 162 ++++++++++ .../connector/jdbc/catalog/PostgresCatalog.java | 338 ++++---------------- ...lectFactory.java => JdbcDialectTypeMapper.java} | 25 +- .../mysql/{MySQLDialect.java => MySqlDialect.java} | 6 +- ...ialectFactory.java => MySqlDialectFactory.java} | 6 +- .../jdbc/dialect/mysql/MySqlTypeMapper.java | 223 +++++++++++++ .../jdbc/dialect/psql/PostgresTypeMapper.java | 174 +++++++++++ ...flink.connector.jdbc.dialect.JdbcDialectFactory | 2 +- .../flink/connector/jdbc/JdbcDataTypeTest.java | 2 +- .../connector/jdbc/catalog/MySqlCatalogITCase.java | 346 +++++++++++++++++++++ .../jdbc/catalog/MySqlCatalogTestBase.java | 136 ++++++++ .../mysql-scripts/catalog-init-for-test.sql | 107 +++++++ 18 files changed, 1527 insertions(+), 358 deletions(-) create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalog.java copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{mysql/MySQLDialectFactory.java => JdbcDialectTypeMapper.java} (60%) rename flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/{MySQLDialect.java => MySqlDialect.java} (96%) rename flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/{MySQLDialectFactory.java => MySqlDialectFactory.java} (89%) create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlTypeMapper.java create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/psql/PostgresTypeMapper.java create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogITCase.java create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogTestBase.java create mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/mysql-scripts/catalog-init-for-test.sql