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
