This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 216f65f [hotfix][runtime] Remove ExecutionSlotAllocator#stop() which
is never used in production
add f59b8b4 [FLINK-18232][hive] Fix Hive streaming source bugs
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSource.java | 7 +-
.../hive/read/DirectoryMonitorDiscovery.java | 32 +++++++-
.../hive/read/HiveMapredSplitReader.java | 49 +++++-------
.../hive/read/HiveTableFileInputFormat.java | 19 ++++-
.../connectors/hive/HiveTableSourceITCase.java | 10 ++-
.../hive/read/DirectoryMonitorDiscoveryTest.java | 90 ++++++++++++++++++++++
.../hive/read/HiveTableFileInputFormatTest.java | 33 ++++----
7 files changed, 183 insertions(+), 57 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/read/DirectoryMonitorDiscoveryTest.java
copy
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemRecoverableWriterTest.java
=>
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormatTest.java
(54%)
