SDK version support status

This page lists the support status for Apache Beam and Dataflow SDK releases:

Support-level definitions

The following are the support levels for the Apache Beam SDK:

  • Supported - Apache Beam SDK versions are supported by Dataflow from their release date until their deprecation date.
  • Deprecated - Once an SDK version has been announced as deprecated, it will continue to work with Dataflow, but is eligible to be decommissioned. The deprecated version may or may not be scheduled to be decommissioned. Requests for jobs submitted from deprecated SDK versions will result in a warning message. Environments using a deprecated version of an SDK should be updated to a supported version to avoid interruptions.
  • Decommissioned - After the deprecation period, decommissioned SDK versions will no longer work with Dataflow. Requests for jobs submitted from decommissioned SDK versions will result in an error. Environments using a decommissioned version of an SDK must be updated to a supported version to be used with Dataflow.

Note that the above definitions do not apply to SDKs or features that have never been supported.

Apache Beam 2.x SDKs

Apache Beam is an open source, community-led project. Google is part of the community, but we do not own the project or control the release process. We might open bugs or submit patches to the Apache Beam codebase on behalf of Dataflow customers, but we cannot create hotfixes or official releases of Apache Beam on demand. See the Apache Beam policies page for more details about release policies.

Dataflow supports specific Apache Beam SDK components for the SDK releases listed below. These components have been tested thoroughly with Dataflow. Experimental features are not supported.

See the Apache Beam release notes for change information.

Note: Development SDK versions (marked as -SNAPSHOT for Java and .dev for Python and Go) are unsupported.

The following tables contain the support status for the Apache Beam 2.x SDKs:

Java

SDK version Status Supported components Details
2.40.0 Supported

If your pipeline writes to BigQuery, do NOT use 2.40.0. Under certain circumstances, if the sink is idle, an invalid timestamp can be emitted, throwing an exception and preventing the job from being drained.

org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on June 27, 2023.
2.39.0 Supported org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on May 25, 2023.
2.38.0 Supported org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on April 20, 2023.
2.37.0 Supported org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on March 4, 2023.
2.36.0 Supported

If your pipeline reads from a Cloud Spanner database, do NOT use 2.34.0 – 2.36.0. Immediately upgrade to 2.37.0 or later.

org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on February 7, 2023.
2.35.0 Supported

If your pipeline reads from a Cloud Spanner database, do NOT use 2.34.0 – 2.36.0. Immediately upgrade to 2.37.0 or later.

org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-io-jdbc
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on December 29, 2022.
2.34.0 Supported

If your pipeline reads from a Cloud Spanner database, do NOT use 2.34.0 – 2.36.0. Immediately upgrade to 2.37.0 or later.

org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
org.apache.beam:beam-sdks-java-extensions-sql
 This version will be deprecated on November 11, 2022.
2.33.0 Supported org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
 This version will be deprecated on October 7, 2022.
2.32.0 Supported org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
 This version will be deprecated on August 25, 2022.
2.31.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
 Deprecated on July 8, 2022.
2.30.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka
 Deprecated on June 10, 2022.
2.29.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on April 29, 2022.

Known issue: If you use Runner V2, by default Dataflow will use a Java 8 SDK container regardless of user Java version. To work around for Java 11, you can override the default SDK image by providing pipeline option `--worker_harness_container_image=gcr.io/cloud-dataflow/v1beta3/beam_java11_sdk:2.29.0` See Apache Beam issue tracker for more information.

2.28.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on February 22, 2022.
2.27.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on January 7, 2022.

This release adds support for JDK 11.
2.26.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on December 11, 2021.
2.25.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on October 23, 2021.
2.24.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on September 18, 2021.

Known issue: If you use timers that reset, rather than timers that are set and only fired once, you should not upgrade to 2.24.0. When a timer fires but is reset prior to being executed, a watermark hold can be leaked, causing your pipeline job to be stuck. See the Apache Beam issue tracker for more information.
2.23.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on July 29, 2021.
2.22.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
Google Cloud I/O connectors under module org.apache.beam:beam-runners-google-cloud-dataflow-java: bigquery, bigtable, datastore, healthcare, pubsub, spanner
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on June 8, 2021.
2.21.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on May 27, 2021.
2.20.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on April 15, 2021.
2.19.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on February 4, 2021.
2.18.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on January 23, 2021.
2.17.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on January 6, 2021.
2.16.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on October 7, 2020.
2.15.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on August 23, 2020.

Known issues:
  • Dataflow users who use schema features (including SQL transforms) should not upgrade to 2.15.0 due to a known issue. See the Apache Beam issue tracker for more information.
2.14.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on August 1, 2020.
2.13.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on June 6, 2020.

This release adds experimental support for JDK 9 or above. See the Apache Beam issue tracker for more information.
2.12.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated on April 25, 2020.

Known issues:
  • The Dataflow runner has an incorrect logging configuration that might cause all logs to be missing. To work around this issue, add slf4j-jdk14 to your runtime dependencies.
2.11.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of March 1, 2020.

Known issues:
  • The Dataflow runner has an incorrect logging configuration that might cause all logs to be missing. To work around this issue, add slf4j-jdk14 to your runtime dependencies.
2.10.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of February 11, 2020.

Known issues:
  • SDK 2.10.0 depends on gcsio client library version 1.9.13, which has known issues:

    To work around these issues, either upgrade to SDK 2.11.0, or override the gcsio client library version to 1.9.16 or later.

  • The Dataflow runner has an incorrect logging configuration that might cause all logs to be missing. To work around this issue, add slf4j-jdk14 to your runtime dependencies.
2.9.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of December 13, 2019.

Known issues:
  • Users enabling the Streaming Engine (Beta) experiment should not upgrade to SDK 2.9.0 due to a known issue. If you choose to use SDK 2.9.0, you must also set the enable_conscrypt_security_provider experimental flag to enable Conscrypt, which has known stability issues.
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.8.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of October 25, 2019.

Known issues:
  • Pipelines might become stuck due to an issue with the Conscrypt library. If you see errors in Stackdriver logging with stack traces that include Conscrypt related calls, you might be affected by this issue. To resolve the issue, upgrade to SDK 2.9.0 or higher.
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.7.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of October 3, 2019.

Known issues:
  • Pipelines might become stuck due to an issue with the Conscrypt library. If you see errors in Stackdriver logging with stack traces that include Conscrypt related calls, you might be affected by this issue. To resolve the issue, upgrade to SDK 2.9.0 or higher.
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.6.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of August 8, 2019.

Known issues:
  • Pipelines might become stuck due to an issue with the Conscrypt library. If you see errors in Stackdriver logging with stack traces that include Conscrypt related calls, you might be affected by this issue. To resolve the issue, upgrade to SDK 2.9.0 or higher.
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.5.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management
org.apache.beam:beam-sdks-java-io-kafka

Deprecated as of June 6, 2019.

Known issues:
  • Pipelines might become stuck due to an issue with the Conscrypt library. If you see errors in Stackdriver logging with stack traces that include Conscrypt related calls, you might be affected by this issue. To resolve the issue, upgrade to SDK 2.9.0 or higher.
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.4.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management

Deprecated as of March 20, 2019.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.3.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management

Deprecated as of January 30, 2019.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.2.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management

Deprecated as of December 2, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.1.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management

Deprecated as of August 23, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.0.0 Deprecated org.apache.beam:beam-sdks-java-core
org.apache.beam:beam-sdks-java-io-google-cloud-platform
org.apache.beam:beam-sdks-java-extensions-google-cloud-platform-core
org.apache.beam:beam-sdks-java-extensions-protobuf
org.apache.beam:beam-runners-direct-java
org.apache.beam:beam-runners-google-cloud-dataflow-java
org.apache.beam:beam-model-pipeline
org.apache.beam:beam-runners-core-construction-java
org.apache.beam:beam-model-job-management

Deprecated as of May 17, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Apache Beam Java SDKs 2.9.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.

Python

SDK version Status Supported components Details
2.40.0 Supported Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, ml.inference (excluding PytorchModelHandlerKeyedTensor and SklearnModelHandlerPandas), options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on June 27, 2023.
2.39.0 Supported Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on May 25, 2023.
2.38.0 Supported Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on April 20, 2023.
2.37.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

If your pipeline reads from Datastore, do NOT use 2.34.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on March 4, 2023.

Known issues:
  • When you use WriteToBigQuery with the ignore_unknown_columns parameter set to true, the parameter value is ignored. This issue is fixed in version 2.38.0. See BEAM-14039 for details.
2.36.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

If your pipeline reads from Datastore, do NOT use 2.34.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on February 7, 2023.

Known issues:
  • When you use WriteToBigQuery with the ignore_unknown_columns parameter set to true, the parameter value is ignored. This issue is fixed in version 2.38.0. See BEAM-14039 for details.
2.35.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

If your pipeline reads from Datastore, do NOT use 2.34.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub
The connectors under apache_beam.io.jdbc: ReadFromJdbc, WriteToJdbc.

This version will be deprecated on December 29, 2022.
2.34.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

If your pipeline reads from Datastore, do NOT use 2.34.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints, sql
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

This version will be deprecated on November 11, 2022.
2.33.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

This version will be deprecated on October 7, 2022.
2.32.0 Supported

If your pipeline reads from Cloud Storage, do NOT use 2.32.0 – 2.37.0. Immediately upgrade to 2.38.0 or later.

Core Python SDK library under module apache_beam: sub-modules coders, dataframe, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

This version will be deprecated on August 25, 2022.
2.31.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem, filesystems, fileio
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on July 8, 2022.
2.30.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on June 10, 2022.
2.29.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on April 29, 2022.
2.28.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on February 22, 2022.
2.27.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on January 7, 2022.
2.26.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, dataframe (preview), metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on December 11, 2021.
2.25.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on October 23, 2021.
2.24.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on September 18, 2021. Also, this is the last Apache Beam SDK version to support Python 2 and Python 3.5.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.23.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on July 29, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.22.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp: bigquery, datastore, pubsub

Deprecated on June 8, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.21.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on May 27, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.20.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on April 15, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.19.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on February 4, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.18.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on January 23, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.17.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on January 6, 2021.

Dataflow no longer supports pipelines using Python 2. Read more information on the Python 2 support on Google Cloud page.
2.16.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp
 Deprecated on October 7, 2020.
2.15.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp
 Deprecated on August 23, 2020.
2.14.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp

Deprecated on August 1, 2020.

Known issues:
  • The MongoDB source added in this release has a known issue that can result in data loss. See BEAM-7866 for details.
2.13.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp
 Deprecated as of June 6, 2020.
2.12.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp
 Deprecated as of April 25, 2020.
2.11.0 Deprecated Core Python SDK library under module apache_beam: sub-modules coders, metrics, options, portability, runners.dataflow, runners.direct, transforms, typehints
File-based sources and sinks and related modules under module apache_beam.io: textio, avroio, parquetio, tfrecordio, gcsfilesystem, localfilesystem
Google Cloud I/O connectors under module apache_beam.io.gcp
 Deprecated as of March 1, 2020.
2.10.0 Deprecated Deprecated as of February 11, 2020.
2.9.0 Deprecated Deprecated as of December 13, 2019.
2.8.0 Deprecated Deprecated as of October 25, 2019.
2.7.0 Deprecated

Deprecated as of October 3, 2019.
2.6.0 Deprecated Deprecated as of August 8, 2019.
2.5.0 Deprecated Deprecated as of June 6, 2019.
2.4.0 Deprecated Deprecated as of March 20, 2019.
2.3.0 Deprecated Deprecated as of January 30, 2019.
2.2.0 Deprecated Deprecated as of December 2, 2018.
2.1.1
2.1.0		 Deprecated Deprecated as of August 23, 2018.
2.0.0 Deprecated Deprecated as of May 17, 2018.

Go

SDK version Status Supported components Details
2.40.0 Supported Packages under the following directories:
- Core Beam Go SDK package
- beam/transforms
- beam/io/textio
- beam/io/xlang
 This version will be deprecated on June 27, 2023.
2.39.0 Supported Packages under the following directories:
- Core Beam Go SDK package
- beam/transforms
- beam/io/textio
- beam/io/xlang
 This version will be deprecated on May 25, 2023.
2.38.0 Supported Packages under the following directories:
- Core Beam Go SDK package
- beam/transforms
- beam/io/textio
- beam/io/xlang
 This version will be deprecated on April 20, 2023.
2.37.0 Supported Packages under the following directories:
- Core Beam Go SDK package
- beam/transforms
- beam/io/textio
- beam/io/xlang
 This version will be deprecated on March 4, 2023.

Dataflow 2.x SDKs

Note: Development SDK versions (marked as -SNAPSHOT for Java and .dev for Python) are unsupported.

The following tables contains the support status for the Dataflow 2.x SDKs:

Java

See the Dataflow SDK 2.x for Java release notes for change information.

SDK version Status Details
2.5.0 Deprecated

Deprecated as of June 6, 2019.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.4.0 Deprecated

Deprecated as of March 20, 2019.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.3.0 Deprecated

Deprecated as of January 30, 2019.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.2.0 Deprecated

Deprecated as of December 2, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.1.0 Deprecated

Deprecated as of August 23, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.0.0 Deprecated

Deprecated as of May 17, 2018.

This version will be decommissioned by August 12, 2020 due to the discontinuation of support for JSON-RPC and Global HTTP Batch Endpoints.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.
2.0.0-beta3
2.0.0-beta2
2.0.0-beta1
 Decommissioned

Decommissioned as of February 28, 2018.

Known issue:
  • In a specific case, users of Dataflow Java SDKs 2.5.0 and earlier might experience data duplication when reading files from Cloud Storage. Duplication might occur when all of the following conditions are true:
    • You are reading files with the content-encoding set to gzip, and the files are dynamically decompressive transcoded by Cloud Storage.
    • The file size (decompressed) is larger than 2.14 GB.
    • The input stream runs into an error (and is recreated) after 2.14 GB is read.
    As a workaround, do not set the content-encoding header, and store compressed files in Cloud Storage with the proper extension (for example, gz for gzip). For existing files, you can update the content-encoding header and file name with the gsutil tool.

Python

See the Dataflow SDK 2.x for Python release notes for change information.

SDK version Status Details
2.5.0 Deprecated Deprecated as of June 6, 2019.
2.4.0 Deprecated Deprecated as of March 20, 2019.
2.3.0 Deprecated Deprecated as of January 30, 2019.
2.2.0 Deprecated Deprecated as of December 2, 2018.
2.1.1 Deprecated Deprecated as of August 23, 2018.
Fixes a compatibility issue with the Python six package.
See the release notes for more information.
2.1.0 Deprecated Deprecated as of August 23, 2018.
This release has a compatibility issue with the Python six 1.11.0 package.
See the Release Notes for more information.
2.0.0 Deprecated Deprecated as of May 17, 2018.
This release has a compatibility issue with the Python six 1.11.0 package.
See the Release Notes for more information.
0.6.0
0.5.5
0.5.1
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
 Decommissioned Decommissioned as of January 29, 2018.
0.2.7 and earlier versions Decommissioned Decommissioned as of March 23, 2017.