You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by le...@apache.org on 2022/06/24 12:03:52 UTC

[flink] branch master updated (cef491eab34 -> d0cee16e6db)

This is an automated email from the ASF dual-hosted git repository.

leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from cef491eab34 [FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators
     add d0cee16e6db [FLINK-27794][connectors/jdbc] Fix the wrong primary key for MysqlCatalog when there are tables with same name in different databases

No new revisions were added by this update.

Summary of changes:
 .../jdbc/catalog/AbstractJdbcCatalog.java          | 21 ++++++--
 .../flink/connector/jdbc/catalog/MySqlCatalog.java |  2 +-
 .../connector/jdbc/catalog/MySqlCatalogITCase.java | 48 ++++++++++++++++--
 .../jdbc/catalog/MySqlCatalogTestBase.java         | 58 +++++++++++++++-------
 .../mysql-scripts/catalog-init-for-test.sql        | 32 ++++++++++--
 5 files changed, 128 insertions(+), 33 deletions(-)