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 b4d0943 [hotfix][docs] Fix incorrect Python tableEnvironment
attribute reference
add 2824c90 [FLINK-25010][hive] Speed up hive's createMRSplits by multi
thread (#17988)
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/table/hive/hive_read_write.md | 4 +
.../docs/connectors/table/hive/hive_read_write.md | 4 +
.../hive/ContinuousHiveSplitEnumerator.java | 7 +
.../connectors/hive/HiveLookupTableSource.java | 1 +
.../apache/flink/connectors/hive/HiveOptions.java | 7 +
.../apache/flink/connectors/hive/HiveSource.java | 9 ++
.../flink/connectors/hive/HiveSourceBuilder.java | 2 +
.../connectors/hive/HiveSourceFileEnumerator.java | 75 +++++------
...mFactory.java => HiveTablePartitionSplits.java} | 38 +++---
.../flink/connectors/hive/HiveTableSource.java | 5 +-
.../flink/connectors/hive/MRSplitsGetter.java | 142 +++++++++++++++++++++
.../hive/read/HiveInputFormatPartitionReader.java | 5 +
.../connectors/hive/read/HiveTableInputFormat.java | 35 +++--
.../connectors/hive/PartitionMonitorTest.java | 1 +
.../read/HiveInputFormatPartitionReaderITCase.java | 2 +
15 files changed, 265 insertions(+), 72 deletions(-)
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HadoopFileSystemFactory.java
=> HiveTablePartitionSplits.java} (53%)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/MRSplitsGetter.java
