Skip to content

[Tech Debt] Update flink version after 1.20.5 & 2.1.3 release. #692

@wenjin272

Description

@wenjin272

Search before asking

  • I searched in the issues and found nothing similar.

Description

In flink-agents, cross-language interaction between Python and Java relies on the pemja framework. Before pemja 0.5.7, errors or JVM crashes could occur when flink-agents performed cross-language interaction from an asynchronous thread. This issue was fixed in pemja 0.5.7: alibaba/pemja#95.
Since flink-agents depends on pemja transitively through PyFlink, adopting pemja 0.5.7 in flink-agents requires the following steps:

  1. Bump the pemja version used by Flink.
  2. Release a Flink version that includes this bump.
  3. Update the Flink version that flink-agents depends on.

Status:

The remaining tasks are:

  1. Release versions 1.20 and 2.1 that include the pemja upgrade.

  2. Update the minor Flink version dependency in dist.

Are you willing to submit a PR?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    fixVersion/0.3.0The feature or bug should be implemented/fixed in the 0.3.0 version.priority/majorDefault priority of the PR or issue.tech debt[Issue Type] User-unaware issues, such as code refactor and infrastructure maintenance.

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions