Skip to content

[FLINK-39640][hive] Bump Flink 1.20.0 to 1.20.3 and shade plugin to 3.6.0#40

Open
jlalwani-amazon wants to merge 1 commit into
apache:mainfrom
jlalwani-amazon:flink-1.20.3-bump
Open

[FLINK-39640][hive] Bump Flink 1.20.0 to 1.20.3 and shade plugin to 3.6.0#40
jlalwani-amazon wants to merge 1 commit into
apache:mainfrom
jlalwani-amazon:flink-1.20.3-bump

Conversation

@jlalwani-amazon
Copy link
Copy Markdown

@jlalwani-amazon jlalwani-amazon commented May 8, 2026

What is the purpose of the change

Fix broken CI: Flink 1.20.0 binary is no longer available on Apache download mirrors (only the latest patch release per minor version is hosted). Bump to 1.20.3.

Additionally, Flink 1.20.3 upgraded parquet-hadoop from 1.13.1 to 1.15.2. The parquet 1.15.x line includes multi-release JAR entries with Java 17/22 class files under META-INF/versions/. The inherited maven-shade-plugin:3.2.4 cannot process these, failing with Unsupported class file major version 61. Upgraded to 3.6.0.

JIRA: FLINK-39640

Brief change log

  • Bump flink.version from 1.20.0 to 1.20.3
  • Override maven-shade-plugin version to 3.6.0 (multi-release JAR support)
  • Update CI workflows to reference Flink 1.20.3 binary
  • Fix pre-existing dependency convergence errors from Hive/Hadoop transitive dependencies (pin versions in dependencyManagement)
  • Update NOTICE file for parquet 1.13.1 → 1.15.2
  • Exclude HiveServer2EndpointITCase (FLINK-31351): flaky test that times out on CI. The fix in the main Flink repo (flink-sql-gateway OperationManager) reduced but did not eliminate the race condition on resource-constrained runners.

Verifying this change

CI passed on fork: https://github.com/jlalwani-amazon/flink-connector-hive/actions

mvn clean install -DskipTests
mvn clean install -Phive3 -DskipTests

Does this pull request potentially affect one of the following parts?

  • Dependencies (does it add or upgrade a dependency): yes (Flink patch version bump, shade plugin upgrade, dependency convergence pins)
  • The public API: no
  • The serializers: no
  • The runtime per-record code paths: no
  • Anything that affects deployment or recovery: no

….6.0

Flink 1.20.0 binary is no longer available on Apache download mirrors.
Bump to 1.20.3 which is the current latest 1.20.x release.

Flink 1.20.3 upgraded parquet-hadoop from 1.13.1 to 1.15.2 which
includes multi-release JAR entries with Java 17/22 class files. The
inherited maven-shade-plugin 3.2.4 cannot process these. Upgrade to
3.6.0 which supports multi-release JARs.

Also fix pre-existing dependency convergence errors from Hive/Hadoop
transitive dependencies by pinning versions in dependencyManagement,
and update NOTICE file for the parquet version change.
Comment thread pom.xml
<version>0.13.0</version>
</dependency>
<!-- For dependency convergence: Hive/Hadoop transitive conflicts -->
<dependency>
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

A lot of the dependencies have active CVEs, Can you look into moving the packages to a api version to minimise them without breaking.

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

These are dependency convergence pins to support 1.20.3 . These versions came from 1.20.3. Main has moved to 2.0-preview. I'm not sure if we want to support 1.20.3 in this connector. If not, then this PR is obsolete

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fyi the HTTP connector is going straight to supporting 2.2. I guess it depends on whetehr there is an appetite for a v1.20 version.

@jlalwani-amazon
Copy link
Copy Markdown
Author

Do we still need to support Flink 1.20.x? I can base this off a branch if there is any need to support 1.20.x

Comment thread pom.xml
Comment on lines +391 to +396
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty</artifactId>
<version>3.10.6.Final</version>
</dependency>
<dependency>
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

are you sure we need it?

strategy:
matrix:
flink: [ 1.20.0 ]
flink: [ 1.20.3 ]
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
flink: [ 1.20.3 ]
flink: [ 1.20.4 ]

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants