[Snyk] Security upgrade org.apache.flink:flink-streaming-java_2.12 from 1.13.5 to 1.14.0

[malhanpraveen]

Snyk has created this PR to fix 1 vulnerabilities in the maven dependencies of this project.

Snyk changed the following file(s):

• pom.xml

Vulnerabilities that will be fixed with an upgrade:

	Issue	Score	Upgrade
	NULL Pointer Dereference SNYK-JAVA-ORGLZ4-18313067	701	org.apache.flink:flink-streaming-java_2.12: 1.13.5 -> 1.14.0 No Known Exploit

Breaking Change Risk

Notice: This assessment is enhanced by AI.

---

Important

• Check the changes in this PR to ensure they won't cause issues with your project.
• Max score is 1000. Note that the real score may have changed since the PR was raised.
• This PR was automatically created by Snyk using the credentials of a real user.

---

Note: You are seeing this because you or someone else with access to this repository has authorized Snyk to open fix PRs.

For more information:
🧐 View latest project report
📜 Customise PR templates
🛠 Adjust project settings
📚 Read about Snyk's upgrade logic

---

Learn how to fix vulnerabilities with free interactive lessons:

🦉 NULL Pointer Dereference

[malhanpraveen]

The upgrade to Apache Flink 1.14.0 is a minor version update but includes significant breaking changes that require developer action.

Key Breaking Changes:

• Legacy SQL Engine Removed: The old (pre-Blink) SQL engine has been completely removed. This action also removed many outdated interfaces that were associated with it. If your application uses custom connectors or user-defined functions that were built against the legacy interfaces, they will need to be updated to use the current APIs.
• Mesos Support Removed: Support for Apache Mesos has been dropped in this version.

Other Notable Changes:

• Checkpointing for Bounded Streams: Flink 1.14 introduces the ability to take a final checkpoint when a bounded stream finishes, ensuring sinks commit all data. This is an opt-in feature and is not enabled by default.

Recommendation:
Before upgrading, carefully review any custom SQL integrations, connectors, or functions to ensure they are compatible with the default Blink SQL engine's APIs. Migrations from the legacy SQL engine's interfaces are required.

Source: Apache Flink 1.14.0 Release Announcement

Notice 🤖: This content was augmented using artificial intelligence. AI-generated content may contain errors and should be reviewed for accuracy before use.