{"id":23270,"library":"apache-flink-libraries","title":"Apache Flink Libraries for Python","description":"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).","status":"active","version":"2.2.0","language":"python","source_language":"en","source_url":"https://github.com/apache/flink","tags":["flink","streaming","data","connectors","state"],"install":[{"cmd":"pip install apache-flink-libraries","lang":"bash","label":"PyPI Install"}],"dependencies":[],"imports":[{"note":"Correct import uses 'pyflink_libraries' as the package name.","wrong":"from apache_flink_libraries import FlinkLibraries","symbol":"FlinkLibraries","correct":"from pyflink_libraries import FlinkLibraries"},{"note":"Connectors are under 'pyflink_libraries.connectors'.","wrong":"from pyflink.connectors import KafkaConnector","symbol":"KafkaConnector","correct":"from pyflink_libraries.connectors import KafkaConnector"},{"note":"State backends are under 'pyflink_libraries.state'.","wrong":"from pyflink.state import RocksDBStateBackend","symbol":"RocksDBStateBackend","correct":"from pyflink_libraries.state import RocksDBStateBackend"}],"quickstart":{"code":"from pyflink_libraries import FlinkLibraries\nfrom pyflink_libraries.connectors import KafkaConnector\nfrom pyflink.table import EnvironmentSettings, TableEnvironment\n\n# Create batch table environment\nsettings = EnvironmentSettings.in_batch_mode()\ntenv = TableEnvironment.create(settings)\n\n# Example: use Kafka connector\nkafka = KafkaConnector(\n    properties={'bootstrap.servers': 'localhost:9092'},\n    topic='test-topic'\n)\n\nprint('Flink Libraries %s loaded successfully' % FlinkLibraries.__version__)","lang":"python","description":"Initialize Flink table environment and use Kafka connector."},"warnings":[{"fix":"Update imports to use 'pyflink_libraries' as the package name.","message":"In 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.","severity":"breaking","affected_versions":">=2.0.0"},{"fix":"Install 'apache-flink' for core Flink API and 'apache-flink-libraries' for additional libraries.","message":"This library is separate from the main 'apache-flink' Python package. Do not confuse the two; install and import both if needed.","severity":"gotcha","affected_versions":"all"},{"fix":"Ensure a Flink cluster is running or use local execution with appropriate settings.","message":"The library requires a Flink cluster or a local session to run. TableEnvironment creation may fail if no Flink service is available.","severity":"gotcha","affected_versions":"all"}],"env_vars":null,"last_verified":"2026-05-01T00:00:00.000Z","next_check":"2026-07-30T00:00:00.000Z","problems":[{"fix":"Use 'from pyflink_libraries import ...' instead.","cause":"Incorrect import path after version 2.0.0.","error":"ModuleNotFoundError: No module named 'apache_flink_libraries'"},{"fix":"Run 'pip install apache-flink' to install the core Flink Python API.","cause":"Missing 'apache-flink' core package.","error":"ModuleNotFoundError: No module named 'pyflink'"},{"fix":"Start a Flink cluster (e.g., 'docker-compose up -d') or configure local execution mode.","cause":"No Flink cluster is running or configured.","error":"pyflink_libraries.exceptions.FlinkRuntimeError: Cannot find a suitable Flink cluster"}],"ecosystem":"pypi","meta_description":null,"install_score":null,"install_tag":null,"quickstart_score":null,"quickstart_tag":null}