You are viewing a plain text version of this content. The canonical link for it is here.

---

- [PR] Add sleep to give enough time for server to be up [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/01 00:23:00 UTC, 2 replies.
- Re: [PR] Kafka add counters v1 uw2 [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/01 00:24:08 UTC, 32 replies.
- Re: [PR] [Prism] Refactor stageState to a behavior interface to reduce branch combinatorics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/03/01 00:28:49 UTC, 4 replies.
- Re: [PR] Fix race condition [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/01 01:20:17 UTC, 2 replies.
- Re: [I] [Bug]: Fix JdbcIO Thread contention [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/01 01:20:18 UTC, 0 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/01 04:06:17 UTC, 3 replies.
- [PR] [Java] Allow users to specify custom audit entries in pipeline options [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/01 05:49:45 UTC, 5 replies.
- Re: [PR] Spark Runner : Replace queueStream with custom DStream in Spark streaming Flatten transform [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/03/01 06:13:41 UTC, 3 replies.
- Re: [PR] [BEAM-34076] Cache BigQuery table definitions to reduce API calls [beam] - posted by "Strikerrx01 (via GitHub)" <gi...@apache.org> on 2025/03/01 12:52:53 UTC, 2 replies.
- Re: [I] [Feature Request]: [IcebergIO] Configure data writers to track metrics [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/01 13:02:33 UTC, 8 replies.
- Re: [PR] Update RecordWriter.java [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/01 13:22:17 UTC, 2 replies.
- [PR] [Python] Add caching for BigQuery table definitions [beam] - posted by "Strikerrx01 (via GitHub)" <gi...@apache.org> on 2025/03/01 14:25:37 UTC, 67 replies.
- Re: [I] [Bug]: Dataflow option validation fails in VSCode Jupyter notebook [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/01 17:32:38 UTC, 2 replies.
- Re: [I] [Bug]: `beam.transforms.util.LogElements(with_timestamp=True, with_window=True)` does not work with GlobalWindows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/01 17:35:01 UTC, 0 replies.
- [PR] Make pydoc docstring reflecting deprecated [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/01 18:19:07 UTC, 2 replies.
- [PR] Update 2024.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/01 18:43:28 UTC, 2 replies.
- Re: [PR] Add docs about withQueryFn, logic to detect other functions, and new … [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/01 21:43:23 UTC, 1 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/01 22:15:54 UTC, 3 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 2025/03/01 22:15:59 UTC, 1 replies.
- Re: [PR] Jdbc shcema [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/03/02 02:41:18 UTC, 0 replies.
- Re: [I] Beam metrics should be displayed in Flink UI "Metrics" tab [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/03/02 03:02:19 UTC, 1 replies.
- Re: [PR] Automatically refresh Performance Metrics Graphs using Looker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/02 05:36:17 UTC, 1 replies.
- Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] - posted by "Strikerrx01 (via GitHub)" <gi...@apache.org> on 2025/03/02 08:07:11 UTC, 1 replies.
- [PR] [Java] Added Metrics Configuration Support to Iceberg Data Writers [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/02 09:29:09 UTC, 13 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to specify a partition spec when creating tables [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/02 13:19:32 UTC, 3 replies.
- Re: [I] [Bug]: Cross-language JDBC (MSSQL) - incorrect negative Integer type conversion [beam] - posted by "Brijeshthummar02 (via GitHub)" <gi...@apache.org> on 2025/03/02 13:29:08 UTC, 10 replies.
- [PR] Clean up GCP Resources (Pubsub) [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/03/02 18:14:01 UTC, 1 replies.
- [PR] Fix Docker dev environment set up [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/03/02 22:10:16 UTC, 7 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/02 22:16:30 UTC, 1 replies.
- Re: [PR] Clarify BigQuery InsertRetryPolicy behavior for non-200 responses [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/03/03 01:20:13 UTC, 3 replies.
- [PR] Fix Docker build error by adding fallback for python3.12-distutils [beam] - posted by "utkarshparekh (via GitHub)" <gi...@apache.org> on 2025/03/03 07:05:43 UTC, 7 replies.
- Re: [PR] fix for adding unexpected Empty Records in Nested Arrays in BigQueryIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/03 09:17:44 UTC, 7 replies.
- [I] [Bug]: BigQueryIO - unknown repeated fields are merged incorrectly to payload [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/03 11:53:54 UTC, 2 replies.
- Re: [PR] Switch to use registerFileSystemsOnce for SerializablePipelineOptions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/03 12:14:31 UTC, 1 replies.
- Re: [PR] Bump serialize-javascript and mocha in /sdks/typescript [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/03 12:14:33 UTC, 3 replies.
- Re: [PR] Replace StorageV1 client with GCS client - Draft [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/03 12:46:10 UTC, 0 replies.
- [PR] [Java] Fix UnboundedReaderAsSdfFn to avoid using unstarted unbounded reader. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/03 12:55:26 UTC, 9 replies.
- [PR] Call out race condition fix in CHANGES [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 13:37:09 UTC, 3 replies.
- Re: [I] [Task]: Make pydoc docstring reflecting deprecated and experimental API [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/03 14:48:45 UTC, 0 replies.
- Re: [PR] Make sure sbt is installed in sbt workflow [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 15:22:16 UTC, 0 replies.
- Re: [PR] Update republish workflow to split docker pushes [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/03 15:23:24 UTC, 2 replies.
- Re: [I] [Task]: Speed up Docker Push Steps [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 15:29:38 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE]: Test pr, try limiting jdbcio max connections [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 15:30:03 UTC, 0 replies.
- Re: [PR] Fix bq write doc string [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 15:30:36 UTC, 0 replies.
- Re: [PR] Update beam_PostCommit_Python_Arm.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/03 15:31:07 UTC, 0 replies.
- Re: [PR] Add resource hint capabilities to YAML. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/03 17:24:50 UTC, 0 replies.
- Re: [PR] Add explicit schema support to JdbcIO read and xlang transform. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/03 17:58:53 UTC, 5 replies.
- Re: [PR] Use bigdataoss 3.x-compatible API in BigQueryIO's BatchLoads [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/03 18:23:33 UTC, 0 replies.
- Re: [PR] [Managed Iceberg] unbounded source [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/03 19:29:21 UTC, 41 replies.
- Re: [I] The PostCommit Java Examples Spark job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:32:37 UTC, 1 replies.
- Re: [I] The PostCommit Java ValidatesRunner Spark job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:33:04 UTC, 1 replies.
- Re: [I] The PostCommit Java ValidatesRunner Spark Java8 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:33:47 UTC, 1 replies.
- Re: [I] The PostCommit Java Hadoop Versions job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:34:09 UTC, 5 replies.
- Re: [I] The PostCommit Java ValidatesRunner SparkStructuredStreaming job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:34:54 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:41:15 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:41:25 UTC, 2 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:41:37 UTC, 3 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:41:46 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:41:54 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/03 19:42:42 UTC, 2 replies.
- Re: [I] Add support for checkpointing in Spark streaming [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/03 19:48:13 UTC, 3 replies.
- Re: [I] Flatten of Bounded and Unbounded repeats the union with the RDD for each micro-batch. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/03 19:48:13 UTC, 0 replies.
- [PR] test commit [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2025/03/03 19:54:11 UTC, 8 replies.
- Re: [PR] Updates Managed Javadocs and pydocs to refer to runner specific features [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/03 21:09:25 UTC, 3 replies.
- [I] [Feature Request]: Properly incorporate bulk multimap side input reads into caching. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/03 21:21:22 UTC, 0 replies.
- [PR] Don't attempt to cache the bulk multimap lookup call. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/03 21:24:31 UTC, 6 replies.
- Re: [PR] Bump SLF4J from 1.7.30 to 2.0.16. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/03 22:30:14 UTC, 1 replies.
- [I] [Bug]: Unable to use S3 bucket for ReadFromSnowflake staging bucket name [beam] - posted by "seanhagen (via GitHub)" <gi...@apache.org> on 2025/03/03 23:12:30 UTC, 4 replies.
- [PR] Updates the information regarding Managed I/O [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/04 00:28:58 UTC, 3 replies.
- [PR] Enable kafka metrics by default for streaming dataflow jobs on v1 [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 00:34:20 UTC, 2 replies.
- [I] [Feature Request]: Add InsertRetryPolicy for non-successful BigQuery insertAll responses. [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/03/04 02:38:02 UTC, 0 replies.
- Re: [I] Add documentation and improved errors for QueryFn in MongoDbIO [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/04 03:08:23 UTC, 0 replies.
- [PR] Fix hadoop version tests. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/04 03:13:48 UTC, 3 replies.
- [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 03:40:36 UTC, 3 replies.
- [PR] Alloy language connector [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/04 04:10:49 UTC, 5 replies.
- [PR] Bump google.golang.org/api from 0.221.0 to 0.223.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 04:59:36 UTC, 3 replies.
- [PR] introduce flags for customizing standard providers using their own YA… [beam] - posted by "zilin (via GitHub)" <gi...@apache.org> on 2025/03/04 07:23:51 UTC, 7 replies.
- [I] [Feature Request]: Add ClickHouse Resource Manager for Integration Tests [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/03/04 08:25:42 UTC, 2 replies.
- [I] [Bug]: cassandraIO ReadAll does not let a pipeline handle or retry exceptions [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2025/03/04 08:29:37 UTC, 4 replies.
- [PR] Putting the default retry settings which was overridden in Dataflow templates [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2025/03/04 11:44:10 UTC, 10 replies.
- Re: [PR] add waitForReady to logging stream and control stream to handle sdk starting before runner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/04 11:55:14 UTC, 1 replies.
- Re: [PR] SnowflakeIO: be consistent with backslash escape char [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:14:26 UTC, 6 replies.
- Re: [PR] Tour of Beam: update GroupByKey example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:14:27 UTC, 5 replies.
- Re: [PR] Read RabbitMQ messages with headers containing nested objects [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:14:28 UTC, 4 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:14:30 UTC, 4 replies.
- Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:14:32 UTC, 5 replies.
- Re: [PR] chore: update to use versions for LTS 8 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:46:06 UTC, 2 replies.
- Re: [PR] Suppress DataFrame.applymap deprecation warning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 12:46:07 UTC, 1 replies.
- [PR] Fix test [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/04 15:07:04 UTC, 13 replies.
- Re: [PR] [Java] Allow users to specify GCS custom audit entries in pipeline options [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/04 15:12:57 UTC, 3 replies.
- [PR] updated Go to 1.24.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/04 15:15:19 UTC, 3 replies.
- Re: [PR] [Spark] Skip unused outputs of ParDo in SparkRunner (#33771) [beam] - posted by "JozoVilcek (via GitHub)" <gi...@apache.org> on 2025/03/04 15:31:55 UTC, 2 replies.
- Re: [PR] #34009 avro generic record to beam row conversion added support for a… [beam] - posted by "wollowizard (via GitHub)" <gi...@apache.org> on 2025/03/04 15:58:53 UTC, 9 replies.
- [PR] Revert jdbc [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/04 16:51:01 UTC, 1 replies.
- Re: [PR] Use BoundedTrie metric to track lineage in IO [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/04 16:56:15 UTC, 6 replies.
- [PR] [KafkaIO] Fix average record size data race and backlog estimation [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/03/04 17:17:06 UTC, 12 replies.
- [PR] [Java] Added Part Spec when creating Tables [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/04 17:23:41 UTC, 5 replies.
- [PR] Bump @octokit/plugin-paginate-rest and @octokit/rest in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/04 17:43:12 UTC, 5 replies.
- [I] [Task]: Fill feature gaps between regular and CDC Iceberg sources [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/04 18:05:37 UTC, 0 replies.
- [PR] Add Sequences support to Breaking Changes [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/04 19:33:14 UTC, 2 replies.
- [PR] Run Python Postcommit on High mem 22. Increase max nodes and replicas [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/04 19:53:10 UTC, 3 replies.
- Re: [I] [Task]: Update the minor version of cloudpickle library prior to Beam release. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/04 20:19:00 UTC, 1 replies.
- Re: [I] [Bug]: Unexpected Empty Records in Nested Arrays When Using BigQueryIO.write() with .withAutoSchemaUpdate(true) and .ignoreUnknownValues() [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/04 20:28:07 UTC, 0 replies.
- [I] [Failing Test]: org.apache.beam.runners.dataflow.worker.streaming.harness.FanOutStreamingEngineWorkerHarnessTest.testOnNewWorkerMetadata_redistributesBudget [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 21:18:01 UTC, 0 replies.
- [I] [Failing Test]: org.apache.beam.sdk.transforms.RedistributeTest.testRedistributeAfterFixedWindows [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 21:19:43 UTC, 2 replies.
- [I] [Failing Test]: org.apache.beam.sdk.io.gcp.spanner.changestreams.SpannerChangeStreamErrorTest.testInvalidRecordReceived [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 21:21:49 UTC, 2 replies.
- [I] [Failing Test]: org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.unbounded.FlinkUnboundedSourceReaderTest.testIsAvailableAlwaysWakenUp [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 21:22:48 UTC, 2 replies.
- [I] [Failing Test]: org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadWithMetadata [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 21:24:21 UTC, 3 replies.
- [I] [Bug]: Provisioning runners fails [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/04 21:43:09 UTC, 2 replies.
- Re: [PR] Add histogram to metrics container [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/04 22:03:28 UTC, 4 replies.
- [PR] Add test ensuring pipeline options observes kwargs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/04 23:36:13 UTC, 2 replies.
- Re: [PR] Add Encryption When Writing to Iceberg Tables in RecordWriter.java [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/03/05 04:43:16 UTC, 11 replies.
- [I] [Bug]: FlinkRunner never calls finish_bundle and OOM eventually [beam] - posted by "muyangyuapple (via GitHub)" <gi...@apache.org> on 2025/03/05 04:51:08 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.62 to 1.17.65 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 05:01:35 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.62 to 1.17.64 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 05:01:38 UTC, 1 replies.
- Re: [PR] add equals hashCode to BoundedToUnboundedSourceAdapter [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/05 09:37:40 UTC, 7 replies.
- Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 12:46:06 UTC, 1 replies.
- Re: [PR] Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 12:46:09 UTC, 1 replies.
- [PR] Fix failing test: Add more time for grpc cleanup [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/05 13:42:16 UTC, 5 replies.
- [PR] Fix failing test: Increase timeout [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/05 13:46:32 UTC, 7 replies.
- Re: [I] [Bug]: Race condition in FileSystems initialisation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/05 14:25:35 UTC, 0 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/05 14:27:34 UTC, 3 replies.
- Re: [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/05 14:28:55 UTC, 0 replies.
- Re: [I] [Bug]: Iceberg sink is not resilient to worker crash [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/05 14:29:52 UTC, 1 replies.
- [PR] Install docker compose in PostCommit Python Xlang Gcp Direct to run xlang_jdbc tests in xlang direct workflow. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/05 15:34:54 UTC, 1 replies.
- [PR] Correctly parse labels if they are passed as a single string instead of a list [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/05 16:29:11 UTC, 7 replies.
- [PR] Add AlloyDB embeddings colab. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/05 17:33:39 UTC, 4 replies.
- [PR] Fix cleanPython [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/05 17:46:08 UTC, 2 replies.
- Re: [I] [Task]: Create a script to train sklearn model for IT test. [beam] - posted by "sonjaove (via GitHub)" <gi...@apache.org> on 2025/03/05 18:15:49 UTC, 1 replies.
- Re: [I] [Bug]: `gradlew clean` involves external transform generation and fails [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/05 18:31:26 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 18:40:15 UTC, 7 replies.
- [PR] Catch union-of-iterables case in get_yielded_type() [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/05 20:50:07 UTC, 2 replies.
- [I] The Go tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/05 21:34:39 UTC, 5 replies.
- [I] [Bug]: `beam.io.WriteToCsv` ignores `num_shards` argument. [beam] - posted by "ganesh4991 (via GitHub)" <gi...@apache.org> on 2025/03/06 00:20:47 UTC, 4 replies.
- [PR] Bump jinja2 from 3.1.4 to 3.1.6 in /.test-infra/jenkins/metrics_report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/06 03:33:45 UTC, 2 replies.
- [PR] Bump golang.org/x/oauth2 from 0.26.0 to 0.28.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/06 04:31:05 UTC, 4 replies.
- Re: [PR] Bump golang.org/x/oauth2 from 0.26.0 to 0.27.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/06 04:31:07 UTC, 1 replies.
- [PR] Rethrowing Exception from CassandraIO's ReadFn [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2025/03/06 05:49:25 UTC, 6 replies.
- Re: [I] [Bug]: java.lang.IllegalStateException: Expected output stream to be empty [beam] - posted by "Kannndev (via GitHub)" <gi...@apache.org> on 2025/03/06 05:56:15 UTC, 0 replies.
- [PR] Remove retry count assertion from testInvalidRecordReceived [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/06 11:31:58 UTC, 3 replies.
- Re: [PR] Add support for collections.abc.Mapping [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/06 12:14:22 UTC, 6 replies.
- Re: [PR] Bump @octokit/request-error, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/06 12:14:23 UTC, 4 replies.
- [PR] Use individual windows rather than window sets in the combining table. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/06 17:41:09 UTC, 7 replies.
- Re: [I] Hint to template job creation in DataflowRunner / DataflowPipelineOptions [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/03/06 17:51:54 UTC, 1 replies.
- Re: [I] [Bug]: JDBC javasdk_date:v1 decode error [beam] - posted by "gcarson30 (via GitHub)" <gi...@apache.org> on 2025/03/06 17:52:01 UTC, 0 replies.
- [PR] Fix ProtoCoder NoSuchMethodException [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/06 18:25:48 UTC, 12 replies.
- [I] [Feature Request]: Unify metrics that are to be aggregated on google worker and on the portable runner [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/06 19:12:21 UTC, 0 replies.
- [PR] [DO NOT MERGE] Removed < 1.66 for grpcio [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/06 19:59:37 UTC, 15 replies.
- [PR] Update pinned kafka version to 3.9.0 in Expansion Service. [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/03/06 20:01:01 UTC, 7 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 2025/03/06 22:15:01 UTC, 2 replies.
- Re: [I] [Feature Request]: Upgrade or provide ETA on dill [beam] - posted by "baq (via GitHub)" <gi...@apache.org> on 2025/03/06 22:28:08 UTC, 3 replies.
- [PR] Remove a note about cloudpickle support being experimental [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/07 00:19:01 UTC, 4 replies.
- [PR] cloudpickle support is no longer experimental. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/07 00:20:09 UTC, 0 replies.
- Re: [I] [Bug]: class org.apache.logging.slf4j.SLF4JLoggerContext cannot be cast to class org.apache.logging.log4j.core.LoggerContext (org.apache.logging.slf4j.SLF4JLoggerContext and org.apache.logging.log4j.core.LoggerContext are in unnamed module of loader 'app') [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/07 00:28:57 UTC, 0 replies.
- [PR] [KafkaIO] Remove duplicate offset in range check [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/03/07 00:49:47 UTC, 5 replies.
- [PR] [KafkaIO] Update tracker and watermark for non-visible progress [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/03/07 00:54:18 UTC, 5 replies.
- [PR] Bump google.golang.org/api from 0.221.0 to 0.224.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 04:45:13 UTC, 3 replies.
- [PR] Add Documentation Hint for Template Job Creation in DataflowRunner [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/03/07 05:14:39 UTC, 8 replies.
- [PR] Add support for top-level table properties table creation [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/03/07 07:27:47 UTC, 5 replies.
- [I] [Bug]: Long running DoFn.Setup methods lead to job failure in Dataflow Java legacy runner. [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/03/07 08:18:43 UTC, 2 replies.
- Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] - posted by "zendesk-kjaanson (via GitHub)" <gi...@apache.org> on 2025/03/07 10:19:50 UTC, 5 replies.
- Re: [PR] Fix incorrect nullness in FlinkJobInvoker and JobInvoker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 12:14:28 UTC, 4 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 12:14:35 UTC, 4 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 12:14:36 UTC, 2 replies.
- [I] The PostCommit Java PVR Spark3 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 12:46:36 UTC, 2 replies.
- [PR] File staging [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/07 13:39:45 UTC, 0 replies.
- Re: [I] [Bug]: Cross-language pipeline options are not picked up in Java DoFns [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/07 13:44:55 UTC, 0 replies.
- [PR] Skip some tests on Dataflow runners [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/07 14:56:53 UTC, 3 replies.
- [PR] Bump dataflow java container version to beam-master-20250307 [beam] - posted by "apanich (via GitHub)" <gi...@apache.org> on 2025/03/07 15:02:20 UTC, 5 replies.
- [I] [Task]: Add Python AfterSynchronizedProcessingTime trigger and add an Iceberg CDC streaming read test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/07 15:31:23 UTC, 2 replies.
- [PR] [Java] Add parsedData to Hl7v2Message and Update HL7v2IO Docs [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/07 16:07:02 UTC, 9 replies.
- Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/07 16:45:25 UTC, 4 replies.
- [PR] Declare volitile to ExecutionStateTracker.nextBundleLullDurationReportMs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/07 20:09:27 UTC, 1 replies.
- Re: [PR] Declare ExecutionStateTracker.nextBundleLullDurationReportMs as volitile [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 20:11:25 UTC, 2 replies.
- Re: [PR] Fix PostCommit Java DataflowV2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 21:33:27 UTC, 7 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 21:36:04 UTC, 13 replies.
- Re: [PR] add restart mechanics to windmill streams [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/07 21:51:41 UTC, 0 replies.
- [PR] Issue warning on long running DoFn.Setup on legacy Dataflow runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/07 22:31:38 UTC, 4 replies.
- Re: [PR] add default port for HostAndPort instances used in Windmill [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/07 22:34:44 UTC, 1 replies.
- [PR] Fix typo on resource hints page. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/08 00:53:46 UTC, 2 replies.
- [PR] Add yaml examples generation to the release scripts. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/08 01:07:54 UTC, 5 replies.
- [PR] [AnomalyDetection] Add transforms and detectors. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/08 03:48:39 UTC, 5 replies.
- [PR] [Java] Added tests for S3ReadableSeekableByteChannel [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/08 03:50:25 UTC, 5 replies.
- [PR] [Java] Ensure Pipeline Execution Requires Configuration Options or Logs Warning [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/08 06:56:49 UTC, 6 replies.
- [I] The StressTests Java BigQueryIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/08 15:34:15 UTC, 3 replies.
- [I] [Bug]: Python Unit Tests are flaky on windows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/08 16:41:39 UTC, 0 replies.
- [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/08 18:48:52 UTC, 11 replies.
- [PR] Enable cloudpickle default [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/08 21:58:35 UTC, 1 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to pass table properties to be set when creating a table [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/03/09 09:37:26 UTC, 0 replies.
- [I] [Bug]: typo in docs - Python Composition with AfterWatermark example [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2025/03/09 10:29:32 UTC, 12 replies.
- Re: [PR] ignore overridden setters and getters in JavaBeanSchema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/09 12:39:41 UTC, 2 replies.
- [PR] call out the snappy version in the warning message [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/09 15:27:00 UTC, 5 replies.
- [I] [Feature Request]: Replace snappy with other `crc32c ` packages for tfrecordio [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/09 15:31:55 UTC, 5 replies.
- Re: [I] [Bug]: tfrecordio does not work with snappy >= 0.7 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/09 15:32:25 UTC, 1 replies.
- Re: [I] WriteToBigQuery Dynamic table destinations returns wrong tableId [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/09 15:43:19 UTC, 1 replies.
- [PR] Reduce allowed lateness in FixedWindows from 10 to 2 seconds [beam] - posted by "Brijeshthummar02 (via GitHub)" <gi...@apache.org> on 2025/03/09 16:22:14 UTC, 4 replies.
- Re: [I] [Bug]: SpannerIO.Write does not support named schemas [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/09 17:13:36 UTC, 0 replies.
- [PR] Added BigEndianInt32Coder [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/09 20:16:18 UTC, 2 replies.
- [PR] Precommit flink container 2 [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/10 04:54:20 UTC, 4 replies.
- [PR] Implement ClickHouse Integration Testing Resource Manager [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/03/10 09:06:34 UTC, 5 replies.
- Re: [I] The Republish Released Docker Images job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/10 09:34:34 UTC, 3 replies.
- Re: [PR] [KafkaIO] Decouple consumer threads from harness threads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/10 12:46:16 UTC, 2 replies.
- [PR] Update to latest bom [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/10 15:32:35 UTC, 2 replies.
- Re: [PR] Fix cleanup timer timestamp to not exceed max allowed timestamp [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/03/10 15:35:27 UTC, 1 replies.
- Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/10 15:36:14 UTC, 5 replies.
- Re: [I] How can I use HadoopFileSystem to read from s3a:// ? [beam] - posted by "shai-rubin (via GitHub)" <gi...@apache.org> on 2025/03/10 15:58:22 UTC, 1 replies.
- [PR] Add detectors and some necessary univariate trackers. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/10 16:01:03 UTC, 1 replies.
- Re: [PR] [AnomalyDetection] Add detectors and some necessary univariate trackers. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/10 16:04:15 UTC, 23 replies.
- Re: [PR] Update allowed lateness in FixedWindows example to 2 days [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/10 16:29:29 UTC, 13 replies.
- [PR] Pin python-snappy==0.6.1 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/10 16:35:25 UTC, 4 replies.
- [PR] [AnomalyDetection] Add main and auxiliary transforms. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/10 16:39:43 UTC, 22 replies.
- [PR] [AnomalyDetection] Refactor code and add more docstrings [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/10 16:51:33 UTC, 5 replies.
- Re: [PR] Precommit flink container 2 (PR for testing purposes) [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/10 17:13:24 UTC, 0 replies.
- [I] [Feature Request]: VertexAIImageEmbeddings adding the ability to send in contextual text too [beam] - posted by "weifonghsia (via GitHub)" <gi...@apache.org> on 2025/03/10 17:59:18 UTC, 1 replies.
- [PR] Clean up ExternalTransformRegistrar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/10 18:05:06 UTC, 4 replies.
- Re: [PR] Update to Beam 2.63.0 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/10 18:19:49 UTC, 0 replies.
- Re: [PR] Switch to use registerFileSystemsOnce for SerializablePipelineOptions constructor [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/10 18:29:59 UTC, 3 replies.
- [PR] Factor out data file discovery. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/10 21:02:02 UTC, 2 replies.
- [PR] Remove obsolete release script. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/10 23:50:33 UTC, 2 replies.
- [I] [Failing Test]: Go test workflow is read now [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/11 01:43:22 UTC, 0 replies.
- [PR] Update go_tests.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/11 01:51:20 UTC, 3 replies.
- [I] [Bug]: ./gradlew checkSetup fails with Java 8 on Docker dev image [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/03/11 03:45:37 UTC, 2 replies.
- [PR] Bump python-snappy from 0.6.1 to 0.7.3 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/11 04:10:19 UTC, 3 replies.
- [PR] Refactor bq per worker metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/11 05:57:51 UTC, 2 replies.
- [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] - posted by "sarthakbhutani (via GitHub)" <gi...@apache.org> on 2025/03/11 10:06:26 UTC, 4 replies.
- Re: [PR] Refactor per worker histogram metrics [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/11 10:51:49 UTC, 14 replies.
- [PR] Fix PostCommit Python ValidatesContainer Dataflow With RC job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/11 11:05:10 UTC, 6 replies.
- [I] [Bug]: WriteToBigQuery doesn't do WRITE_TRUNCATE properly with identical table names but in different datasets [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2025/03/11 11:37:21 UTC, 1 replies.
- [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2025/03/11 11:53:28 UTC, 8 replies.
- Re: [I] [Failing Test]: Go test workflow is red now [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/11 11:58:06 UTC, 0 replies.
- [PR] Request to use BASIC enum when calling tables.get() in BigQuery #34075 [beam] - posted by "tamannakakkar93 (via GitHub)" <gi...@apache.org> on 2025/03/11 13:20:10 UTC, 5 replies.
- [PR] Fix precommit flink container [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/11 13:40:20 UTC, 10 replies.
- [PR] Add streaming example to AlloyDB colab. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/11 14:06:39 UTC, 8 replies.
- Re: [PR] Move ExecutionStateTracker.nextBundleLullDurationReportMs reset attempt to resolve race detection [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/11 14:40:49 UTC, 6 replies.
- Re: [PR] [Python] File staging to user worker support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/11 15:07:07 UTC, 11 replies.
- [PR] Add Triton Inference Server Support [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/03/11 16:51:14 UTC, 7 replies.
- Re: [I] [Feature Request]: Vertex AI Triton Inference Server Support [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/03/11 16:52:28 UTC, 0 replies.
- [PR] Fix PostCommit Java PVR Spark3 Streaming job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/11 19:00:56 UTC, 15 replies.
- [PR] [DO NOT MERGE] Add support for collections dict subclasses [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/11 19:17:12 UTC, 4 replies.
- [PR] Update DF Python container tag [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/11 20:48:24 UTC, 4 replies.
- Re: [I] [Bug]: beam_PreCommit_PythonDocker misconfigured running on snapshot container [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/11 21:22:12 UTC, 3 replies.
- [PR] Bump dataflow java container versions - 20250312/11 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/11 22:28:34 UTC, 0 replies.
- [PR] Update docstring to clarify numShards=0 doesn't neccessarily enable autosharding [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/11 22:40:19 UTC, 7 replies.
- [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/03/11 23:19:54 UTC, 17 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.62 to 1.17.66 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/12 05:03:09 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.221.0 to 0.225.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/12 05:03:57 UTC, 3 replies.
- [PR] [Java]Add Support for Named Schemas in SpannerIO.Write by Enhancing Schema Retrieval [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/12 11:14:18 UTC, 4 replies.
- Re: [PR] Bump dataflow java container version - 20250312 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/12 11:35:02 UTC, 3 replies.
- Re: [I] [Failing Test]: dataflow runner worker project test stuck causing Java PreCommit time out [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/12 13:19:05 UTC, 1 replies.
- [PR] Use same format for next and current release versions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/12 13:46:16 UTC, 3 replies.
- [PR] Bump @babel/runtime from 7.10.5 to 7.26.10 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/12 14:08:17 UTC, 4 replies.
- Re: [I] [YAML][Feature Request]: Integration and Usage of GCP Secret Manager with the different Apache Beam IOs [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2025/03/12 14:52:46 UTC, 0 replies.
- Re: [I] [Feature Request]: YAML to support creating BQT4AI [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2025/03/12 15:01:00 UTC, 0 replies.
- [PR] [IcebergIO] Filter out data files that have already been committed [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/12 15:40:55 UTC, 10 replies.
- Re: [I] [Feature Request]: {Managed IO Iceberg} - Allow users to run streaming reads [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/12 16:55:12 UTC, 1 replies.
- [PR] Remove 2.1 and 2.2 and add 2.8 for Kafka compatibility test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/12 20:08:11 UTC, 2 replies.
- [PR] Update code-change-guide.md [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2025/03/12 21:01:23 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.23.0 to 0.36.0 in /learning/katas/go [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/12 22:21:04 UTC, 2 replies.
- Re: [PR] add vendor to manually shutdown and restart GetWorkerMetadataStream to prevent DEADLINE_EXCEEDED errors [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/12 23:26:29 UTC, 11 replies.
- [PR] Fix Republish Released Docker Images workflow [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/13 00:33:44 UTC, 5 replies.
- [PR] Bump golang.org/x/net from 0.33.0 to 0.36.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/13 01:39:34 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.35.0 to 0.36.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/13 02:03:45 UTC, 4 replies.
- [I] [Bug]: Bigquery python streaming insertAll SSLError leads to stuck streaming job [beam] - posted by "quentin-sommer (via GitHub)" <gi...@apache.org> on 2025/03/13 02:19:43 UTC, 1 replies.
- [PR] Making setServiceFactory public in SpannerConfig for Failure injection testing in Dataflow templates [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2025/03/13 02:46:05 UTC, 2 replies.
- [PR] Spark Runner : Fix invalid translateImpulse [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/03/13 03:31:55 UTC, 8 replies.
- [PR] Support functions and classes as init arguments in specifiable. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/13 03:32:09 UTC, 0 replies.
- [PR] Bump golang.org/x/net from 0.35.0 to 0.37.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/13 04:19:12 UTC, 7 replies.
- Re: [PR] [AnomalyDetection] Support functions and classes as init arguments in specifiable. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/13 05:06:56 UTC, 4 replies.
- [PR] Add sdf kafka poll latencies [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/13 07:13:56 UTC, 19 replies.
- Re: [PR] Fix Stress Tests Java Bigquery [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/13 13:50:06 UTC, 3 replies.
- [I] [Bug]: Unknown spanner type FLOAT32>(VECTOR_LENGTH=>128 [beam] - posted by "gradients-rogo (via GitHub)" <gi...@apache.org> on 2025/03/13 14:21:39 UTC, 4 replies.
- [I] [Task]: Update KafkaIO ConsumerSpEL and eliminate springframework dependencies [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/13 14:23:45 UTC, 1 replies.
- [PR] Eliminate springframework dependency in KafkaIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/13 14:47:25 UTC, 4 replies.
- [PR] Fix spotless [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/13 15:12:37 UTC, 3 replies.
- [PR] Update doc [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/13 16:55:39 UTC, 0 replies.
- [PR] Use Avro 1.8-compatible Schema constructors in Storage Write API translator [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2025/03/13 17:27:50 UTC, 6 replies.
- [PR] Fix programming guide python reference for combining pcollection into a single value [beam] - posted by "jbandoro (via GitHub)" <gi...@apache.org> on 2025/03/13 18:18:37 UTC, 5 replies.
- [PR] do not block other threads from health checking if a stream is blocked [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/13 19:22:19 UTC, 14 replies.
- [PR] Update join beam doc [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 19:34:20 UTC, 3 replies.
- [PR] Add Custom Detector to support model handlers from RunInference [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/13 19:55:58 UTC, 0 replies.
- [PR] [AnomalyDetection] Call RunInference for custom detectors [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/13 20:24:59 UTC, 8 replies.
- [I] [Bug]: Python doc misses Copyright [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/13 20:51:46 UTC, 3 replies.
- [PR] fix typo in docs (python snipptets_test) [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2025/03/13 20:56:57 UTC, 4 replies.
- [PR] Expose add-modules JVM option in SDKHarnessOptions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/13 21:24:28 UTC, 14 replies.
- Re: [PR] [AnomalyDetection] Add Custom Detector to support custom model handlers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/13 21:35:35 UTC, 3 replies.
- Re: [I] [Feature Request]: Running Word-Count with Gradle for PowerShell [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 21:41:23 UTC, 2 replies.
- Re: [I] [Bug]: Roadmap page is out of date. [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 21:44:03 UTC, 7 replies.
- [PR] refactor main.py so that it can be called by runner.run_async(). [beam] - posted by "zilin (via GitHub)" <gi...@apache.org> on 2025/03/13 21:51:46 UTC, 3 replies.
- Re: [I] Beam directRunner documentation java tab has python information [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 22:00:46 UTC, 1 replies.
- [PR] Updates 2.64.0 release notes to highlight recent additions to the Managed API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/13 23:18:20 UTC, 2 replies.
- Re: [I] Improve case studies section of website [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 23:42:20 UTC, 3 replies.
- Re: [I] [Bug]: Javadoc still incorrectly renders non-ascii characters [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/13 23:44:14 UTC, 1 replies.
- [PR] [Dataflow Streaming] WindmillTimerInternals: Use a single map to store timer data + liveness [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/03/14 04:21:10 UTC, 7 replies.
- [PR] Bump google.golang.org/api from 0.221.0 to 0.226.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/14 04:28:02 UTC, 3 replies.
- [PR] Revert Skip BoundedTrie on Dataflow till service is have BoundedTrie … [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2025/03/14 08:33:05 UTC, 9 replies.
- [PR] docs: update CHANGES.md for Spark Runner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/03/14 13:36:03 UTC, 3 replies.
- [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/14 14:05:23 UTC, 4 replies.
- Re: [I] [Task]: Improve project documentation on apache-beam pypi page. [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/14 14:20:20 UTC, 5 replies.
- [PR] docs: fix typo in snippets_test.py [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2025/03/14 15:47:35 UTC, 5 replies.
- [PR] Fix pre/postprocess type hints [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/14 18:08:46 UTC, 2 replies.
- [PR] Healthcare Label Update [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2025/03/14 19:31:09 UTC, 3 replies.
- [I] Big Query Python Documentation Typo [beam] - posted by "Mikep89 (via GitHub)" <gi...@apache.org> on 2025/03/14 20:41:17 UTC, 2 replies.
- [PR] Add a STRING format to PubSub reading that interpretes the payload as utf-8 encoded. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/14 21:03:00 UTC, 2 replies.
- [PR] Add STRING format to ReadFromKafka schema transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/14 21:50:02 UTC, 5 replies.
- [PR] Add option to disable Kafka metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/14 22:44:10 UTC, 2 replies.
- [PR] Better error messages for unavailable providers. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/14 22:57:02 UTC, 5 replies.
- [PR] More precise binary operation inference. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/15 00:13:27 UTC, 4 replies.
- Re: [I] [Bug]: Update or Remove Integrations page [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/15 03:23:38 UTC, 1 replies.
- [PR] Add Year and Apache Beam in Copyright [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/15 03:51:38 UTC, 4 replies.
- Re: [PR] [WIP] [Do not Merge] [Dataflow Streaming] Support for using virtual harness threads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/15 12:44:36 UTC, 2 replies.
- Re: [PR] Fix: Replace deprecated DataFrame.applymap with map for compatibility [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/15 12:44:37 UTC, 3 replies.
- [PR] [Java] Add Gauge Metric Extraction to DataflowMetrics [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/15 16:56:43 UTC, 12 replies.
- [I] [Task]: Improve README.md for https://github.com/apache/beam-starter-java-provider [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/15 17:46:56 UTC, 2 replies.
- Re: [I] Log GCS upload ID for Python GCS connector [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/15 20:21:34 UTC, 1 replies.
- [PR] Add Offline Detectors [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/15 21:54:32 UTC, 0 replies.
- Re: [I] GCS IO fails with uninformative 'Broken pipe' errors while attempting to write to a GCS bucket without proper permissions. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/15 22:01:14 UTC, 1 replies.
- [PR] [AnomalyDetection] Better typehinting in specifiable. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/15 22:04:53 UTC, 2 replies.
- [PR] [AnomalyDetection] Support offline detectors [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/15 22:09:17 UTC, 5 replies.
- [PR] Add an experiment named enableLineageRollup which when passed to Java… [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2025/03/16 01:11:43 UTC, 8 replies.
- Re: [PR] [AnomalyDetection] Better type hinting in specifiable. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/16 01:33:36 UTC, 0 replies.
- Re: [I] Update Python SDK example tests to use assert_that [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/16 01:41:24 UTC, 1 replies.
- [PR] Honor JAVA_HOME when it is set [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/16 02:06:30 UTC, 2 replies.
- Re: [PR] Backlog metrics do not showing up in FlinkRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/16 12:44:47 UTC, 2 replies.
- [I] The PreCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/16 12:45:42 UTC, 1 replies.
- Re: [I] Remove deprecated 'compare' argument from combiners.Top in PyDocs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/16 18:52:47 UTC, 0 replies.
- [PR] added test_accessing_valueprovider_info_after_run [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/16 19:23:30 UTC, 2 replies.
- [I] [Bug]: Go Prism Runner has a Data Race in v2.63.0 [beam] - posted by "jeremyje (via GitHub)" <gi...@apache.org> on 2025/03/16 21:40:45 UTC, 0 replies.
- [PR] Fix typo in BigQuery Python Documentation [beam] - posted by "AaronTrelstad (via GitHub)" <gi...@apache.org> on 2025/03/16 23:31:29 UTC, 4 replies.
- [PR] Support directory separator for Python local filesystem [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/17 01:13:57 UTC, 3 replies.
- Re: [PR] [AnomalyDetection] Add offline detectors [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/17 02:05:24 UTC, 0 replies.
- Re: [PR] [AnomalyDetection] Refactor and improve Specifiable [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/17 02:48:41 UTC, 15 replies.
- [I] [Feature Request]: Record Aggregation option in Kinesis Writer [beam] - posted by "Nakachi-S (via GitHub)" <gi...@apache.org> on 2025/03/17 03:32:11 UTC, 0 replies.
- [PR] Fix Precommit SQL [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/17 05:02:26 UTC, 12 replies.
- [PR] Consider workflow flaky if the 5 last runs were failed [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/17 09:25:25 UTC, 4 replies.
- [PR] Add 3 examples in playground SQL transform, schema transform and Composite Combine [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/03/17 10:21:47 UTC, 5 replies.
- [PR] Aggregation option in Kinesis Writer Python sdk [beam] - posted by "Nakachi-S (via GitHub)" <gi...@apache.org> on 2025/03/17 10:36:56 UTC, 6 replies.
- Re: [PR] Handle missing tables more gracefully. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/17 12:46:21 UTC, 2 replies.
- Re: [I] Prefer java binary from $JAVA_HOME in JavaJarServer [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/17 12:55:14 UTC, 0 replies.
- [PR] Key by paneindex and reshuffle before loading files. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/17 15:10:52 UTC, 13 replies.
- [PR] Revert "Update to latest bom" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/17 16:26:12 UTC, 1 replies.
- [I] [Feature Request]: Enable AWS SQS reads for Python SDK [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/03/17 16:48:42 UTC, 1 replies.
- [PR] Enabling xlang utilization for SQS read functionality [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/03/17 20:53:06 UTC, 1 replies.
- Re: [I] Add test for snippet accessing_valueprovider_info_after_run [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/18 00:05:45 UTC, 0 replies.
- Re: [PR] Enable xlang access for SQS read functionality [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/18 02:32:28 UTC, 5 replies.
- Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.3.1 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:23:07 UTC, 5 replies.
- Re: [PR] Bump github.com/fsouza/fake-gcs-server from 1.52.1 to 1.52.2 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:23:43 UTC, 2 replies.
- Re: [PR] Bump github.com/nats-io/nats.go from 1.39.0 to 1.39.1 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:27:53 UTC, 2 replies.
- Re: [PR] Upgrade Kafka client version to 3.7.0 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:35:40 UTC, 0 replies.
- Re: [PR] Adding credentials option to PubsubMessageMatcher [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:37:15 UTC, 0 replies.
- Re: [PR] Enable timeout setting for Python TestPipeline (#29646) [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:38:50 UTC, 0 replies.
- Re: [PR] [Dataflow Streaming] Cache StateNamespace encoded keys using SoftReference [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:41:16 UTC, 0 replies.
- Re: [PR] Add support for Iceberg table identifiers with special characters [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:44:25 UTC, 0 replies.
- Re: [PR] Remove type coercion of `FinalizeWrite` in iobase.py [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:45:30 UTC, 3 replies.
- Re: [PR] Support sharding in WriteToFiles (tested for to_csv) [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/18 03:46:15 UTC, 1 replies.
- [PR] Update pypi documentation 30145 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/18 05:37:40 UTC, 7 replies.
- [PR] Update roadmap page 28342 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/03/18 06:07:25 UTC, 6 replies.
- Re: [PR] Allow declaration of external dependencies for YAML UDFs. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/03/18 08:48:58 UTC, 2 replies.
- [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/03/18 10:07:19 UTC, 3 replies.
- [PR] Fix PostCommit Python ValidatesContainer with RC workflow [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/18 10:37:03 UTC, 2 replies.
- [I] [Bug]: withOutputTags (aka side output) requires ParDo to run on each output separately [beam] - posted by "shai-rubin (via GitHub)" <gi...@apache.org> on 2025/03/18 14:01:19 UTC, 0 replies.
- [PR] Kafka Consumer Group Properties [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/03/18 17:59:11 UTC, 4 replies.
- Re: [I] [Feature Request]: Enable to configure `--add-modules` jvm flag [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/18 18:30:46 UTC, 0 replies.
- Re: [I] Python local filesystem match does not work without directory separator. [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/18 19:07:24 UTC, 0 replies.
- [PR] Remove cancelled tasks from ReadOperation queue when shutting down [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/18 20:44:18 UTC, 3 replies.
- [PR] Fix pandas doctests sensitive to NumpyExtensionArray formatting. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/18 21:15:27 UTC, 3 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/18 22:13:38 UTC, 1 replies.
- Re: [I] [Bug]: apache-beam is unusable in recent python due to pinning an old dill library from 2019 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/18 23:24:52 UTC, 1 replies.
- Re: [I] [Bug]: Python 3.12 in-compatibility of Apache Beam [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/18 23:25:10 UTC, 1 replies.
- Re: [I] [Bug]: Python 3.10 installing `apache-beam==2.43.0` with `multiprocess>=0.70.12` has incompatibility for `dill` [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/18 23:25:30 UTC, 1 replies.
- Re: [I] Make cloudpickle the default pickle library [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/18 23:26:04 UTC, 0 replies.
- Re: [PR] DRAFT: Deploy Prism on Kubernetes [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2025/03/19 03:29:24 UTC, 0 replies.
- [I] The Clean Up GCP Resources job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/19 03:41:22 UTC, 7 replies.
- [I] [Bug]: Unauthenticated error when running tests on Dataproc using Flink and Docker with private repos [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/19 04:10:50 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/storage from 1.50.0 to 1.51.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/19 04:31:56 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.77.0 to 1.78.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/19 04:32:44 UTC, 3 replies.
- [I] [Feature Request]: Add support for tracking lineage with BoundedTrie [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2025/03/19 05:17:21 UTC, 1 replies.
- [I] [Bug]: javaJar provider does not work with --yaml_pipeline flag: TypeError: a bytes-like object is required, not 'str' [beam] - posted by "jonathaningram (via GitHub)" <gi...@apache.org> on 2025/03/19 05:48:28 UTC, 12 replies.
- [PR] update CHANGES with Read bugs/improvements [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/19 11:00:00 UTC, 3 replies.
- Re: [I] Support streaming side-inputs in the Spark runner. [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/03/19 11:43:54 UTC, 0 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Flink_Container not build Python SDK container causing test failure at PR run [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/19 14:33:08 UTC, 0 replies.
- [PR] Add docs for yaml dependencies. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/19 16:24:54 UTC, 3 replies.
- [PR] [#31438] Add changes.md message for Trigger support in Prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/03/19 17:23:48 UTC, 3 replies.
- [PR] [Java]Add Map Type Support to JsonToRow Transformer [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/03/19 18:17:39 UTC, 4 replies.
- [PR] Preserve pane index through reshuffle. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/19 18:28:20 UTC, 19 replies.
- [I] [Feature Request]: Yaml JdbcIO partitioning [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/19 18:51:57 UTC, 8 replies.
- [I] [Bug]: Docker worker containers are confusingly named. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/19 19:14:52 UTC, 0 replies.
- [PR] Fix relative path yaml provider error when no base provided. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/19 19:49:30 UTC, 3 replies.
- [PR] Fix dockerfile version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/19 20:47:04 UTC, 2 replies.
- Re: [PR] Avoid holding data elements alive via stack frame gc roots. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/19 20:48:18 UTC, 3 replies.
- [PR] Enabling AWS STS credentials refresh for federated authentication [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/03/19 22:24:40 UTC, 1 replies.
- [I] The Java Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 03:41:09 UTC, 3 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 03:41:12 UTC, 2 replies.
- [PR] Create a varint32 coder and used it for RowCoder [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/20 03:51:15 UTC, 13 replies.
- [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/03/20 04:20:36 UTC, 6 replies.
- [PR] Bump google.golang.org/api from 0.226.0 to 0.227.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 04:57:08 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.6 to 1.29.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 04:58:11 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.25 to 2.11.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 04:58:25 UTC, 2 replies.
- [PR] Remove finalizers from sdb-cluster before deleting singlestoreio name… [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/03/20 07:18:44 UTC, 0 replies.
- Re: [PR] Remove finalizers from sdb-cluster before deleting singlestoreio namespaces [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/20 08:08:58 UTC, 1 replies.
- Re: [I] Add "How to Build the Sources" section to README.md and Contribute pages [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/03/20 08:40:36 UTC, 2 replies.
- [I] [Bug]: beam.Map function outputs no data after beam.GroupByKey using DataflowRunner [beam] - posted by "bgalvao (via GitHub)" <gi...@apache.org> on 2025/03/20 11:04:15 UTC, 3 replies.
- Re: [I] [Bug]: beam_CleanupGCPResources is failing with log "The operation was canceled" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/20 13:56:14 UTC, 0 replies.
- [PR] ML benchmark pipelines [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/20 14:11:39 UTC, 11 replies.
- [PR] Mention __init__.py, which is customary for packages. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/20 16:22:09 UTC, 3 replies.
- [PR] Safeguard boundedtrie result [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2025/03/20 16:47:49 UTC, 7 replies.
- [PR] Revert "Support directory separator for Python local filesystem" [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/20 17:06:57 UTC, 2 replies.
- [PR] Fix MongoDB connector by adding codec options [beam] - posted by "haperski (via GitHub)" <gi...@apache.org> on 2025/03/20 17:44:59 UTC, 0 replies.
- [PR] Kafta Table consumer properties feature for beamSQL [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/03/20 18:35:30 UTC, 2 replies.
- [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/20 21:24:42 UTC, 8 replies.
- Re: [I] [Feature Request]: Apply encryption when writing to Iceberg [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/03/20 21:28:58 UTC, 0 replies.
- [PR] remove private ipv6 check [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/20 21:39:28 UTC, 2 replies.
- [PR] update the changes.md by adding 2.65.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/20 21:51:46 UTC, 3 replies.
- [PR] fix the check [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/20 23:40:44 UTC, 0 replies.
- [PR] Fix version on the master [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/20 23:43:50 UTC, 4 replies.
- Re: [PR] fix the check on the 2.64 release branch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 01:34:48 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.47.0 to 1.48.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 04:15:12 UTC, 3 replies.
- [PR] Bump github.com/avast/retry-go/v4 from 4.6.0 to 4.6.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 04:15:19 UTC, 1 replies.
- [PR] Removing snappy adding crc32c [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/21 07:11:31 UTC, 2 replies.
- [PR] Fix PostCommit TransformService Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/21 11:12:52 UTC, 8 replies.
- [PR] [Java] Improve Java FnStatus page to include bundle start time, oldest bundles by start time, and total bundles. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/21 12:34:49 UTC, 5 replies.
- [I] The PostCommit Java Jpms Dataflow Java11 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 12:46:37 UTC, 3 replies.
- [I] The PostCommit Java Jpms Dataflow Java17 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 12:46:40 UTC, 8 replies.
- [PR] Bump @octokit/plugin-paginate-rest, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 13:22:23 UTC, 1 replies.
- [PR] Perform correct release version validation [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/21 13:23:09 UTC, 3 replies.
- [PR] [DO NOT MERGE] Prototype RemoteModelHandler base class [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/03/21 13:50:24 UTC, 1 replies.
- [PR] Attempt to repro grpc issue with debugging [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/21 13:55:50 UTC, 1 replies.
- Re: [I] [Failing Test]: AttributeError for MaybeReshuffle in Python SDK [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/21 14:57:28 UTC, 0 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/21 15:10:29 UTC, 12 replies.
- [PR] Update verify_release_build.sh [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/21 15:12:16 UTC, 2 replies.
- [PR] Update release-guide.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/21 16:53:21 UTC, 3 replies.
- [PR] Update CONTRIBUTING.md to point to code-change-guide [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/21 18:07:29 UTC, 4 replies.
- [PR] Bump transformers from 4.30.0 to 4.48.0 in /sdks/python/apache_beam/ml/inference [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/21 18:13:50 UTC, 1 replies.
- Re: [PR] adding google-crc32c [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/22 08:07:47 UTC, 3 replies.
- [PR] Added 'How to Build the Sources' section to README.md and Contribute pages fixes #19820 [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/03/22 15:24:25 UTC, 3 replies.
- [PR] cherry pick 34375 to 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/22 15:55:10 UTC, 3 replies.
- [PR] Fix the error for directory separator [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/22 22:14:10 UTC, 4 replies.
- [I] [Feature Request]: Add keyed data to `KafkaReadSchemaTransformProvider` [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2025/03/23 00:47:36 UTC, 0 replies.
- [PR] Correcting array truncation logic to satisfy schema ARRAY(vector_length=>128) [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/23 06:14:02 UTC, 2 replies.
- [PR] Feature: Yaml JdbcIO partitioning for ReadRows [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/03/23 10:49:23 UTC, 27 replies.
- [PR] Interpolate console URL properly in error case [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/03/23 17:30:08 UTC, 1 replies.
- [PR] Add ability to specify partition bounds via jdbc xlang. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/23 17:42:00 UTC, 14 replies.
- [PR] Issue warnings when dataSourceConfiguration and dataSourceProviderFn are set [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/23 19:28:16 UTC, 2 replies.
- [I] The PostCommit Go Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/23 21:34:51 UTC, 1 replies.
- [I] The PostCommit Go job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/24 03:41:59 UTC, 1 replies.
- Re: [I] [Bug]: ignoreUnknownValues not working when using CreateDisposition.CREATE_IF_NEEDED [beam] - posted by "vamsiprasanth-narvar (via GitHub)" <gi...@apache.org> on 2025/03/24 04:28:24 UTC, 0 replies.
- Re: [I] [Feature Request]: CloudSQL Enrichment Handler [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/03/24 05:07:09 UTC, 2 replies.
- [PR] sdks/python: enrich data with CloudSQL [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/03/24 05:08:41 UTC, 5 replies.
- [PR] upgraded gcp-bom to 26.57.0 [beam] - posted by "sarthakbhutani (via GitHub)" <gi...@apache.org> on 2025/03/24 09:20:09 UTC, 3 replies.
- Re: [PR] [Dataflow Streaming] Use concurrent queue for commit queue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/24 12:46:22 UTC, 2 replies.
- [PR] CP: Perform correct release version validation (#34378) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/24 13:57:06 UTC, 1 replies.
- [PR] Update build.gradle [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/24 16:16:44 UTC, 4 replies.
- [PR] Cherry-pick #34401 for Beam 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/24 16:23:30 UTC, 1 replies.
- [PR] Cherry pick 34401 for 2.64 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/24 16:27:21 UTC, 1 replies.
- [PR] Factor out a get_default_sql_provider() function. [beam] - posted by "zilin (via GitHub)" <gi...@apache.org> on 2025/03/24 16:47:32 UTC, 7 replies.
- [PR] Enforce ordering to avoid svn conflicts [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/24 16:51:16 UTC, 1 replies.
- [PR] Update build.gradle (#34401) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/24 16:59:37 UTC, 1 replies.
- [PR] Clickhouse IT RM JDBC fix + ClickHouseRowsCheck [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/03/24 17:19:00 UTC, 2 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/24 18:40:35 UTC, 4 replies.
- [PR] Add to CHANGES.md follow up negative int32 fix [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/24 20:08:12 UTC, 2 replies.
- [PR] Add warning comment so that folks don't change this [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/24 20:25:48 UTC, 1 replies.
- [I] [Feature Request]: Deterministic serialization of type hints [beam] - posted by "AdrS (via GitHub)" <gi...@apache.org> on 2025/03/24 20:35:02 UTC, 1 replies.
- [PR] Normalize tf record io [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/03/24 20:54:01 UTC, 4 replies.
- [PR] track GetWork from WindmillWorker to UserWorker in proxyless path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/03/25 03:45:15 UTC, 6 replies.
- [PR] Use list instead of set to make type hint serialization deterministic [beam] - posted by "AdrS (via GitHub)" <gi...@apache.org> on 2025/03/25 04:10:11 UTC, 8 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.6 to 1.29.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/25 04:20:23 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.62 to 1.17.67 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/25 04:21:27 UTC, 3 replies.
- [PR] [Dataflow Streaming] Improve exception handling in PubsubSink to rest stream to prevent precondition exception on reuse [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/25 11:54:17 UTC, 2 replies.
- Re: [PR] Bump net.researchgate.release from 2.8.1 to 3.1.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/25 12:46:16 UTC, 0 replies.
- [I] [Bug]: Inline exception propagation with fused DoFns can lead to unexpected behavior [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/25 13:47:48 UTC, 1 replies.
- [PR] [wip] Report total backlog in unbounded source sdf wrapper [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/25 13:52:38 UTC, 6 replies.
- [PR] correcting array truncation logic (resolves #34276) [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/25 13:59:16 UTC, 2 replies.
- [PR] [DO NOT MERGE] Added blog post for 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/25 14:21:16 UTC, 6 replies.
- [I] [Task]: Deprecate ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/25 16:15:00 UTC, 0 replies.
- [PR] Add vendored cloudpickle [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/03/25 16:28:51 UTC, 11 replies.
- [PR] Bump serialize-javascript and mocha in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/25 18:37:55 UTC, 2 replies.
- [PR] Passing in key metadata when Reading From Kafka [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2025/03/25 19:59:16 UTC, 5 replies.
- [PR] Refactor per worker counter metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/25 20:02:38 UTC, 0 replies.
- [PR] Fix IndexOutOfBoundsException invoking expansion service [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/25 21:08:27 UTC, 2 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/25 22:13:22 UTC, 1 replies.
- [I] The PostCommit XVR Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 03:41:37 UTC, 3 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 03:41:40 UTC, 3 replies.
- [I] The PostCommit XVR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 03:41:43 UTC, 3 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 03:41:46 UTC, 3 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 03:41:49 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.63 to 1.17.64 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 04:19:51 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.39.1 to 1.40.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 04:19:57 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.227.0 to 0.228.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 04:20:05 UTC, 2 replies.
- [PR] Bump org.sonarqube from 3.0 to 6.1.0.5360 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 04:32:43 UTC, 1 replies.
- [I] [Task]: 3l#34423 [beam] - posted by "lizjordan44 (via GitHub)" <gi...@apache.org> on 2025/03/26 06:38:16 UTC, 2 replies.
- [I] Not able to Read compressed csv file without passing any size limit [beam] - posted by "shipragoyal07 (via GitHub)" <gi...@apache.org> on 2025/03/26 13:13:31 UTC, 1 replies.
- [PR] [wip] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/26 14:23:18 UTC, 0 replies.
- Re: [PR] Report total backlog in unbounded source sdf wrapper [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/26 14:39:02 UTC, 5 replies.
- [I] [Bug]: Error in BaseErrorProneJavaCompiler when building a local beam container. [beam] - posted by "ryan-mbuashundip (via GitHub)" <gi...@apache.org> on 2025/03/26 14:48:57 UTC, 0 replies.
- [I] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/26 15:23:16 UTC, 2 replies.
- [PR] tolerate integer overflow when encoding varint32 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/03/26 15:33:10 UTC, 3 replies.
- Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] - posted by "jyemin (via GitHub)" <gi...@apache.org> on 2025/03/26 19:52:03 UTC, 1 replies.
- [PR] Enabling long-running jobs to use federated STS assume role authentication for AWS resources. [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/03/26 19:54:36 UTC, 3 replies.
- Re: [I] [Bug]: AWS SQSIO - SocketTimeoutException is thrown after 5 minutes of inactivity [beam] - posted by "ajuliang (via GitHub)" <gi...@apache.org> on 2025/03/26 19:58:35 UTC, 0 replies.
- [I] [Feature Request]: Enabling long-running jobs to use federated STS assume role authentication for AWS resources [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/03/26 20:24:07 UTC, 1 replies.
- Re: [PR] Move interactive-specific TestStreamService to interactive protos. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/03/26 21:11:29 UTC, 0 replies.
- [PR] Remove dependency of core-runners in kafka:io [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/03/26 21:28:24 UTC, 1 replies.
- [PR] Remove legacy setup.py clean command [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/03/26 22:30:28 UTC, 3 replies.
- [PR] Updates Dataflow HEAD containers for Java SDK. [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/27 00:11:35 UTC, 4 replies.
- [PR] Bump github.com/aws/smithy-go from 1.22.2 to 1.22.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 04:31:22 UTC, 2 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.0.2 to 2.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 04:45:44 UTC, 3 replies.
- Re: [I] [BUG] | Not able to Read compressed csv file without passing any size limit [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/27 06:01:43 UTC, 2 replies.
- [PR] Bump dataflow java container version to beam-master-20250326 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/27 09:26:30 UTC, 2 replies.
- [PR] extend timeout for beam_PreCommit_Java_GCP_IO_Direct and beam_PreCommit_Java actions [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/27 12:37:03 UTC, 3 replies.
- Re: [PR] init dummy file [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 12:47:07 UTC, 0 replies.
- Re: [PR] Newtypes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 12:47:09 UTC, 0 replies.
- [PR] Add known protobuf issue [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/27 13:37:17 UTC, 6 replies.
- [I] [Bug]: The ":runners:flink:1.19:runQuickstartJavaFlinkLocal" gradle command does not work now [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/27 14:03:20 UTC, 3 replies.
- [PR] GCP BOM update to 26.57.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/27 15:10:38 UTC, 2 replies.
- [I] [Bug]: Current Protobuf causes incompatibility issues [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/27 15:18:56 UTC, 1 replies.
- [PR] Update run_rc_validation.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/27 17:12:34 UTC, 5 replies.
- Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 17:35:31 UTC, 2 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 18:40:22 UTC, 3 replies.
- [PR] [DO NOT MERGE] Run Python RC Validation Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 19:05:13 UTC, 3 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/27 22:14:24 UTC, 1 replies.
- [PR] added "Run Java Mobile Gaming RC Validation" [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/27 22:18:07 UTC, 5 replies.
- [I] [Task]: Create RC validation workflows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/28 00:26:20 UTC, 1 replies.
- [PR] Avoid hard dependency on clonevirtualenv. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/03/28 00:41:44 UTC, 3 replies.
- [PR] [AnomalyDetection] Add a notebook for anomaly detection with Z-Score [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/03/28 02:18:49 UTC, 2 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.0.2 to 2.2.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/28 04:52:55 UTC, 1 replies.
- Re: [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] - posted by "joseph6x (via GitHub)" <gi...@apache.org> on 2025/03/28 05:22:27 UTC, 1 replies.
- [PR] [Dataflow] Remove unused PhysicalElementCount Counter [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/03/28 05:28:44 UTC, 3 replies.
- [PR] [Go] Fix reshuffle implementation to use the global window for gbk output [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/28 09:26:08 UTC, 4 replies.
- [PR] chore: test beam against protobuf 3.25 [beam] - posted by "ldetmer (via GitHub)" <gi...@apache.org> on 2025/03/28 12:57:02 UTC, 0 replies.
- [PR] Expose drain_mode in windmill proto [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/03/28 14:45:20 UTC, 3 replies.
- [I] [Feature Request]: Enable to capture Kafka errors like JMSWriteResult [beam] - posted by "Culby4335 (via GitHub)" <gi...@apache.org> on 2025/03/28 15:11:45 UTC, 1 replies.
- [PR] Update run_rc_validation_java_mobile_gaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/28 15:29:16 UTC, 2 replies.
- [PR] Create run_rc_validation_python_mobile_gaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/28 21:48:29 UTC, 2 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 2025/03/28 22:14:47 UTC, 1 replies.
- [I] [Feature Request]: Support Time Partitioned Test Tables in BigqueryResourceManager [beam] - posted by "joy91227 (via GitHub)" <gi...@apache.org> on 2025/03/28 22:21:46 UTC, 1 replies.
- [PR] Support Time Partitioned Test Tables in BigqueryResourceManager [beam] - posted by "joy91227 (via GitHub)" <gi...@apache.org> on 2025/03/28 22:36:08 UTC, 4 replies.
- [PR] added run_rc_validation_python_mobile_gaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/28 23:14:38 UTC, 1 replies.
- [PR] Update run_rc_validation_python_mobile_gaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/28 23:42:10 UTC, 10 replies.
- [I] [Bug]: copy_tests_from_docs should not raise error [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/29 00:12:12 UTC, 3 replies.
- Re: [PR] Revert "Updated the python dependencies (targeted for Beam 2.63.0)" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/29 12:45:16 UTC, 0 replies.
- [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/03/29 17:27:24 UTC, 1 replies.
- [PR] Add the simple RC workflow to validate Go SDK with wordcount [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/29 17:49:22 UTC, 4 replies.
- [PR] warning for copy_tests_from_docs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/29 20:09:59 UTC, 5 replies.
- [PR] Added a new RC validation workflow for Java quickstart [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/29 21:37:42 UTC, 5 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 2025/03/29 22:13:53 UTC, 1 replies.
- Re: [PR] Update CHANGES.md to include streaming NPE issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/30 12:45:43 UTC, 0 replies.
- [PR] improve yaml schema validation error message [beam] - posted by "joseph6x (via GitHub)" <gi...@apache.org> on 2025/03/31 03:59:10 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.66.2 to 1.67.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/31 05:03:33 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.37.0 to 0.38.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/31 05:05:20 UTC, 1 replies.
- [PR] Bump github.com/docker/docker from 28.0.1+incompatible to 28.0.4+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/03/31 05:05:42 UTC, 1 replies.
- Re: [PR] [BEAM-34076] Implement TTL-based caching for BigQuery table definitions [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/03/31 08:48:15 UTC, 0 replies.
- [PR] Fn Runner Watermark issue [beam] - posted by "13MaxG (via GitHub)" <gi...@apache.org> on 2025/03/31 09:24:33 UTC, 1 replies.
- [I] [Feature Request]: [beam] - posted by "Avi-Sikirov (via GitHub)" <gi...@apache.org> on 2025/03/31 11:46:51 UTC, 0 replies.
- [PR] SnowflakeIO: filter on db and schema when searching for existing table [beam] - posted by "turb (via GitHub)" <gi...@apache.org> on 2025/03/31 13:19:11 UTC, 1 replies.
- [PR] Fix looker metrics [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/03/31 13:25:06 UTC, 4 replies.
- Re: [PR] Added blog post for 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/03/31 14:34:15 UTC, 0 replies.
- [I] Upgrade Netty version vulnerable to CVE-2025-24970 [beam] - posted by "dvgica (via GitHub)" <gi...@apache.org> on 2025/03/31 14:36:11 UTC, 0 replies.
- [PR] Fix Spanner NPE when withHost called with null or empty host [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/03/31 14:51:44 UTC, 6 replies.
- [PR] Modify JVM options if enableHeapDumps is specified to dump heap in directory that MemoryMonitor will look in. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/03/31 16:32:30 UTC, 0 replies.
- [PR] Auto-enable allowDuplicates for Redistribute with ALO streaming mode [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2025/03/31 19:46:07 UTC, 4 replies.
- [PR] Adds instructions regarding building the Go SDK harness container for Dataflow [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/03/31 19:50:33 UTC, 3 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/31 22:16:38 UTC, 0 replies.