github  

Messages by Thread

• • Re: [PR] Bumpy numpy bounds to include 2.3.X [beam] via GitHub
  • Re: [PR] Bump numpy bounds to include 2.3.X [beam] via GitHub
  • Re: [PR] Bump numpy bounds to include 2.3.X [beam] via GitHub
• [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
  • Re: [PR] Reduce weighing overhead for caching blocks [beam] via GitHub
• Re: [I] [Bug]: [Flink] JdbcIO metrics are always `NaN` when using the FlinkRunner [beam] via GitHub
  • Re: [I] [Bug]: [Flink] JdbcIO metrics are always `NaN` when using the FlinkRunner [beam] via GitHub
• Re: [I] [Bug]: segmentation fault in WriteToFile with DirectRunner [beam] via GitHub
  • Re: [I] [Bug]: segmentation fault in WriteToFile with DirectRunner [beam] via GitHub
• Re: [I] [Task]: Yaml - Consider checking for callable in the if branch [beam] via GitHub
  • Re: [I] [Task]: Yaml - Consider checking for callable in the if branch [beam] via GitHub
• Re: [I] [Task] [IcebergIO]: Add RESTCatalog tests [beam] via GitHub
• [PR] Update _index.md [beam] via GitHub
  • Re: [PR] Update _index.md [beam] via GitHub
  • Re: [PR] Update _index.md [beam] via GitHub
  • Re: [PR] Update _index.md [beam] via GitHub
• Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
  • Re: [I] The Content-Security-Policy header must not be overridden [beam] via GitHub
• [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
  • Re: [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] via GitHub
• [I] [Bug]: FirestoreV1 Beam connectors allow configuring inconsistent project/database IDs between RPC requests and routing headers [beam] via GitHub
  • Re: [I] [Bug]: FirestoreV1 Beam connectors allow configuring inconsistent project/database IDs between RPC requests and routing headers [beam] via GitHub
  • Re: [I] [Bug]: FirestoreV1 Beam connectors allow configuring inconsistent project/database IDs between RPC requests and routing headers [beam] via GitHub
• [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
  • Re: [PR] Flink 1.20 support [beam] via GitHub
• [PR] Add timestamp-nanos avro logical type support in bigquery utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
  • Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] via GitHub
• Re: [I] [Task]: Single dockerhub repository for Flink job server container [beam] via GitHub
• [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
  • Re: [PR] Add new method of generating key for GBEK [beam] via GitHub
• [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
  • Re: [PR] Fix nullness in some of Beam SQL [beam] via GitHub
• Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Java SDK breaking changes [beam] via GitHub
• Re: [I] Python Unit Tests is getting much slower since 2.67.0 [beam] via GitHub
• [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] via GitHub
  • Re: [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] via GitHub
  • Re: [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] via GitHub
  • Re: [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] via GitHub
  • Re: [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] via GitHub
• [I] [Feature Request]: Add Support for ClickHouse Cluster in `ClickHouseResourceManager` [beam] via GitHub
• [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
  • Re: [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] via GitHub
• [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] via GitHub
  • Re: [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] via GitHub
  • Re: [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] via GitHub
  • Re: [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] via GitHub
  • Re: [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] via GitHub
• [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] via GitHub
  • Re: [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] via GitHub
  • Re: [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] via GitHub
• [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] via GitHub
  • Re: [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] via GitHub
  • Re: [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] via GitHub
• Re: [I] [Feature Request]: Hudi Table support / IO Connector for HoodieIO [beam] via GitHub
• Re: [PR] [Python]Fix type inference for closures in lambdas [beam] via GitHub
  • Re: [PR] [Python]Fix type inference for closures in lambdas [beam] via GitHub
  • Re: [PR] [Python]Fix type inference for closures in lambdas [beam] via GitHub
• Re: [I] [Task]: [flink] portable runner is not ported on new Source API [beam] via GitHub
  • Re: [I] [Task]: [flink] portable runner is not ported on new Source API [beam] via GitHub
• Re: [I] [Bug]: Spark and Samza runner fail on a test of sliding windows [beam] via GitHub
  • Re: [I] [Bug]: Spark and Samza runner fail on a test of sliding windows [beam] via GitHub
  • Re: [I] [Bug]: Spark and Samza runner fail on a test of sliding windows [beam] via GitHub
• Re: [I] [Bug]: BigQuery streaming at-least-once job missing records [beam] via GitHub
  • Re: [I] [Bug]: BigQuery streaming at-least-once job missing records [beam] via GitHub
• Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] via GitHub
  • Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] via GitHub
  • Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] via GitHub
• Re: [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] via GitHub
  • Re: [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] via GitHub
  • Re: [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] via GitHub
• Re: [PR] Update default max publish batch byte size calculation [beam] via GitHub
  • Re: [PR] Update default max publish batch byte size calculation [beam] via GitHub
  • Re: [PR] Update default max publish batch byte size calculation [beam] via GitHub
• Re: [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] via GitHub
  • Re: [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] via GitHub
• Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
  • Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
  • Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
  • Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
  • Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
  • Re: [PR] Bump Beartype bounds to >= 0.22.0 [beam] via GitHub
• [I] [Feature Request]: Propagate drain mode up to reduceFn [beam] via GitHub
  • Re: [I] [Feature Request]: Propagate drain mode up to reduceFn [beam] via GitHub
• [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
  • Re: [PR] Add python side input pattern [beam] via GitHub
• Re: [I] [Task]: Update Python slowly updating side input example [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.9 to 1.20.11 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.9 to 1.20.11 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.9 to 1.20.11 in /sdks [beam] via GitHub
• [PR] [TEST] [No need to reivew] Fix Spark 4.x compilation errors for Beam Spark Runner [beam] via GitHub
• [PR] Fix GcsEndpoint serialization in GcsOptions [beam] via GitHub
  • Re: [PR] Fix GcsEndpoint serialization in GcsOptions [beam] via GitHub
  • Re: [PR] Fix GcsEndpoint serialization in GcsOptions [beam] via GitHub
  • Re: [PR] Fix GcsEndpoint serialization in GcsOptions [beam] via GitHub
• Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] via GitHub
  • [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] via GitHub
  • [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] via GitHub
  • [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
  • [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
• [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] via GitHub

• Earlier messages
• Later messages