This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 15f87d4a470 [FLINK-28873][configuration] Make jobmanager.scheduler
visible in documentation
add 3c8402a97a2 [FLINK-28854][connector/jdbc] Migrate JDBC lookup table to
the new LookupFunction and caching interface
No new revisions were added by this update.
Summary of changes:
.../0f94f11b-9bc8-445a-8be8-e7dfd8a384b0} | 0
.../e3f99de4-2505-469a-8910-ce53aec7cd1d | 2 -
.../archunit-violations/stored.rules | 4 +-
.../jdbc/internal/options/JdbcLookupOptions.java | 111 ------------
.../connector/jdbc/table/JdbcConnectorOptions.java | 10 +-
.../jdbc/table/JdbcDynamicTableFactory.java | 51 ++++--
.../jdbc/table/JdbcDynamicTableSource.java | 42 +++--
.../jdbc/table/JdbcRowDataLookupFunction.java | 86 ++-------
.../jdbc/table/JdbcDynamicTableFactoryTest.java | 79 +++++----
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 193 +++++++++++++++++++--
.../connector/jdbc/table/JdbcLookupTestBase.java | 11 +-
.../jdbc/table/JdbcRowDataLookupFunctionTest.java | 131 +++-----------
.../source/lookup/cache/DefaultLookupCache.java | 19 ++
.../table/test/lookup/cache/LookupCacheAssert.java | 97 +++++++++++
14 files changed, 468 insertions(+), 368 deletions(-)
copy
flink-connectors/{flink-connector-aws-base/archunit-violations/33252236-fc9f-4f63-b537-39e2322f7ccd
=>
flink-connector-jdbc/archunit-violations/0f94f11b-9bc8-445a-8be8-e7dfd8a384b0}
(100%)
delete mode 100644
flink-connectors/flink-connector-jdbc/archunit-violations/e3f99de4-2505-469a-8910-ce53aec7cd1d
delete mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcLookupOptions.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/lookup/cache/LookupCacheAssert.java
