github  

Messages by Thread

• • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
• Re: [I] [Feature Request]: Wait.on for Go SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Wait.on for Go SDK [beam] via GitHub
• Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
  • Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] via GitHub
• [PR] Fix KafkaToPubsubE2ETest by bumping the purged cloud-sdk emulator image tag [beam] via GitHub
  • Re: [PR] [Kafka] Fix KafkaToPubsubE2ETest by bumping the purged cloud-sdk emulator image tag [beam] via GitHub
• Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
• [PR] Update Java BOM [beam] via GitHub
  • Re: [PR] Update Java BOM [beam] via GitHub
  • Re: [PR] Update republish released workflow default values [beam] via GitHub
  • Re: [PR] Update republish released workflow default values [beam] via GitHub
• Re: [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
• Re: [PR] [Flink] Select bounded-source split assignment by estimated size [beam] via GitHub
  • Re: [PR] [Flink] Select bounded-source split assignment by estimated size [beam] via GitHub
• [I] [Failing Test]: KafkaToPubsubE2ETest fails everywhere, pinned cloud-sdk:316.0.0-emulators image was removed from gcr.io [beam] via GitHub
  • Re: [I] [Failing Test]: KafkaToPubsubE2ETest fails everywhere, pinned cloud-sdk:316.0.0-emulators image was removed from gcr.io [beam] via GitHub
• [PR] Bump to Beam 2.76.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump to Beam 2.76.0 [beam-starter-java] via GitHub
• Re: [I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam] via GitHub
  • Re: [I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam] via GitHub
• Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] via GitHub
  • Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] via GitHub
  • Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] via GitHub
  • Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] via GitHub
• Re: [I] [Task]: Build RC and non-RC wheels in parallel. [beam] via GitHub
  • Re: [I] [Task]: Build RC and non-RC wheels in parallel. [beam] via GitHub
  • Re: [I] [Task]: Build RC and non-RC wheels in parallel. [beam] via GitHub
• Re: [I] [Task]: Rewrite Go README [beam] via GitHub
  • Re: [I] [Task]: Rewrite Go README [beam] via GitHub
  • Re: [I] [Task]: Rewrite Go README [beam] via GitHub
• Re: [I] [Bug]: Java portable SDK should enable heap dumping with HeapDumpOnOutOfMemoryError if configured [beam] via GitHub
  • Re: [I] [Bug]: Java portable SDK should enable heap dumping with HeapDumpOnOutOfMemoryError if configured [beam] via GitHub
  • Re: [I] [Bug]: Java portable SDK should enable heap dumping with HeapDumpOnOutOfMemoryError if configured [beam] via GitHub
• Re: [I] [Feature Request]: Add hint to ReadFromMongoDB, MongoDBIO Connector [beam] via GitHub
  • Re: [I] [Feature Request]: Add hint to ReadFromMongoDB, MongoDBIO Connector [beam] via GitHub
  • Re: [I] [Feature Request]: Add hint to ReadFromMongoDB, MongoDBIO Connector [beam] via GitHub
• Re: [I] [Bug]: [Java BQ] Reduce the number of retries for streaming Storage API writes [beam] via GitHub
  • Re: [I] [Bug]: [Java BQ] Reduce the number of retries for streaming Storage API writes [beam] via GitHub
  • Re: [I] [Bug]: [Java BQ] Reduce the number of retries for streaming Storage API writes [beam] via GitHub
• Re: [I] [Bug]: JdbcIO.readRows() incompatible with AvroUtils for DECIMAL\NUMERIC(10,2) [beam] via GitHub
  • Re: [I] [Bug]: JdbcIO.readRows() incompatible with AvroUtils for DECIMAL\NUMERIC(10,2) [beam] via GitHub
  • Re: [I] [Bug]: JdbcIO.readRows() incompatible with AvroUtils for DECIMAL\NUMERIC(10,2) [beam] via GitHub
• [I] The PreCommit Java job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Java job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Java job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• Re: [PR] Handle multi-key bundles in side-input runner [beam] via GitHub
  • Re: [PR] Handle multi-key bundles in side-input runner [beam] via GitHub
  • Re: [PR] Handle multi-key bundles in side-input runner [beam] via GitHub
• [PR] [Python] Honor fixed object detection batch size [beam] via GitHub
  • Re: [PR] [Python] Honor fixed object detection batch size [beam] via GitHub
  • Re: [PR] [Python] Honor fixed object detection batch size [beam] via GitHub
• Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
  • Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
  • Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
  • Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
  • Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
  • Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
• Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
  • Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] via GitHub
• Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] via GitHub
  • Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] via GitHub
  • Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] via GitHub
  • Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] via GitHub
  • Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] via GitHub
• Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
• [PR] [#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] via GitHub
• Re: [PR] [#36841] Add streaming dispatch seam to the Spark Structured Streaming runner [beam] via GitHub
  • Re: [PR] [#36841] Add streaming dispatch seam to the Spark Structured Streaming runner [beam] via GitHub
  • Re: [PR] [#36841] Add streaming dispatch seam to the Spark Structured Streaming runner [beam] via GitHub
• Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
• [PR] [Java] Remove MS_EXPOSE_REP from the global SpotBugs filter [beam] via GitHub
  • Re: [PR] [Java] Remove MS_EXPOSE_REP from the global SpotBugs filter [beam] via GitHub
  • Re: [PR] [Java] Remove MS_EXPOSE_REP from the global SpotBugs filter [beam] via GitHub
  • Re: [PR] [Java] Remove MS_EXPOSE_REP from the global SpotBugs filter [beam] via GitHub
• Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
  • Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] via GitHub
• Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
• [PR] Updates Beam SQL to support Delta Lake read via Beam DeltaIO [beam] via GitHub
  • Re: [PR] Adds Delta Lake read support to Beam SQL [beam] via GitHub
  • Re: [PR] Adds Delta Lake read support to Beam SQL [beam] via GitHub
  • Re: [PR] Adds Delta Lake read support to Beam SQL [beam] via GitHub
  • Re: [PR] Adds Delta Lake read support to Beam SQL [beam] via GitHub
  • Re: [PR] Adds Delta Lake read support to Beam SQL [beam] via GitHub
• Re: [I] [Feature Request]: SolaceIO: Support binary content data payload [beam] via GitHub
• Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
• [PR] [Python] Configure object detection benchmark timeout [beam] via GitHub
  • Re: [PR] [Python] Configure object detection benchmark timeout [beam] via GitHub
• Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.3 to 1.109.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.3 to 1.109.1 in /sdks [beam] via GitHub
• Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.44 to 1.23.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.44 to 1.23.1 in /sdks [beam] via GitHub
• Re: [PR] Bump cloud.google.com/go/storage from 1.65.0 to 1.66.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/storage from 1.65.0 to 1.66.0 in /sdks [beam] via GitHub
• Re: [PR] Bump cloud.google.com/go/bigquery from 1.81.0 to 1.82.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/bigquery from 1.81.0 to 1.82.0 in /sdks [beam] via GitHub
• Re: [PR] Bump cloud.google.com/go/bigtable from 1.52.0 to 1.53.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/bigtable from 1.52.0 to 1.53.0 in /sdks [beam] via GitHub

• Later messages