github  

Messages by Thread

• • Re: [PR] SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed [beam] via GitHub
  • Re: [PR] SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed [beam] via GitHub
• [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
  • Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
  • Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
  • Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
  • Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
  • Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] via GitHub
• Re: [I] [Task]: Sunset Python 3.8 support [beam] via GitHub
• [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
  • Re: [PR] Distroless python sdk [beam] via GitHub
• [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
  • Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] via GitHub
• [PR] Update discussion docs [beam] via GitHub
  • Re: [PR] Update discussion docs [beam] via GitHub
  • Re: [PR] Update discussion docs [beam] via GitHub
  • Re: [PR] Update discussion docs [beam] via GitHub
• [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] via GitHub
  • Re: [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] via GitHub
  • Re: [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] via GitHub
  • Re: [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] via GitHub
  • Re: [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] via GitHub
• [PR] Suppress future warning affecting Dataflow notebook [beam] via GitHub
  • Re: [PR] Suppress future warning affecting Dataflow notebook [beam] via GitHub
  • Re: [PR] Suppress future warning affecting Dataflow notebook [beam] via GitHub
  • Re: [PR] Suppress future warning affecting Dataflow notebook [beam] via GitHub
• [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
  • Re: [PR] Add a simple validation transform to yaml. [beam] via GitHub
• [PR] Fix gemma notebook formatting [beam] via GitHub
  • Re: [PR] Fix gemma notebook formatting [beam] via GitHub
  • Re: [PR] Fix gemma notebook formatting [beam] via GitHub
  • Re: [PR] Fix gemma notebook formatting [beam] via GitHub
• [PR] Remove duplicate button from notebook [beam] via GitHub
  • Re: [PR] Remove duplicate button from notebook [beam] via GitHub
  • Re: [PR] Remove duplicate button from notebook [beam] via GitHub
  • Re: [PR] Remove duplicate button from notebook [beam] via GitHub
• [PR] Modify JVM options if enableHeapDumps is specified to dump heap in directory that MemoryMonitor will look in. [beam] via GitHub
• Re: [PR] Implement a `Top` partitioner [beam] via GitHub
• [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] via GitHub
• [PR] Add Python 3.12 to documentation [beam] via GitHub
  • Re: [PR] Add Python 3.12 to documentation [beam] via GitHub
  • Re: [PR] Add Python 3.12 to documentation [beam] via GitHub
  • Re: [PR] Add Python 3.12 to documentation [beam] via GitHub
  • Re: [PR] Add Python 3.12 to documentation [beam] via GitHub
  • Re: [PR] Add Python 3.12 to documentation [beam] via GitHub
• Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] via GitHub
• [PR] WIP: OnWindowExpiry, and OrderedListState WIP: DO NOT SUBMIT [beam] via GitHub
• [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] via GitHub
• [I] The PreCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is flaky [beam] via GitHub
• Re: [I] [prism] Support OnWindowExpiry [beam] via GitHub
• [PR] Fix a few notebook typos [beam] via GitHub
  • Re: [PR] Fix a few notebook typos [beam] via GitHub
• [PR] Rethrow BQ file loads writer errors [beam] via GitHub
  • Re: [PR] Rethrow BQ file loads writer errors [beam] via GitHub
  • Re: [PR] Rethrow BQ file loads writer errors [beam] via GitHub
  • Re: [PR] Don't swallow BQ file loads writer errors [beam] via GitHub
  • Re: [PR] Don't swallow BQ file loads writer errors [beam] via GitHub
• [PR] learning+website: add `FlattenWith` to Playground and Transform Catalog [beam] via GitHub
  • Re: [PR] learning+website: add `FlattenWith` and `Tee` to Playground and Transform Catalog [WIP] [beam] via GitHub
  • Re: [PR] learning+website: add `FlattenWith` and `Tee` to Playground and Transform Catalog [WIP] [beam] via GitHub
• Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] via GitHub
  • Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] via GitHub
  • Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] via GitHub
  • Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] via GitHub
  • Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] via GitHub
• Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
  • Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] via GitHub
• Re: [I] [Bug]: KafkaIO Should not throw errors for empty topics. [beam] via GitHub
• Re: [I] [Bug]: org.apache.avro.UnresolvedUnionException: Not in union after updating schema-registry [beam] via GitHub
• Re: [I] Incorrect Spanner IO Request Count metrics [beam] via GitHub
  • Re: [I] Incorrect Spanner IO Request Count metrics [beam] via GitHub
• Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] via GitHub
  • Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] via GitHub
• Re: [I] [Bug]: UnboundedSourceWrapper.splitSources is assigned too early. [beam] via GitHub
  • Re: [I] [Bug]: UnboundedSourceWrapper.splitSources is assigned too early. [beam] via GitHub
• Re: [I] [Bug]: Window trigger has lag when using Kafka and GroupByKey on Dataflow Runner [beam] via GitHub
• Re: [I] [Bug]: Backlog Does Not Track Consumer Lag for DataFlow Python Kafka Pipeline [beam] via GitHub
  • Re: [I] [Bug]: Backlog Does Not Track Consumer Lag for DataFlow Python Kafka Pipeline [beam] via GitHub
• Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] via GitHub
  • Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] via GitHub
• [PR] Upgrade go for various vulnz fixes [beam] via GitHub
  • Re: [PR] Upgrade go for various vulnz fixes [beam] via GitHub
  • Re: [PR] Upgrade go for various vulnz fixes [beam] via GitHub
  • Re: [PR] Upgrade go for various vulnz fixes [beam] via GitHub
  • Re: [PR] Upgrade go for various vulnz fixes [beam] via GitHub
• [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] via GitHub
  • Re: [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] via GitHub
  • Re: [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] via GitHub
  • Re: [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] via GitHub
  • Re: [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] via GitHub
• [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
  • Re: [PR] don't log missing computation state as error [beam] via GitHub
• [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
  • Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
  • Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
  • Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
  • Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
  • Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] via GitHub
• [I] [Failing Test]: Python Post-Commits are Perma-Red with Debezium IO failure [beam] via GitHub
  • Re: [I] [Failing Test]: Python Post-Commits are Perma-Red with Debezium IO failure [beam] via GitHub
• [I] [Bug]: Beam Jobs built using ver 2.50 and above are not running with FlinkRunners v 1.16.x [beam] via GitHub
  • Re: [I] [Bug]: Beam Jobs built using ver 2.50 and above are not running with FlinkRunners v 1.16.x [beam] via GitHub
• [PR] Pin debezium test container version [beam] via GitHub
  • Re: [PR] Pin debezium test container version [beam] via GitHub
  • Re: [PR] Pin debezium test container version [beam] via GitHub
  • Re: [PR] Pin debezium test container version [beam] via GitHub
  • Re: [PR] Pin debezium test container version [beam] via GitHub
  • Re: [PR] Pin debezium test container version [beam] via GitHub
• [PR] Remove gradle task java8's [beam] via GitHub
  • Re: [PR] Remove gradle task java8's [beam] via GitHub
  • Re: [PR] Remove gradle task java8's [beam] via GitHub
  • Re: [PR] Remove gradle task java8's [beam] via GitHub
• [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
  • Re: [PR] Windowing Support for the Dask Runner [beam] via GitHub
• Re: [I] [Task]: Update Debezium test container back to latest [beam] via GitHub
  • Re: [I] [Task]: Update Debezium test container back to latest [beam] via GitHub
• Re: [I] [Task][prism]: Be able to execute non-Go SDKs on Prism. [beam] via GitHub
• [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
  • Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] via GitHub
• Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
  • Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] via GitHub
• [PR] Fix web page references to Flink 1.19 support since it is not released until 2.61.0 [beam] via GitHub
  • Re: [PR] Fix web page references to Flink 1.19 support since it is not released until 2.61.0 [beam] via GitHub
  • Re: [PR] Fix web page references to Flink 1.19 support since it is not released until 2.61.0 [beam] via GitHub
  • Re: [PR] Fix web page references to Flink 1.19 support since it is not released until 2.61.0 [beam] via GitHub
• [PR] Kafka uw poll metrics [beam] via GitHub
  • Re: [PR] Kafka uw poll metrics [beam] via GitHub
  • Re: [PR] Kafka uw poll metrics [beam] via GitHub
  • Re: [PR] Kafka uw poll metrics [beam] via GitHub
  • Re: [PR] Kafka uw poll metrics [beam] via GitHub
  • Re: [PR] Kafka SDF add Poll Latency Metrics [beam] via GitHub
  • Re: [PR] Kafka SDF add Poll Latency Metrics [beam] via GitHub

• Earlier messages
• Later messages