You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gi...@apache.org on 2025/01/15 07:17:26 UTC
(flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 updated (c6b8b4e5 -> 7f0fdb93)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/commons-net-commons-net-3.9.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
discard c6b8b4e5 Bump commons-net:commons-net from 3.6 to 3.9.0
add 30bfa216 [hotfix] flink-connector-hive artifactId with scala version
add 04213267 [hotfix] Add release tools as submodule
add bb951091 [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)
add 12926764 Revert "[FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)"
add 74c0ad0d [FLINK-33905][core] Unify the provision of metadata in RuntimeContext
add d8522747 [hotfix] Bump Flink to 1.19.0
add 38d857f5 [FLINK-33705] Upgrade to flink-shaded 18.0
add 917e84ce [hotfix] Use guava instead of flink-shaded
add d96d0357 [FLINK-34081][configuration] Refactor all callers of deprecated `getXxx(ConfigOption<Xxx>)`, `getXxx(ConfigOption<Xxx>, Xxx)` and `setXxx(ConfigOption<Integer>, Xxx)` methods of Configuration
add 756b1d9b [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig
add da3c3bac [FLINK-16627][json] Support ignore null fields when serializing into JSON
add ddbb538e [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)
add 55f1063f [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory
add 66c3d014 [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator.
add ddf03a30 [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777)
add b5d928a6 [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table
add 54dfc322 [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix.
add cab36b34 [FLINK-35293][hive] Hive source supports dynamic parallelism inference
add 31e841cc [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core (#24881)
add e7a0158d [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (#24905)
add 71723093 [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 adapt for external connector
add 4aefc5b4 [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style
add 56740edd [FLINK-35656][hive] Fix the issue that Hive Source incorrectly set max parallelism in dynamic inference mode
add 204c8bdc [hotfix] Apply 1.20.0 in github ci
add e9b15d59 [hotfix] Dependency convergence
add 9a845b4f [hotfix] Update dependencies
add 7f0fdb93 Bump commons-net:commons-net from 3.6 to 3.9.0
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (c6b8b4e5)
\
N -- N -- N refs/heads/dependabot/maven/commons-net-commons-net-3.9.0 (7f0fdb93)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/push_pr.yml | 14 +-
.github/workflows/weekly.yml | 10 +-
.gitmodules | 4 +
.../docs/connectors/table/hive/hive_catalog.md | 12 +-
.../docs/connectors/table/hive/hive_read_write.md | 15 +-
.../docs/connectors/table/hive/overview.md | 9 +-
.../docs/connectors/table/hive/hive_catalog.md | 12 +-
.../docs/connectors/table/hive/hive_read_write.md | 17 +-
.../content/docs/connectors/table/hive/overview.md | 9 +-
.../26d337fc-45c4-4d03-a84a-6692c37fafbc | 8 +-
flink-connector-hive/pom.xml | 23 +-
.../hive/ContinuousHiveSplitEnumerator.java | 4 +-
.../HiveDynamicParallelismInferenceFactory.java | 79 ++++++
.../apache/flink/connectors/hive/HiveOptions.java | 53 +++-
.../connectors/hive/HiveParallelismInference.java | 33 ++-
.../apache/flink/connectors/hive/HiveSource.java | 55 +++-
.../flink/connectors/hive/HiveSourceBuilder.java | 34 ++-
.../hive/HiveSourceDynamicFileEnumerator.java | 3 +-
.../connectors/hive/HiveSourceFileEnumerator.java | 4 +
.../HiveStaticParallelismInferenceFactory.java | 64 +++++
.../flink/connectors/hive/HiveTableSink.java | 11 +-
.../flink/connectors/hive/HiveTableSource.java | 9 +-
.../table/catalog/hive/client/HiveShimLoader.java | 4 +
.../{HiveShimV121.java => HiveShimV2310.java} | 4 +-
.../table/endpoint/hive/HiveServer2Endpoint.java | 5 -
.../hive/util/OperationExecutorFactory.java | 12 +-
.../hive/util/ThriftObjectConversions.java | 2 +-
.../delegation/hive/HiveParserConstants.java | 2 +
.../delegation/hive/parse/FromClauseASTParser.g | 3 +
.../planner/delegation/hive/parse/HiveASTParser.g | 7 +
.../delegation/hive/parse/IdentifiersASTParser.g | 24 ++
.../delegation/hive/parse/SelectClauseASTParser.g | 3 +
.../connectors/hive/FlinkEmbeddedHiveRunner.java | 3 +-
.../connectors/hive/FlinkStandaloneHiveRunner.java | 5 +-
...portSQL11ReservedKeywordAsIdentifierITTest.java | 223 +++++++++++++++
.../connectors/hive/HiveRunnerShimLoader.java | 1 +
.../hive/HiveSourceDynamicFileEnumeratorTest.java | 17 +-
.../flink/connectors/hive/HiveSourceITCase.java | 2 +-
.../flink/connectors/hive/HiveSourceTest.java | 304 +++++++++++++++++++++
.../flink/connectors/hive/HiveTableSinkITCase.java | 52 ++--
.../connectors/hive/HiveTableSourceITCase.java | 40 +--
.../hive/HiveTableSpeculativeSinkITCase.java | 12 +-
.../table/catalog/hive/HiveCatalogITCase.java | 3 +-
.../table/catalog/hive/HiveCatalogUdfITCase.java | 4 +-
.../flink/table/catalog/hive/HiveTestUtils.java | 21 ++
.../endpoint/hive/HiveServer2EndpointITCase.java | 53 ++--
.../HiveServer2DelegationTokenProviderITCase.java | 28 +-
.../pom.xml | 10 +-
.../src/main/resources/META-INF/NOTICE | 29 +-
.../main/resources/META-INF/licenses/LICENSE.antlr | 0
.../resources/META-INF/licenses/LICENSE.javolution | 0
.../main/resources/META-INF/licenses/LICENSE.jodd | 0
.../main/resources/META-INF/licenses/LICENSE.kryo | 0
.../resources/META-INF/licenses/LICENSE.minlog | 0
.../resources/META-INF/licenses/LICENSE.protobuf | 0
.../resources/META-INF/licenses/LICENSE.reflectasm | 0
.../resources/META-INF/licenses/LICENSE.slf4j-api | 0
flink-sql-connector-hive-3.1.3/pom.xml | 12 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
pom.xml | 18 +-
tools/releasing/shared | 1 +
61 files changed, 1145 insertions(+), 243 deletions(-)
create mode 100644 .gitmodules
create mode 100644 flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicParallelismInferenceFactory.java
create mode 100644 flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveStaticParallelismInferenceFactory.java
copy flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/{HiveShimV121.java => HiveShimV2310.java} (90%)
create mode 100644 flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectSupportSQL11ReservedKeywordAsIdentifierITTest.java
create mode 100644 flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceTest.java
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/pom.xml (94%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/NOTICE (79%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.antlr (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.javolution (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.jodd (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.kryo (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.minlog (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.protobuf (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.reflectasm (100%)
rename {flink-sql-connector-hive-2.3.9 => flink-sql-connector-hive-2.3.10}/src/main/resources/META-INF/licenses/LICENSE.slf4j-api (100%)
create mode 160000 tools/releasing/shared