Issues

• AvroToProtoSerializer produces invalid BigQuery DATETIME strings for values on exact minute boundaries (LocalDateTime.toString() omits the seconds)

  GoogleCloudDataproc/flink-bigquery-connector#350 · Filter by author seokjin0414 opened on Sep 3, 2026

• Exactly-once BigQueryBufferedWriter creates a new StreamWriter after every checkpoint without closing the previous one (thread and native memory leak)

  GoogleCloudDataproc/flink-bigquery-connector#348 · Filter by author seokjin0414 opened on Sep 2, 2026
  1

• feat: Support Flink 2.3

  GoogleCloudDataproc/flink-bigquery-connector#345 · Filter by author james-kan-shopify opened on Aug 28, 2026

• feat: Extend view auto-materialization (#307) to the Table API

  GoogleCloudDataproc/flink-bigquery-connector#331 · Filter by author d-cole opened on Jun 19, 2026

• feat: Support "ends with" and "contains" for LIKE pushdown

  GoogleCloudDataproc/flink-bigquery-connector#330 · Filter by author fqshopify opened on Jun 9, 2026

• bug: Row restriction literals are not single-quote escaped

  GoogleCloudDataproc/flink-bigquery-connector#329 · Filter by author fqshopify opened on Jun 9, 2026

• Make indirect write job/temp BigQuery options optional with clear defaults

  GoogleCloudDataproc/flink-bigquery-connector#325 · Filter by author fqshopify opened on May 29, 2026

• How to configure writer max batch size, max inflight requests?

  GoogleCloudDataproc/flink-bigquery-connector#292 · Filter by author korkeatw opened on Mar 16, 2026

• BigQuery Storage Read API session expiration causes failures for large source reads

  GoogleCloudDataproc/flink-bigquery-connector#285 · Filter by author fqshopify opened on Mar 4, 2026

• Add support for CDC operations

  GoogleCloudDataproc/flink-bigquery-connector#261 · Filter by author fadelananda opened on Jan 27, 2026
  2

• Add support for indirect writes

  GoogleCloudDataproc/flink-bigquery-connector#253 · Filter by author fqshopify opened on Jan 14, 2026
  1

• Stream has been finalized and cannot be appended during Flink job recovery after task manager restart

  GoogleCloudDataproc/flink-bigquery-connector#235 · Filter by author lpvcpp opened on Sep 19, 2025
  2

• Multiple Parallelism Support missing

  GoogleCloudDataproc/flink-bigquery-connector#228 · Filter by author abhinav0kumar opened on May 15, 2025

• Reading TIMESTAMP fields

  GoogleCloudDataproc/flink-bigquery-connector#227 · Filter by author abhinav0kumar opened on May 13, 2025

• Errors on Flink deployments

  GoogleCloudDataproc/flink-bigquery-connector#223 · Filter by author mina-asham opened on Mar 17, 2025

• PyFlink Table SQL Job on GKE Failed to Sink Data to BigQuery

  GoogleCloudDataproc/flink-bigquery-connector#216 · Filter by author emersonwangsd opened on Feb 23, 2025

• Table API implementation is unable to read BigNumeric Records

  GoogleCloudDataproc/flink-bigquery-connector#126 · Filter by author prashastia opened on Jun 10, 2024
  1

• Introduce reuse of BigQuery connector common implementation

  GoogleCloudDataproc/flink-bigquery-connector#58 · Filter by author prodriguezdefino opened on Aug 8, 2023