You are viewing a plain text version of this content. The canonical link for it is here.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.53.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 05:01:53 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.53.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 05:01:56 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.14 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 05:04:46 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.13 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 05:04:47 UTC, 1 replies.
- [I] [Bug]: Install fails with Python3.12 due to old grpcio-tools version [beam] - posted by "sehoffmann (via GitHub)" <gi...@apache.org> on 2024/04/01 09:50:02 UTC, 4 replies.
- Re: [PR] [YAML] Add support for callable kwargs for Combine, PyTransform and custom python transform providers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 12:40:42 UTC, 2 replies.
- Re: [PR] Periodically send perworkermetric updates on the WorkerMessages api. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 12:40:44 UTC, 1 replies.
- Re: [PR] [YAML] Add MLTransform. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/01 12:40:45 UTC, 1 replies.
- [I] [Feature Request]: Add a ValueProvider option for BQ clustering [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/01 13:15:15 UTC, 1 replies.
- Re: [PR] Update python transform catalog [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/01 13:35:57 UTC, 13 replies.
- Re: [I] The PreCommit Python Coverage job is flaky [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/01 14:00:27 UTC, 5 replies.
- Re: [PR] fix error in BigQueryUtils when retrieving non existent avro field [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:07:58 UTC, 1 replies.
- Re: [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:08:07 UTC, 0 replies.
- Re: [I] The PostCommit Java Dataflow V1 job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:08:07 UTC, 0 replies.
- Re: [PR] Removing deprecated TestRule in TestPipeline [beam] - posted by "scott-strong (via GitHub)" <gi...@apache.org> on 2024/04/01 14:22:11 UTC, 0 replies.
- Re: [I] [Bug]: org.junit.rules.TestRule class referenced in TestPipeline deprecated in newest version of junit [beam] - posted by "scott-strong (via GitHub)" <gi...@apache.org> on 2024/04/01 14:23:30 UTC, 1 replies.
- Re: [PR] Include everit_json_schema in schemaio expansion service uber jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:26:33 UTC, 0 replies.
- Re: [PR] add get beam latest release and fix GCP auth [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:29:10 UTC, 0 replies.
- Re: [I] [Task]: Update beam_PostCommit_Java_IO_Performance_Tests.yml to select release branch automatically [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:29:11 UTC, 0 replies.
- Re: [I] [Failing Test]: Python Coverage is failing because of new version of typing-extension release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 14:36:07 UTC, 5 replies.
- [PR] [Python] Update tensorflow version in relevant tests [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/01 15:18:32 UTC, 2 replies.
- Re: [PR] only record per state change processing times for streaming pipelines [beam] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/04/01 16:55:29 UTC, 1 replies.
- Re: [PR] Export gcs options [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/04/01 17:05:23 UTC, 9 replies.
- Re: [PR] [Java] ManagedIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/01 17:40:35 UTC, 51 replies.
- Re: [I] [Failing Test]: beam_PostRelease_NightlySnapshot red due to various flakes in Dataflow example tests [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/01 17:43:10 UTC, 1 replies.
- Re: [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1711845145 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 18:16:08 UTC, 4 replies.
- Re: [PR] python sdk: fix several bugs regarding avto <-> beam schema conversion [beam] - posted by "benkonz (via GitHub)" <gi...@apache.org> on 2024/04/01 18:29:57 UTC, 17 replies.
- Re: [I] [Bug]: Beam Sql is ignoring aliases fields in some situations which causes to huge data loss [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/01 20:17:44 UTC, 13 replies.
- [PR] Include everit_json_schema in schemaio expansion service uber jar (#30779) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/01 20:21:52 UTC, 4 replies.
- Re: [PR] Fix typo in side-inputs `README.md` [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/01 21:07:44 UTC, 1 replies.
- Re: [PR] Add WaitOn transform to Python, analogous to Java's Wait.on. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/01 22:02:01 UTC, 4 replies.
- Re: [PR] Lower various logging statement levels to clean up example printing [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/01 23:23:01 UTC, 6 replies.
- Re: [PR] Add identity function as default to FlatMap [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/01 23:26:37 UTC, 4 replies.
- Re: [PR] Tune maximum thread count for streaming dataflow worker executor dynamically. [beam] - posted by "MelodyShen (via GitHub)" <gi...@apache.org> on 2024/04/01 23:28:48 UTC, 4 replies.
- Re: [PR] Don't double-nest display data payloads. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/01 23:50:00 UTC, 0 replies.
- Re: [PR] Re-add iceberg bounded source; test splitting [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/02 01:00:02 UTC, 17 replies.
- Re: [PR] Initial Iceberg Sink [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/04/02 02:03:16 UTC, 11 replies.
- [PR] Elasticsearch enable Point In Time based searches [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/04/02 06:55:04 UTC, 11 replies.
- Re: [PR] Add direct path code path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/02 07:16:01 UTC, 33 replies.
- [PR] Add /job/cancel endpoint to prism web server. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/02 07:20:50 UTC, 6 replies.
- Re: [PR] add channel cache [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/02 07:57:09 UTC, 3 replies.
- Re: [PR] Add SpannerIO Stress test [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/02 08:16:33 UTC, 1 replies.
- Re: [I] adding extra_header causing issue while reading GCS file in colab [beam] - posted by "minhajpasha (via GitHub)" <gi...@apache.org> on 2024/04/02 09:29:31 UTC, 1 replies.
- [PR] Docker - Remove Deprecated Types [beam] - posted by "evan-burrell (via GitHub)" <gi...@apache.org> on 2024/04/02 10:18:04 UTC, 2 replies.
- Re: [PR] Duet ai code prompts for gcloud services [beam] - posted by "dariabezkorovaina (via GitHub)" <gi...@apache.org> on 2024/04/02 13:05:58 UTC, 3 replies.
- Re: [PR] Duet AI code prompts final [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 14:54:50 UTC, 1 replies.
- Re: [I] [Feature Request]: Support for Apache Flink 1.18 in Beam Runners [beam] - posted by "danielmfinn (via GitHub)" <gi...@apache.org> on 2024/04/02 15:40:06 UTC, 9 replies.
- [PR] Update dataflow containers on release branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 16:41:10 UTC, 5 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:09 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:09 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:10 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:10 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:10 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:11 UTC, 3 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 17:38:11 UTC, 0 replies.
- [PR] Add Python 3.12 support [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/02 17:44:26 UTC, 0 replies.
- [I] [Failing Test]: JS2PY not supporting Python 3.12 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/02 17:47:32 UTC, 4 replies.
- Re: [PR] Add cancel button to Prism UI [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/02 19:01:33 UTC, 1 replies.
- [I] [Feature Request]: Managed transforms Java API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/02 19:31:40 UTC, 1 replies.
- Re: [PR] Bump github.com/tetratelabs/wazero from 1.6.0 to 1.7.0 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/02 19:34:47 UTC, 2 replies.
- Re: [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.0.0+incompatible in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/02 19:45:06 UTC, 2 replies.
- Re: [PR] [Python] Add a couple quality-of-life improvemenets to `testing.util.assert_that` [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/04/02 20:00:04 UTC, 27 replies.
- [I] [Task]: Read using JDBCIO in Python does not return helpful error message if a coder was not registered [beam] - posted by "andreigurau (via GitHub)" <gi...@apache.org> on 2024/04/02 20:03:57 UTC, 0 replies.
- [PR] Protect 2.55.1 branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/02 20:10:37 UTC, 3 replies.
- Re: [I] [prism]: Add cancel button to Prism UI [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/02 20:21:45 UTC, 0 replies.
- [PR] Add back Avro 1.8.2 to test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/02 20:51:43 UTC, 6 replies.
- Re: [PR] Create YAML Join Trasnform [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/02 23:44:15 UTC, 2 replies.
- [I] [Bug]: KafkaIO should assign partitions uniformly. [beam] - posted by "damnMeddlingKid (via GitHub)" <gi...@apache.org> on 2024/04/02 23:52:23 UTC, 1 replies.
- [PR] [yaml] add --providers and --providers_file flags [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/03 01:12:24 UTC, 5 replies.
- [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 04:16:25 UTC, 3 replies.
- Re: [PR] Bump com.gradle.enterprise from 3.15.1 to 3.16.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 04:16:28 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.59.1 to 1.60.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 04:17:54 UTC, 3 replies.
- Re: [I] [Bug]: Messages are not ACK on Pubsub starting Beam 2.52.0 on Flink Runner in detached mode [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/04/03 09:05:08 UTC, 3 replies.
- Re: [PR] [Flink] Speed up file write in batch mode by using larger bundle size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 11:34:47 UTC, 4 replies.
- Re: [PR] Call `DateTime(long)` instead of `DateTime(Object)`. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 12:13:45 UTC, 5 replies.
- Re: [PR] replace clock.milliseconds with stopwatch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 12:13:47 UTC, 4 replies.
- Re: [PR] Implement ordered list state for FnApi. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 12:13:48 UTC, 1 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 12:13:52 UTC, 5 replies.
- [PR] Add patch release docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/03 15:39:30 UTC, 3 replies.
- [PR] Patch release website changes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/03 15:47:23 UTC, 5 replies.
- [PR] Bump pillow from 10.2.0 to 10.3.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 16:22:56 UTC, 4 replies.
- [PR] Bump pillow from 10.2.0 to 10.3.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 16:24:00 UTC, 1 replies.
- Re: [PR] White space Fix log and error messages [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/03 17:07:44 UTC, 2 replies.
- [PR] Proposed edits for Beam YAML overview [beam] - posted by "VeronicaWasson (via GitHub)" <gi...@apache.org> on 2024/04/03 20:31:01 UTC, 5 replies.
- [PR] [yaml] disable javascript mapping for python >=3.12 [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/03 21:44:24 UTC, 8 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/03 22:13:31 UTC, 1 replies.
- Re: [PR] Implement LockFreeHistogram and use it for PerWorkerHistograms [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/04 00:04:28 UTC, 2 replies.
- [PR] ignore -- end of options [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/04 02:07:13 UTC, 2 replies.
- Re: [PR] byte-buddy:1.14.12 [beam] - posted by "labianchin (via GitHub)" <gi...@apache.org> on 2024/04/04 09:19:27 UTC, 1 replies.
- [PR] update gcloud to 471 in runner image [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/04 09:22:01 UTC, 2 replies.
- Re: [PR] Correct per-entry HashMap overhead in WindmillStateCache [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/04 09:23:40 UTC, 4 replies.
- [PR] add terraform for utility cluster. Add name override to gke [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/04 09:40:31 UTC, 36 replies.
- [PR] Load and Stress Tests: Add workflows, improvements and fixes [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/04/04 09:45:27 UTC, 4 replies.
- [PR] [Flink] finalize checkpoint marks in the new Flink source implementation [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/04/04 10:27:59 UTC, 7 replies.
- Re: [I] [Bug]: Kafka consumer offsets are not being committed to Kafka in Beam v2.52.0 on Flink Runner [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/04/04 10:30:08 UTC, 1 replies.
- Re: [PR] Clean up stale code in BigtableService [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/04 12:15:27 UTC, 4 replies.
- Re: [PR] Remove unused it-gcp and it-jdbc modules [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/04 12:39:36 UTC, 2 replies.
- Re: [PR] Fix Splunk resource manager max messages limit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/04 12:39:38 UTC, 2 replies.
- Re: [PR] Add support for M1/M2 mac in PytorchModelHandlerTensor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/04 12:39:40 UTC, 1 replies.
- Re: [PR] [DO NOT MERGE] Flink 1.17 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/04 14:43:25 UTC, 3 replies.
- Re: [PR] Fix Jms drop record [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/04/04 14:52:27 UTC, 8 replies.
- [I] [Bug]: ClassCastException with unknown fields in STORAGE_WRITE_API [beam] - posted by "lucasnoetzold (via GitHub)" <gi...@apache.org> on 2024/04/04 15:05:02 UTC, 0 replies.
- [PR] Allow lazy iteration for non-reiterables. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/04 15:45:51 UTC, 4 replies.
- [I] [Failing Test]: beam_PreCommit_Python_Coverage suite fails with ModuleNotFoundError: No module named 'pydantic._hypothesis_plugin' [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/04 17:48:17 UTC, 10 replies.
- [PR] [Test only] Introduce checkpointtimeout [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/04 18:47:21 UTC, 0 replies.
- Re: [PR] Implementing lull reporting at bundle level processing [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2024/04/04 18:49:51 UTC, 28 replies.
- [I] [Failing Test]: Running `which java` seems to cause flakes in some YAML tests on GHA runners [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/04 19:20:28 UTC, 0 replies.
- [PR] [Testing] Try fixing inference benchmark tests [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/04 19:30:06 UTC, 9 replies.
- Re: [PR] Implement LengthPrefixCoder.to_type_hint [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/04 19:52:19 UTC, 12 replies.
- [PR] Correct the version spec [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/04 19:58:17 UTC, 2 replies.
- Re: [PR] Add Redistribute transform to model, Java SDK, and most active runners [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/04 20:52:07 UTC, 12 replies.
- [PR] Use empty flags for default expansion service options. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/04 20:59:32 UTC, 3 replies.
- [PR] [do not merge] remove --pre for testing purposes [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/04 21:03:52 UTC, 5 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/04 22:12:48 UTC, 1 replies.
- Re: [PR] Create YAML Join Transform [beam] - posted by "itodotimothy6 (via GitHub)" <gi...@apache.org> on 2024/04/04 22:20:55 UTC, 15 replies.
- [PR] [YAML] Interpret PDone as no outputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/04 22:44:42 UTC, 3 replies.
- [PR] Add a lower bound on pydantic [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/04 22:55:26 UTC, 1 replies.
- [PR] merging non-canonical environments fails [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/05 01:19:00 UTC, 8 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 1.12.1 to 2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/05 04:48:59 UTC, 3 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 1.12.1 to 1.13 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/05 04:49:02 UTC, 1 replies.
- [PR] update runner image [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/05 08:17:15 UTC, 2 replies.
- [I] [Bug]: [beam] - posted by "DerRidda (via GitHub)" <gi...@apache.org> on 2024/04/05 13:08:02 UTC, 0 replies.
- Re: [I] [Bug]: Side Input Singleton View throw error when impulse period is short: PCollection with more than one element accessed as a singleton view [beam] - posted by "IvanFroehlich (via GitHub)" <gi...@apache.org> on 2024/04/05 13:27:04 UTC, 4 replies.
- Re: [I] [Bug]: GRCPIO 1.62.1 deadlocks in Beam SDK worker with Dataflow [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/05 13:50:03 UTC, 27 replies.
- [PR] Bump GCP-BOM to 26.36.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/05 15:05:32 UTC, 6 replies.
- [PR] Adding support for high priority queries to xlang transforms writing … [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2024/04/05 15:46:57 UTC, 10 replies.
- Re: [I] [Bug]: WriteToPubSub failing on Beam YAML [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 16:09:58 UTC, 0 replies.
- [I] [Bug]: Cannot read from Kafka due to short poll timeout of consumer in KafkaIO [beam] - posted by "xianhualiu (via GitHub)" <gi...@apache.org> on 2024/04/05 16:40:20 UTC, 2 replies.
- Re: [PR] Yaml API: Day Zero tutorial notebook [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 16:51:35 UTC, 0 replies.
- Re: [PR] Adds a bound on pydantic to exclude incompatible versions in the compat test. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/05 17:43:10 UTC, 4 replies.
- [PR] Remove outdated comment about docker. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 18:15:07 UTC, 4 replies.
- [I] [Bug]: Spanner module in Python SDK does not support read/write priority [beam] - posted by "angad (via GitHub)" <gi...@apache.org> on 2024/04/05 18:17:29 UTC, 0 replies.
- [PR] Duet AI Prompts - Documentation Lookup Without Links [beam] - posted by "dariabezkorovaina (via GitHub)" <gi...@apache.org> on 2024/04/05 18:43:37 UTC, 5 replies.
- [PR] Add gradle target and github workflow for cross-langauge yaml tests. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 18:53:29 UTC, 5 replies.
- Re: [PR] [YAML] Disable Java variant of WriteToJson [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 18:55:11 UTC, 1 replies.
- [I] [Task]: Split up the beam_PreCommit_Python_Coverage test suite [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/05 19:41:48 UTC, 0 replies.
- [I] [Bug]: Java expansion service does not respect the namespace for all environments. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 20:08:20 UTC, 1 replies.
- [PR] [bug30870]: make consumer polling timeout configurable for KafkaIO.Read [beam] - posted by "xianhualiu (via GitHub)" <gi...@apache.org> on 2024/04/05 20:38:16 UTC, 19 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/05 22:13:38 UTC, 1 replies.
- [PR] Add code change guide contributor-doc [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/05 22:20:42 UTC, 17 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Python_Coverage suite fails with ModuleNotFoundError: No module named 'pydantic._hypothesis_plugin' and `pip check` failures [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/05 23:43:58 UTC, 0 replies.
- [PR] [YAML] Adds several tests exercising the cross-language capabilities. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/05 23:51:38 UTC, 6 replies.
- Re: [PR] Add more descriptive resource hint failure message [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/06 12:38:25 UTC, 2 replies.
- Re: [PR] Support logical types with arguments in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/06 12:38:27 UTC, 2 replies.
- [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1712449899 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/07 00:31:44 UTC, 2 replies.
- [I] The PostCommit Sickbay Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/07 12:38:42 UTC, 4 replies.
- [PR] Bump github.com/aws/smithy-go from 1.20.1 to 1.20.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 04:14:41 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.15 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 04:20:37 UTC, 1 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 1.12.1 to 2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 04:53:04 UTC, 3 replies.
- [PR] Add PubSubIO Stress test [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/08 10:33:27 UTC, 6 replies.
- [PR] Clean doc related to write data in bigquery.py [beam] - posted by "kevinzous (via GitHub)" <gi...@apache.org> on 2024/04/08 11:02:55 UTC, 4 replies.
- Re: [PR] Implement Web API connector interfaces [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 12:13:39 UTC, 4 replies.
- Re: [PR] [Typescript] SDK fixes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 12:39:45 UTC, 1 replies.
- [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py39 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 16:37:08 UTC, 3 replies.
- [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 16:37:20 UTC, 3 replies.
- [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 16:37:24 UTC, 3 replies.
- [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/08 16:37:24 UTC, 3 replies.
- [I] [Feature Request]: Add Java API for using and upgrading Iceberg via the Managed transforms API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/08 16:44:16 UTC, 2 replies.
- [PR] Support FLOAT32 type in Spanner [beam] - posted by "arawind (via GitHub)" <gi...@apache.org> on 2024/04/08 16:45:59 UTC, 5 replies.
- Re: [PR] Optimize histograms and metric names in BigQuerySinkMetrics [beam] - posted by "codecov-commenter (via GitHub)" <gi...@apache.org> on 2024/04/08 18:37:26 UTC, 0 replies.
- [PR] Revert "Revert #30533: Automatically execute unbounded pipelines in streaming mode." [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/08 20:57:27 UTC, 3 replies.
- Re: [PR] Windowing Support for the DaskRunner [beam] - posted by "cisaacstern (via GitHub)" <gi...@apache.org> on 2024/04/08 21:08:31 UTC, 0 replies.
- [PR] [yaml] backtick generated aliases on sql mappings [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/08 22:19:28 UTC, 16 replies.
- [PR] [yaml] add use-case example [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/08 22:42:30 UTC, 16 replies.
- [PR] [yaml] remove Combine from yaml_experimental_features [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/08 23:10:27 UTC, 4 replies.
- [PR] [yaml] Add Beam YAML Blog [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/08 23:37:57 UTC, 4 replies.
- [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 03:33:31 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.62.1 to 1.63.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 04:50:55 UTC, 1 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.26.0 to 0.30.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 04:59:14 UTC, 1 replies.
- Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.26.0 to 0.29.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 04:59:15 UTC, 1 replies.
- [PR] [java-extension-sql]Beam Sql doesn't honor aliases because of `BeamAggregateProjectMergeRule` optimization [beam] - posted by "brachi-wernick (via GitHub)" <gi...@apache.org> on 2024/04/09 07:15:04 UTC, 3 replies.
- [I] [Bug]: FlinkRunner emits new output from Impulse after restoring from savepoint [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/09 07:38:37 UTC, 1 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.55.0 to 2.55.1 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 09:05:31 UTC, 1 replies.
- [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 09:34:11 UTC, 2 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 09:34:12 UTC, 3 replies.
- Re: [PR] Add config validation to kafka read schema transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 12:13:46 UTC, 1 replies.
- [PR] Bump apache-beam from 2.55.0 to 2.55.1 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/09 13:01:28 UTC, 1 replies.
- [PR] #30903: Do not reemit data from impulse [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/09 14:02:47 UTC, 8 replies.
- Re: [PR] Revert #30533: Automatically execute unbounded pipelines in streaming mode. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/09 15:21:27 UTC, 1 replies.
- [PR] Add withFormatOnFailureFunction for BQ TableRow input [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/04/09 16:14:12 UTC, 0 replies.
- Re: [PR] [wip]Add withFormatOnFailureFunction for BQ STORAGE_WRITE_API [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/04/09 16:14:59 UTC, 0 replies.
- [PR] Update a restriction for another test suite [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/09 18:22:36 UTC, 5 replies.
- [I] [Task]: Document compatibility asipirations & test coverage policies for optional Beam dependencies [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/09 19:17:05 UTC, 0 replies.
- [I] [Feature Request]: Beam compat test suites should create compatible environments that installs Beam and Test environment dependencies [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/09 19:25:07 UTC, 0 replies.
- [PR] Iceberg Write SchemaTransform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/09 20:57:55 UTC, 4 replies.
- [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/04/09 23:34:45 UTC, 1 replies.
- [PR] Upgrade grpcio-tools. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/09 23:52:12 UTC, 2 replies.
- [PR] Skip calling Compute in RemoveSafeDeltaCounterCell if value exists [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/09 23:54:23 UTC, 8 replies.
- [PR] [#30870]: support consumer polling timeout in KafkaIO expansion service [beam] - posted by "xianhualiu (via GitHub)" <gi...@apache.org> on 2024/04/10 02:52:47 UTC, 9 replies.
- [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 05:03:17 UTC, 3 replies.
- Re: [I] [Feature Request]: Add Spanner ChangeStream support to Golang [beam] - posted by "chrispanag (via GitHub)" <gi...@apache.org> on 2024/04/10 09:33:00 UTC, 0 replies.
- [PR] Remove Bruno from reviewer pool [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 13:27:02 UTC, 3 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 15:29:16 UTC, 0 replies.
- Re: [I] [Task]: Update the minor version of cloudpickle library prior to Beam release. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 15:32:26 UTC, 0 replies.
- [PR] Add snappy to 3.11 containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 17:31:15 UTC, 4 replies.
- [PR] Update sqlalchemy requirement from >=1.3,<2.0 to >=1.3,<3.0 in /sdks/python [beam] - posted by "Dippatel98 (via GitHub)" <gi...@apache.org> on 2024/04/10 17:55:15 UTC, 8 replies.
- [PR] Add important category [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 20:52:28 UTC, 2 replies.
- Re: [I] [Task]: Include python-snappy in Python 3.11 containers once python-snappy supports Python 3.11 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/10 20:54:37 UTC, 0 replies.
- Re: [PR] Upload PerWorkerMetrics every 30 second instead of every 10 seconds [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/10 21:17:35 UTC, 3 replies.
- Re: [PR] Move logic to build a Labeled Metric Name to a util file. [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/10 21:19:00 UTC, 3 replies.
- [PR] Bump protobufjs from 6.11.3 to 6.11.4 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 21:48:02 UTC, 1 replies.
- [PR] Bump transformers from 4.30.0 to 4.38.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 22:46:51 UTC, 3 replies.
- [PR] Bump transformers from 4.30.0 to 4.38.0 in /sdks/python/apache_beam/ml/inference [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 22:47:12 UTC, 1 replies.
- [PR] Bump transformers from 4.36.0 to 4.38.0 in /sdks/python/apache_beam/examples/inference/runinference_metrics [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 22:58:41 UTC, 2 replies.
- [PR] Bump transformers from 4.36.0 to 4.38.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 22:58:41 UTC, 1 replies.
- [PR] Bump transformers from 4.36.0 to 4.38.0 in /sdks/python/apache_beam/examples/inference/large_language_modeling [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/10 22:58:43 UTC, 3 replies.
- [I] [Failing Test]: BigtableIOWriteTest::test_bigtable_write is about 50% flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/10 23:57:17 UTC, 4 replies.
- [PR] Bump tar from 6.1.11 to 6.2.1 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/11 03:59:36 UTC, 2 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/11 13:23:42 UTC, 2 replies.
- Re: [PR] create helper function [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/11 13:28:31 UTC, 0 replies.
- [PR] Fix cron in github workflow file [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/04/11 13:32:10 UTC, 2 replies.
- [PR] Fix playground typo breaking rendering [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/11 14:13:51 UTC, 3 replies.
- [PR] Remove comma that breaks formatting [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/11 14:28:14 UTC, 3 replies.
- Re: [I] [Bug]: OnTimer("loopingTimer") not triggered on 2.52.0 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/11 15:24:40 UTC, 3 replies.
- [PR] [yaml] Fix Beam YAML blog links [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/11 15:30:02 UTC, 5 replies.
- [PR] IcebergIO translation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/11 16:05:33 UTC, 3 replies.
- Re: [PR] [YAML] Increase re-use of providers with implicitly overlapping transforms. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/11 16:06:51 UTC, 1 replies.
- [PR] Add a link to Grafana statistics for flaky workflows [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/04/11 16:11:28 UTC, 6 replies.
- [PR] Fixup iceberg GitHub Action workflow [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/11 17:02:42 UTC, 6 replies.
- [PR] Restore pip logs also for requirements.txt case [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/11 22:31:37 UTC, 4 replies.
- [PR] Change ManagedSchemaTransformProvider to take a Row config [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/11 22:35:13 UTC, 3 replies.
- [PR] Disable profiling in cythonized code by default. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/11 23:16:53 UTC, 4 replies.
- [PR] Move dependency updates to right after branch cut [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/11 23:29:12 UTC, 8 replies.
- [PR] Fix broken lint and improve lint rules. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/11 23:37:35 UTC, 9 replies.
- [I] [Failing Test]: Java IO Precommit failing due to KafkaIOTranslation being out of sync [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/12 00:43:41 UTC, 3 replies.
- Re: [I] [Feature Request]: Support table schema field addition with Storage Write API autoSchemaUpdate [beam] - posted by "lucasnoetzold (via GitHub)" <gi...@apache.org> on 2024/04/12 01:57:38 UTC, 0 replies.
- [PR] Update java-dependency-guide contributor-doc reflecting gcpbomupgrader script [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/12 02:56:41 UTC, 6 replies.
- [PR] SchemaTransformProviderTranslation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/12 04:07:19 UTC, 0 replies.
- [PR] Bump idna from 3.6 to 3.7 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/12 04:09:54 UTC, 3 replies.
- [PR] Bump idna from 3.6 to 3.7 in /sdks/python/container/py39 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/12 04:10:50 UTC, 3 replies.
- [PR] Bump idna from 3.6 to 3.7 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/12 04:10:57 UTC, 3 replies.
- [PR] Bump idna from 3.6 to 3.7 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/12 04:11:08 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.0.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/12 05:09:27 UTC, 3 replies.
- Re: [I] [Bug]: RunInference with automatic refresh using a global window side inputs takes too long to update sometimes [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/12 12:19:05 UTC, 2 replies.
- Re: [PR] Args to set the max shard size in WriteToParquet [beam] - posted by "lpolisi (via GitHub)" <gi...@apache.org> on 2024/04/12 13:08:29 UTC, 1 replies.
- Re: [I] [Task]: Python Jdbc xlang test uses deprecated API for sqlalchemy [beam] - posted by "Dippatel98 (via GitHub)" <gi...@apache.org> on 2024/04/12 14:37:50 UTC, 1 replies.
- [PR] Increase the timeout value for LeaderBoard example on DataflowRunner [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/12 14:55:11 UTC, 2 replies.
- [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails with with external bigquery write [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/12 15:26:59 UTC, 3 replies.
- [PR] [BEAM-30950] Disable failing test for now. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/12 15:29:41 UTC, 3 replies.
- [PR] Revert "Tune maximum thread count for streaming dataflow worker executor dynamically. [beam] - posted by "MelodyShen (via GitHub)" <gi...@apache.org> on 2024/04/12 17:21:54 UTC, 5 replies.
- [PR] Document how to trigger test suites. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/12 17:45:08 UTC, 3 replies.
- [I] [Bug]: gradlew clean involves external transform generation and fails [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/12 18:20:58 UTC, 1 replies.
- [I] [Failing Test]: setuptools 69.3.0 breaks sdist [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/12 18:40:57 UTC, 3 replies.
- [PR] Fix sdist [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/12 18:42:19 UTC, 3 replies.
- [PR] [Python] Add feast feature store handler for enrichment transform [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/12 19:46:17 UTC, 14 replies.
- [PR] Revert setuptools upperbound since buggy releases are yanked. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/12 23:18:53 UTC, 4 replies.
- [PR] Automatically execute unbounded pipelines in streaming mode. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/13 01:33:46 UTC, 4 replies.
- Re: [PR] Debugging the TransformService test suite [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:22 UTC, 2 replies.
- Re: [PR] [Draft] Return methods in a lexicographical order from ReflectUtils.getMethods() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:23 UTC, 7 replies.
- Re: [PR] Schema field number documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:25 UTC, 2 replies.
- Re: [PR] Remove/Reserve PerStepNamespaceMetrics fields from GlobalGetDataRequest [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:26 UTC, 2 replies.
- Re: [PR] [yaml] Add UDF docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:29 UTC, 1 replies.
- Re: [PR] Log a warning, if the process method of DoFn returns None [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 12:37:31 UTC, 1 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/13 15:33:30 UTC, 2 replies.
- [PR] Add mechanism for skipping batching if your data is prebatched [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/13 17:18:58 UTC, 2 replies.
- Re: [I] The PostCommit Python Dependency job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/13 18:05:45 UTC, 1 replies.
- Re: [I] The LoadTests Python Combine Dataflow Streaming job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/13 18:09:28 UTC, 1 replies.
- [PR] [Do Not Merge Now] Test 'google-auth-httplib2>=0.1.0,<=0.2.0' [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/13 18:45:38 UTC, 4 replies.
- [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1713054671 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 00:31:16 UTC, 3 replies.
- Re: [PR] Include MLTransform IT test suite as a part of PostCommits [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:09:58 UTC, 2 replies.
- Re: [PR] [Draft] Batched DoFn prompt for Duet AI [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:10:01 UTC, 2 replies.
- Re: [PR] Initialize BeamFnStatusClient after SDK Harness enters processing loop [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:10:06 UTC, 2 replies.
- Re: [PR] Fix flaky test suite beam_PostCommit_XVR_Direct [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:10:07 UTC, 1 replies.
- Re: [PR] Remove unneeded View.asList when View.asIterable suffices. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:10:11 UTC, 2 replies.
- Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/14 14:10:13 UTC, 1 replies.
- [I] [Feature Request]: Implement Feast feature store handler for Enrichment transform [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/15 02:40:24 UTC, 1 replies.
- [I] [Bug]: Kafka timeout before the position for partition could be determined in one topic [beam] - posted by "i-emek (via GitHub)" <gi...@apache.org> on 2024/04/15 08:38:56 UTC, 1 replies.
- [I] The PreCommit Python Docs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 12:38:30 UTC, 1 replies.
- [PR] use strimzi kafka on beam_utility cluster [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/15 13:01:01 UTC, 8 replies.
- [PR] change grafana creds to use readonly account for beammetrics cloudsql db [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/15 13:06:06 UTC, 3 replies.
- [PR] [runners-flink] Fix watermark emission for empty splits (#29816) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/15 14:27:29 UTC, 6 replies.
- [PR] remove CLOUDSDK env variable , not needed here [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/15 15:00:32 UTC, 2 replies.
- [PR] 29902 finalize checkpoints after checkpoint [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/15 15:29:45 UTC, 0 replies.
- Re: [PR] #29902 finalize checkpoints after checkpoint [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/15 15:30:57 UTC, 3 replies.
- [PR] Fix build wheels due to setuptools changed naming [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/15 15:48:34 UTC, 4 replies.
- [I] [Bug]: Duplicate rows inserted in BigQuery [beam] - posted by "prasanthkn83 (via GitHub)" <gi...@apache.org> on 2024/04/15 16:58:45 UTC, 1 replies.
- [PR] [Python] Allow lambda function in bigtable handler to build a custom row key [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/15 17:52:41 UTC, 6 replies.
- Re: [PR] [Do Not Merge Now] Test 'google-auth-httplib2>=0.1.0,<0.3.0' [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/15 18:19:14 UTC, 0 replies.
- Re: [PR] Update the upper bound for google-auth-httplib2 to 'google-auth-httplib2>=0.1.0,<0.3.0' [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/15 18:27:24 UTC, 4 replies.
- [I] [Feature Request]: Allow passing a custom function for row key in BigTableEnrichmentHandler [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/15 18:50:34 UTC, 2 replies.
- [PR] [YAML] Add the ability to pre-process yaml files with jinja2. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/15 19:10:36 UTC, 32 replies.
- [PR] Switch to width 2 exponential histograms [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/15 20:15:53 UTC, 1 replies.
- [I] [Feature Request]: Support structured logging in Python [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/15 21:08:41 UTC, 0 replies.
- [PR] Add some metrics for CoGBK profiling. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/15 22:09:08 UTC, 4 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 22:13:43 UTC, 0 replies.
- [PR] Bump sqlparse from 0.4.4 to 0.5.0 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 22:55:52 UTC, 3 replies.
- [I] [Bug]: Embedded Video links are not working [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/04/15 22:55:52 UTC, 0 replies.
- [PR] Bump sqlparse from 0.4.4 to 0.5.0 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 22:57:22 UTC, 3 replies.
- [PR] Bump sqlparse from 0.4.4 to 0.5.0 in /sdks/python/container/py39 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 22:59:12 UTC, 3 replies.
- [PR] Bump sqlparse from 0.4.4 to 0.5.0 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/15 22:59:25 UTC, 3 replies.
- Re: [I] [Bug]: Embedded Video (and other content) in iframes are not working [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/04/15 23:01:15 UTC, 9 replies.
- [PR] Skip generating docs for yaml/integration_tests.py. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/15 23:49:01 UTC, 3 replies.
- [PR] [Flink] finalize checkpoint marks in the new Flink source implementation (#30849) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/16 06:53:33 UTC, 3 replies.
- [PR] Remove flink 1.12 1.13 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/16 07:39:07 UTC, 6 replies.
- [PR] add new user info to metrics Readme [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/16 08:44:43 UTC, 2 replies.
- [PR] Improvements to GetWorkTimingInfosTracker when there is clock skew between the worker and service. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/16 09:40:20 UTC, 4 replies.
- Re: [I] [Feature Request]: Flink runner savepoint backward compatibility [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/16 10:02:53 UTC, 0 replies.
- Re: [PR] Flink 1.17 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/16 10:04:00 UTC, 7 replies.
- Re: [I] groupby cannot aggregate grouped column [beam] - posted by "prakhar-dhakar (via GitHub)" <gi...@apache.org> on 2024/04/16 10:35:21 UTC, 1 replies.
- Re: [PR] Generalize file based source output capabilities [beam] - posted by "RCQE-bot (via GitHub)" <gi...@apache.org> on 2024/04/16 11:18:54 UTC, 0 replies.
- Re: [PR] Mltransform Criteo 10GB perf test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/16 12:40:09 UTC, 2 replies.
- [PR] Remove caching of global window side input param when invoking. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/16 12:42:18 UTC, 7 replies.
- [I] [Bug]: Issues observed in maven to gradle conversion example [beam] - posted by "rajkgupt (via GitHub)" <gi...@apache.org> on 2024/04/16 13:16:48 UTC, 0 replies.
- [PR] Fix ConcurrentModification exception possible in DataflowExecutionStateSampler [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/16 13:38:30 UTC, 3 replies.
- Re: [PR] Support BQ clustering with value provider [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/16 14:02:24 UTC, 5 replies.
- [I] [Bug]: Uber jar not work with Dataflow runner v2 due to `UnknownCoderWrapper` for Beam 2.55 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/16 15:18:56 UTC, 4 replies.
- [PR] Add ReadChangeStream IO param to adjust backlog estimates for replication delay [beam] - posted by "jackdingilian (via GitHub)" <gi...@apache.org> on 2024/04/16 15:28:58 UTC, 15 replies.
- Re: [I] [Bug]: spammy and non-actionable "Work item creation time X is after the work received time Y ..." warnings [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/16 16:30:12 UTC, 0 replies.
- [PR] Follow up of recent GHA breakages [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/16 17:12:26 UTC, 2 replies.
- Re: [I] [Bug]: ConcurrentModificationException in DataflowExecutionStateSampler (Beam 2.54.0) [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/16 17:16:37 UTC, 0 replies.
- [I] [Bug]: New option in KafkaIO.Read breaks upgrade compatibility [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/16 17:19:54 UTC, 4 replies.
- [PR] [#30941]fix upgrade test due to missed config ConsumerPollingTimeout [beam] - posted by "xianhualiu (via GitHub)" <gi...@apache.org> on 2024/04/16 18:42:34 UTC, 10 replies.
- [PR] Test cases improvement [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/16 18:47:19 UTC, 0 replies.
- [PR] Use base 2 exponential histograms in BigQuerySinkMetrics [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/16 19:03:25 UTC, 6 replies.
- [PR] Revert #30877 and #30915 to fix Java IOs PreCommit - Kafka upgrade test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/16 19:17:02 UTC, 7 replies.
- Re: [PR] Bump github.com/apple/swift-nio-http2 from 1.27.0 to 1.28.1 [beam-swift] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2024/04/16 19:33:38 UTC, 4 replies.
- [I] [Feature Request]: add documentation on maintaining transform update compatiblity when performing changes [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/16 20:11:30 UTC, 1 replies.
- [PR] Minor updates to StreamingInsertsMetrics [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/16 20:32:57 UTC, 6 replies.
- [PR] Downgrade google-api-core to mitigate #30927 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/16 21:30:01 UTC, 9 replies.
- [PR] Cache parsed metrics in StreamingStepMetricsContainer [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/17 01:01:04 UTC, 5 replies.
- Re: [PR] Iceberg SchemaTransforms and Translation [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/17 01:19:54 UTC, 6 replies.
- Re: [I] FakeJobsService tries to base64 decode a plain QueryString resulting in an error. [beam] - posted by "hanalaydrus (via GitHub)" <gi...@apache.org> on 2024/04/17 02:45:52 UTC, 0 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/17 03:33:44 UTC, 1 replies.
- [I] [Feature Request]: SpannerIO: support max commit delay [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/04/17 05:43:25 UTC, 4 replies.
- [PR] SpannerIO: support max commit delay [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/04/17 05:53:52 UTC, 15 replies.
- [PR] add Yaml_Xlang_Direct PreCommit to README [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/17 11:17:43 UTC, 2 replies.
- [PR] Revert "Docker - Remove Deprecated Types" [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/17 11:26:17 UTC, 2 replies.
- Re: [PR] Remove GlobalWindows for unbounded pcoll without a default global window [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/17 11:27:41 UTC, 0 replies.
- [PR] Fix workflow param value for Grafana link [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/04/17 11:51:48 UTC, 3 replies.
- [PR] fix naming changes caused by setuptools [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/17 11:53:13 UTC, 2 replies.
- Re: [PR] [DRAFT] Attempt fix Jms watermark [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/17 12:39:55 UTC, 2 replies.
- Re: [PR] [#30184][runners][spark] GBK with global window translation OOM fix [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/17 12:39:58 UTC, 2 replies.
- Re: [PR] Add retry to VertexAI embeddings call [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/17 12:40:01 UTC, 2 replies.
- [PR] Change caching of global window inputs to be guarded by experiment [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/17 12:41:23 UTC, 8 replies.
- [I] [Bug]: Side effect during the for loop execution in beam Pipeline [beam] - posted by "giovanni-prestipino (via GitHub)" <gi...@apache.org> on 2024/04/17 14:17:31 UTC, 2 replies.
- Re: [I] [Feature Request]: Upgrade Beam Flink Runner to Flink 1.17 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/17 14:52:41 UTC, 0 replies.
- [PR] Enable BigQueryMetrics by default [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/04/17 14:57:27 UTC, 4 replies.
- Re: [I] [Feature Request]: YAML Join transform [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/17 15:30:08 UTC, 0 replies.
- Re: [PR] Propagate display_data to Job proto [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/04/17 15:46:27 UTC, 0 replies.
- Re: [I] [Bug]: Uber jar not register coders causing `UnknownCoderWrapper` error [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/17 15:46:35 UTC, 2 replies.
- [PR] remove CLOUDSDK from javausingpython dataflow xvr workflow [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/17 15:51:46 UTC, 2 replies.
- [PR] [changes] Update CHANGES.md (#29939) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/17 17:33:17 UTC, 3 replies.
- [I] [Feature Request]: Change Beam Website Youtube embeddings to follow suggested samples [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/17 17:53:29 UTC, 0 replies.
- [PR] fix website embedding issue [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/04/17 17:57:05 UTC, 6 replies.
- [PR] [runners-flink] remove 1.12 and 1.13 runners [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/17 18:15:44 UTC, 4 replies.
- [PR] Allow IFrames to youtube. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/17 18:23:28 UTC, 3 replies.
- Re: [PR] Managed Transform protos & translation; Iceberg SchemaTransforms & translation [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/17 19:05:39 UTC, 77 replies.
- [PR] [changes] Update CHANGES.md (#29939) (#31017) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/17 19:13:38 UTC, 2 replies.
- [PR] Fix typo in count_unique_words() [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/17 19:14:16 UTC, 4 replies.
- [PR] Re-enable schedule trigger for PostCommit Java IO Performance Tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/17 19:58:50 UTC, 0 replies.
- Re: [I] [Task]: Re-enable schedule trigger for PostCommit Java IO Performance Tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/17 19:59:09 UTC, 0 replies.
- [PR] Don't re-encode byte[] values in SortValues transform [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/04/17 20:13:53 UTC, 4 replies.
- [PR] Add ScaleToGaussian TFTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/17 20:32:27 UTC, 6 replies.
- [PR] Update KeysExample [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/04/17 20:42:16 UTC, 1 replies.
- [PR] Connect Web UI cancel requests with backend [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/17 22:37:00 UTC, 0 replies.
- Re: [PR] [PRISM] Connect Web UI cancel requests with backend [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/17 23:05:58 UTC, 1 replies.
- [PR] Updates Python Dev container used by Dataflow [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/18 00:08:36 UTC, 3 replies.
- Re: [PR] Replace Source type for BigTable and Kafka stress tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/18 00:19:42 UTC, 3 replies.
- [I] [Documentation Request]: Including reference to Dataflow Metrics exporter tool in README.md [beam] - posted by "prathapreddy123 (via GitHub)" <gi...@apache.org> on 2024/04/18 00:23:59 UTC, 2 replies.
- [I] beam build error [Bug]: [beam] - posted by "zhoujianjun (via GitHub)" <gi...@apache.org> on 2024/04/18 04:05:16 UTC, 0 replies.
- [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/18 04:40:48 UTC, 2 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 1.12.1 to 2.0.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/18 04:40:53 UTC, 1 replies.
- [PR] Bump commons-cli:commons-cli from 1.6.0 to 1.7.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/18 04:41:00 UTC, 4 replies.
- [PR] CP #31013: Change caching of global window inputs to be guarded by experiment [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/04/18 08:49:58 UTC, 3 replies.
- [PR] Add Ms part of duration for UnboundedReaderMaxReadTime [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/04/18 09:10:47 UTC, 3 replies.
- [PR] Change type for UnboundedReaderMaxReadTimeSec [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/04/18 13:33:29 UTC, 6 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/18 13:58:19 UTC, 6 replies.
- [PR] Cherry picking (#30460) BQ clustering valueprovider [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/18 14:52:15 UTC, 3 replies.
- [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "janowskijak (via GitHub)" <gi...@apache.org> on 2024/04/18 15:23:52 UTC, 11 replies.
- [PR] Bump TPCDS test Flink version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/18 15:40:30 UTC, 5 replies.
- [PR] Better and earlier error for #30994. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/18 16:58:04 UTC, 5 replies.
- [PR] fix url for content security [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/04/18 17:11:58 UTC, 4 replies.
- [PR] Upgrade the version of GRPC to pick up a fix for #30867 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/18 20:19:53 UTC, 4 replies.
- [PR] [release-2.56.0] Exclude broken versions of GRPCIO and upgrade the base image requirements [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/18 20:23:24 UTC, 3 replies.
- [PR] [#30083][prism] Stabilize additional teststream cases. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/04/18 21:33:45 UTC, 5 replies.
- [I] [Feature Request]: Support Type Inference on Python 3.12 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/18 21:56:13 UTC, 1 replies.
- [I] [Failing Test]: Remove usages of a deprecated test helper assertDictContainsSubset in Beam codebase. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/18 22:39:52 UTC, 0 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.0.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 04:17:45 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.17.0 to 0.23.0 in /learning/katas/go [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 09:50:07 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.17.0 to 0.23.0 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 12:26:36 UTC, 2 replies.
- [PR] Add ability to load multiple copies of a model across processes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/19 12:53:55 UTC, 21 replies.
- [I] Kafka to Mongo DB Apach Beam Dataflow Dependency conflict issue. [beam] - posted by "dneema (via GitHub)" <gi...@apache.org> on 2024/04/19 13:14:08 UTC, 0 replies.
- [PR] Bump golang.org/x/net from 0.21.0 to 0.23.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 13:16:10 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.22.0 to 0.23.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 13:27:15 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.9.0 to 0.23.0 in /playground/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 14:18:59 UTC, 1 replies.
- [PR] Better and earlier error for missing service loader metadata. (#31042) [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/19 15:40:56 UTC, 4 replies.
- [PR] [#30083][prism] Refactor Residuals to prepare for processing time scheduling. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/04/19 17:35:19 UTC, 8 replies.
- [PR] fix broken links on website [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/04/19 18:01:39 UTC, 3 replies.
- Re: [I] [Task] Publish Prism binary (os + architecture combos) artifacts on Beam Release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/04/19 19:53:23 UTC, 0 replies.
- Re: [PR] [Prism] Connect Web UI cancel requests with backend [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/19 21:34:00 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/19 22:12:39 UTC, 0 replies.
- [I] [Task]: TypedSchemaTransformProvider should generate Schema field names with `lower_snake_case` convention [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/19 22:13:46 UTC, 1 replies.
- [PR] [#30789] Add support for Flink 1.18 [beam] - posted by "thebozzcl (via GitHub)" <gi...@apache.org> on 2024/04/19 22:41:30 UTC, 16 replies.
- [PR] Fix typo [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/19 22:54:38 UTC, 4 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/21 00:28:30 UTC, 2 replies.
- Re: [PR] break up streaming execution context [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/21 12:39:11 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.22.0 to 0.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/22 04:59:33 UTC, 2 replies.
- [PR] Rajkgupt patch 1 [beam] - posted by "rajkgupt (via GitHub)" <gi...@apache.org> on 2024/04/22 12:00:29 UTC, 0 replies.
- [I] [Task]: Normalize Beam YAML PubSub format to uppercase [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/04/22 12:22:01 UTC, 4 replies.
- [PR] [YAML] - Normalize YAML PubSub format [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/04/22 12:33:39 UTC, 6 replies.
- Re: [PR] [yaml] Add generic expression to filter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/22 12:40:56 UTC, 2 replies.
- Re: [PR] fix examples on website [beam] - posted by "rajkgupt (via GitHub)" <gi...@apache.org> on 2024/04/22 12:51:31 UTC, 6 replies.
- Re: [I] The LoadTests Python Smoke job is flaky [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/04/22 17:21:33 UTC, 0 replies.
- Re: [I] The LoadTests Java GBK Smoke job is flaky [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/04/22 17:30:37 UTC, 2 replies.
- [PR] Fix test failure due to locale sensitivity. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/22 18:49:40 UTC, 2 replies.
- [PR] Don't use isolated builds when building an sdist. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/22 19:11:55 UTC, 3 replies.
- [PR] Exclude three months old grafana workflow runs [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/04/22 19:40:43 UTC, 1 replies.
- [PR] [release-2.56.0] Cherry-picks #31070 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/22 19:57:40 UTC, 3 replies.
- [PR] Remove usages of assert dict contains subset [beam] - posted by "itsayushpandey (via GitHub)" <gi...@apache.org> on 2024/04/22 21:04:31 UTC, 1 replies.
- Re: [PR] Don't use isolated builds when building an sdist for a pipeline package supplied in --setup_file option. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/22 21:16:18 UTC, 0 replies.
- [I] The StressTests Java KafkaIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/22 21:33:41 UTC, 4 replies.
- Re: [PR] [#30083] Add processing time to prism. [beam] - posted by "codecov-commenter (via GitHub)" <gi...@apache.org> on 2024/04/22 21:44:05 UTC, 0 replies.
- Re: [I] The PostCommit Python Arm job is flaky [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/04/23 00:19:09 UTC, 14 replies.
- [PR] Create :runners:prism:java:validatesRunner task [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/23 00:53:03 UTC, 1 replies.
- [PR] Cherrypicking #30910 into release-2.56.0 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/23 01:14:09 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/23 04:22:51 UTC, 1 replies.
- [I] Parent issue: Support for Apache Pulsar [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/23 09:32:20 UTC, 0 replies.
- [I] [Feature Request]: Doc: add current state of Pulsar support [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/23 09:57:05 UTC, 0 replies.
- Re: [I] [Bug]: Flink fails with "cannot handle nodes with more than 64 outputs" [beam] - posted by "tandelDipak (via GitHub)" <gi...@apache.org> on 2024/04/23 10:30:47 UTC, 0 replies.
- [I] [Feature Request]: [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2024/04/23 11:59:26 UTC, 0 replies.
- Re: [PR] DO NOT SUBMIT Direct path test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/23 12:40:36 UTC, 0 replies.
- Re: [PR] Default max Parallelism should not apply all UnBoundedSource. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/23 12:40:39 UTC, 0 replies.
- [I] [Failing Test]: [beam] - posted by "szxyks (via GitHub)" <gi...@apache.org> on 2024/04/23 13:41:20 UTC, 2 replies.
- [PR] Revert "Change type for UnboundedReaderMaxReadTimeSec" [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/04/23 14:42:40 UTC, 5 replies.
- [PR] Add usage counters to ListView side inputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/23 16:18:31 UTC, 3 replies.
- [PR] Fix building release candidate [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/23 16:40:25 UTC, 3 replies.
- [I] [Bug]: Watermarks and Windowing Not Working with FlinkRunner and KinesisIO Read Transform [beam] - posted by "akashk99 (via GitHub)" <gi...@apache.org> on 2024/04/23 18:22:22 UTC, 0 replies.
- [PR] Simplify intermediate data in Iceberg sink; use manifest files [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/23 19:38:04 UTC, 8 replies.
- [PR] Optimise View.asList() side inputs for iterating rather than for indexing. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/23 23:27:51 UTC, 6 replies.
- [PR] Mention known issues in release notes. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/23 23:30:49 UTC, 3 replies.
- Re: [I] [Parent issue] Support for Apache Pulsar [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:00:08 UTC, 0 replies.
- Re: [PR] Validate timestamps when creating windowed or timestamped values [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:48:32 UTC, 0 replies.
- Re: [PR] [BEAM-14269] PulsarIOTest.testReadFromSimpleTopic flaky test [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:49:27 UTC, 0 replies.
- Re: [PR] pulsar connector produces message asynchronously [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:49:43 UTC, 0 replies.
- Re: [PR] pulsar connector accepts auth params [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:49:57 UTC, 0 replies.
- Re: [PR] fix pulsar reader calls [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:50:13 UTC, 0 replies.
- Re: [PR] Bump Jackson dependency due to CVE-2022-1471 [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:50:25 UTC, 0 replies.
- Re: [PR] #26395 Disabling possibly unnecessary prefetching during GroupIntoBatches by using an experimental flag [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/24 11:50:38 UTC, 0 replies.
- [PR] Change assertion and pipeline timeout for kafka stress test [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/24 13:08:54 UTC, 4 replies.
- Re: [PR] Merge runners-core-construction into sdks-java-core [beam] - posted by "honnix (via GitHub)" <gi...@apache.org> on 2024/04/24 14:24:48 UTC, 2 replies.
- [PR] Cherrypick #31086 to release 2.56.X branch [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/24 14:26:45 UTC, 3 replies.
- [PR] Add UnboundedReaderMaxReadTimeMs to DataflowPipelineDebugOptions, deprecate UnboundedReaderMaxReadTimeSec [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/04/24 15:14:56 UTC, 12 replies.
- [PR] FnAPI proto changes for ordered list state. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/04/24 15:47:12 UTC, 12 replies.
- [PR] Python package string change [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/24 17:11:47 UTC, 2 replies.
- [PR] Add docs/blog for release [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/24 17:42:22 UTC, 0 replies.
- [I] [Bug]: Reshuffle.viaRandomKey timeout since version 2.54.0 [beam] - posted by "djaneluz (via GitHub)" <gi...@apache.org> on 2024/04/24 18:57:02 UTC, 18 replies.
- [PR] Fix reporting metrics not supported warning for BigQueryIO Direct read when throttled [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/24 19:08:37 UTC, 5 replies.
- Re: [I] [Bug]: Python SDK avro to beam schema conversion defaults to Any type for nullable atomic union fields [beam] - posted by "benkonz (via GitHub)" <gi...@apache.org> on 2024/04/24 19:36:16 UTC, 0 replies.
- Re: [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/24 22:33:47 UTC, 2 replies.
- [PR] add job name to the gcs user-agent string [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/25 00:11:37 UTC, 0 replies.
- [I] [Bug]: Beam programming guide missing Counters example [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/04/25 03:52:38 UTC, 3 replies.
- [PR] Bump pydantic from 1.10.2 to 1.10.13 in /playground/infrastructure [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/04/25 05:23:12 UTC, 1 replies.
- Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/25 12:47:55 UTC, 0 replies.
- Re: [I] The LoadTests Python Combine Flink Streaming job is flaky [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/25 13:07:54 UTC, 0 replies.
- Re: [I] The LoadTests Go GBK Flink Batch job is flaky [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/25 13:09:15 UTC, 0 replies.
- Re: [PR] [Python] add job name to the gcs user-agent string [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/25 13:51:25 UTC, 2 replies.
- Re: [I] The Dask Runner Tests job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/25 14:21:42 UTC, 0 replies.
- [PR] Use java 11 for java_tests workflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/25 15:00:58 UTC, 4 replies.
- [PR] remove cloudsdk environment variable, not needed here [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/25 15:17:53 UTC, 2 replies.
- Re: [I] [Failing Test]: macos-latest fails on actions/setup-java@v3 - can't find java 8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/25 15:21:11 UTC, 0 replies.
- [PR] Fix :examples:java:twitter:execute task [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/25 15:36:49 UTC, 4 replies.
- [PR] Add ability to load multiple copies of a model across processes (#31052) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/25 16:14:21 UTC, 3 replies.
- [PR] [#30083][prism] Factor out hold tracking to dedicated structures [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/04/25 16:28:50 UTC, 7 replies.
- [PR] Pass original message down through conversion for storage write api [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/04/25 17:23:43 UTC, 2 replies.
- Re: [I] [Failing Test]: SpannerReadIT.testReadWithDataBoost failing [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/25 18:07:56 UTC, 0 replies.
- [PR] Revert "python sdk: fix several bugs regarding avto <-> beam schema conversion" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/25 18:08:36 UTC, 11 replies.
- [I] [Bug]: SyntheticUnboundedSource missing records [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/25 20:21:36 UTC, 0 replies.
- Re: [PR] Implement BigQuery Stress Test [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/04/25 20:58:33 UTC, 0 replies.
- Re: [PR] add a new IO named DataLakeIO (#23074) [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/04/25 21:09:25 UTC, 0 replies.
- [PR] Revert global snake_case convention for SchemaTransforms [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/25 22:36:14 UTC, 2 replies.
- [PR] Cherry picking snake_case conversions [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/04/26 02:05:19 UTC, 5 replies.
- [I] JdbcIO informix connection problem [beam] - posted by "gbuzic (via GitHub)" <gi...@apache.org> on 2024/04/26 07:23:35 UTC, 0 replies.
- [I] [Task]: Remove Flink 1.14 and cleanup [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/04/26 10:02:13 UTC, 0 replies.
- [PR] rename cluster used [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/26 11:53:56 UTC, 5 replies.
- [I] [Failing Test]: The Build python source distribution and wheels job is permared [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/26 13:08:38 UTC, 2 replies.
- [PR] Try fixing build wheels [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/26 13:09:34 UTC, 3 replies.
- [PR] fix test added in previous commit [beam] - posted by "benkonz (via GitHub)" <gi...@apache.org> on 2024/04/26 13:42:51 UTC, 0 replies.
- Re: [I] [Feature Request]: Custom naming for error handler transforms [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/04/26 13:59:54 UTC, 0 replies.
- [PR] Beam SQL Extension raised an error when the input row contained iterable fields [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/04/26 14:12:33 UTC, 1 replies.
- [I] [Bug]: Beam SQL Extension raised an error when the input row contained iterable fields [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/04/26 14:14:17 UTC, 0 replies.
- [PR] Try fixing build wheels (#31115) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/26 15:23:13 UTC, 3 replies.
- [PR] (testing, no need to review) update libraries-bom to 26.38.0 [beam] - posted by "zhumin8 (via GitHub)" <gi...@apache.org> on 2024/04/26 16:09:12 UTC, 1 replies.
- Re: [PR] fix test added in "python sdk: fix several bugs regarding avto <-> beam schema conversion" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/26 16:54:20 UTC, 0 replies.
- Re: [PR] [test only] Test PostCommit runs for #31116 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/26 16:59:41 UTC, 0 replies.
- Re: [I] [Task]: Client-side throttling for BigQueryIO DIRECT_READ mode [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/26 17:04:09 UTC, 2 replies.
- [I] [Bug]: IntelliJ dependencies on jars, not modules, due to shadow plugin [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/26 17:22:43 UTC, 0 replies.
- [I] The PostCommit Go VR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/26 18:34:01 UTC, 0 replies.
- [PR] One more macos change [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/04/26 18:47:08 UTC, 7 replies.
- Re: [PR] (testing, no need to review) update libraries-bom to 26.37.0 [beam] - posted by "zhumin8 (via GitHub)" <gi...@apache.org> on 2024/04/26 20:43:51 UTC, 0 replies.
- [PR] Suppress BigQuery read stream splitAtFraction when API busy call or timeout [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/04/27 00:54:14 UTC, 9 replies.
- Re: [PR] [OLD with links] Duet AI training - AI/ML data processing prompts [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/27 12:38:39 UTC, 0 replies.
- Re: [PR] [OLD - with links] Data encoding prompts for Duet AI [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/27 12:38:40 UTC, 0 replies.
- Re: [I] Find a way to set a default global per-test timeout for Java Java unit tests [beam] - posted by "sulthan309 (via GitHub)" <gi...@apache.org> on 2024/04/27 17:31:53 UTC, 0 replies.
- [I] [Feature Request]: Set quota project in `beam.io.ReadFromBigQuery` [beam] - posted by "shahar1 (via GitHub)" <gi...@apache.org> on 2024/04/28 08:40:31 UTC, 7 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/04/28 12:39:55 UTC, 1 replies.
- Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:02:02 UTC, 0 replies.
- Re: [I] The PostCommit Java Sickbay job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:03:03 UTC, 0 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:03:41 UTC, 0 replies.
- Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:21:36 UTC, 0 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:24:17 UTC, 5 replies.
- [PR] Add "all runs" link to flake issues [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 13:54:00 UTC, 2 replies.
- Re: [I] [Bug]: Schema inference is non-deterministic [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/29 14:53:49 UTC, 1 replies.
- [PR] Create option to specify temp query project, and wire into source tab… [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/04/29 15:48:21 UTC, 0 replies.
- [PR] Allow users to configure wait options for new Neo4j databases [beam] - posted by "fbiville (via GitHub)" <gi...@apache.org> on 2024/04/29 15:58:40 UTC, 8 replies.
- Re: [PR] [Prism] Enable Java validatesRunner tests on Prism [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/04/29 16:46:00 UTC, 1 replies.
- [PR] add finalizers to kafka loadbalancer services [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/29 17:29:41 UTC, 4 replies.
- [PR] Also allow links to Drive materials. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/29 17:34:44 UTC, 3 replies.
- Re: [I] [Feature Request]: Build beam.MLTransform [beam] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2024/04/29 19:02:53 UTC, 1 replies.
- Re: [I] [Feature Request]: Add support for apache pinot [beam] - posted by "hpvd (via GitHub)" <gi...@apache.org> on 2024/04/29 20:09:29 UTC, 0 replies.
- [PR] remove atomic and wait from strimzi helm terrafrom [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/04/30 09:10:30 UTC, 4 replies.
- [PR] add computation state cache, config loaders, and status pages [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/04/30 11:40:59 UTC, 2 replies.
- Re: [PR] [Python] Return dicts from enrichment handlers to save conversion cost to rows. [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/04/30 13:57:26 UTC, 0 replies.
- Re: [I] [Bug]: WriteToFiles in python leave few records in temp directory when writing to large number (100+) of files [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/30 14:42:47 UTC, 0 replies.
- [PR] Update game_stats.py [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/04/30 20:13:37 UTC, 3 replies.
- [PR] Add `.python-version` to .gitignore [beam] - posted by "shahar1 (via GitHub)" <gi...@apache.org> on 2024/04/30 20:40:00 UTC, 1 replies.
- [PR] Add support for int gauge metrics in DataflowRunner [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/04/30 22:18:17 UTC, 1 replies.
- [PR] Set backlog in gauge metric for Kafka Reader [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/04/30 22:19:03 UTC, 0 replies.
- [I] [Failing Test]: Some tests in tox-py38-embeddings are flaky or failing [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/04/30 22:30:08 UTC, 0 replies.
- [I] [Bug]: Python Pipeline Options Grandchildren Args [beam] - posted by "manav-glean (via GitHub)" <gi...@apache.org> on 2024/04/30 23:22:27 UTC, 0 replies.
- [PR] Revert addition of Redistribute and tests to Java SDK, and translations from runners [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/04/30 23:23:21 UTC, 0 replies.
- [PR] [Pipeline Options] Recursively Get All Subclasses [beam] - posted by "manav-glean (via GitHub)" <gi...@apache.org> on 2024/04/30 23:23:28 UTC, 0 replies.
- [PR] Terraform module to provision a kafka proxy [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/04/30 23:41:56 UTC, 0 replies.