This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 94e4d2a [FLINK-20665][connector-fs][table] FileNotFoundException when
restore from latest Checkpoint in Sink Compaction
add 7ca2dd3 [FLINK-19435][connectors/jdbc] Add hang test case to reveal
deadlock when loading different sql driver classes concurrently using
Class.forName
add 84ed653 [FLINK-19435][connectors/jdbc] Fix deadlock when loading
different sql driver classes concurrently using Class.forName
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-connector-jdbc/pom.xml | 13 +
.../flink/connector/jdbc/JdbcInputFormat.java | 6 +
.../connection/SimpleJdbcConnectionProvider.java | 12 +
.../connector/jdbc/table/JdbcLookupFunction.java | 6 +
.../jdbc/table/JdbcRowDataLookupFunction.java | 6 +
.../flink/connector/jdbc/fakedb/FakeDBUtils.java | 30 +-
.../jdbc/fakedb/driver/FakeConnection.java | 318 +++++++++++++++++++++
.../jdbc/fakedb/driver/FakeConnection1.java} | 9 +-
.../jdbc/fakedb/driver/FakeConnection2.java} | 9 +-
.../connector/jdbc/fakedb/driver/FakeDriver1.java | 82 ++++++
.../connector/jdbc/fakedb/driver/FakeDriver2.java | 82 ++++++
...onProviderDriverClassConcurrentLoadingTest.java | 102 +++++++
.../resources/META-INF/services/java.sql.Driver} | 3 +-
13 files changed, 655 insertions(+), 23 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/cost/FlinkCostBase.scala
=>
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/FakeDBUtils.java
(60%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection.java
copy
flink-connectors/{flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV111.java
=>
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection1.java}
(79%)
copy
flink-connectors/{flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV111.java
=>
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection2.java}
(79%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver1.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver2.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderDriverClassConcurrentLoadingTest.java
copy
flink-connectors/{flink-connector-elasticsearch7/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=> flink-connector-jdbc/src/test/resources/META-INF/services/java.sql.Driver}
(87%)
