This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
from 98e4258c [FLINK-34961] Use dedicated CI name for Hive connector to
differentiate it in infra-reports
new 84a16e1b [FLINK-35702][parquet] support parquet read nested in nested
(#24991)
new 141964e6 [hotfix][parquet] Fix dependences and variable name problems
in FLINK-35702 (#25004)
new bb52a874 [FLINK-36085][table] Refactor SHOW operations with LIKE/ILIKE
new 05d8cdc0 [FLINK-36249][streaming-java] Remove RestartStrategy-related
configuration getters/setters that return/set complex Java objects.
new 42004db0 [FLINK-29741][scala] Remove flink-scala and
flink-streaming-scala dependency exclude table module
new 82ef7b8e [FLINK-36273][table] Remove all deprecated configuration in
2.0 in flink-connector-hive module
new 463292a0 [FLINK-36369][table] Move deprecated user-visible classes in
table-common to the legacy package
new 327a7d58 [FLINK-36369][table] Move deprecated user-visible classes in
table-api-java-bridge to the legacy package
new 3e281029 [FLINK-36366][core] Remove deprecate API in flink-core
exclude connector and state part
new ed05a8a3 [FLINK-36245] Relocate deprecated SourceFunction /
SinkFunction and remove deprecated Sink V1 in 2.0 (#25331)
new 96935281 [FLINK-36336] Remove deprecated dataset API exclude table
module
new 32a4703a [hotfix] Remove minor unused deprecated method/class
new 9045295d [hotfix] Make it compilable with Flink 2.0-preview
new 399d2aec [hotfix] Use jdk11 as minimum for Flink 2.0
new f94c0202 [hotfix] Dependency convergence
The 15 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/push_pr.yml | 10 +----
.../docs/connectors/table/hive/hive_read_write.md | 2 +-
.../docs/connectors/table/hive/overview.md | 6 +--
.../docs/connectors/table/hive/hive_read_write.md | 2 +-
.../content/docs/connectors/table/hive/overview.md | 6 +--
flink-connector-hive-e2e-tests/pom.xml | 8 ++--
flink-connector-hive/pom.xml | 21 +++++-----
.../HiveDynamicParallelismInferenceFactory.java | 8 +---
.../connectors/hive/HiveLookupTableSource.java | 2 +-
.../apache/flink/connectors/hive/HiveOptions.java | 17 +-------
.../connectors/hive/HiveParallelismInference.java | 1 -
.../flink/connectors/hive/HiveSourceBuilder.java | 3 --
.../HiveStaticParallelismInferenceFactory.java | 7 +---
.../flink/connectors/hive/HiveTableFactory.java | 8 ++--
.../flink/connectors/hive/HiveTableSink.java | 4 +-
.../hive/read/HiveBulkFormatAdapter.java | 48 ----------------------
.../connectors/hive/read/HiveSourceSplit.java | 16 --------
.../hive/write/HiveOutputFormatFactory.java | 2 +-
.../flink/table/catalog/hive/HiveCatalog.java | 4 +-
.../hive/client/HiveMetastoreClientWrapper.java | 2 +-
.../flink/table/catalog/hive/client/HiveShim.java | 2 +-
.../table/catalog/hive/client/HiveShimV100.java | 2 +-
.../table/catalog/hive/client/HiveShimV210.java | 2 +-
.../table/catalog/hive/client/HiveShimV310.java | 2 +-
.../table/catalog/hive/util/HiveTableUtil.java | 2 +-
.../hive/parse/HiveParserDDLSemanticAnalyzer.java | 17 +++++---
.../hive/HiveDynamicPartitionPruningITCase.java | 10 ++++-
.../hive/HiveDynamicTableFactoryTest.java | 17 --------
.../connectors/hive/HiveSinkCompactionITCase.java | 5 ++-
.../connectors/hive/HiveTableFactoryTest.java | 10 ++---
.../flink/connectors/hive/HiveTableSinkITCase.java | 8 ++--
.../connectors/hive/HiveTableSourceITCase.java | 41 +++++++++---------
.../connectors/hive/PartitionMonitorTest.java | 2 +-
.../table/catalog/hive/HiveCatalogUdfITCase.java | 2 +-
.../hive/factories/TestLockTableSinkFactory.java | 10 ++---
flink-sql-connector-hive-2.3.10/pom.xml | 8 ++--
flink-sql-connector-hive-3.1.3/pom.xml | 12 ++++--
pom.xml | 2 +-
38 files changed, 118 insertions(+), 213 deletions(-)
delete mode 100644
flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveBulkFormatAdapter.java
