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 3387fffb05e [FLINK-29337][hive] Fix fail to query non-hive table in
Hive dialect
add ab9e5844703 [FLINK-26726][connector][hive]Hive enumerators do not
assign splits to unregistered (failed) readers
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-connector-hive/pom.xml | 7 +
.../hive/ContinuousHiveSplitEnumerator.java | 8 +
.../hive/ContinuousHiveSplitEnumeratorTest.java | 191 +++++++++++++++++++++
3 files changed, 206 insertions(+)
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/ContinuousHiveSplitEnumeratorTest.java
