This is an automated email from the ASF dual-hosted git repository.
libenchao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1d33773e6b7 [FLINK-25509][connector-base] Add RecordEvaluator to
dynamically stop source based on de-serialized records
add 25798e8b2ed [FLINK-31521][jdbc-driver] Initialize jdbc driver modules
in flink-table
No new revisions were added by this update.
Summary of changes:
.../pom.xml | 54 ++++-----------
.../flink-sql-jdbc-driver}/pom.xml | 46 +++---------
.../org/apache/flink/table/jdbc/FlinkDriver.java | 81 ++++++++++++++++++++++
.../resources/META-INF/services/java.sql.Driver | 2 +-
flink-table/pom.xml | 2 +
5 files changed, 108 insertions(+), 77 deletions(-)
copy flink-table/{flink-table-planner-loader-bundle =>
flink-sql-jdbc-driver-bundle}/pom.xml (60%)
copy {flink-connectors/flink-connector-datagen =>
flink-table/flink-sql-jdbc-driver}/pom.xml (59%)
create mode 100644
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkDriver.java
copy
flink-end-to-end-tests/flink-plugins-test/dummy-fs/src/main/resources/META-INF/services/org.apache.flink.core.fs.FileSystemFactory
=>
flink-table/flink-sql-jdbc-driver/src/main/resources/META-INF/services/java.sql.Driver
(95%)
