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

Posted to commits@inlong.apache.org by zi...@apache.org on 2022/08/02 02:04:11 UTC

[inlong] branch master updated (fcc30cbaa -> 635c974dd)

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

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


    from fcc30cbaa [INLONG-5308][Dashboard] Change MQ and cluster type to adapt the Manager module (#5310)
     add 635c974dd [INLONG-4814][Sort][Manager] Declare the primary key for sink table when the query contains update/delete (#4882)

No new revisions were added by this update.

Summary of changes:
 .../manager/pojo/sort/util/LoadNodeUtils.java      |   3 +-
 .../protocol/node/load/ClickHouseLoadNode.java     |  15 +-
 .../protocol/node/load/ClickHouseLoadNodeTest.java |   4 +-
 .../sort/jdbc/dialect/ClickHouseDialect.java       |  36 +++++
 .../sort/parser/ClickHouseSqlParserTest.java       |   5 +-
 inlong-sort/sort-end-to-end-tests/pom.xml          |  11 +-
 .../apache/inlong/sort/tests/ClickHouseCase.java   | 163 +++++++++++++++++++++
 .../test/resources/flinkSql/clickhouse_test.sql    |  33 +++++
 8 files changed, 263 insertions(+), 7 deletions(-)
 create mode 100644 inlong-sort/sort-end-to-end-tests/src/test/java/org/apache/inlong/sort/tests/ClickHouseCase.java
 create mode 100644 inlong-sort/sort-end-to-end-tests/src/test/resources/flinkSql/clickhouse_test.sql