apache/beam

Issues

• [Feature Request]: Topic array support for MqttIO.Read

  #32468 opened 2 months ago by SamLeurink
  6

• [Feature Request]: Enable CDC configuration for cross language StorageWrite API usage

  #32527 opened a month ago by prodriguezdefino
  1

• [Feature Request]: vLLM model handler

  #32528 opened a month ago by damccorm
  0

• [Feature Request]: Protobuf 5+ support

  #32302 opened 2 months ago by steerlink
  1

• [Feature Request]: Add A Freature to get bigquery schema dynamically from a POJO class.

  #32311 opened 3 months ago by nivedha1
  1

• [Task]: Add utilities to easily implement portable dynamic destinations

  #32365 opened 2 months ago by ahmedabu98
  0

• [Bug]: Unable to Restart Google Spanner Change Streams Consumer due to tableExists(table_name) bug

  #32509 opened 2 months ago by NimzyMaina
  9

• [Prism][Task]: Register Java Prism Runner pipeline options

  #32364 opened 2 months ago by damondouglas
  0

• [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew

  #32508 opened 2 months ago by ns-shua
  15

• [Feature Request][Java]:filesToStage should support the gcs file path

  #32531 opened 2 months ago by liferoad
  0

• [Bug]: How to run YAML pipeline from Python SDK rather than from command line

  #32416 opened 2 months ago by diptenduLF
  1

• [Bug]: minimal wordcount golang example is freezeing on gcs reading

  #32498 opened 2 months ago by LeoCBS
  7

• [Bug]: ParDoLifeCycleTest in Stateful DoFn fails on Samza PVR runner

  #32520 opened 2 months ago by Abacn
  0

• [Bug]: PeriodicSequence reports large amount of remaining work / size when used with infinite stop time

  #32506 opened 2 months ago by scwhittle
  0

• [Bug]: Pipeline may stuck after error thrown in transform due to racing condition in CancellableQueue

  #32502 opened 2 months ago by Abacn
  0

• [Bug]: PubsubIO on Flink Runner not acknowledging old messages

  #32461 opened 2 months ago by xzhang2sc
  8

• [Bug]: NPE on JmsIO

  #32483 opened 2 months ago by flo076
  1

• [Bug]: Re-enable GoUsingJava xlang suites

  #32492 opened 2 months ago by tvalentyn
  0

• [Bug]: Error when using ReadFromCsv to read non-utf8 encoding file

  #32462 opened 2 months ago by shunping
  1

• [Feature Request]: Add option to set maximum Storage API streams when using autosharding

  #32490 opened 2 months ago by ahmedabu98
  0

• Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec

  #32457 opened 2 months ago by github-actions
  0

• [CsvIO]: Support non-UTF8 text encoding for parse/reads and writes

  #32485 opened 2 months ago by damondouglas
  0

• [Bug]: tour of beam content cannot be scrolled on ipad

  #32481 opened 2 months ago by captainhunt
  0

• [Feature Request]: Add soft-deadline before 1 minute hard-deadline to Spanner Change Stream IO connector

  #32473 opened 2 months ago by dedocibula
  1

• [Bug]: Incorrect Output for Beam SQL MONTH and YEAR window queries

  #32458 opened 2 months ago by experiencedProcrastinator
  0

• [Bug]: Playground needs to be updated to use a more recent version of Go (minimum Go 1.21)

  #32441 opened 2 months ago by lostluck
  0

• The PreCommit GoPortable job is flaky

  #32324 opened 2 months ago by github-actions
  8

• [Bug]: `TestPipeline` Behavior Different on Windows vs Linux

  #32448 opened 2 months ago by jd185367
  0

• [Task]: Re-enable pip check on macos tests

  #32431 opened 2 months ago by shunping
  0

• [Bug]: Java generated RowCoder doesn't use encodingPositions when encoding/decoding the null set

  #32388 opened 2 months ago by scwhittle
  0

• Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime

  #32343 opened 2 months ago by github-actions
  0

• [RRIO] [Task]: Add withErrorHandler to accept ErrorHandler.BadRecordErrorHandler

  #32418 opened 2 months ago by damondouglas
  0

• [Feature Request]: Support Zstd codec in SerializableAvroCodecFactory

  #32349 opened 2 months ago by clairemcginty
  0

• [Failing Test]:

  #32315 opened 3 months ago by Lucky777178
  2

• [Feature Request]: Docker images with both runtime and launch environments

  #32387 opened 3 months ago by amardeep
  2

• [Feature Request]: Expand --extra_package option to allow passing a directory containing the package and deprecate the --setup_file option

  #32380 opened 3 months ago by tvalentyn
  1

• [Bug]: Using `GcsIO` in Python with a `DoFn` fails

  #32361 opened 3 months ago by iht
  1

• [Bug]: Flink Job manager metaspace classloader leak

  #32372 opened 3 months ago by gli-marc-hurabielle
  0

• Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec

  #32370 opened 3 months ago by github-actions
  0

• Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime

  #32371 opened 3 months ago by github-actions
  0

• [Bug]: Add check for self-referencing input in YAML transform

  #32339 opened 3 months ago by Polber
  0

• [Bug]: BigQueryIO storage write api streaming dynamic destination conflicts if multiple transforms set same destination key

  #32335 opened 3 months ago by Abacn
  0

• [Feature Request]: Emit warnings when pcollection elements approach or exceed 2GB limits.

  #32334 opened 3 months ago by tvalentyn
  0

• [Bug]: Better error message for specifying inputs on chain pipeline in Beam YAML

  #32333 opened 3 months ago by Polber
  0

• [Bug]: Support error handling in PyTransform

  #32332 opened 3 months ago by Polber
  0

• [Feature Request]: Auto-detect Schema for Parquet Sink

  #32322 opened 3 months ago by gbsDojo
  0

• [Task]: Fix invalid links in `Beam Programming Guide`

  #32316 opened 3 months ago by twosom
  1

• [Bug]: Beam Interactive Tour Mismatch

  #32309 opened 3 months ago by MrYanMYN
  0

• [Bug]: Issue with the script for adding execute task in "Convert from Maven to Gradle" section

  #32306 opened 3 months ago by KomiB-Atsou
  1

• [Feature Request]: Running Word-Count with Gradle for PowerShell

  #32307 opened 3 months ago by KomiB-Atsou
  1