[Flink] Cache batch side input materialization in Flink 2 (#39867)

3b476c4

Select commit

Loading

Failed to load commit list.

Uh oh!

There was an error while loading. Please reload this page.

Sign in for the full log view

Build python source distribution and wheels on: pull_request 6

Check environment variables

Build python source distribution

Prepare GCS

Build python ${{ matrix.py_version }} wheels on ${{ matrix.os_python.arch }} for ${{ matrix.os_python.os }}

Upload python source distribution to GCS bucket

Upload wheels to GCS bucket

Branch repo nightly

List files on Google Cloud Storage Bucket

Publish SpotBugs

Python 3.13 Test Results (ubuntu-latest)

Test Results

Python tests on: pull_request 8

Check GCP variables

Python Unit Tests (macos-latest, 3.10, py310)

Python Unit Tests (macos-latest, 3.11, py311)

Python Unit Tests (macos-latest, 3.12, py312)

Python Unit Tests (macos-latest, 3.13, py313)

Python Unit Tests (macos-latest, 3.14, py314)

Python Unit Tests (windows-latest, 3.10, py310)

Python Unit Tests (windows-latest, 3.11, py311)

Python Unit Tests (windows-latest, 3.12, py312)

Python Unit Tests (windows-latest, 3.13, py313)

Python Unit Tests (windows-latest, 3.14, py314)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.10)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.11)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.12)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.13)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.14)

Python Wordcount Direct Runner (macos-latest, 3.10)

Python Wordcount Direct Runner (macos-latest, 3.11)

Python Wordcount Direct Runner (macos-latest, 3.12)

Python Wordcount Direct Runner (macos-latest, 3.13)

Python Wordcount Direct Runner (macos-latest, 3.14)

Python Wordcount Direct Runner (windows-latest, 3.10)

Python Wordcount Direct Runner (windows-latest, 3.11)

Python Wordcount Direct Runner (windows-latest, 3.12)

Python Wordcount Direct Runner (windows-latest, 3.13)

Python Wordcount Direct Runner (windows-latest, 3.14)

Build python source distribution

Java Tests on: pull_request 7

Java Unit Tests (self-hosted, ubuntu-24.04, main)

Java Unit Tests (macos-latest)

Java Unit Tests (windows-latest)

Java Wordcount Direct Runner (self-hosted, ubuntu-24.04, main)

Java Wordcount Direct Runner (macos-latest)

Java Wordcount Direct Runner (windows-latest)

CodeQL Advanced on: pull_request 2

detect-changes

Analyze (go)

Analyze (java-kotlin)

Analyze (python)

Go tests on: pull_request 2

Go Build

Local environment tests on: pull_request 11

Ubuntu run local environment shell script

Mac run local environment shell script

PreCommit Python Docker on: pull_request_target 5

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.10)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.11)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.12)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.13)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.14)

PreCommit Java Google-ads IO Direct on: pull_request_target 1

beam_PreCommit_Java_Google-ads_IO_Direct (Run Java_Google-ads_IO_Direct PreCommit)

PreCommit Java Amazon-Web-Services2 IO Direct on: pull_request_target 1

beam_PreCommit_Java_Amazon-Web-Services2_IO_Direct (Run Java_Amazon-Web-Services2_IO_Direct PreCommit)

PreCommit Python PVR Flink on: pull_request_target 1

beam_PreCommit_Python_PVR_Flink (Run Python_PVR_Flink PreCommit)

PreCommit Java MongoDb IO Direct on: pull_request_target 1

beam_PreCommit_Java_MongoDb_IO_Direct (Run Java_MongoDb_IO_Direct PreCommit)

PreCommit SQL on: pull_request_target 1

beam_PreCommit_SQL (Run SQL PreCommit)

PreCommit Java Cassandra IO Direct on: pull_request_target 1

beam_PreCommit_Java_Cassandra_IO_Direct (Run Java_Cassandra_IO_Direct PreCommit)

PreCommit Java PVR Prism Loopback on: pull_request_target 1

beam_PreCommit_Java_PVR_Prism_Loopback (Run Java_PVR_Prism_Loopback PreCommit)

PreCommit Java RequestResponse IO Direct on: pull_request_target 1

beam_PreCommit_Java_RequestResponse_IO_Direct (Run Java_RequestResponse_IO_Direct PreCommit)

PreCommit Spotless on: pull_request_target 1

beam_PreCommit_Spotless (Run Spotless PreCommit)

PreCommit Java Splunk IO Direct on: pull_request_target 1

beam_PreCommit_Java_Splunk_IO_Direct (Run Java_Splunk_IO_Direct PreCommit)

PreCommit Whitespace on: pull_request_target 1

beam_PreCommit_Whitespace (Run Whitespace PreCommit)

PreCommit Java Delta IO Direct on: pull_request_target 1

beam_PreCommit_Java_Delta_IO_Direct (Run Java_Delta_IO_Direct PreCommit)

PreCommit Xlang Generated Transforms on: pull_request_target 1

beam_PreCommit_Xlang_Generated_Transforms (Run Xlang_Generated_Transforms PreCommit 3.10)

PreCommit Java Cdap IO Direct on: pull_request_target 1

beam_PreCommit_Java_Cdap_IO_Direct (Run Java_Cdap_IO_Direct PreCommit)

PreCommit Java Jms IO Direct on: pull_request_target 1

beam_PreCommit_Java_Jms_IO_Direct (Run Java_Jms_IO_Direct PreCommit)

PreCommit Integration and Load Test Framework on: pull_request_target 1

beam_PreCommit_ItFramework (Run It_Framework PreCommit)

PreCommit Java IOs Direct on: pull_request_target 1

beam_PreCommit_Java_IOs_Direct (Run Java_IOs_Direct PreCommit)

PreCommit Python Integration on: pull_request_target 2

beam_PreCommit_Python_Integration (Run Python_Integration PreCommit 3.10)

beam_PreCommit_Python_Integration (Run Python_Integration PreCommit 3.14)

PreCommit Prism Python on: pull_request_target 2

beam_PreCommit_Prism_Python (Run Prism_Python PreCommit 3.10)

beam_PreCommit_Prism_Python (Run Prism_Python PreCommit 3.14)

PreCommit GoPrism on: pull_request_target 1

beam_PreCommit_GoPrism (Run GoPrism PreCommit)

PreCommit Java Clickhouse IO Direct on: pull_request_target 1

beam_PreCommit_Java_Clickhouse_IO_Direct (Run Java_Clickhouse_IO_Direct PreCommit)

PreCommit Java RabbitMq IO Direct on: pull_request_target 1

beam_PreCommit_Java_RabbitMq_IO_Direct (Run Java_RabbitMq_IO_Direct PreCommit)

PreCommit Java PVR Flink Batch on: pull_request_target 1

beam_PreCommit_Java_PVR_Flink_Batch (Run Java_PVR_Flink_Batch PreCommit)

LabelPrs on: pull_request_target 1

label

PreCommit Java ElasticSearch IO Direct on: pull_request_target 1

beam_PreCommit_Java_ElasticSearch_IO_Direct (Run Java_ElasticSearch_IO_Direct PreCommit)

PreCommit Python Formatter on: pull_request_target 1

beam_PreCommit_PythonFormatter (Run PythonFormatter PreCommit)

PreCommit Java Hadoop IO Direct on: pull_request_target 1

beam_PreCommit_Java_Hadoop_IO_Direct (Run Java_Hadoop_IO_Direct PreCommit)

PreCommit Java GCP IO Direct on: pull_request_target 1

beam_PreCommit_Java_GCP_IO_Direct (Run Java_GCP_IO_Direct PreCommit)

PreCommit Portable Python on: pull_request_target 2

beam_PreCommit_Portable_Python (Run Portable_Python PreCommit 3.10)

beam_PreCommit_Portable_Python (Run Portable_Python PreCommit 3.14)

PreCommit Go on: pull_request_target 1

beam_PreCommit_Go (Run Go PreCommit)

PreCommit YAML Xlang Direct on: pull_request_target 1

beam_PreCommit_Yaml_Xlang_Direct (Run Yaml_Xlang_Direct PreCommit)

PreCommit Python Runners on: pull_request_target 2

beam_PreCommit_Python_Runners (Run Python_Runners PreCommit 3.10)

beam_PreCommit_Python_Runners (Run Python_Runners PreCommit 3.14)

PreCommit Java HCatalog IO Direct on: pull_request_target 1

beam_PreCommit_Java_HCatalog_IO_Direct (Run Java_HCatalog_IO_Direct PreCommit)

PreCommit RAT on: pull_request_target 1

beam_PreCommit_RAT (Run RAT PreCommit)

PreCommit Java Kafka IO Direct on: pull_request_target 1

beam_PreCommit_Java_Kafka_IO_Direct (Run Java_Kafka_IO_Direct PreCommit)

PreCommit Python ML tests with ML deps installed on: pull_request_target 12

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.10) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.11) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.12) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.13) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.13) (ubuntu-latest)

PreCommit Java Spark Versions on: pull_request_target 1

beam_PreCommit_Java_Spark_Versions (Run Java_Spark_Versions PreCommit)

PreCommit GoPortable on: pull_request_target 1

beam_PreCommit_GoPortable (Run GoPortable PreCommit)

IcebergIO Unit Tests on: pull_request_target 1

IO_Iceberg_Unit_Tests (Run IcebergIO Unit Tests)

PreCommit Java Parquet IO Direct on: pull_request_target 1

beam_PreCommit_Java_Parquet_IO_Direct (Run Java_Parquet_IO_Direct PreCommit)

PreCommit Java Solace IO Direct on: pull_request_target 1

beam_PreCommit_Java_Solace_IO_Direct (Run Java_Solace_IO_Direct PreCommit)

PreCommit Java Flink Versions on: pull_request_target 1

beam_PreCommit_Java_Flink_Versions (Run Java_Flink_Versions PreCommit)

PreCommit Java on: pull_request_target 1

beam_PreCommit_Java (Run Java PreCommit)

PreCommit Python Dataframes on: pull_request_target 2

beam_PreCommit_Python_Dataframes (Run Python_Dataframes PreCommit 3.10)

beam_PreCommit_Python_Dataframes (Run Python_Dataframes PreCommit 3.14)

PreCommit Java JDBC IO Direct on: pull_request_target 1

beam_PreCommit_Java_JDBC_IO_Direct (Run Java_JDBC_IO_Direct PreCommit)

PreCommit Java Dataflow Non-portable Worker on: pull_request_target 1

beam_PreCommit_Java_Dataflow_NonportableWorker (Run Java Dataflow Non-portable Worker PreCommit)

PreCommit Python Docs on: pull_request_target 1

beam_PreCommit_PythonDocs (Run PythonDocs PreCommit)

PreCommit Java Snowflake IO Direct on: pull_request_target 1

beam_PreCommit_Java_Snowflake_IO_Direct (Run Java_Snowflake_IO_Direct PreCommit)

PreCommit Java Azure IO Direct on: pull_request_target 1

beam_PreCommit_Java_Azure_IO_Direct (Run Java_Azure_IO_Direct PreCommit)

PreCommit Java Examples Dataflow on: pull_request_target 1

beam_PreCommit_Java_Examples_Dataflow (Run Java_Examples_Dataflow PreCommit)

PreCommit Java Neo4j IO Direct on: pull_request_target 1

beam_PreCommit_Java_Neo4j_IO_Direct (Run Java_Neo4j_IO_Direct PreCommit)

PreCommit Community Metrics on: pull_request_target 1

beam_PreCommit_CommunityMetrics (Run CommunityMetrics PreCommit)

PreCommit Kotlin Examples on: pull_request_target 1

beam_PreCommit_Kotlin_Examples (Run Kotlin_Examples PreCommit)

PreCommit Java File-schema-transform IO Direct on: pull_request_target 1

beam_PreCommit_Java_File-schema-transform_IO_Direct (Run Java_File-schema-transform_IO_Direct PreCommit)

PreCommit Java Debezium IO Direct on: pull_request_target 1

beam_PreCommit_Java_Debezium_IO_Direct (Run Java_Debezium_IO_Direct PreCommit)

PreCommit Python Lint on: pull_request_target 1

beam_PreCommit_PythonLint (Run PythonLint PreCommit)

PreCommit SQL Java17 on: pull_request_target 1

beam_PreCommit_SQL_Java17 (Run SQL_Java17 PreCommit)

PreCommit Java Thrift IO Direct on: pull_request_target 1

beam_PreCommit_Java_Thrift_IO_Direct (Run Java_Thrift_IO_Direct PreCommit)

PreCommit Java Examples Dataflow Java11 on: pull_request_target 1

beam_PreCommit_Java_Examples_Dataflow_Java11 (Run Java_Examples_Dataflow_Java11 PreCommit)

PreCommit Java InfluxDb IO Direct on: pull_request_target 1

beam_PreCommit_Java_InfluxDb_IO_Direct (Run Java_InfluxDb_IO_Direct PreCommit)

PreCommit Java Csv IO Direct on: pull_request_target 1

beam_PreCommit_Java_Csv_IO_Direct (Run Java_Csv_IO_Direct PreCommit)

PreCommit Python Transforms on: pull_request_target 2

beam_PreCommit_Python_Transforms (Run Python_Transforms PreCommit 3.10)

beam_PreCommit_Python_Transforms (Run Python_Transforms PreCommit 3.14)

PreCommit Java PVR Flink Docker on: pull_request_target 1

beam_PreCommit_Java_PVR_Flink_Docker (Run Java_PVR_Flink_Docker PreCommit)

PreCommit Flink Container on: pull_request_target 1

beam_PreCommit_Flink_Container (Run Flink Container PreCommit)

PreCommit Python Coverage on: pull_request_target 1

beam_PreCommit_Python_Coverage (Run Python_Coverage PreCommit 3.10)

PreCommit Python Examples on: pull_request_target 2

beam_PreCommit_Python_Examples (Run Python_Examples PreCommit 3.10)

beam_PreCommit_Python_Examples (Run Python_Examples PreCommit 3.14)

PreCommit Python on: pull_request_target 2

beam_PreCommit_Python (Run Python PreCommit 3.10)

beam_PreCommit_Python (Run Python PreCommit 3.14)

PreCommit Java SingleStore IO Direct on: pull_request_target 1

beam_PreCommit_Java_SingleStore_IO_Direct (Run Java_SingleStore_IO_Direct PreCommit)

PreCommit SQL on: push 1

beam_PreCommit_SQL (Run SQL PreCommit)

PreCommit Java PVR Prism Loopback on: push 1

beam_PreCommit_Java_PVR_Prism_Loopback (Run Java_PVR_Prism_Loopback PreCommit)

PreCommit Java MongoDb IO Direct on: push 1

beam_PreCommit_Java_MongoDb_IO_Direct (Run Java_MongoDb_IO_Direct PreCommit)

PreCommit Java PVR Flink Batch on: push 1

beam_PreCommit_Java_PVR_Flink_Batch (Run Java_PVR_Flink_Batch PreCommit)

PreCommit RAT on: push 1

beam_PreCommit_RAT (Run RAT PreCommit)

PreCommit Java Jms IO Direct on: push 1

beam_PreCommit_Java_Jms_IO_Direct (Run Java_Jms_IO_Direct PreCommit)

PreCommit Kotlin Examples on: push 1

beam_PreCommit_Kotlin_Examples (Run Kotlin_Examples PreCommit)

Go tests on: push 1

Go Build

PreCommit Java Delta IO Direct on: push 1

beam_PreCommit_Java_Delta_IO_Direct (Run Java_Delta_IO_Direct PreCommit)

PreCommit Python Lint on: push 1

beam_PreCommit_PythonLint (Run PythonLint PreCommit)

PreCommit Java Cdap IO Direct on: push 1

beam_PreCommit_Java_Cdap_IO_Direct (Run Java_Cdap_IO_Direct PreCommit)

PreCommit Go on: push 1

beam_PreCommit_Go (Run Go PreCommit)

PreCommit Python ML tests with ML deps installed on: push 4

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.10) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.11) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.12) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.13) (self-hosted, ubuntu-24.04, main)

beam_PreCommit_Python_ML (Run Python_ML PreCommit 3.13) (ubuntu-latest)

PreCommit Flink Container on: push 2

beam_PreCommit_Flink_Container (Run Flink Container PreCommit)

Java Tests on: push 11

Java Unit Tests (self-hosted, ubuntu-24.04, main)

Java Unit Tests (macos-latest)

Java Unit Tests (windows-latest)

Java Wordcount Direct Runner (self-hosted, ubuntu-24.04, main)

Java Wordcount Direct Runner (macos-latest)

Java Wordcount Direct Runner (windows-latest)

PreCommit Java RequestResponse IO Direct on: push 1

beam_PreCommit_Java_RequestResponse_IO_Direct (Run Java_RequestResponse_IO_Direct PreCommit)

PreCommit Xlang Generated Transforms on: push 1

beam_PreCommit_Xlang_Generated_Transforms (Run Xlang_Generated_Transforms PreCommit 3.10)

PreCommit Python Formatter on: push 1

beam_PreCommit_PythonFormatter (Run PythonFormatter PreCommit)

PreCommit Java Splunk IO Direct on: push 1

beam_PreCommit_Java_Splunk_IO_Direct (Run Java_Splunk_IO_Direct PreCommit)

CodeQL Advanced on: push 2

detect-changes

Analyze (go)

Analyze (java-kotlin)

Analyze (python)

PreCommit Java Examples Dataflow on: push 1

beam_PreCommit_Java_Examples_Dataflow (Run Java_Examples_Dataflow PreCommit)

PreCommit Java RabbitMq IO Direct on: push 1

beam_PreCommit_Java_RabbitMq_IO_Direct (Run Java_RabbitMq_IO_Direct PreCommit)

PostCommit Java PVR Flink Batch on: push 4

beam_PostCommit_Java_PVR_Flink_Batch (1.20)

beam_PostCommit_Java_PVR_Flink_Batch (2.0)

beam_PostCommit_Java_PVR_Flink_Batch (2.1)

beam_PostCommit_Java_PVR_Flink_Batch (2.2)

PreCommit Java GCP IO Direct on: push 1

beam_PreCommit_Java_GCP_IO_Direct (Run Java_GCP_IO_Direct PreCommit)

PreCommit Java Flink Versions on: push 1

beam_PreCommit_Java_Flink_Versions (Run Java_Flink_Versions PreCommit)

PreCommit Python PVR Flink on: push 1

beam_PreCommit_Python_PVR_Flink (Run Python_PVR_Flink PreCommit)

PostCommit Python Versions on: push 3

beam_PostCommit_Python_Versions (Run Python Version PostCommit 3.11)

beam_PostCommit_Python_Versions (Run Python Version PostCommit 3.12)

beam_PostCommit_Python_Versions (Run Python Version PostCommit 3.13)

PreCommit Portable Python on: push 2

beam_PreCommit_Portable_Python (Run Portable_Python PreCommit 3.10)

beam_PreCommit_Portable_Python (Run Portable_Python PreCommit 3.14)

PreCommit Java PVR Flink Docker on: push 1

beam_PreCommit_Java_PVR_Flink_Docker (Run Java_PVR_Flink_Docker PreCommit)

PreCommit Java Solace IO Direct on: push 1

beam_PreCommit_Java_Solace_IO_Direct (Run Java_Solace_IO_Direct PreCommit)

Local environment tests on: push 11

Ubuntu run local environment shell script

Mac run local environment shell script

PreCommit Java Kafka IO Direct on: push 1

beam_PreCommit_Java_Kafka_IO_Direct (Run Java_Kafka_IO_Direct PreCommit)

PreCommit Python Examples on: push 2

beam_PreCommit_Python_Examples (Run Python_Examples PreCommit 3.10)

beam_PreCommit_Python_Examples (Run Python_Examples PreCommit 3.14)

PreCommit Java Neo4j IO Direct on: push 1

beam_PreCommit_Java_Neo4j_IO_Direct (Run Java_Neo4j_IO_Direct PreCommit)

PreCommit Python Docs on: push 1

beam_PreCommit_PythonDocs (Run PythonDocs PreCommit)

PreCommit Java Hadoop IO Direct on: push 1

beam_PreCommit_Java_Hadoop_IO_Direct (Run Java_Hadoop_IO_Direct PreCommit)

PreCommit Java on: push 1

beam_PreCommit_Java (Run Java PreCommit)

PreCommit Java IOs Direct on: push 1

beam_PreCommit_Java_IOs_Direct (Run Java_IOs_Direct PreCommit)

PreCommit Java Parquet IO Direct on: push 1

beam_PreCommit_Java_Parquet_IO_Direct (Run Java_Parquet_IO_Direct PreCommit)

PreCommit Java Thrift IO Direct on: push 1

beam_PreCommit_Java_Thrift_IO_Direct (Run Java_Thrift_IO_Direct PreCommit)

PreCommit Integration and Load Test Framework on: push 1

beam_PreCommit_ItFramework (Run It_Framework PreCommit)

PreCommit Java Debezium IO Direct on: push 1

beam_PreCommit_Java_Debezium_IO_Direct (Run Java_Debezium_IO_Direct PreCommit)

TypeScript Tests on: push 1

TypeScript Unit Tests (self-hosted, ubuntu-24.04, main)

TypeScript Unit Tests (macos-latest)

TypeScript xlang Tests

Check GCP variables

TypeScript Dataflow Tests

PreCommit Java Clickhouse IO Direct on: push 1

beam_PreCommit_Java_Clickhouse_IO_Direct (Run Java_Clickhouse_IO_Direct PreCommit)

PreCommit Java File-schema-transform IO Direct on: push 1

beam_PreCommit_Java_File-schema-transform_IO_Direct (Run Java_File-schema-transform_IO_Direct PreCommit)

PreCommit YAML Xlang Direct on: push 1

beam_PreCommit_Yaml_Xlang_Direct (Run Yaml_Xlang_Direct PreCommit)

PreCommit Java Dataflow Non-portable Worker on: push 1

beam_PreCommit_Java_Dataflow_NonportableWorker (Run Java Dataflow Non-portable Worker PreCommit)

PreCommit Python Dataframes on: push 2

beam_PreCommit_Python_Dataframes (Run Python_Dataframes PreCommit 3.10)

beam_PreCommit_Python_Dataframes (Run Python_Dataframes PreCommit 3.14)

PreCommit Java Amazon-Web-Services2 IO Direct on: push 1

beam_PreCommit_Java_Amazon-Web-Services2_IO_Direct (Run Java_Amazon-Web-Services2_IO_Direct PreCommit)

PreCommit Whitespace on: push 1

beam_PreCommit_Whitespace (Run Whitespace PreCommit)

Python tests on: push 7

Check GCP variables

Python Unit Tests (macos-latest, 3.10, py310)

Python Unit Tests (macos-latest, 3.11, py311)

Python Unit Tests (macos-latest, 3.12, py312)

Python Unit Tests (macos-latest, 3.13, py313)

Python Unit Tests (macos-latest, 3.14, py314)

Python Unit Tests (windows-latest, 3.10, py310)

Python Unit Tests (windows-latest, 3.11, py311)

Python Unit Tests (windows-latest, 3.12, py312)

Python Unit Tests (windows-latest, 3.13, py313)

Python Unit Tests (windows-latest, 3.14, py314)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.10)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.11)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.12)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.13)

Python Wordcount Direct Runner (self-hosted, ubuntu-24.04, main, 3.14)

Python Wordcount Direct Runner (macos-latest, 3.10)

Python Wordcount Direct Runner (macos-latest, 3.11)

Python Wordcount Direct Runner (macos-latest, 3.12)

Python Wordcount Direct Runner (macos-latest, 3.13)

Python Wordcount Direct Runner (macos-latest, 3.14)

Python Wordcount Direct Runner (windows-latest, 3.10)

Python Wordcount Direct Runner (windows-latest, 3.11)

Python Wordcount Direct Runner (windows-latest, 3.12)

Python Wordcount Direct Runner (windows-latest, 3.13)

Python Wordcount Direct Runner (windows-latest, 3.14)

Build python source distribution

PreCommit Java ElasticSearch IO Direct on: push 1

beam_PreCommit_Java_ElasticSearch_IO_Direct (Run Java_ElasticSearch_IO_Direct PreCommit)

PreCommit Java SingleStore IO Direct on: push 1

beam_PreCommit_Java_SingleStore_IO_Direct (Run Java_SingleStore_IO_Direct PreCommit)

PreCommit Java JDBC IO Direct on: push 1

beam_PreCommit_Java_JDBC_IO_Direct (Run Java_JDBC_IO_Direct PreCommit)

Build python source distribution and wheels on: push 3

Check environment variables

Build python source distribution

Prepare GCS

Build python ${{ matrix.py_version }} wheels on ${{ matrix.os_python.arch }} for ${{ matrix.os_python.os }}

Upload python source distribution to GCS bucket

Upload wheels to GCS bucket

Branch repo nightly

List files on Google Cloud Storage Bucket

PreCommit Java InfluxDb IO Direct on: push 1

beam_PreCommit_Java_InfluxDb_IO_Direct (Run Java_InfluxDb_IO_Direct PreCommit)

PreCommit SQL Java17 on: push 1

beam_PreCommit_SQL_Java17 (Run SQL_Java17 PreCommit)

PreCommit Python Integration on: push 2

beam_PreCommit_Python_Integration (Run Python_Integration PreCommit 3.10)

beam_PreCommit_Python_Integration (Run Python_Integration PreCommit 3.14)

PreCommit Python on: push 2

beam_PreCommit_Python (Run Python PreCommit 3.10)

beam_PreCommit_Python (Run Python PreCommit 3.14)

PreCommit Java HCatalog IO Direct on: push 1

beam_PreCommit_Java_HCatalog_IO_Direct (Run Java_HCatalog_IO_Direct PreCommit)

PreCommit Java Examples Dataflow Java11 on: push 1

beam_PreCommit_Java_Examples_Dataflow_Java11 (Run Java_Examples_Dataflow_Java11 PreCommit)

PreCommit Java Cassandra IO Direct on: push 1

beam_PreCommit_Java_Cassandra_IO_Direct (Run Java_Cassandra_IO_Direct PreCommit)

PreCommit Prism Python on: push 2

beam_PreCommit_Prism_Python (Run Prism_Python PreCommit 3.10)

beam_PreCommit_Prism_Python (Run Prism_Python PreCommit 3.14)

PreCommit Java Google-ads IO Direct on: push 1

beam_PreCommit_Java_Google-ads_IO_Direct (Run Java_Google-ads_IO_Direct PreCommit)

IcebergIO Unit Tests on: push 1

IO_Iceberg_Unit_Tests (Run IcebergIO Unit Tests)

PreCommit Python Runners on: push 2

beam_PreCommit_Python_Runners (Run Python_Runners PreCommit 3.10)

beam_PreCommit_Python_Runners (Run Python_Runners PreCommit 3.14)

PreCommit Java Azure IO Direct on: push 1

beam_PreCommit_Java_Azure_IO_Direct (Run Java_Azure_IO_Direct PreCommit)

PreCommit Python Docker on: push 5

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.10)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.11)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.12)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.13)

beam_PreCommit_PythonDocker (Run PythonDocker PreCommit 3.14)

PreCommit Community Metrics on: push 1

beam_PreCommit_CommunityMetrics (Run CommunityMetrics PreCommit)

PreCommit Python Transforms on: push 2

beam_PreCommit_Python_Transforms (Run Python_Transforms PreCommit 3.10)

beam_PreCommit_Python_Transforms (Run Python_Transforms PreCommit 3.14)

PreCommit Java Snowflake IO Direct on: push 1

beam_PreCommit_Java_Snowflake_IO_Direct (Run Java_Snowflake_IO_Direct PreCommit)

PreCommit GoPortable on: push 1

beam_PreCommit_GoPortable (Run GoPortable PreCommit)

PreCommit GoPrism on: push 1

beam_PreCommit_GoPrism (Run GoPrism PreCommit)

PreCommit Java Csv IO Direct on: push 1

beam_PreCommit_Java_Csv_IO_Direct (Run Java_Csv_IO_Direct PreCommit)

PreCommit Python Coverage on: push 1

beam_PreCommit_Python_Coverage (Run Python_Coverage PreCommit 3.10)

PreCommit Java Spark Versions on: push 1

beam_PreCommit_Java_Spark_Versions (Run Java_Spark_Versions PreCommit)

Code scanning results

CodeQL

Annotations

2 errors

Canceling since a higher priority waiting request for Build python source distribution and wheels @ apache:master-pull[bot] exists

Job log options

Download log archive

This job was cancelled

Loading

[Flink] Cache batch side input materialization in Flink 2 (#39867)

Uh oh!

Annotations

This job was cancelled

Re-running jobs...