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 11550ed [FLINK-21333] Add StopWithSavepoint state to adaptive
scheduler
add c0cf91c [FLINK-21894][hive] Update type of
HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String>
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveLookupTableSource.java | 8 +-
.../flink/connectors/hive/HiveTablePartition.java | 6 +-
.../flink/connectors/hive/HiveTableSource.java | 9 +--
.../hive/read/HiveBulkFormatAdapter.java | 36 +++++++--
.../hive/read/HiveCompactReaderFactory.java | 16 +---
.../hive/read/HiveMapredSplitReader.java | 14 +++-
.../hive/read/HiveVectorizedOrcSplitReader.java | 15 +++-
.../read/HiveVectorizedParquetSplitReader.java | 13 ++-
.../connectors/hive/util/HivePartitionUtils.java | 94 +++++++++++++---------
.../flink/connectors/hive/util/JobConfUtils.java | 36 +++++----
.../table/catalog/hive/util/HiveTypeUtil.java | 26 +++++-
.../functions/hive/conversion/HiveInspectors.java | 5 ++
.../connectors/hive/PartitionMonitorTest.java | 2 +-
13 files changed, 174 insertions(+), 106 deletions(-)
copy
flink-clients/src/main/java/org/apache/flink/client/cli/ApplicationDeployer.java
=>
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/util/JobConfUtils.java
(51%)
