github@beam.apache.org, 2025-07

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

- Re: [PR] added the job id for spanner IO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 01:36:49 UTC, 5 replies.
- Re: [PR] reconnect when publishMessage in JMS fails [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 01:37:03 UTC, 3 replies.
- Re: [PR] Fix PostCommit Python Xlang IO Direct [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/07/01 02:29:38 UTC, 9 replies.
- Re: [I] [Bug]: Missing `create_blob` and incorrect returns in FakeBucket's `lookup_blob` [beam] - posted by "nhonx (via GitHub)" <gi...@apache.org> on 2025/07/01 02:40:48 UTC, 1 replies.
- [I] The PreCommit Portable Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 06:44:35 UTC, 6 replies.
- Re: [PR] [Dataflow Streaming] Modify AbstractWindmillStream to separate logical stream from physical streams. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/07/01 08:10:58 UTC, 6 replies.
- Re: [PR] Fix TypeError in avro_union_type_to_beam_type with complex union types [beam] - posted by "RRap0so (via GitHub)" <gi...@apache.org> on 2025/07/01 09:34:29 UTC, 7 replies.
- Re: [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:02 UTC, 27 replies.
- Re: [PR] Iobase streaming support in FileBasedSink, exposed in TextIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:04 UTC, 21 replies.
- Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:05 UTC, 5 replies.
- Re: [PR] [KafkaIO] Report unknown backlog size when latest offset lags behind next offset [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:06 UTC, 5 replies.
- Re: [PR] Fix out of range [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:08 UTC, 8 replies.
- Re: [PR] fix user metrics in @OnTimer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:09 UTC, 3 replies.
- Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:16:10 UTC, 5 replies.
- Re: [PR] [DO NOT MERGE] bigquery pico brainstorming [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:46:46 UTC, 2 replies.
- Re: [PR] Python PTransform wrapper for AWS SQS [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:46:48 UTC, 2 replies.
- Re: [I] [Failing Test]: Integrating SQL file with YAML for transformation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:01 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a flag to disable emission of lineage from IOs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:03 UTC, 1 replies.
- Re: [I] [Distroless]: Add Beam ML distroless container images [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:05 UTC, 2 replies.
- Re: [I] [Distroless]: Support distroless container images [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:06 UTC, 2 replies.
- Re: [I] [Failing Test]: testKafkaIOSDFReadWithErrorHandler failing on kafka-client 2.0-2.2 cannot serialize ConsumerRecords [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:13 UTC, 2 replies.
- Re: [I] [Bug]: ByteBuddy doesn't do well with Map [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 12:47:13 UTC, 1 replies.
- Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 13:44:49 UTC, 0 replies.
- Re: [PR] run bomupgrader.py to update Google Cloud-related dependency [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 14:10:58 UTC, 0 replies.
- Re: [PR] Actually publish distroless containers when releasing [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/01 14:12:41 UTC, 0 replies.
- Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.4 to 2.11.5 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/01 14:13:19 UTC, 0 replies.
- Re: [PR] Bump github.com/docker/docker from 28.2.2+incompatible to 28.3.0+incompatible in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/01 14:13:48 UTC, 0 replies.
- Re: [PR] Bump google.golang.org/api from 0.238.0 to 0.239.0 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/01 14:29:30 UTC, 3 replies.
- Re: [PR] Consider windows with bands outside of [Min, Max] equivalent [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 14:32:33 UTC, 0 replies.
- Re: [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/01 14:44:39 UTC, 5 replies.
- Re: [I] [Task]: Upgrade calcite to a more recent version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 14:55:34 UTC, 3 replies.
- Re: [PR] Add logic for generating ml requirements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 15:07:35 UTC, 3 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/01 15:58:30 UTC, 3 replies.
- [PR] Re-add v2 record parsing [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 16:22:41 UTC, 1 replies.
- Re: [PR] Update Beam website to release 2.66.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 16:31:20 UTC, 2 replies.
- Re: [PR] Enable prism by default (where supported) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 16:32:49 UTC, 15 replies.
- [I] [Bug]: Row is not adaptable from Scala/JVM -> Python via PythonExternalTransform [beam] - posted by "mydimension (via GitHub)" <gi...@apache.org> on 2025/07/01 16:56:29 UTC, 2 replies.
- Re: [PR] Revert "Revert "Deserialize proto based (mutable key range) change stream return records"" [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 17:02:56 UTC, 2 replies.
- [PR] Add test for user counters in timer processing to FnApiDoFnRunnerTest and fix metrics test. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/01 17:12:25 UTC, 3 replies.
- [PR] [IcebergIO] Create tables with a Iceberg Table Properties [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/07/01 17:24:06 UTC, 0 replies.
- Re: [PR] Remove unused IOException from Backoff and BackoffUtils. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/01 17:24:10 UTC, 0 replies.
- [PR] Revert "Revert "Parse v2 record. (#35408)" (#35469)" [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 17:26:08 UTC, 3 replies.
- Re: [PR] Another attempt to fix jdbc timestamp logical type. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/01 18:15:09 UTC, 8 replies.
- Re: [PR] Fix(java/sql): Fix NullPointerException in TextTableProvider for Java 17 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/01 18:35:37 UTC, 1 replies.
- Re: [I] [Bug]: FnAPI Java SDK Harness doesn't update user counters in OnTimer callback functions [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/01 18:51:34 UTC, 1 replies.
- [PR] [Jules] Add OpenAI Remote Model Handler implementation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/01 19:09:58 UTC, 0 replies.
- Re: [I] [Bug]: TypeError: unhashable type: 'dict' in avroio.py [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 19:26:39 UTC, 0 replies.
- Re: [PR] fixed encoding_positions_set [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 19:31:24 UTC, 7 replies.
- Re: [I] [Bug]: Got error 'ValueError: Schema with id has encoding_positions_set=True, but not all fields have encoding_position set' for no apparent reason [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/01 19:32:28 UTC, 4 replies.
- Re: [PR] [IcebergIO] Create tables with Iceberg Table Properties [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/01 19:35:48 UTC, 8 replies.
- Re: [PR] GCP Access Control [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 19:35:50 UTC, 15 replies.
- [PR] Update AlloyDB colab notebook [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/01 19:44:43 UTC, 3 replies.
- [PR] Set pubsup topic cleaner to run [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/01 19:49:53 UTC, 2 replies.
- Re: [I] Re-enable FnApiDoFnRunner.testUsingMetrics [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/01 19:50:27 UTC, 0 replies.
- [PR] Replace port_to_expose with port as testcontainers upgrade [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/01 19:54:24 UTC, 9 replies.
- Re: [PR] Mysql embeddings [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/01 20:00:31 UTC, 5 replies.
- Re: [PR] Add filter to GetMinUnfinishedWatermark query [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:51:46 UTC, 0 replies.
- Re: [PR] add partition start record model, action function, and metrics [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:51:54 UTC, 0 replies.
- Re: [PR] Cdc v2 record [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:52:03 UTC, 0 replies.
- Re: [PR] Refactor GetUnfinishedMinWatermark query/index to improve performance. [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:52:26 UTC, 0 replies.
- Re: [PR] Refactor how to run connector forever [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:52:45 UTC, 0 replies.
- Re: [PR] V2 record parser [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:53:27 UTC, 0 replies.
- Re: [PR] V2 integration test [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:54:08 UTC, 0 replies.
- [PR] Proto-based connector integration test. [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 20:58:25 UTC, 3 replies.
- Re: [PR] Add integration test against placement table [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/01 21:24:58 UTC, 0 replies.
- Re: [PR] [IO] Fix Python Transform and IT for DebeziumIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 21:26:41 UTC, 4 replies.
- Re: [PR] Refactor: separate SplittableTruncateSizedRestrictions [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/07/01 21:49:59 UTC, 2 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/07/01 22:14:23 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 22:14:35 UTC, 1 replies.
- Re: [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 22:43:44 UTC, 2 replies.
- [PR] [test only] Fix Debezium xlang [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 23:02:46 UTC, 1 replies.
- Re: [PR] Fix Debezium xlang [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/01 23:10:17 UTC, 4 replies.
- [PR] Fix flake in StreamingEngineWorkCommitterTest by waiting for responses [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/01 23:21:51 UTC, 6 replies.
- [PR] Add mysqlclient dependency to address missing MySQLdb module [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/01 23:52:20 UTC, 4 replies.
- [PR] Bump org.apache.beam:beam-sdks-java-core from 2.65.0 to 2.66.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 01:28:26 UTC, 5 replies.
- [PR] Bump org.apache.beam:beam-runners-direct-java from 2.65.0 to 2.66.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 01:28:27 UTC, 5 replies.
- Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.64.0 to 2.65.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 01:36:16 UTC, 1 replies.
- Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.64.0 to 2.65.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 01:36:21 UTC, 1 replies.
- [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 03:49:07 UTC, 3 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 03:49:10 UTC, 8 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.82.0 to 1.83.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 04:42:22 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.5 to 2.11.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 04:42:36 UTC, 3 replies.
- [PR] Bump to Beam 2.66.0 [beam-starter-java] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/02 07:00:53 UTC, 1 replies.
- [PR] Update Republish Released Docker Images [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/02 07:05:33 UTC, 2 replies.
- Re: [PR] Iobase streaming others [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:15:43 UTC, 8 replies.
- Re: [PR] Support Docker Compose v2 in Python TransformServiceLauncher [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:15:45 UTC, 10 replies.
- Re: [PR] Distinguishing bigquery logging failures severities [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:15:52 UTC, 18 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/07/02 12:15:57 UTC, 5 replies.
- Re: [PR] [Java] Add parsedData to Hl7v2Message and Update HL7v2IO Docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:15:59 UTC, 5 replies.
- Re: [PR] Bump apache-beam from 2.65.0 to 2.66.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:36:56 UTC, 2 replies.
- Re: [I] Apache Beam Java Lib and ANTLR [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:46:55 UTC, 1 replies.
- Re: [I] [Bug]: NPE in SolaceIO getWatermark [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:46:57 UTC, 0 replies.
- Re: [I] [Bug]: Go Prism Runner Concurrent Map Mutations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:46:58 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support for Flink 1.20 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:46:59 UTC, 0 replies.
- Re: [I] [Bug]: grpc error when reading Kafka with flink runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 12:47:00 UTC, 0 replies.
- [PR] Fix yaml postcommit test failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/02 13:46:40 UTC, 3 replies.
- Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/07/02 16:30:39 UTC, 0 replies.
- [I] [Bug]: JDBCIO failed to handle TIMESTAMP field. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/02 16:58:56 UTC, 1 replies.
- Re: [PR] Support BigQuery dialect in Beam SQL [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/02 17:51:52 UTC, 0 replies.
- Re: [I] [Feature Request]: Use bigquery calcite dialect [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/02 17:51:52 UTC, 0 replies.
- Re: [PR] RabbitMqIO doesn't handle closed channels [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/02 17:52:17 UTC, 0 replies.
- Re: [I] [Bug]: com.rabbitmq.client.AlreadyClosedException causes RabbitMQIO pipeline to fail [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/02 17:52:18 UTC, 0 replies.
- [PR] Quick fix on deleting pubsub resources [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/02 18:11:27 UTC, 3 replies.
- [I] The PostCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 21:36:35 UTC, 2 replies.
- Re: [PR] [1/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/02 22:08:25 UTC, 22 replies.
- [PR] [IcebergIO] robust handling for filtering time types; expose new features to YAML SDK [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/02 22:14:00 UTC, 7 replies.
- [PR] Refactor prism runner python class [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/03 03:37:30 UTC, 0 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 03:50:24 UTC, 2 replies.
- [PR] Bump github.com/docker/docker from 28.3.0+incompatible to 28.3.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 05:03:18 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.238.0 to 0.240.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 05:04:45 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.83 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 05:05:43 UTC, 2 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.82 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 05:05:46 UTC, 1 replies.
- [PR] Fix PostCommit Python Dependency job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/03 08:08:48 UTC, 3 replies.
- [PR] Remove warning for dofns that don't return anything [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/03 10:31:31 UTC, 10 replies.
- Re: [I] [Task]: Simplify management of Beam infrastructure, access control and permissions via Platform features [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:46:40 UTC, 0 replies.
- Re: [I] [Bug]: Reading Kinesis' stream shards fails when the number of shards is greater than 1000 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:46:51 UTC, 1 replies.
- Re: [I] [Bug]: Gauge metrics are not extracted in metrics result. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:46:52 UTC, 1 replies.
- Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:47:03 UTC, 0 replies.
- [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:47:21 UTC, 2 replies.
- Re: [PR] Refactor PrismJobServer python class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 12:47:50 UTC, 1 replies.
- [I] The PerformanceTests SQLBigQueryIO Batch Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 15:38:24 UTC, 11 replies.
- Re: [PR] Allow STRING format in Kafka config [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/03 18:32:55 UTC, 0 replies.
- Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] - posted by "jbandoro (via GitHub)" <gi...@apache.org> on 2025/07/03 19:42:46 UTC, 3 replies.
- [PR] WIP Add support to AbstractWindmillStream to transition between physical streams within the same logical stream [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/03 23:18:37 UTC, 6 replies.
- [PR] Secret management service [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/04 00:47:32 UTC, 0 replies.
- Re: [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/07/04 06:41:16 UTC, 2 replies.
- [PR] Add ingress object for Grafana metrics [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/04 07:08:14 UTC, 2 replies.
- [PR] Adding clustering support for python storage write api [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/07/04 08:44:34 UTC, 12 replies.
- [I] [Feature Request]: YAML API - allow specifying expansion service for java-backed providers when running on Flink [beam] - posted by "cliffsun91 (via GitHub)" <gi...@apache.org> on 2025/07/04 09:51:39 UTC, 1 replies.
- Re: [I] [Bug]: Use Python 3.12 for pull_licenses_java.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 12:46:38 UTC, 0 replies.
- Re: [I] [Bug]: Beam Jobs built using version 2.50 and above are not running with FlinkRunners v 1.16.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 12:46:45 UTC, 0 replies.
- Re: [I] [Distroless] Publish Python distroless variants [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 12:46:46 UTC, 1 replies.
- Re: [PR] Fix: Prevent race conditions in Python SDK monitoring info collection. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/04 13:40:36 UTC, 1 replies.
- Re: [I] [Flaky Py SDK Snapshots]: Publish Beam SDK Snapshots is failing for Python distroless container [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/04 18:08:19 UTC, 0 replies.
- [PR] Update Python version matrix in [.github/workflows/README.md](.github/workflows/README.md) [beam] - posted by "BorisQuanLi (via GitHub)" <gi...@apache.org> on 2025/07/04 19:20:01 UTC, 0 replies.
- Re: [PR] Update Python version matrix in .github/workflows/README.md [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 20:07:39 UTC, 1 replies.
- Re: [PR] Sliding window ptransform for time series data [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/05 12:14:22 UTC, 3 replies.
- Re: [PR] Make dill optional and fix coders. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/05 12:46:17 UTC, 2 replies.
- Re: [I] [Task]: Migrate Beam I/O Metrics to use a platform that allows public embedding [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/05 12:46:20 UTC, 0 replies.
- Re: [I] [Task]: Add new Python SchemaTransform multi-language documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/05 12:46:28 UTC, 0 replies.
- [PR] Update Python version matrix in .github/workflows documentation [beam] - posted by "BorisQuanLi (via GitHub)" <gi...@apache.org> on 2025/07/05 18:30:44 UTC, 2 replies.
- Re: [I] [Bug]: pubsubio in Go SDK incorrectly sets Topic when Subscription is specified [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/07/05 20:46:10 UTC, 0 replies.
- Re: [PR] [WIP] Update Error Prone for ThreadSafe analysis [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/06 12:46:19 UTC, 2 replies.
- Re: [I] [Bug]: BigQueryIO with AvroFormat fails on nullable nested record types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/06 12:46:22 UTC, 0 replies.
- Re: [I] [Bug]: PostRelease Nightly workflow flaky for release candidate validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/06 12:46:31 UTC, 1 replies.
- Re: [I] [Bug]: UnsupportedOperationException when spin up beam-examples-multi-language expansion service [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/06 12:46:32 UTC, 1 replies.
- Re: [I] [Feature Request]: Support Java 14 records in `SchemaCoder` [beam] - posted by "eledhwen (via GitHub)" <gi...@apache.org> on 2025/07/06 17:27:02 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.37.0 to 1.38.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/07 06:01:04 UTC, 4 replies.
- [PR] Fix failed rows conversion missing 'as_dict' error [beam] - posted by "addenergyx (via GitHub)" <gi...@apache.org> on 2025/07/07 08:42:26 UTC, 16 replies.
- [PR] CI: add Gemini assist for code reviews [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/07 09:08:52 UTC, 11 replies.
- Re: [I] [Feature Request]: Provide the Python equivalent to Java's BigQueryIO `writeProtos` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/07 12:46:57 UTC, 1 replies.
- Re: [I] SVN removed from GitHub ubuntu-latest causing build_release_candidate workflow failure [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/07 12:46:58 UTC, 1 replies.
- Re: [I] KafkaIO does not handle null keys [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 15:41:58 UTC, 1 replies.
- Re: [I] [Bug]: KafkaIO Batch Write Failing due to producer cannot commit messages within timeout [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 15:47:34 UTC, 0 replies.
- Re: [I] Support for Confluent Schema Registry [beam] - posted by "an2x (via GitHub)" <gi...@apache.org> on 2025/07/07 15:48:59 UTC, 1 replies.
- Re: [I] Support ValueProviders in KafkaIO [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 15:51:59 UTC, 0 replies.
- Re: [I] [Bug]: Add a Python Kafka read test that uses the with_metadata option [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 15:55:58 UTC, 0 replies.
- Re: [I] Create KafkaIO SchemaTransform [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 15:57:27 UTC, 1 replies.
- Re: [I] Unable to use KafkaIO with SSL via Python API [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:03:43 UTC, 0 replies.
- Re: [I] Caveats with KafkaIO exactly once support. [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:07:33 UTC, 0 replies.
- [PR] Add alloy db password to precommit python [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/07 16:07:38 UTC, 0 replies.
- Re: [I] KafkaRecordCoder.encode throws NullPointerException [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:08:37 UTC, 0 replies.
- Re: [I] Improve work with SSL/TLS certificates in SDK IO, for Google Dataflow [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:09:14 UTC, 4 replies.
- Re: [I] KafkaIO withEOS option does not use the topic provided in ProducerRecord [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:12:46 UTC, 0 replies.
- Re: [I] KafkaIO attempting to make connection when uploading via Dataflow Runner [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:15:13 UTC, 1 replies.
- Re: [I] KafkaIO supports consumer group? [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:15:58 UTC, 1 replies.
- Re: [I] Build Kafka Read on top of Java SplittableDoFn [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:16:35 UTC, 1 replies.
- Re: [I] Create external transform builder for KafkaIO.ReadAll() [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:17:10 UTC, 1 replies.
- Re: [I] ReadFromKafkaDoFn should perform seft-checkpoint when there is no offset returned by offsetForTime [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/07/07 16:17:45 UTC, 1 replies.
- Re: [PR] workflows: add `ALLOYDB_PASSWORD` env variable to `beam_PreCommit_Python_Transforms` [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/07 16:21:28 UTC, 8 replies.
- Re: [PR] Add dataflow option go [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/07/07 17:07:59 UTC, 3 replies.
- Re: [PR] Add dataflow option python [beam] - posted by "ryan-mbuashundip (via GitHub)" <gi...@apache.org> on 2025/07/07 17:53:58 UTC, 9 replies.
- Re: [PR] Arnav Arora BigTablePR [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2025/07/07 18:19:05 UTC, 10 replies.
- [PR] Update beam master tag. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/07 21:46:19 UTC, 1 replies.
- [PR] fix the end_stamp issue for the initial partition [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/08 00:56:33 UTC, 4 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 7.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 05:11:03 UTC, 3 replies.
- Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 7.0.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 05:11:05 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 05:31:05 UTC, 3 replies.
- Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.0.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 05:31:07 UTC, 1 replies.
- Re: [PR] fixed the large row errors fof BigQuery IO storage write [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:16:11 UTC, 4 replies.
- Re: [PR] Fix The PostCommit Python job [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:16:13 UTC, 1 replies.
- Re: [PR] [Spark runner] Support for ProcessingTime Timer for Spark Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:16:15 UTC, 5 replies.
- Re: [I] [Feature Request]: [Portable BigQueryIO] support fetching Schema from dynamic destinations when setting useBeamSchema() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:46:57 UTC, 0 replies.
- Re: [I] [Bug]: Managed BQ read transform fails to attach config row [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:46:58 UTC, 0 replies.
- Re: [I] [Bug]: IcebergIO - Write performance issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:47:11 UTC, 1 replies.
- Re: [I] [Bug][Prism]: Unsupported feature Create/MaybeReshuffle (Python SDK) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:47:13 UTC, 1 replies.
- Re: [I] [Bug]: Processing time timers are fired after the window closed in Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:47:14 UTC, 1 replies.
- [I] The Generate issue report job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 12:47:32 UTC, 2 replies.
- [I] [Feature Request]: Allow users to pass service name for profiler for java [beam] - posted by "aaryan-srivastava-glean (via GitHub)" <gi...@apache.org> on 2025/07/08 14:30:25 UTC, 1 replies.
- Re: [PR] Add dataflow option [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/07/08 14:57:57 UTC, 19 replies.
- [PR] Fix Generate issue report job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/08 16:05:01 UTC, 7 replies.
- Re: [PR] Bump @octokit/plugin-paginate-rest and @octokit/rest in /scripts/ci/issue-report [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/08 16:05:32 UTC, 1 replies.
- [PR] Added beam summit 2025 hackathon blog - Pcollectors [beam] - posted by "adityashukla8 (via GitHub)" <gi...@apache.org> on 2025/07/08 18:43:57 UTC, 4 replies.
- [PR] Update Python version matrix in workflow documentation (#35529) [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/08 20:39:09 UTC, 1 replies.
- [PR] fix endtimestamp issue [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/07/08 20:53:20 UTC, 5 replies.
- [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 21:36:40 UTC, 6 replies.
- Re: [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/07/09 10:01:57 UTC, 22 replies.
- Re: [I] [Task]: Remove Avro dependency from "sdks/java/core" [beam] - posted by "therealdorin (via GitHub)" <gi...@apache.org> on 2025/07/09 11:23:55 UTC, 1 replies.
- Re: [I] [Feature Request]: BigQuery as Unbounded Source via Storage Read API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/09 12:47:03 UTC, 0 replies.
- Re: [I] [Bug]: Windowed Streaming OnTimer State Wiped [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/09 12:47:04 UTC, 0 replies.
- Re: [I] [Bug]: SolaceIO does not acknowledge messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/09 12:47:04 UTC, 0 replies.
- Re: [I] [prism] Good Non-Go Beam developer experience [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/09 12:47:06 UTC, 0 replies.
- [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work wi… [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2025/07/09 16:08:57 UTC, 2 replies.
- [PR] Avoid unreasonably long stage names for @ptransform_fn. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/07/09 19:59:12 UTC, 19 replies.
- [PR] Add more Pub/Sub topic prefixes to the topic cleaner [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/09 20:39:17 UTC, 2 replies.
- [PR] draft [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2025/07/09 20:49:14 UTC, 2 replies.
- [PR] Draft: Phun fix copy job writetruncate on identical tableid tmp fix pipelines v2.66 [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2025/07/09 21:20:09 UTC, 2 replies.
- [PR] Fix javadoc workflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/09 21:23:04 UTC, 6 replies.
- [PR] [Dataflow Streaming] Fix grpc commit stream test [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/07/10 01:17:54 UTC, 10 replies.
- [PR] Stale pubsub subscriptions cleaner [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/10 03:16:30 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.240.0 to 0.241.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 04:42:40 UTC, 2 replies.
- [PR] Bump github.com/docker/docker from 28.3.0+incompatible to 28.3.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 04:43:06 UTC, 2 replies.
- [PR] Fix PostCommit Python ValidatesContainer Dataflow With RC job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/10 04:45:29 UTC, 4 replies.
- Re: [I] [prism] Smarter "globally" aware dynamic splits. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 12:47:12 UTC, 0 replies.
- Re: [I] [Bug]: ParDoLifeCycleTest in Stateful DoFn fails on Samza PVR runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 12:47:14 UTC, 0 replies.
- [I] [Bug]: DebeziumIO and RequestResponseIO in different package than all other IOs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/10 14:11:58 UTC, 1 replies.
- Re: [I] [Bug]: Breaking change in Coder introduced in 2.63 is leading to incompatiblities [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/07/10 14:38:36 UTC, 1 replies.
- Re: [I] [Bug]: Error in SolaceIO during autoscaling events ("Tried to start a closed message consumer") [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/07/10 14:39:58 UTC, 1 replies.
- [PR] Move remaining workflow to Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/10 15:43:14 UTC, 6 replies.
- [I] [Failing Test]: GoogleCloudStorageImpl constructor mismatch in GcsUtil [beam] - posted by "jinseopkim0 (via GitHub)" <gi...@apache.org> on 2025/07/10 18:26:53 UTC, 1 replies.
- [PR] Use unsigned integer math to calculate differences between range start, consumed and estimated end positions. The difference between two values does not exceed the maximum value of unsigned longs so BigDecimal isn't strictly necessary here. For high volume consumption in KafkaIO this reduces CPU time spent in RestrictionTracker.getProgress by ~30x. [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/07/10 18:33:17 UTC, 0 replies.
- Re: [PR] [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 20:38:55 UTC, 6 replies.
- [PR] [Iceberg SQL] Add iceberg CDC table [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/10 22:31:19 UTC, 1 replies.
- [I] [Bug]: Python experiments and dataflow_service_options do not handle comma separated options [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/11 02:42:13 UTC, 2 replies.
- [PR] adds pre-commit hook to standardize whitespaces, adds EditorConfig to set the indents [beam] - posted by "nyoungstudios (via GitHub)" <gi...@apache.org> on 2025/07/11 02:45:09 UTC, 8 replies.
- [PR] removes Hazelcast Jet runner links from the documentation [beam] - posted by "nyoungstudios (via GitHub)" <gi...@apache.org> on 2025/07/11 03:23:51 UTC, 1 replies.
- Re: [PR] updates Hazelcast website link in the documentation [beam] - posted by "nyoungstudios (via GitHub)" <gi...@apache.org> on 2025/07/11 03:56:09 UTC, 2 replies.
- Re: [PR] Adding GCP Spanner Change Stream support for Python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 12:15:51 UTC, 3 replies.
- Re: [PR] Fix flink runner test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 12:46:47 UTC, 14 replies.
- Re: [I] [Bug]: beam-starter-typescript: npm run build: TypeError: Cannot set property constructor of [object Object] which has only a getter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 12:47:01 UTC, 1 replies.
- Re: [I] [Bug]: Building wheels failing on self hosted actions, working on github's runners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 12:47:02 UTC, 1 replies.
- Re: [PR] Update Beam Protobuf Schema (Java) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/11 14:30:23 UTC, 6 replies.
- [I] [Bug]: BQ log message covering up real reason for failure [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/11 17:09:50 UTC, 0 replies.
- [PR] [BQ]: Update error message for too big of a BQ tablerow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/11 17:10:46 UTC, 23 replies.
- [PR] [YAML] A Streaming Inference Pipeline - Taxi Fare Estimation [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/12 03:28:14 UTC, 28 replies.
- [PR] Add a flag in PeriodicImpulse to rebase timestamp. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/12 04:01:21 UTC, 28 replies.
- [PR] Fix metrics url [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/12 05:00:59 UTC, 2 replies.
- [PR] Updated User Defined Function Document for SQL [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/07/12 06:15:30 UTC, 3 replies.
- [PR] BeamSQL Datagen Table Provider [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/07/12 11:26:50 UTC, 12 replies.
- Re: [PR] [WIP] Raise an exception/warning when using BatchElements on a streaming case. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 12:46:29 UTC, 2 replies.
- Re: [PR] [WIP] Flink watermark emission [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 12:46:33 UTC, 2 replies.
- Re: [I] [Feature Request]: PubsubMessageMatcher Credentials Argument [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 12:46:34 UTC, 0 replies.
- Re: [I] [Bug]: Hitting 'tensorrt_bindings.tensorrt.ICudaEngine' object has no attribute 'num_bindings' while running RunInference on Colab [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 12:46:36 UTC, 0 replies.
- [I] [Feature Request]: Time series processing for batch data [beam] - posted by "pritamdodeja (via GitHub)" <gi...@apache.org> on 2025/07/12 17:28:17 UTC, 1 replies.
- [PR] retry validateOutputFilePrefixSupported for tempLocation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/12 22:40:21 UTC, 6 replies.
- [PR] Another try to fix IllegalStateException [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/12 23:19:35 UTC, 7 replies.
- [PR] try synchronized when calling APPEND_CLIENTS [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/13 01:45:47 UTC, 7 replies.
- Re: [I] Improve textio: Write sharding [beam] - posted by "amardeep (via GitHub)" <gi...@apache.org> on 2025/07/13 05:14:06 UTC, 0 replies.
- [PR] [2/3] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/13 11:06:01 UTC, 7 replies.
- Re: [I] [Bug]: BigQuery streaming throwing OutOfRangeException [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/13 11:46:19 UTC, 6 replies.
- Re: [I] [Feature Request]: Allowed write to custom sink from unbounded source [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/13 11:52:00 UTC, 1 replies.
- [PR] Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/07/13 12:06:00 UTC, 8 replies.
- Re: [PR] [DO NOT MERGE] add nullable proto3 tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/13 12:46:29 UTC, 2 replies.
- Re: [I] [Feature Request]: Support generic PTransforms in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/13 12:46:38 UTC, 1 replies.
- Re: [I] [Task]: Utilize Managed Service for Apache Kafka resources for testing purposes. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/13 12:46:50 UTC, 1 replies.
- [I] [Bug]: Beam YAML documentation not reflecting full parameters. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/07/13 12:52:47 UTC, 4 replies.
- [PR] added the manual check for the Yaml release doc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/13 14:34:12 UTC, 3 replies.
- [PR] feat(options): add support for comma-separated options [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/13 18:15:44 UTC, 5 replies.
- [PR] Add watermark strategy for BeamSQL Kafka tables [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/07/14 00:29:00 UTC, 4 replies.
- Re: [PR] Fix loopback [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/07/14 03:30:46 UTC, 1 replies.
- [PR] fix(setup.py): modernize packaging and require setuptools>=80.9.0 for Python 3.12 compatibility [beam-starter-python] - posted by "BorisQuanLi (via GitHub)" <gi...@apache.org> on 2025/07/14 04:34:27 UTC, 0 replies.
- [PR] Add glob and single file support to BeamSQL ParquetTable LOCATION [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/07/14 05:31:11 UTC, 6 replies.
- [PR] Bump golang.org/x/sys from 0.33.0 to 0.34.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 05:46:18 UTC, 2 replies.
- Re: [I] [Bug]: Python Interactive Beam show() does not work [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/07/14 06:11:29 UTC, 1 replies.
- Re: [I] [Feature Request]: Add capability to visualization lineage through existing visualization tools [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 12:47:05 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support for Lineage Graphs in Beam's direct runner through job graph traversal [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 12:47:06 UTC, 0 replies.
- Re: [I] [Bug]: Issue with GroupIntoBatches Between Two Aggregations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 12:47:16 UTC, 0 replies.
- Re: [I] [Dataflow Streaming] Micro Optimizations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 12:47:18 UTC, 1 replies.
- Re: [I] [Bug]: Can't build and deploy dataflow-runner with readFromPubSubWithAttributes (but can with readFromPubSub) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 12:47:19 UTC, 1 replies.
- [I] [Feature Request]: Resilient Fallback and Auto-Creation of Default Storage Bucket [beam] - posted by "yquaziii (via GitHub)" <gi...@apache.org> on 2025/07/14 13:35:22 UTC, 1 replies.
- Re: [I] [Feature Request]: Resilient Fallback log and Auto-Creation of Default Storage Bucket. [beam] - posted by "yquaziii (via GitHub)" <gi...@apache.org> on 2025/07/14 13:38:05 UTC, 2 replies.
- [PR] workflows+gradle: run ML tests that require non self-hosted environment [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/14 16:38:13 UTC, 0 replies.
- [PR] Bump gradle plugin versions previously blocked by Java8 support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/14 17:41:58 UTC, 4 replies.
- Re: [PR] workflows+gradle: capture and run ML tests that require non self-hosted environment on `ubuntu-latest` [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/14 17:48:17 UTC, 6 replies.
- [PR] Remove beam summit banners [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/14 18:25:09 UTC, 3 replies.
- Re: [PR] test: check for incompatibility for versions selected for LTS 9 [beam] - posted by "jinseopkim0 (via GitHub)" <gi...@apache.org> on 2025/07/14 21:33:43 UTC, 0 replies.
- [PR] [Test only] Vendor Calcite 1.40 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/14 22:13:13 UTC, 11 replies.
- Re: [I] ParquetTableProvider doesn't support globs or path to file in LOCATION [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/15 00:07:54 UTC, 0 replies.
- [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 06:27:08 UTC, 6 replies.
- [PR] Bump golang.org/x/sync from 0.15.0 to 0.16.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 06:29:18 UTC, 3 replies.
- [PR] Bump aiohttp from 3.12.13 to 3.12.14 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 09:51:56 UTC, 7 replies.
- Re: [I] [Feature Request]: Support for Storage Read API Enrichment Handler [beam] - posted by "stoppie (via GitHub)" <gi...@apache.org> on 2025/07/15 11:38:15 UTC, 0 replies.
- Re: [PR] draft: fix split overflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 12:46:58 UTC, 2 replies.
- Re: [PR] Support customizing how built-in types are pickled for cloudpickle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 12:47:01 UTC, 2 replies.
- Re: [I] [Feature Request]: managed IO connector for Apache Iceberg to offer Configurable Write Options for Target Table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 12:47:11 UTC, 1 replies.
- Re: [I] [Feature Request]: Provide error log for troubleshooting newJarGetter function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 12:47:12 UTC, 1 replies.
- [I] [Bug]: package google-apitools missing when using PDM package manager [beam] - posted by "pineapple-pokopo (via GitHub)" <gi...@apache.org> on 2025/07/15 13:49:25 UTC, 2 replies.
- [I] [Task]: Google Cloud Platform Expansion Service still contains CVE-2024-47561 [beam] - posted by "pineapple-pokopo (via GitHub)" <gi...@apache.org> on 2025/07/15 14:01:56 UTC, 6 replies.
- [PR] Start pushing ml containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/15 15:01:56 UTC, 1 replies.
- [PR] Fix bad error assert [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/15 17:17:42 UTC, 4 replies.
- [PR] Fix json schema test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/15 17:30:59 UTC, 7 replies.
- [PR] workflows: update marker from `require_non_self_hosted` to `require_docker_in_docker` in `Pposargs` [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/15 17:54:54 UTC, 14 replies.
- [PR] Add Iceberg Rest Catalog Example [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/07/15 18:08:49 UTC, 10 replies.
- [PR] Partially revert #35598 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/15 18:45:15 UTC, 5 replies.
- [PR] Combine sideinputs [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/15 23:28:20 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.83.0 to 1.84.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 04:41:13 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.83 to 1.17.84 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 04:42:16 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.41.0 to 0.42.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 04:42:23 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Direct JavaVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 06:45:44 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Spark Java8 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 06:45:45 UTC, 3 replies.
- [I] The PostCommit Go VR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 06:45:48 UTC, 3 replies.
- [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 09:40:59 UTC, 7 replies.
- [PR] Reenable The PostCommit XVR GoUsingJava Dataflow job [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/07/16 10:06:48 UTC, 4 replies.
- [PR] raise errors instead of warnings for no iterators [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/16 11:44:10 UTC, 0 replies.
- Re: [I] [Feature Request]: Dynamic partition key in WriteToKinesis [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 12:47:17 UTC, 1 replies.
- Re: [PR] [Python] Implement combiner deferred side inputs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 12:48:31 UTC, 12 replies.
- [PR] Try bumping up workflow timeouts [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/16 13:30:38 UTC, 4 replies.
- [PR] Fix Java8 tests to have gradle run on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/16 14:02:46 UTC, 3 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow JavaVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 15:39:43 UTC, 3 replies.
- Re: [I] [Feature Request]: Add the job id to userAgentString for Spanner IO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/16 16:42:54 UTC, 0 replies.
- [PR] Temporarily move back to fnapi runner as default [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/16 17:28:30 UTC, 3 replies.
- [I] [Task]: Migrate Python SDK away from the google-apitools library [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/16 19:11:39 UTC, 1 replies.
- Re: [PR] WIP - fix Debezium xlang test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/16 19:30:25 UTC, 0 replies.
- Re: [PR] feat(yaml): Add BigTable write connector [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/16 22:04:12 UTC, 29 replies.
- Re: [PR] Another attempt to fix timestamp logical type. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/17 01:01:54 UTC, 1 replies.
- [PR] Update CI.md [beam] - posted by "GautamGottipati (via GitHub)" <gi...@apache.org> on 2025/07/17 01:35:42 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.73.0 to 1.74.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 04:37:54 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.241.0 to 0.242.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 04:38:04 UTC, 3 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.37.0 to 0.38.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 04:38:16 UTC, 2 replies.
- [PR] Remove redundant Useful links panel [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/17 11:53:48 UTC, 2 replies.
- [I] [Bug]: YAML provider fails on Windows due to 'which' command not available [beam] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/07/17 12:02:29 UTC, 3 replies.
- [PR] Fix #[35617] Windows compatibility for YAML JavaJarProvider [beam] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/07/17 12:26:41 UTC, 4 replies.
- Re: [I] [Task]: Modernize Protos to Editions, with minimal SDK code changes due to code generation. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 12:47:03 UTC, 1 replies.
- Re: [I] [Feature Request]: Support ProcessingTime Timer in Spark Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 12:47:04 UTC, 2 replies.
- [PR] Fix Java version test for Legacy Dataflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/17 13:57:15 UTC, 5 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to specify a partition spec when creating tables [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/17 14:42:26 UTC, 0 replies.
- [PR] Actually bump Avro to 1.11.4 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/17 16:11:20 UTC, 5 replies.
- Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/17 16:13:02 UTC, 0 replies.
- Re: [PR] Extend Schema Registry Support on Managed Kafka I/O to Google's Managed Schema Registry Solution [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/07/17 17:27:14 UTC, 4 replies.
- [PR] Reenable prism as default [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/17 18:24:55 UTC, 5 replies.
- [PR] Revert "Avoid unreasonably long stage names for @ptransform_fn." [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/17 21:37:35 UTC, 2 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 22:14:09 UTC, 1 replies.
- [PR] build: update gradle wrapper from 8.4 to 8.5 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/17 22:14:36 UTC, 3 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 00:50:17 UTC, 3 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 00:50:20 UTC, 5 replies.
- [I] [Bug]: BigqueryIO - can't insert data to bigquery table which's field name start with number [beam] - posted by "ZwxwZ (via GitHub)" <gi...@apache.org> on 2025/07/18 03:56:08 UTC, 5 replies.
- [PR] Bump distlib from 0.3.7 to 0.4.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 04:47:55 UTC, 6 replies.
- [I] [Feature Request]: Support Java 25 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/18 07:01:25 UTC, 0 replies.
- [PR] Update Java SDK Roadmap on website [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/18 07:04:22 UTC, 5 replies.
- Re: [I] [Bug]: Avro GenericRecord to Row conversion does not support some logical types and any custom conversions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 12:47:16 UTC, 1 replies.
- Re: [I] [Failing Test]: TypeError for EncodedFIle in Python SDF [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 12:47:19 UTC, 0 replies.
- Re: [I] [Failing Test]: Namespace error for prism_runner in Python STD [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 12:47:21 UTC, 0 replies.
- Re: [I] [Failing Test]: ValueError in yaml for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 12:47:22 UTC, 1 replies.
- Re: [I] [Failing Test]: portable_runner_test in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 12:47:24 UTC, 1 replies.
- [PR] Use bqms-1.6.1-1.0.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/18 13:58:52 UTC, 5 replies.
- [PR] Bump golang.org/x/oauth2 from 0.12.0 to 0.27.0 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 17:55:56 UTC, 3 replies.
- [PR] handle flexible BigQuery column names [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2025/07/18 18:28:34 UTC, 5 replies.
- [PR] Bump golang.org/x/oauth2 from 0.24.0 to 0.27.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 18:37:24 UTC, 2 replies.
- Re: [I] [Feature Request]: Support for BigTable from YAML [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/18 21:41:19 UTC, 0 replies.
- [PR] [Java Harness] Improve caching measurements of overhead for cache objects. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/18 21:46:36 UTC, 6 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/18 23:09:05 UTC, 1 replies.
- Re: [PR] Cloudpickle deterministic [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/19 12:46:34 UTC, 2 replies.
- Re: [I] [Feature Request]: Managed transforms should extract the config provided as a YAML file and store in the pipeline proto [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/19 12:46:39 UTC, 0 replies.
- Re: [I] [Task]: Support non-ascii BigQuery field name for BigQueryIO STORAGE_WRITE_API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/19 12:46:41 UTC, 3 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/19 15:37:36 UTC, 3 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 03:58:08 UTC, 2 replies.
- Re: [PR] Add section to README describing PCollections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 12:46:35 UTC, 2 replies.
- Re: [I] [Bug]: Managed IO of Iceberg appends NULL / Unprintable characters for string type columns. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 12:46:40 UTC, 0 replies.
- Re: [I] [Task]: Add Python documentation for BQ Storage API pipeline options [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 12:46:47 UTC, 0 replies.
- Re: [PR] build: update gradle wrapper from 8.4 to 8.14.3 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/21 01:42:59 UTC, 0 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 7.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 05:46:52 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.17 to 1.29.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 05:47:05 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 05:50:59 UTC, 3 replies.
- [I] > # :wave: Welcome to GitHub Learning Lab's "Introduction to GitHub" [beam] - posted by "Balmasexy (via GitHub)" <gi...@apache.org> on 2025/07/21 07:40:28 UTC, 0 replies.
- [I] [Task]: Polish user experience for Beam SQL with Iceberg tables [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/21 12:37:32 UTC, 0 replies.
- Re: [PR] [Gradle] Clean up DataflowRunner's Java distroless container image build tasks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 12:47:07 UTC, 2 replies.
- Re: [I] [Bug]: BQ TableRow does not accept column named 'f' [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 12:47:20 UTC, 2 replies.
- Re: [I] [Feature Request]: Update Python JDBC write transforms to support configuring the batch size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 12:47:23 UTC, 1 replies.
- [PR] Fix PostCommit Python Xlang IO Dataflow job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/21 16:03:35 UTC, 4 replies.
- [PR] Fix typo [beam] - posted by "mvhensbergen (via GitHub)" <gi...@apache.org> on 2025/07/21 17:51:22 UTC, 2 replies.
- [PR] Dont fail pipeline on failed stat [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/21 18:40:02 UTC, 2 replies.
- [PR] [Beam SQL] Support DATABASE concept in Beam SQL, with implementation for Iceberg [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/07/21 18:55:12 UTC, 8 replies.
- [PR] Use unvendored calcite [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/21 19:03:38 UTC, 2 replies.
- [PR] Exclude META-INF/maven in expansion services [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/21 19:45:41 UTC, 5 replies.
- [PR] Introduce Schema Registry Functionality to Managed KafkaIO Write. [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/07/21 20:39:18 UTC, 0 replies.
- [PR] Include WaitOn in wildcard imports [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/21 20:45:00 UTC, 1 replies.
- [I] [Task]: Document WaitOn / WaitOn transforms in Beam Transform catalog [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/21 20:56:37 UTC, 2 replies.
- [PR] Add documentation for Wait.On and WaitOn transforms [beam] - posted by "dizzydroid (via GitHub)" <gi...@apache.org> on 2025/07/21 21:50:15 UTC, 18 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/07/21 22:15:19 UTC, 1 replies.
- [PR] Add Example for Iceberg REST Catalog CDC [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/07/21 22:55:19 UTC, 12 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 00:50:19 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.84.0 to 1.84.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 04:31:28 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.2.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 04:46:05 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 7.2.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 04:46:16 UTC, 1 replies.
- Re: [I] [Bug]: BigTable client "One or more TimeSeries could not be written" Java 2.65.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/22 05:54:59 UTC, 1 replies.
- [PR] Fix IcebergIO Integration Tests job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/22 07:32:19 UTC, 3 replies.
- Re: [I] [Bug]: BigQuery failures logged as warning even when the rows won't be retried [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/22 11:49:06 UTC, 0 replies.
- [PR] Bump form-data from 4.0.3 to 4.0.4 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 12:46:05 UTC, 2 replies.
- Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 12:47:07 UTC, 2 replies.
- Re: [I] [Bug]: SpannerIO ExecuteStreamingRead timeout not being set [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 12:47:15 UTC, 1 replies.
- Re: [I] [Feature Request]: Managed IO connector for Apache Iceberg to allow users to define file size for writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 12:47:17 UTC, 1 replies.
- Re: [I] [Feature Request]: {BigQuery IO Iceberg} - Allow users to run streaming reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/22 12:47:18 UTC, 1 replies.
- Re: [I] [Bug]: JDBC javasdk_date:v1 decode error [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2025/07/22 13:11:08 UTC, 5 replies.
- [PR] sdks/python/scripts: support pytest user markers [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/22 13:34:06 UTC, 5 replies.
- [PR] Add support for lambda name pickling. [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2025/07/22 17:57:22 UTC, 7 replies.
- [PR] #30760 fix dicomio tag mismatch [beam] - posted by "A1K28 (via GitHub)" <gi...@apache.org> on 2025/07/22 19:24:30 UTC, 1 replies.
- [PR] fix dicomio tag mismatch (#30760) [beam] - posted by "A1K28 (via GitHub)" <gi...@apache.org> on 2025/07/22 21:16:07 UTC, 4 replies.
- [PR] Fix jdbc logical type issues when running a yaml pipeline. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/22 21:34:44 UTC, 4 replies.
- Re: [I] Side inputs not working in CombineGlobally [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/22 21:43:30 UTC, 1 replies.
- [PR] Adds First Class Container Support for Beam Swift [beam-swift] - posted by "byronellis (via GitHub)" <gi...@apache.org> on 2025/07/22 23:23:19 UTC, 6 replies.
- [PR] vendor calcite 1.40 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/23 02:35:20 UTC, 5 replies.
- [PR] Remove ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/23 02:54:29 UTC, 4 replies.
- [PR] Bump google.golang.org/api from 0.241.0 to 0.243.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 04:59:45 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.73.0 to 1.74.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 04:59:53 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.84 to 1.17.85 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 05:00:05 UTC, 3 replies.
- Re: [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/07/23 06:38:28 UTC, 0 replies.
- Re: [PR] use WindmillChannelFactory to control what types of channels to generate [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 12:47:07 UTC, 2 replies.
- Re: [I] [Task]: Remove powermock dependency [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 12:47:09 UTC, 0 replies.
- Re: [PR] Enable timeout setting for Python TestPipeline (#29646) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 12:47:15 UTC, 2 replies.
- Re: [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 12:47:20 UTC, 1 replies.
- Re: [I] [Feature Request]: Managed IO connector for Apache Iceberg to offer dynamically handling schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 12:47:22 UTC, 1 replies.
- [I] [Bug]: YAML Flatten incorrectly drops fields when input PCollections' schema are different [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/23 13:12:23 UTC, 10 replies.
- [I] [Bug]: Yaml writeToBigQuery - java.lang.IllegalArgumentException: Unexpected type_info: TYPEINFO_NOT_SET [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/23 16:51:05 UTC, 0 replies.
- [PR] Allow setting BatchSize and MaxBufferingDuration in JDBCIO's WriteWithResults [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/23 17:38:06 UTC, 4 replies.
- [PR] Update Vertex AI embedding handlers to use RemoteModelHandler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/23 17:54:04 UTC, 3 replies.
- [PR] Fix vendor Calcite 1.40 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/23 19:24:57 UTC, 3 replies.
- [PR] feat(yaml): add schema unification for Flatten transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/23 21:28:32 UTC, 16 replies.
- [PR] [Java] Further simplify MoreFutures usage in case it is cause of issues with ForkJoin pool stuckness [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/23 23:13:45 UTC, 3 replies.
- [I] The LoadTests Java PubsubIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/24 03:53:36 UTC, 8 replies.
- Re: [I] [Task]: Manage Infra privileges via Infra-as-code [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/24 12:47:15 UTC, 3 replies.
- [PR] Allow setting BatchSize and MaxBufferingDuration in JDBC IO WriteWith… [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/24 12:55:02 UTC, 0 replies.
- Re: [PR] [release-2.67] Cherrypick #35669 onto the release branch [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/24 12:56:38 UTC, 2 replies.
- [PR] feat(yaml): add schema validation for flatten transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/24 13:55:38 UTC, 5 replies.
- [PR] Reflect that my previous PR was cherrypicked into 2.67 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/07/24 14:26:10 UTC, 4 replies.
- [PR] [DO NOT MERGE] Prototype Vertex MultiModal embedding handler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/24 15:20:30 UTC, 0 replies.
- [PR] docs: update known issues in CHANGES.md with YAML Flatten bug [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/24 17:22:20 UTC, 1 replies.
- [PR] Remove tox dependency [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/24 20:30:19 UTC, 5 replies.
- [PR] Remove tox dependency (backup) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/24 20:36:35 UTC, 2 replies.
- [PR] docs: update known issues in CHANGES.md with YAML Flatten bug (#35678) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/24 20:41:41 UTC, 3 replies.
- [PR] Bump github.com/aws/smithy-go from 1.22.4 to 1.22.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 04:22:33 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.55.0 to 1.56.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 04:22:45 UTC, 1 replies.
- [PR] Upgrade Errorprone to 2.31.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/25 04:31:32 UTC, 1 replies.
- [I] Log Spam - Auto Commit has been disabled [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2025/07/25 07:15:46 UTC, 0 replies.
- Re: [PR] feat(WIP): Qdrant Search Handler [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 09:52:10 UTC, 0 replies.
- [PR] Cherrypick: Remove tox dependency [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/25 11:59:47 UTC, 5 replies.
- Re: [PR] Fix Docker build error by adding fallback for python3.12-distutils [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 12:46:57 UTC, 0 replies.
- Re: [I] [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 12:47:13 UTC, 0 replies.
- Re: [PR] Bump github.com/go-sql-driver/mysql from 1.9.2 to 1.9.3 in /sdks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/25 13:39:02 UTC, 3 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.2.1 to 2.3 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/25 13:39:23 UTC, 2 replies.
- Re: [I] JUnit5 support [beam] - posted by "chennu2020 (via GitHub)" <gi...@apache.org> on 2025/07/25 14:26:48 UTC, 0 replies.
- [PR] JUnit5 support [beam] - posted by "chennu2020 (via GitHub)" <gi...@apache.org> on 2025/07/25 14:28:37 UTC, 3 replies.
- [PR] Update README.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/25 14:30:33 UTC, 3 replies.
- [PR] Cloudsql pg colab [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/25 15:42:19 UTC, 5 replies.
- [I] [Failing Test]: beam_PreCommit_Python_Dataframes (Run Python_Dataframes PreCommit 3.12) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/25 15:44:23 UTC, 2 replies.
- [PR] [yaml] - add nullable field test for readFromBigQuery and update create core logic [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/25 15:48:54 UTC, 29 replies.
- [I] [Bug]: YAML MLTransformer is not registering SentenceTransformerEmbeddings [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/25 15:52:09 UTC, 5 replies.
- [PR] Upgrade base image for dev-support docker image(Ubuntu 20.04 -> Ubuntu 24.04) [beam] - posted by "marblejenka (via GitHub)" <gi...@apache.org> on 2025/07/25 15:55:37 UTC, 7 replies.
- [PR] Cloudsql embeddings colab. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/25 16:14:40 UTC, 1 replies.
- Re: [PR] Cloudsql MySQL embeddings colab. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/25 16:14:58 UTC, 1 replies.
- [PR] Add BigTableRead connector and new feature implemented [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2025/07/25 17:12:12 UTC, 40 replies.
- [PR] Revert "Cloudsql pg colab" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/25 18:20:26 UTC, 3 replies.
- [PR] workflows: run ML tests requiring docker-in-docker environment on `ubuntu-latest` [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/25 19:45:36 UTC, 11 replies.
- [PR] Update beam_PostCommit_Python_Portable_Flink.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/25 20:10:20 UTC, 4 replies.
- [PR] Revert "Refactor: separate SplittableTruncateSizedRestrictions" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/25 20:50:20 UTC, 4 replies.
- [PR] Add Terraform configuration and IAM management scripts for GCP project [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/07/25 22:54:10 UTC, 10 replies.
- Re: [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/26 12:46:50 UTC, 0 replies.
- [I] [Failing Test]: :sdks:python:test-suites:portable:py39:flinkCompatibilityMatrixPROCESS falis [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/26 16:25:52 UTC, 0 replies.
- [PR] fix: use Strings.isNullOrEmpty for version string checks in KafkaIO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/26 22:27:32 UTC, 1 replies.
- [PR] Cachiman README.md [beam] - posted by "cachiman (via GitHub)" <gi...@apache.org> on 2025/07/27 00:00:38 UTC, 2 replies.
- Re: [PR] fix the version string checks in KafkaIO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/27 00:29:33 UTC, 1 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 01:25:03 UTC, 7 replies.
- [I] [Task]: Add Anomaly Detection PTransform to Beam [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/27 02:32:31 UTC, 0 replies.
- [I] [Task]: Stablize and improve Prism runner [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/07/27 02:47:53 UTC, 0 replies.
- [PR] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/27 11:21:55 UTC, 3 replies.
- Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:46:49 UTC, 0 replies.
- Re: [PR] [Java] Add Gauge Metric Extraction to DataflowMetrics [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:46:51 UTC, 0 replies.
- Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:46:52 UTC, 0 replies.
- Re: [I] [Bug]: SparkRunner reads input data twice when using FileIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:46:58 UTC, 1 replies.
- Re: [PR] init dummy file [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:46:59 UTC, 0 replies.
- Re: [I] [Bug]: Missing Type Implementations in parseDefaultExpression for ClickHouseIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/27 12:47:01 UTC, 1 replies.
- Re: [I] Support state API in Spark streaming mode. [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/07/28 03:51:52 UTC, 0 replies.
- Re: [PR] Migrate Vertex AI Model Handler to new base class [beam] - posted by "senim2 (via GitHub)" <gi...@apache.org> on 2025/07/28 10:32:46 UTC, 3 replies.
- Re: [PR] feat: Qdrant Search Handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 11:07:16 UTC, 1 replies.
- [PR] Fix PostCommit Python job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/28 11:44:11 UTC, 8 replies.
- [I] [Feature Request]: KafkaIO - redistribute by key [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/07/28 12:45:51 UTC, 0 replies.
- Re: [PR] Default getUseStorageApiConnectionPool to true instead of false [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 12:47:09 UTC, 0 replies.
- Re: [I] [Feature Request]: Request to use BASIC enum when calling tables.get() in BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 12:47:16 UTC, 2 replies.
- Re: [I] [Bug]: Periodic Impulse with Fixed Window Stalls When Used as a Side Input in a Session Window Pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 12:47:18 UTC, 0 replies.
- Re: [I] [Bug]: SDK 2.59.0 Java SpannerIO ChangeStream Can't Use the same metadata database for multiple pipelines [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 12:47:31 UTC, 0 replies.
- [I] [Feature Request]: Port ReadAllFromBigQuery from Python to Java [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/07/28 12:53:51 UTC, 0 replies.
- [PR] Bump Dataflow container version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/28 13:34:41 UTC, 1 replies.
- [PR] [Release-2.67] Revert "Refactor: separate SplittableTruncateSizedRestrictions" (#35700) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/28 14:38:33 UTC, 2 replies.
- [PR] Reapply "Refactor: separate SplittableTruncateSizedRestrictions" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/28 14:59:10 UTC, 13 replies.
- Re: [PR] [Java Harness] Improve caching performance and measure overhead for cache internals. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/07/28 16:08:18 UTC, 10 replies.
- [PR] [yaml] Fix ml embeddings issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/28 16:24:07 UTC, 20 replies.
- [PR] YAML MLTransform import more transforms [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/28 16:48:55 UTC, 3 replies.
- [I] [Bug]: [Python] Python cache directory leaks cached packages between pipeline runs [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/28 16:56:50 UTC, 0 replies.
- Re: [I] [Task]: Deprecate ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/28 19:32:15 UTC, 0 replies.
- [PR] Use vendor calcite [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/28 20:08:43 UTC, 0 replies.
- Re: [PR] Use vendored calcite 1.40 [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 20:14:13 UTC, 6 replies.
- [I] [Bug]: YAML Test with Join Transform [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/28 20:37:23 UTC, 1 replies.
- [I] [Bug]: YAML Test command flag [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/28 20:42:34 UTC, 3 replies.
- [PR] YAML Test CLI Flag Fix [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/07/28 20:54:17 UTC, 3 replies.
- [PR] Metastore example [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/07/28 21:34:56 UTC, 6 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.84 to 1.18.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 06:03:16 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.84.1 to 1.85.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 06:43:03 UTC, 3 replies.
- Re: [PR] Update GitHub Actions to run Python 3.13 Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 12:47:10 UTC, 0 replies.
- Re: [PR] Introduce a helper to reduce logs in frequently invoked codepaths. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 12:47:12 UTC, 0 replies.
- Re: [I] [Feature Request]: Cache the BigQuery table definition instead of calling tables.get() from every worker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 12:47:20 UTC, 1 replies.
- [PR] Pass update compat through as_deterministic_coder. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/07/29 13:09:04 UTC, 1 replies.
- [PR] add note on spammy logs and mitigation [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/07/29 16:23:22 UTC, 3 replies.
- [PR] Fix(df): Remove obsolete version check in doctest checker & fix rate limit hits [beam] - posted by "A1K28 (via GitHub)" <gi...@apache.org> on 2025/07/29 16:24:30 UTC, 3 replies.
- [PR] feat(yaml): add a simple schema unification for Flatten transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/07/29 17:00:27 UTC, 5 replies.
- [PR] adapt to new np outputs (#35691) [beam] - posted by "A1K28 (via GitHub)" <gi...@apache.org> on 2025/07/29 17:10:50 UTC, 18 replies.
- Re: [I] Update vendored calcite to eliminate vulnerability from shaded log4j:1.2.17 and protobuf-java:3.19.2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/29 17:38:32 UTC, 0 replies.
- [PR] Controlling reshuffle in `FileIO.MatchAll` [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2025/07/29 18:56:18 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 28.3.2+incompatible to 28.3.3+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 20:02:11 UTC, 1 replies.
- [PR] Update Java beam-master container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/29 22:34:56 UTC, 6 replies.
- [PR] sdks/python/scripts: fix posargs for `run_pytest.sh` [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/30 01:44:52 UTC, 27 replies.
- [PR] .github: remove `ubuntu-latest` environment temporary from `beam_PreCommit_Python_ML` and `beam_PostCommit_Python` to make CI green again [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/30 04:01:44 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.84 to 1.18.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 04:24:37 UTC, 3 replies.
- [I] [Bug]: Beam SQL cannot work with array[DATETIME] field [beam] - posted by "vampire-hunter-lincoln (via GitHub)" <gi...@apache.org> on 2025/07/30 04:35:22 UTC, 0 replies.
- [PR] Adding time partitioning support for python storage write api [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/07/30 07:22:12 UTC, 3 replies.
- Re: [I] [Feature Request]: Add support to write record headers in `WriteToKafka` in python SDK [beam] - posted by "jboudouar-onclusive (via GitHub)" <gi...@apache.org> on 2025/07/30 07:55:49 UTC, 1 replies.
- [I] [Bug]: xlang JDBC - No logical type registered for URN 'beam:logical_type:javasdk:v1' [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2025/07/30 09:58:38 UTC, 0 replies.
- Re: [PR] [BEAM-34076] Implement TTL-based caching for BigQuery table definitions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:47:20 UTC, 0 replies.
- Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:47:25 UTC, 1 replies.
- Re: [I] [Bug]: NumPy > 2.x.x is not compatible with sklearn. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:47:30 UTC, 1 replies.
- Re: [I] [Feature Request][Go SDK]: Make lull logging say the Go name of the transform, not just the ID. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:47:34 UTC, 1 replies.
- Re: [I] [Bug]: Apache Beam FlinkRunner does not process Kafka messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:47:35 UTC, 1 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 12:48:04 UTC, 1 replies.
- Re: [I] Use date logical type when converting Avro date to Beam field [beam] - posted by "therealdorin (via GitHub)" <gi...@apache.org> on 2025/07/30 13:52:58 UTC, 0 replies.
- [PR] Element metadata in windowed value for offset deduplication [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/07/30 14:47:31 UTC, 4 replies.
- [PR] sdks/python/scripts: capture `(...)` pytest marker group [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/07/30 15:08:35 UTC, 5 replies.
- [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 15:40:21 UTC, 1 replies.
- [I] [Feature Request]: YAML - add optional output schema and error handling to transforms [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/30 16:14:23 UTC, 0 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/07/30 16:40:10 UTC, 0 replies.
- Re: [I] [Bug]: xlang JDBC (versions 2.65.0, 2.66.65)- No logical type registered for URN 'beam:logical_type:javasdk:v1' [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/30 16:50:12 UTC, 0 replies.
- [PR] Fix BeamSQL CalcRel DATETIME expression [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/07/30 17:19:06 UTC, 5 replies.
- [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] - posted by "yquaziii (via GitHub)" <gi...@apache.org> on 2025/07/30 18:52:55 UTC, 5 replies.
- Re: [PR] Adds support for updating Schema state fields. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/07/30 19:57:44 UTC, 1 replies.
- [PR] precommit python fix - fix _transform_constructors issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/30 21:29:49 UTC, 15 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "jschroed5 (via GitHub)" <gi...@apache.org> on 2025/07/31 00:12:47 UTC, 0 replies.
- [I] [Feature Request]: Add a Github action that triggers managed transform config generation task [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/07/31 01:24:43 UTC, 2 replies.
- [PR] chore(JdbcIO): Lower log level for harmless SchemaCoder inference failure in JdbcIO [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/07/31 01:34:26 UTC, 4 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 03:56:41 UTC, 4 replies.
- [I] The PreCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 03:56:44 UTC, 3 replies.
- [I] The Java Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 03:56:48 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.84 to 1.18.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 04:42:24 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.84.1 to 1.85.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 04:43:40 UTC, 1 replies.
- [PR] Add workflow dispatch for PreCommit Portable Python and PreCommit Prism Python jobs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/31 07:06:07 UTC, 4 replies.
- [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 09:41:37 UTC, 4 replies.
- [PR] [Cherrypick] Fix PostCommit Python job (#35709) [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/31 11:46:58 UTC, 2 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 12:47:58 UTC, 1 replies.
- [PR] Fix race conditions in apache.beam.sdks.schemas [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/31 16:05:52 UTC, 10 replies.
- [PR] Revert #35715 YAML and Python ML [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/07/31 17:19:33 UTC, 2 replies.
- [PR] implement main pcollection as default to dooutputstuple [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/07/31 17:28:06 UTC, 2 replies.
- [I] [Bug]: Java BigQueryIO: Intermittent OffsetOutOfRange and SchemaMismatchedException when multiple BigQueryIO streams operate in a single job, potentially due to shared state. [beam] - posted by "aprochko (via GitHub)" <gi...@apache.org> on 2025/07/31 17:38:00 UTC, 9 replies.
- [PR] [Yaml] - fix ml embeddings issue round2 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/07/31 17:48:39 UTC, 4 replies.
- [PR] Fix race condition in FnApiDoFnRunner.java [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/07/31 19:48:29 UTC, 2 replies.
- [PR] Fix: Dedup input list of Topics/TopicPartitions in KafkaIO [beam] - posted by "Dippatel98 (via GitHub)" <gi...@apache.org> on 2025/07/31 20:32:44 UTC, 3 replies.
- [I] The PostCommit XVR Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 21:37:59 UTC, 1 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 21:38:02 UTC, 1 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 21:38:05 UTC, 1 replies.