Registry / data / apache-flink-libraries

apache-flink-libraries

library2.2.1pypypiunverified

Python library providing Flink libraries (e.g., connectors, state backend interfaces) for building streaming applications with Apache Flink. Version 2.2.0 supports Python >=3.9. Release cadence follows Flink major versions (~1-2 years).

data workflow

pip install apache-flink-libraries

package ↗homepage ↗

INSTALL

IMPORT

SIG · APACHE-FLINK-LIBRA

apache-flink-libraries

datapythonv2.2.1

Install

6.7s avg

Import

—

Disk

330MB

Pass rate

10/ 10

Env Coverage10 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v2.2.1 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

py 3.10–3.95 runs

installs and imports cleanly · install 0.0s · import 0.000s · 332.2MB

glibc

py 3.10–3.95 runs

installs and imports cleanly · install 6.7s · import 0.000s · 333MB

330MB installed

● package 330MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

FlinkLibraries

✓ from pyflink import FlinkLibraries

✗ from pyflink_libraries import FlinkLibraries

Initialize Flink table environment and use Kafka connector.

from pyflink_libraries import FlinkLibraries from pyflink_libraries.connectors import KafkaConnector from pyflink.table import EnvironmentSettings, TableEnvironment # Create batch table environment settings = EnvironmentSettings.in_batch_mode() tenv = TableEnvironment.create(settings) # Example: use Kafka connector kafka = KafkaConnector( properties={'bootstrap.servers': 'localhost:9092'}, topic='test-topic' ) print('Flink Libraries %s loaded successfully' % FlinkLibraries.__version__)

Debug

Known issues

breakingIn version 2.0+, the package structure changed from 'apache-flink-libraries' to 'pyflink_libraries' as the Python import name. Code using old imports will break.

fix

Update imports to use 'pyflink_libraries' as the package name.

affects: >=2.0.0

gotchaThis library is separate from the main 'apache-flink' Python package. Do not confuse the two; install and import both if needed.

fix

Install 'apache-flink' for core Flink API and 'apache-flink-libraries' for additional libraries.

affects: all

gotchaThe library requires a Flink cluster or a local session to run. TableEnvironment creation may fail if no Flink service is available.

fix

Ensure a Flink cluster is running or use local execution with appropriate settings.

affects: all

Upgrade

Version history

2.2.1latest on PyPI · released May 15, 2026

Audit

Dependencies

No dependency data recorded yet.

Agent activity

55 hits · last 30 days

node

OpenAI (training)

Resources

packagehttps://pypi.org/project/apache-flink-libraries/ ↗

homepagehttps://flink.apache.org ↗