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

---

- Re: [I] [Bug]: IcebergIO cannot write Timestamp columns [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/08 14:37:06 UTC, 1 replies.
- Re: [PR] Add support for global sequence processing to the "ordered" extension in Java SDK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/08 14:40:40 UTC, 20 replies.
- Re: [PR] Support Protobuf 5.x [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/08 14:53:53 UTC, 2 replies.
- Re: [PR] Revert "Set setFailIfPoolExhausted in SessionPoolOptions for SpannerA… [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 14:54:43 UTC, 4 replies.
- Re: [PR] Enforce a size limit on StringSetData [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 14:56:44 UTC, 3 replies.
- [I] Apache Beam Java Lib and ANTLR [beam] - posted by "pinfrederic (via GitHub)" <gi...@apache.org> on 2024/10/08 14:58:20 UTC, 0 replies.
- Re: [PR] Add SessionPoolOptions.setFailIfPoolExhausted in SpannerAccessor [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/10/08 16:01:36 UTC, 0 replies.
- Re: [PR] [Managed Iceberg] Add support for TIMESTAMP, TIME, and DATE types [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/08 16:06:09 UTC, 27 replies.
- [I] [Bug]: Regression: spannerio RESOURCE_EXHAUSTED: No session available in the pool [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/10/08 16:07:35 UTC, 5 replies.
- [PR] Add check to avro and kafka compatibility tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 16:10:53 UTC, 4 replies.
- [I] [Bug]: kafka compatibility integration tests not testing with intended kafka client version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 16:15:33 UTC, 1 replies.
- Re: [I] handling Date type in HCatToRow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/08 16:26:06 UTC, 3 replies.
- [PR] Add Application Default Authentication Support for KafkaIO when Using GMK [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2024/10/08 16:26:23 UTC, 0 replies.
- Re: [PR] [Managed Iceberg] Make manifest file writes and commits more efficient [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/08 16:56:02 UTC, 6 replies.
- Re: [PR] allow numpy 2.1.x [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/08 16:58:17 UTC, 8 replies.
- Re: [I] [Feature Request]: Protobuf 5+ support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/08 17:03:47 UTC, 0 replies.
- Re: [PR] Bump cloud.google.com/go/storage from 1.43.0 to 1.44.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/08 17:10:00 UTC, 0 replies.
- Re: [PR] Bump golang.org/x/net from 0.29.0 to 0.30.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/08 17:10:38 UTC, 0 replies.
- Re: [PR] Bump golang.org/x/sys from 0.25.0 to 0.26.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/08 17:11:36 UTC, 1 replies.
- Re: [PR] Report File Lineage on directory [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/10/08 17:27:28 UTC, 3 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/08 17:28:24 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/08 17:28:41 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/08 17:28:52 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/08 17:29:19 UTC, 0 replies.
- Re: [I] [CsvIO]: CsvIOParse::expand implementation and class completion [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/08 17:29:24 UTC, 0 replies.
- Re: [I] [Task]: Implement CsvIO.Read [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/08 17:29:50 UTC, 0 replies.
- [PR] Disable blob level Lineage metrics for FileSystems [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 17:40:53 UTC, 2 replies.
- Re: [PR] [Bug] fix fillna function on a single column fail [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/08 18:29:42 UTC, 5 replies.
- [I] [Bug]: ByteBuddy doesn't do well with Map [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/08 19:11:07 UTC, 6 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.27.41 to 1.27.42 in /sdks [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/08 19:32:41 UTC, 0 replies.
- [PR] Revert "Set setFailIfPoolExhausted in SessionPoolOptions for SpannerAccessor" [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/10/08 19:42:59 UTC, 3 replies.
- Re: [PR] [yaml] Add enrichment transform to Beam YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/08 19:59:00 UTC, 2 replies.
- Re: [PR] Kafka poll interval [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/08 20:28:15 UTC, 1 replies.
- Re: [PR] Integrate direct path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/08 20:31:31 UTC, 27 replies.
- Re: [PR] Support ordered list states in python sdk and fnapi runner [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/08 20:42:33 UTC, 5 replies.
- Re: [PR] Invoke teardown when DoFn throws in portable runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 21:26:42 UTC, 3 replies.
- [PR] Force kafka 3.1.2 for expansion-service jar [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/08 21:56:04 UTC, 5 replies.
- Re: [PR] [Managed Iceberg] Create tables if needed [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/08 22:06:43 UTC, 0 replies.
- [I] [Failing Test]: testKafkaIOSDFReadWithErrorHandler failing on kafka-client 2.0-2.2 cannot serialize ConsumerRecords [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 22:32:52 UTC, 0 replies.
- [PR] fix nested schema inference [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/10/08 22:35:56 UTC, 5 replies.
- Re: [PR] fix: generate random index name for change streams [beam] - posted by "thiagotnunes (via GitHub)" <gi...@apache.org> on 2024/10/08 23:07:27 UTC, 22 replies.
- Re: [I] [Task]: Upgrade numpy to 2.x. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/08 23:13:51 UTC, 1 replies.
- Re: [I] [Bug]: Slowness and/or broken metrics visualization when Lineage metrics is large [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 23:31:14 UTC, 3 replies.
- [PR] [Release-2.60.0] Cherry-pick #32662 into the release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 23:55:25 UTC, 2 replies.
- [PR] [Release-2.60.0] Cherry pick #32650 into the release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 23:55:59 UTC, 3 replies.
- [PR] [Release-2.60.0] Cherry-pick #32703 into the release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/08 23:57:57 UTC, 3 replies.
- [I] [Bug]: Apache Beam FlinkRunner does not process Kafka messages [beam] - posted by "Jerryporter (via GitHub)" <gi...@apache.org> on 2024/10/09 02:17:54 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.27.42 to 1.27.43 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 04:55:34 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.1 to 1.32.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 04:57:05 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.40 to 1.17.41 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 04:58:37 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.28 to 1.17.30 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 05:00:28 UTC, 3 replies.
- Re: [I] [Bug]: Dataflow Runner V2 does not support BigueryIO STORAGE_WRITE_API when configured withAutoSharding [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/09 08:28:25 UTC, 1 replies.
- Re: [I] Beam Core IO: WriteFiles stuck [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/09 08:29:18 UTC, 0 replies.
- [I] [Bug]: Java SDK blocked due to FnApi data stream multiplexing and ProcessBundleHandler exception handling [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/09 08:38:04 UTC, 0 replies.
- [PR] [Dataflow Streaming] Remove call to Thread.setName and track thread name inside Work. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/10/09 09:03:55 UTC, 5 replies.
- Re: [PR] feat: add pubsub topic validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 12:15:15 UTC, 4 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 12:15:21 UTC, 5 replies.
- Re: [PR] Bump org.sonarqube from 3.0 to 5.1.0.4882 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/09 12:45:47 UTC, 3 replies.
- Re: [PR] fix: skip close on bundles [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 13:16:37 UTC, 1 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 13:58:30 UTC, 5 replies.
- Re: [I] [Bug]: In Beam Dataframe api, the fillna operation doesn't work when applied on individual columns [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/09 14:01:45 UTC, 0 replies.
- [PR] Fix assert in TextIOIT [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 14:08:53 UTC, 3 replies.
- [I] [Feature Request]: SolaceIO - publishing to dynamic topic (like TopicNameMapper in JmsIO) [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/10/09 14:21:03 UTC, 0 replies.
- Re: [PR] Bump to Dataproc 2.2 and Flink 1.17 for load tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 14:55:30 UTC, 0 replies.
- [PR] Pin protobuf version for TF dependency tests [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/09 15:41:23 UTC, 9 replies.
- Re: [PR] Handle Date type in HCatToRow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 15:49:21 UTC, 4 replies.
- [I] [Feature Request][Go SDK]: Make lull logging say the Go name of the transform, not just the I'd. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/09 17:31:08 UTC, 0 replies.
- Re: [I] The PostCommit Java PVR Spark Batch job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 17:43:11 UTC, 5 replies.
- [I] [Task]: Utilize Managed Service for Apache Kafka resources for testing purposes. [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2024/10/09 18:01:57 UTC, 0 replies.
- Re: [PR] fix schema inference inside parameterized types [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/10/09 18:09:53 UTC, 0 replies.
- [PR] Add Application Default Authentication as an Option for Kafka Clients in KafkaIO When Using Managed Service for Apache Kafka [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2024/10/09 18:20:09 UTC, 3 replies.
- [PR] Attempt to fix PostCommit PVR Spark [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 19:07:13 UTC, 5 replies.
- [PR] fix: workaround BigtableIO.read() recreating the client for every split [beam] - posted by "igorbernstein2 (via GitHub)" <gi...@apache.org> on 2024/10/09 19:23:43 UTC, 0 replies.
- Re: [I] [Feature Request]: IcebergIO should support table create-on-write [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/09 20:37:39 UTC, 1 replies.
- Re: [PR] Try deepcopy combine_fn and fallback to pickling if TypeError. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/09 22:02:30 UTC, 0 replies.
- [PR] Fix build_wheels and build_release_candidate [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/09 22:23:11 UTC, 9 replies.
- [I] [Bug]: Javadoc generation fails on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/10 01:44:11 UTC, 1 replies.
- [I] [Bug]: Processing time timers are fired after the window closed in Dataflow [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/10/10 02:27:35 UTC, 0 replies.
- [I] [Bug]: PythonDocs fail to build after moving to Python3.9 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/10 03:05:53 UTC, 8 replies.
- [I] [Bug]: beam_Release_Python_NightlySnapshot workflow broken [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/10 04:29:24 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.28 to 1.17.31 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/10 04:56:04 UTC, 3 replies.
- [I] [Feature Request]: Python sdk docker images released in tandem with pypi [beam] - posted by "RobMcKiernan (via GitHub)" <gi...@apache.org> on 2024/10/10 09:57:18 UTC, 12 replies.
- [PR] #28096 go get updated to go install issue [beam] - posted by "SidheshwarSarangal (via GitHub)" <gi...@apache.org> on 2024/10/10 10:48:33 UTC, 1 replies.
- [I] [Bug][Prism]: Unsupported feature Create/MaybeReshuffle (Python SDK) [beam] - posted by "victorrgez (via GitHub)" <gi...@apache.org> on 2024/10/10 10:50:26 UTC, 1 replies.
- Re: [I] [RRIO]: Create and update website examples using RequestResponseIO using the Python SDK [beam] - posted by "winstonwilliamsiii (via GitHub)" <gi...@apache.org> on 2024/10/10 11:05:45 UTC, 0 replies.
- Re: [I] The StressTests Java BigQueryIO job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/10/10 11:23:31 UTC, 1 replies.
- [PR] Efgh [beam] - posted by "UttamKumarReddy (via GitHub)" <gi...@apache.org> on 2024/10/10 11:26:01 UTC, 1 replies.
- [PR] [blog] - Beam YAML protobuf blogpost [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/10/10 14:55:18 UTC, 10 replies.
- [PR] Attempt to fix permred test. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/10 15:02:52 UTC, 0 replies.
- [PR] Fix the FlinkRunner for Dataproc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/10 15:10:43 UTC, 3 replies.
- [PR] 2.60.0 Release blog post [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/10 15:17:29 UTC, 3 replies.
- Re: [PR] Add support for Read with Meatadata in `MqttIO` [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/10 15:28:20 UTC, 3 replies.
- Re: [I] [Feature Request]: Add Topic Information to `MqttIO` Return Value [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/10 15:28:30 UTC, 0 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/10 15:30:47 UTC, 3 replies.
- Re: [PR] Attempt to fix the permred "PostCommit Java IO Performance Tests" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/10 15:35:46 UTC, 1 replies.
- [PR] Polish .with_exception_handling docstring [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/10/10 16:00:45 UTC, 4 replies.
- [PR] Remove beam logging in playground for Python [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/10/10 16:08:00 UTC, 19 replies.
- [PR] Attempt to fix the permred "PostCommit Java IO Performance Tests - another attempt [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/10 16:20:03 UTC, 2 replies.
- Re: [PR] jobid: 2024-10-03_14_45_58-17634551863038429586 with map global per w… [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/10/10 16:37:55 UTC, 0 replies.
- Re: [PR] [DRAFT] fix new golang repo versioning and add python 3.12 venv to install th… [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/10/10 17:00:20 UTC, 0 replies.
- [PR] Checky-pick https://github.com/apache/beam/pull/32737/ [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/10 17:41:26 UTC, 3 replies.
- [I] [Bug]: when submission_environment_dependencies.txt somehow does not exist, the error should be ignored [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/10 17:49:52 UTC, 6 replies.
- [PR] Fix the snapshot publishing script [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/10 19:13:42 UTC, 6 replies.
- [PR] fixed the tox and pyproject settings for numpy 2 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/10 19:40:23 UTC, 0 replies.
- Re: [PR] Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/10 19:44:13 UTC, 3 replies.
- [I] [Bug]: IceberIO - Write performance issues [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/10 20:03:10 UTC, 0 replies.
- Re: [PR] Fixed the tox and pyproject settings for numpy 2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/10 20:35:28 UTC, 2 replies.
- [PR] Fix Pydoc Precommit [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/10 20:36:15 UTC, 5 replies.
- Re: [I] [Bug]: IcebergIO - Write performance issues [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/11 00:53:42 UTC, 22 replies.
- Re: [PR] Reduce setDefaultPipelineOptions call on creating TestPipelineOptions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 03:33:07 UTC, 1 replies.
- [PR] adding example of writting to kafka [beam] - posted by "paulhtremblay (via GitHub)" <gi...@apache.org> on 2024/10/11 03:39:47 UTC, 1 replies.
- Re: [PR] [Python] Managed Transforms API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/11 07:54:39 UTC, 8 replies.
- Re: [PR] [WIP] Add background thread and caching of consumers to Kafka SDF [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/10/11 08:47:36 UTC, 0 replies.
- Re: [PR] Support Map and Arrays of Maps in BQ for StorageWrites API for Beam Rows [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 12:14:09 UTC, 21 replies.
- Re: [PR] Bump com.gradle.develocity from 3.17.6 to 3.18.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 12:14:11 UTC, 3 replies.
- [PR] Fix more numpy 2 test issues [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/11 13:09:45 UTC, 2 replies.
- Re: [I] [Bug]: SolaceIO does not acknowledge messages [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/10/11 13:26:08 UTC, 1 replies.
- [PR] Fix docker search [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/11 13:46:57 UTC, 3 replies.
- [PR] disable remote cache [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 15:48:33 UTC, 0 replies.
- [PR] Do not fail the job when submission_environment_dependencies.txt cannot be loaded [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/11 16:45:56 UTC, 4 replies.
- Re: [PR] disable expansion service cache [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 16:50:57 UTC, 2 replies.
- Re: [PR] Bump snappy-java version to 1.1.10.4 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/11 17:24:20 UTC, 1 replies.
- [PR] Add 2.51->52 breaking incompatibility to CHANGES.md [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/11 17:27:26 UTC, 3 replies.
- [PR] Bump dompurify from 2.3.3 to 2.5.7 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 17:43:49 UTC, 3 replies.
- [PR] Enable ordered list state [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/10/11 18:16:40 UTC, 0 replies.
- [PR] Update the python deps caused by numpy 2.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/11 18:19:40 UTC, 16 replies.
- Re: [PR] vLLM model handler efficiency improvements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 18:39:12 UTC, 1 replies.
- [PR] Schema inference parameterized types [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/10/11 18:44:02 UTC, 16 replies.
- Re: [PR] Add ordered list state to python capabilities [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 19:34:47 UTC, 2 replies.
- [I] [Bug]: vendored jars leak proto [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 19:56:53 UTC, 3 replies.
- [PR] [Release-2.60.0] Cherry pick #32661 into the release branch [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/10/11 20:09:57 UTC, 5 replies.
- [PR] [Managed Iceberg] Use test file size property if exists [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/11 20:20:43 UTC, 0 replies.
- [PR] [Release 2.60.0] Cherry-pick #32725 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 20:21:59 UTC, 3 replies.
- [PR] [Release-2.60.0] cherry-pick #32747 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/11 20:37:42 UTC, 2 replies.
- Re: [PR] [Managed Iceberg] Use table file size property if exists [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/11 21:07:21 UTC, 0 replies.
- Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/11 21:42:09 UTC, 0 replies.
- [PR] Enable external callers to start a WindmillStream [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/12 01:28:39 UTC, 1 replies.
- Re: [PR] Add various utility meta-transforms to Beam. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/12 12:14:06 UTC, 7 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/12 15:33:50 UTC, 4 replies.
- [I] [Task]: fix `MqttIO` flaky test [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/13 04:37:27 UTC, 2 replies.
- [PR] Fix flaky mqtt test [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/13 05:26:12 UTC, 2 replies.
- Re: [PR] [prism] Remove the xlang cogbk test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/13 12:44:12 UTC, 1 replies.
- [I] SVN removed from GitHub ubuntu-latest causing build_release_candidate workflow failure [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/14 03:35:54 UTC, 1 replies.
- [PR] Usse ubuntu-22.04 for release candidate build for now [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/14 04:38:29 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.28 to 1.17.32 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 04:39:42 UTC, 2 replies.
- Re: [PR] make FieldValueTypeInformation creators take a TypeDescriptor parameter [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/10/14 10:37:57 UTC, 29 replies.
- Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 12:14:25 UTC, 3 replies.
- Re: [PR] Enable BigQuery CDC configuration for Python BigQuery sink [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/14 12:24:18 UTC, 9 replies.
- Re: [PR] Add random suffix to IT resource IDs to avoid collision [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 12:46:02 UTC, 2 replies.
- Re: [PR] Fix flaky test suite beam_PostCommit_XVR_Direct [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 12:46:07 UTC, 0 replies.
- Re: [PR] [yaml] Add UDF docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 12:46:08 UTC, 0 replies.
- Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/14 12:46:11 UTC, 0 replies.
- [PR] Proposal: Propagate gcs-connector options to GcsUtil [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/10/14 14:52:05 UTC, 11 replies.
- [PR] Bump avro, fix CVE-2024-47561 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/14 15:27:34 UTC, 0 replies.
- [PR] Revert disabled Gradle cache in #32751 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/14 16:04:49 UTC, 4 replies.
- [PR] Fix download artifact truncate page [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/14 18:28:50 UTC, 4 replies.
- [PR] Update pyproject.toml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/14 21:06:33 UTC, 10 replies.
- [PR] add shutdown and start mechanics to windmill streams [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/14 21:20:53 UTC, 128 replies.
- [PR] Simplify budget distribution logic and new worker metadata consumption [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/14 22:18:37 UTC, 34 replies.
- Re: [PR] Remove Python 3.8 Support from Apache Beam [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/14 22:39:13 UTC, 9 replies.
- [PR] Propogate field_descriptions to RowTypeConstraint [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/14 23:10:31 UTC, 3 replies.
- [PR] plumb backend worker token to work items [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/14 23:32:47 UTC, 2 replies.
- [PR] Integrate direct path with StreamingDataflowWorker code path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/14 23:58:37 UTC, 4 replies.
- [PR] track work before it gets queued/executed as it is awaiting a free thread for processing [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/15 00:35:32 UTC, 6 replies.
- [PR] Bigquery fixes [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/10/15 04:42:30 UTC, 6 replies.
- Re: [I] [Feature Request]: Iceberg Support for Python [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/15 08:10:46 UTC, 1 replies.
- [I] [Feature Request]: Provide the Python equivalent to Java's BigQueryIO `writeProtos` [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/10/15 08:59:59 UTC, 17 replies.
- Re: [PR] Fix tableExists() method [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/15 12:14:35 UTC, 3 replies.
- Re: [PR] Extract background poll thread from KafkaUnboundedReader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/15 12:46:03 UTC, 1 replies.
- [PR] Remove experiments guarding isolated channels enablement based on jobsettings [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/10/15 12:57:28 UTC, 4 replies.
- [PR] Fix Maybereshuffle [beam] - posted by "xliee (via GitHub)" <gi...@apache.org> on 2024/10/15 14:20:12 UTC, 1 replies.
- Re: [I] [Bug]: BigQuery streaming at-least-once job missing records [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/15 14:49:01 UTC, 0 replies.
- Re: [PR] Depend on non-shadow configuration of java core in schemaio expansion… [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/15 14:54:08 UTC, 0 replies.
- [PR] [DO NOT MERGE] Check if grpcio 1.64.x is compatible with grpcio-tools 1.65.0 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/15 15:28:38 UTC, 2 replies.
- [PR] Add license to fix RAT failure [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/15 16:12:32 UTC, 5 replies.
- [I] Using Real Time, when operating in "production" mode. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/15 16:30:46 UTC, 0 replies.
- Re: [I] Unbounded Source for MongoDB [beam] - posted by "eldar-elne (via GitHub)" <gi...@apache.org> on 2024/10/15 17:09:30 UTC, 0 replies.
- [PR] Test vendored_grpc_1_60_1:0.3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/15 17:28:32 UTC, 0 replies.
- [PR] Update CHANGES.md [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/10/15 17:48:05 UTC, 3 replies.
- [PR] Created using Colab [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/10/15 17:53:22 UTC, 3 replies.
- [I] [Bug]: UnsupportedOperationException when spin up beam-examples-multi-language expansion service [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/15 18:09:59 UTC, 0 replies.
- Re: [I] [Feature Request]: vLLM model handler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/15 18:19:07 UTC, 0 replies.
- Re: [PR] [Do not merge] Test vendored_grpc_1_60_1:0.3 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/15 18:58:19 UTC, 3 replies.
- Re: [I] [Feature Request]: Enable CDC configuration for cross language StorageWrite API usage [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/10/15 20:09:45 UTC, 0 replies.
- Re: [PR] Support Map and Arrays of Maps in BQ for StorageWrites for Beam Rows [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/10/15 20:43:36 UTC, 0 replies.
- [PR] Add the beam summit 2024 overview blog [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/15 20:43:42 UTC, 3 replies.
- [I] The PreCommit RAT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/15 21:33:59 UTC, 2 replies.
- [PR] Update CHANGES.md to include streaming NPE issue [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2024/10/15 23:33:37 UTC, 6 replies.
- [I] The PostCommit Python Examples Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 03:38:34 UTC, 0 replies.
- [I] [Bug]: Iceberg Write failing to upgrade due to "IllegalArgumentException: unable to serialize SchemaCoder" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/16 03:58:47 UTC, 13 replies.
- [PR] [Managed Iceberg] Explicitly set SchemaCoder for FileWriteResult [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/16 04:21:34 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.67.0 to 1.70.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 04:42:23 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.43.0 to 1.44.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 04:42:56 UTC, 3 replies.
- [PR] Bump google.golang.org/protobuf from 1.34.2 to 1.35.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 04:43:06 UTC, 2 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.8.0 to 1.8.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 04:43:21 UTC, 2 replies.
- [PR] test iceberg UTs and ITs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/16 09:01:20 UTC, 1 replies.
- [PR] run iceberg tests after reverting "Schema inference parameterized types" [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/16 09:08:30 UTC, 2 replies.
- [PR] Fix StressTests Java BigQueryIO job flakiness [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/10/16 09:24:00 UTC, 6 replies.
- [PR] BigQueryIO : control StorageWrite parallelism in batch, by reshuffling before write on the number of streams set for BigQueryIO.write() using .withNumStorageWriteApiStreams(numStorageWriteApiStreams) [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2024/10/16 12:53:28 UTC, 17 replies.
- [PR] Upgrade grpcio to 1.65.5 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/16 14:00:23 UTC, 9 replies.
- [PR] Update authors.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/16 14:06:53 UTC, 3 replies.
- Re: [I] runMobileGamingJavaDirect FAILED SocketException: Connection reset [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/16 14:33:51 UTC, 1 replies.
- Re: [I] runMobileGamingJavaDirect Aborted after 100 minutes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/16 14:34:09 UTC, 1 replies.
- [I] [Bug]: PostRelease Nightly workflow flaky for release candidate validation [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/16 14:40:40 UTC, 4 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 15:35:45 UTC, 2 replies.
- [PR] make TransformingMap serializable [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/10/16 15:46:42 UTC, 6 replies.
- [I] [Failing Test]: MacOS tests are failing due to psychopg2-binary version release [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/16 15:53:11 UTC, 0 replies.
- [PR] Exclude psycopg2-binary version broken on MacOS [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/16 15:58:19 UTC, 6 replies.
- [PR] DO NOT MERGE: test cloudpickle default [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/10/16 16:25:14 UTC, 0 replies.
- Re: [I] [Task]: Document how to investigate OOMs [beam] - posted by "reddaly (via GitHub)" <gi...@apache.org> on 2024/10/16 16:39:08 UTC, 1 replies.
- Re: [I] [Failing Test]: MacOS tests are failing due to psycopg2-binary version release [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/16 18:19:40 UTC, 0 replies.
- Re: [PR] Add support for Flink 1.19 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/16 18:39:35 UTC, 8 replies.
- [PR] Vendor grpc_1_60_1 v0.3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/16 19:30:01 UTC, 6 replies.
- [I] [Distroless]: Support distroless container images [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:33:09 UTC, 0 replies.
- [I] Support BuildKit and multi-stage container image builds [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:39:59 UTC, 0 replies.
- [I] Enable Distroless Python SDK (non-ML) based container [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:40:04 UTC, 0 replies.
- [I] Enable Distroless Java SDK based container images [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:40:07 UTC, 0 replies.
- [I] [Distroless] Enable BuildKit by default for container image builds [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:47:34 UTC, 1 replies.
- [I] [Distroless] Enable optional multi-stage build support [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 19:47:37 UTC, 1 replies.
- [PR] [Managed Iceberg] Cleanup SerializedDataFile; use ByteBuffer instead [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/16 20:12:03 UTC, 5 replies.
- [I] [Distroless]: Add Beam ML distroless container images [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/16 20:17:07 UTC, 0 replies.
- [PR] Correctly propogate retries [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/16 21:00:49 UTC, 3 replies.
- [I] [Failing Test]: PostRelease Nightly Snapshot is perma-red due to a connect timed out [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/16 21:10:54 UTC, 1 replies.
- [PR] [yaml] Enhance YAML API docs [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/16 22:04:53 UTC, 8 replies.
- [PR] [#30703][prism] Update logging handling [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/16 23:46:14 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.27.43 to 1.28.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 04:48:25 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.199.0 to 0.201.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 04:48:38 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.32 to 1.17.33 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 04:50:03 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.65.3 to 1.66.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 04:51:26 UTC, 2 replies.
- [PR] [Do not Merge] [WIP] Combine.perKeyWithBucketing: Combiner for reducing key cardinality [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/10/17 07:22:33 UTC, 1 replies.
- [I] [Failing Test]: PreCommit Yaml Xlang Direct is broken [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/17 09:57:31 UTC, 1 replies.
- Re: [I] [Feature Request]: Add support for Flink 1.19 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 11:39:28 UTC, 0 replies.
- [PR] Add 2.61 CHANGES section with Flink 1.19 support [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 11:54:52 UTC, 4 replies.
- [PR] Note Flink 1.19 support in CHANGES.md [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 11:59:05 UTC, 2 replies.
- [I] [Task]: Remove Flink 1.15 and cleanup [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 12:12:46 UTC, 1 replies.
- [PR] Drop Flink 1.15 support [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 12:41:54 UTC, 4 replies.
- [PR] Move portable Flink GitHub actions to Flink 1.19 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 12:58:37 UTC, 3 replies.
- Re: [PR] SolaceIO: refactor to allow inheritance of BasicAuthSempClient [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2024/10/17 13:52:51 UTC, 0 replies.
- Re: [I] [Failing Test]: PostRelease Nightly Snapshot is perma-red due to "connect timed out" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/17 14:16:25 UTC, 9 replies.
- Re: [PR] Move GitHub Actions workflows to Flink 1.19 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 14:54:27 UTC, 1 replies.
- Re: [I] [Task]: Remove support for the typing module [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2024/10/17 15:00:16 UTC, 0 replies.
- Re: [PR] Move GitHub Actions workflows to Flink 1.19 and remove 1.15 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 15:06:04 UTC, 0 replies.
- [I] [Task]: Remove Flink 1.16 support and clean up [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 15:11:34 UTC, 1 replies.
- Re: [PR] [flink-runner] Improve Datastream for batch performances [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/10/17 15:37:17 UTC, 1 replies.
- [PR] Use WindowedValueParam for interactive cache. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/17 16:04:00 UTC, 4 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.63.0 to 1.63.1 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 16:07:45 UTC, 1 replies.
- [I] [Feature Request]: Add examples of FlattenWith and Tee to the playground [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/17 16:51:45 UTC, 0 replies.
- [PR] Using single temp maven local repository for release validation tasks [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/17 16:52:22 UTC, 10 replies.
- Re: [PR] Move GitHub Actions workflows to Flink 1.19 and remove 1.15 and 1.16 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/17 17:17:13 UTC, 5 replies.
- [I] [Bug]: apache-beam is unusable in recent python due to pinning an old dill library from 2019 [beam] - posted by "morotti (via GitHub)" <gi...@apache.org> on 2024/10/17 17:35:43 UTC, 1 replies.
- [PR] Drop Flink 1.16 support [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/17 17:59:16 UTC, 0 replies.
- [I] [Feature Request]: Add a flag to disable emission of lineage from IOs [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/10/17 19:00:14 UTC, 0 replies.
- Re: [PR] Drop Flink 1.15 and 1.16 support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 19:35:05 UTC, 3 replies.
- [PR] [prism] Add Github Action for Prism as a Python precommit [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/17 20:51:03 UTC, 0 replies.
- [I] Gradle Target exists [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/17 21:11:41 UTC, 0 replies.
- [I] Github Action exists [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/17 21:12:45 UTC, 1 replies.
- Re: [I] [prism] Python Validates Runner Gradle Target exists [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/17 21:15:03 UTC, 0 replies.
- Re: [PR] [#32847][prism] Add Github Action for Prism as a Python precommit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 21:34:55 UTC, 3 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 22:13:50 UTC, 1 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/17 22:13:58 UTC, 1 replies.
- [PR] Fix beam.Row.__eq__ to ignore key order [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/17 22:41:58 UTC, 5 replies.
- [PR] Fix failing YAML mapping IT [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/17 23:00:35 UTC, 7 replies.
- [PR] Bump org.apache.beam:beam-sdks-java-core from 2.59.0 to 2.60.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 01:10:50 UTC, 1 replies.
- Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.58.0 to 2.59.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 01:10:52 UTC, 1 replies.
- [PR] Revert "Update pyproject.toml by using grpcio-tools==1.65.5" [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/18 01:34:49 UTC, 3 replies.
- [PR] Bump org.apache.beam:beam-runners-direct-java from 2.59.0 to 2.60.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 01:42:49 UTC, 0 replies.
- [PR] Follow up website and change.md after 2.60 release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/18 01:56:06 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/storage from 1.44.0 to 1.45.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 04:55:25 UTC, 2 replies.
- [PR] Bump github.com/fsouza/fake-gcs-server from 1.49.2 to 1.50.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 04:55:38 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.18 to 2.10.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 04:55:53 UTC, 5 replies.
- Re: [PR] Add support for StringSet metric in Java SDK to track set of unique s… [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/10/18 05:21:55 UTC, 0 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.59.0 to 2.60.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 09:38:23 UTC, 1 replies.
- [PR] Support poisioning instruction ids to prevent the FnApi data stream from blocking on failed instructions [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/18 10:07:56 UTC, 15 replies.
- [I] [Bug]: [beam] - posted by "pineapple-pokopo (via GitHub)" <gi...@apache.org> on 2024/10/18 12:14:45 UTC, 0 replies.
- [PR] Bump apache-beam from 2.59.0 to 2.60.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/18 12:19:51 UTC, 1 replies.
- [PR] Add RAG to docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/18 12:59:42 UTC, 6 replies.
- [PR] Add a vLLM notebook [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/18 13:11:12 UTC, 3 replies.
- [PR] Enrichment pydoc improvements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/18 13:53:31 UTC, 2 replies.
- [I] [Bug]: IcebergIO fails when partition layout is changed on Iceberg table at runtime [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/18 14:05:23 UTC, 0 replies.
- [PR] Add support for Flink 1.20 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/18 14:41:20 UTC, 0 replies.
- [PR] Upgrade GCP-BOM to 26.49.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/18 15:47:59 UTC, 3 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "jd185367 (via GitHub)" <gi...@apache.org> on 2024/10/18 15:54:52 UTC, 0 replies.
- [I] [Bug]: IcebergIO cannot write data into an hourly partitioned table [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/18 16:24:50 UTC, 0 replies.
- [I] [Failing Test]: Processing failed records [beam] - posted by "ujjwalrajanand (via GitHub)" <gi...@apache.org> on 2024/10/18 18:18:37 UTC, 0 replies.
- [I] [Failing Test]: Replace missing values with Column Mean [beam] - posted by "ujjwalrajanand (via GitHub)" <gi...@apache.org> on 2024/10/18 18:19:56 UTC, 2 replies.
- [I] [Failing Test]: Calculation of Column Mean [beam] - posted by "ujjwalrajanand (via GitHub)" <gi...@apache.org> on 2024/10/18 18:21:55 UTC, 2 replies.
- [I] [Failing Test]: Integrating SQL file with YAML for transformation [beam] - posted by "ujjwalrajanand (via GitHub)" <gi...@apache.org> on 2024/10/18 18:23:32 UTC, 1 replies.
- [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] - posted by "ujjwalrajanand (via GitHub)" <gi...@apache.org> on 2024/10/18 18:24:32 UTC, 1 replies.
- [PR] Modernize type hints for bundle_processor.py. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/18 19:25:52 UTC, 4 replies.
- [PR] Modernize python type hints for apache_beam. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/18 19:32:40 UTC, 2 replies.
- [I] [Task]: Document Jinja templatization for yaml [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/18 21:30:47 UTC, 1 replies.
- [PR] Update docs on error handling output schema. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/18 21:45:44 UTC, 3 replies.
- Re: [I] Difficulty reprocessing failed records [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/18 21:47:56 UTC, 1 replies.
- [PR] Enable BuildKit on gradle docker task [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/18 22:40:14 UTC, 4 replies.
- [PR] [prism] Dev prism builds for python and Python Direct Runner fallbacks. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/18 23:18:26 UTC, 3 replies.
- [I] Python Runner Wrapper to execute a job against Prism (via Go being available) for dev versions [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/18 23:20:21 UTC, 1 replies.
- [PR] [WIP] Enable configuration of mutation info callable for CDC Writes into BigQuery [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/10/18 23:20:34 UTC, 0 replies.
- [PR] [Managed Iceberg] Allowed updating partition specs at runtime [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/18 23:23:25 UTC, 0 replies.
- Re: [PR] [Managed Iceberg] Allow updating partition specs at runtime [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/18 23:25:39 UTC, 20 replies.
- Re: [I] [Bug]: IcebergIO fails when the table's partition layout is changed at runtime [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/18 23:26:44 UTC, 0 replies.
- Re: [I] [Bug]: BigQuery IO Batch load using File_load causing the same job id ignoring inserts as the job_id is already completed [beam] - posted by "pranjal5215 (via GitHub)" <gi...@apache.org> on 2024/10/19 06:54:10 UTC, 2 replies.
- Re: [I] [Feature Request]: Add examples of FlattenWith and Tee to the playground and transform catalog. [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2024/10/19 16:33:56 UTC, 2 replies.
- [PR] Update typecheck err msg [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/10/19 20:55:46 UTC, 11 replies.
- Re: [I] [Task]: Enable to set timeout for Python TestPipeline [beam] - posted by "Tjindl (via GitHub)" <gi...@apache.org> on 2024/10/20 08:49:38 UTC, 1 replies.
- Re: [PR] Filter empty distribution metrics [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/20 12:44:43 UTC, 2 replies.
- [PR] Added support for reading from multiple topics in MqttIO [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/20 14:00:27 UTC, 3 replies.
- Re: [I] [Feature Request]: Topic array support for MqttIO.Read [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/10/20 14:05:04 UTC, 0 replies.
- [PR] Increase RemoteExecutionTest sdk start timeout, caused flaky failure. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/21 09:23:55 UTC, 2 replies.
- [PR] Add equals/hashcode to test data class to avoid direct runner warning log [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/21 09:28:06 UTC, 1 replies.
- Re: [I] [Task]: Switch to portable Data and Time type for JdbcIO [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/10/21 11:45:51 UTC, 1 replies.
- [I] [Feature Request]: Map Type supported in the JsonToRow Transformer [beam] - posted by "DanielMorales9 (via GitHub)" <gi...@apache.org> on 2024/10/21 12:51:19 UTC, 0 replies.
- [I] [Bug]: error reading Rabbit messages with array headers [beam] - posted by "devfreitag (via GitHub)" <gi...@apache.org> on 2024/10/21 13:39:55 UTC, 0 replies.
- [I] [Prism]: Support on_window_expiration [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/21 17:38:50 UTC, 2 replies.
- [PR] Revert "Merge pull request #32757: Schema inference parameterized types" [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/10/21 18:25:43 UTC, 3 replies.
- [PR] Move enrichment transformns to examples/notebooks/beam-ml [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/10/21 18:45:14 UTC, 3 replies.
- [PR] Determine partition backlog using endOffsets instead of seek2End and position [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/21 20:25:08 UTC, 1 replies.
- Re: [I] JdbcIO informix connection problem [beam] - posted by "cwashcraft (via GitHub)" <gi...@apache.org> on 2024/10/21 21:32:54 UTC, 1 replies.
- [PR] Add target parameter to BeamDockerPlugin [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/21 22:02:14 UTC, 3 replies.
- [I] [Feature Request]: Update Python JDBC write transforms to support configuring the batch size [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/21 22:30:49 UTC, 0 replies.
- [I] [Bug]: Protobuf build error with MapState.remove() in Dataflow Java Streaming Legacy Runner Job without Streaming Engine. [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/10/22 02:51:51 UTC, 1 replies.
- [PR] Fix protobuf build error in WindmillMap.persistDirect() for a removal in Dataflow Streaming Java Legacy Runner without Streaming Engine [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/10/22 03:18:51 UTC, 13 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.33.0 to 0.34.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/22 04:10:45 UTC, 3 replies.
- [I] [Bug]: Metrics not showing up in the FlinkRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/22 12:04:35 UTC, 0 replies.
- Re: [PR] Add Managed Iceberg example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/22 12:14:27 UTC, 2 replies.
- [I] [Failing Test]: Python PreCommit perma-red due to Flink Python xlang test failures: "apache/beam_java11_sdk:2.61.0.dev not found" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/22 15:43:42 UTC, 0 replies.
- Re: [I] [Failing Test]: Python PostCommit perma-red due to Flink Python xlang test failures: "apache/beam_java11_sdk:2.61.0.dev not found" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/22 16:28:55 UTC, 2 replies.
- [PR] Build java 11 container image instead of java 8 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/22 16:54:26 UTC, 3 replies.
- Re: [PR] [yaml] Add use cases for Enrichment transform in YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/22 17:03:11 UTC, 1 replies.
- [I] [distroless] Add ARM-based Distroless Python SDK (non-ML) variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/22 17:41:31 UTC, 0 replies.
- [I] [Distroless] Add ARM-based Distroless Java SDK variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/22 17:44:53 UTC, 0 replies.
- [PR] Fix java sdk container dependency for Python PostCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/22 18:48:37 UTC, 6 replies.
- [I] [Bug]: search stops working in pydoc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/22 19:21:13 UTC, 2 replies.
- [PR] Bump zetasql version to 2024.08.2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/22 19:24:33 UTC, 2 replies.
- [PR] Update generate_pydoc.sh [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/22 19:27:43 UTC, 2 replies.
- Re: [PR] Bump zetasql version to 2024.08.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/22 20:40:05 UTC, 0 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/22 21:33:45 UTC, 3 replies.
- Re: [PR] Support Map in BQ for StorageWrites API for Beam Rows [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/22 21:48:22 UTC, 0 replies.
- [PR] Update streaming platform kafka lib version [beam] - posted by "jingweiz-lyft (via GitHub)" <gi...@apache.org> on 2024/10/22 21:50:14 UTC, 1 replies.
- Re: [I] [Feature Request]: Support maps in BigQuery StorageWrites when using Beam Rows as the PCollection input type [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/10/22 21:55:14 UTC, 0 replies.
- [PR] extract semaphore logic out of WeightBoundedQueue to allow for sharing the weigher [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/22 22:24:28 UTC, 4 replies.
- [PR] Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.5.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/23 01:48:04 UTC, 0 replies.
- Re: [PR] Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.4.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/23 01:48:07 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.199.0 to 0.202.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/23 04:46:35 UTC, 2 replies.
- Re: [I] [Bug]: WriteToFiles using a custom sink with compression type .bz2 flush errors. [beam] - posted by "danipv (via GitHub)" <gi...@apache.org> on 2024/10/23 13:29:07 UTC, 0 replies.
- Re: [PR] Test Enrichment Transform [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/23 14:20:16 UTC, 0 replies.
- Re: [I] Error running Top transform in Dataflow [beam] - posted by "jrecuerda (via GitHub)" <gi...@apache.org> on 2024/10/23 14:45:53 UTC, 0 replies.
- [I] [Bug]: SpannerIO.Write does not support named schemas [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/10/23 15:01:46 UTC, 2 replies.
- [PR] Doc fixes after 2.60 release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/23 15:17:47 UTC, 4 replies.
- [PR] Test fix after runner bump to Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/23 15:31:47 UTC, 11 replies.
- Re: [PR] [BEAM-3655] Port MaxPerKeyExamplesTest off DoFnTester [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/23 16:56:53 UTC, 0 replies.
- [PR] Remove extraneous/incorrect ValidatesRunner classification from examples unit tests [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/23 17:04:25 UTC, 6 replies.
- [I] [Failing Test]: Prism runner execution test failing on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/23 18:52:00 UTC, 2 replies.
- Re: [PR] Kafka metrics [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/23 19:06:25 UTC, 1 replies.
- [PR] Fix JavaPreCommit on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/23 19:25:07 UTC, 5 replies.
- Re: [PR] [BEAM-4130] Add job submission capabilities to Flink runner. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/23 19:30:58 UTC, 1 replies.
- [PR] Remove remaining Python 3.8 Artifacts [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/23 19:54:27 UTC, 5 replies.
- [I] [Distroless] Publish Python distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/23 21:28:51 UTC, 0 replies.
- [PR] Update docs for MapState and SetState support update [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/10/23 22:59:11 UTC, 13 replies.
- [I] [Feature Request]: Beam Python SDK version mismatches between submission/runtime are not detected in some cases [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/24 00:35:13 UTC, 0 replies.
- [PR] Bump actions/checkout from 3.5.3 to 4.2.2 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/24 01:20:26 UTC, 0 replies.
- Re: [PR] Bump actions/checkout from 3.5.3 to 4.2.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/24 01:20:28 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/24 04:53:12 UTC, 4 replies.
- [PR] Bump google.golang.org/api from 0.202.0 to 0.203.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/24 04:53:24 UTC, 2 replies.
- [PR] [#28187] Add a Java gradle task to run validates runner tests on Prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 05:36:47 UTC, 6 replies.
- [PR] Remove unused property, assignment in finalize will not be observed [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/24 07:51:30 UTC, 0 replies.
- [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/24 08:01:10 UTC, 2 replies.
- Re: [PR] [KafkaIO] Remove unused property, assignment in finalize will not be observed [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/24 08:39:55 UTC, 2 replies.
- [PR] fix silent failures in dispatch loop from stalling the pipeline [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/24 08:40:29 UTC, 27 replies.
- [PR] Update commons-codec to 1.17.1 [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/10/24 10:03:31 UTC, 2 replies.
- Re: [PR] Windowing Support for the DaskRunner [beam] - posted by "alxmrs (via GitHub)" <gi...@apache.org> on 2024/10/24 11:49:09 UTC, 1 replies.
- [I] [Bug]: Cross-Language State Growth in Solace IO with Python SDK and Flink Runner [beam] - posted by "AMMJ93 (via GitHub)" <gi...@apache.org> on 2024/10/24 13:55:38 UTC, 0 replies.
- [PR] Eliminate nullness errors from a bit of the FlinkRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/24 14:42:01 UTC, 0 replies.
- [PR] Fix DebeziumIO JmsIO PreCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/24 15:07:11 UTC, 9 replies.
- Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/24 15:10:44 UTC, 1 replies.
- [PR] Fix GCSUtils IT after Gcs gRPC launch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/24 16:01:42 UTC, 6 replies.
- [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/24 16:09:14 UTC, 3 replies.
- [I] OrderedListState [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 16:59:13 UTC, 0 replies.
- [I] [prism] Java FlattenTest.testFlattenMultipleCoders - worker crash [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 17:12:23 UTC, 0 replies.
- [I] org.apache.beam.sdk.transforms.ParDoSchemaTest - UserCoder not a row coder exceptions. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 17:14:50 UTC, 0 replies.
- [I] ViewTest.testSideInputWithNestedIterables - user coder error [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 17:16:30 UTC, 0 replies.
- [PR] Kafka uw poll metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/10/24 18:06:42 UTC, 4 replies.
- [PR] Upgrade go for various vulnz fixes [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/24 18:17:36 UTC, 4 replies.
- [PR] Fix web page references to Flink 1.19 support since it is not released until 2.61.0 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/24 19:17:12 UTC, 3 replies.
- [I] [Failing Test]: Python Post-Commits are Perma-Red with Debezium IO failure [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/24 19:52:04 UTC, 1 replies.
- [I] [Task]: Update Debezium test container back to latest [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/24 19:55:07 UTC, 2 replies.
- [PR] Pin debezium test container version [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/24 20:00:13 UTC, 5 replies.
- [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/24 20:00:58 UTC, 4 replies.
- [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/24 20:33:22 UTC, 6 replies.
- Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/24 20:58:10 UTC, 10 replies.
- Re: [I] [Task][prism]: Be able to execute non-Go SDKs on Prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 21:45:46 UTC, 0 replies.
- [PR] Windowing Support for the Dask Runner [beam] - posted by "alxmrs (via GitHub)" <gi...@apache.org> on 2024/10/24 22:15:21 UTC, 5 replies.
- [PR] don't log missing computation state as error [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/24 22:19:40 UTC, 9 replies.
- [PR] Remove gradle task java8's [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/24 22:56:16 UTC, 3 replies.
- [I] [Bug]: Beam Jobs built using ver 2.50 and above are not running with FlinkRunners v 1.16.x [beam] - posted by "siddhanta-rath (via GitHub)" <gi...@apache.org> on 2024/10/25 04:26:41 UTC, 1 replies.
- Re: [PR] [KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/25 14:19:21 UTC, 3 replies.
- Re: [I] [Bug]: Backlog Does Not Track Consumer Lag for DataFlow Python Kafka Pipeline [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 16:52:07 UTC, 1 replies.
- Re: [I] [Bug]: Window trigger has lag when using Kafka and GroupByKey on Dataflow Runner [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 16:56:06 UTC, 0 replies.
- Re: [I] [Bug]: UnboundedSourceWrapper.splitSources is assigned too early. [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 16:58:56 UTC, 1 replies.
- Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 17:01:55 UTC, 0 replies.
- Re: [I] Incorrect Spanner IO Request Count metrics [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/25 17:03:55 UTC, 1 replies.
- Re: [I] [Bug]: org.apache.avro.UnresolvedUnionException: Not in union after updating schema-registry [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 17:07:05 UTC, 0 replies.
- Re: [I] [Bug]: [Flink] JdbcIO metrics are always `NaN` when using the FlinkRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/10/25 17:07:31 UTC, 0 replies.
- Re: [I] [Bug]: KafkaIO Should not throw errors for empty topics. [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 17:08:19 UTC, 1 replies.
- Re: [I] [Bug]: SchemaParseException: Undefined name with avro union (kafka + schema registry) [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 17:10:49 UTC, 8 replies.
- Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/10/25 17:12:01 UTC, 4 replies.
- [PR] learning+website: add `FlattenWith` to Playground and Transform Catalog [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2024/10/25 17:45:09 UTC, 0 replies.
- [PR] Rethrow BQ file loads writer errors [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/25 17:50:04 UTC, 2 replies.
- Re: [PR] learning+website: add `FlattenWith` and `Tee` to Playground and Transform Catalog [WIP] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2024/10/25 18:32:35 UTC, 1 replies.
- Re: [I] Add CountingInput Transform to python sdk [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2024/10/25 19:07:15 UTC, 0 replies.
- Re: [PR] Don't swallow BQ file loads writer errors [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/10/25 19:19:36 UTC, 1 replies.
- [PR] Fix a few notebook typos [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/25 20:05:40 UTC, 1 replies.
- Re: [I] [prism] Support OnWindowExpiry [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/25 20:51:35 UTC, 0 replies.
- [I] The PreCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/26 06:37:50 UTC, 1 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/26 22:15:56 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/27 12:44:25 UTC, 2 replies.
- [PR] WIP: OnWindowExpiry, and OrderedListState WIP: DO NOT SUBMIT [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/10/27 19:10:54 UTC, 0 replies.
- [PR] Add Python 3.12 to documentation [beam] - posted by "tancnle (via GitHub)" <gi...@apache.org> on 2024/10/28 04:11:35 UTC, 5 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/10/28 04:14:24 UTC, 1 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/28 12:46:11 UTC, 0 replies.
- [PR] Modify JVM options if enableHeapDumps is specified to dump heap in directory that MemoryMonitor will look in. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/28 12:47:10 UTC, 0 replies.
- [PR] Remove duplicate button from notebook [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/28 13:36:30 UTC, 3 replies.
- [PR] Fix gemma notebook formatting [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/28 13:48:32 UTC, 3 replies.
- [PR] Add a simple validation transform to yaml. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/10/28 16:19:51 UTC, 3 replies.
- [PR] Suppress future warning affecting Dataflow notebook [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/28 19:26:59 UTC, 3 replies.
- [PR] Use beam-vendor-grpc-1_60_1:0.3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/28 19:30:45 UTC, 4 replies.
- [PR] Update discussion docs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/28 20:45:22 UTC, 3 replies.
- [PR] Distroless python sdk [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/10/29 00:46:53 UTC, 1 replies.
- Re: [I] [Task]: Sunset Python 3.8 support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 14:10:21 UTC, 0 replies.
- [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/29 14:13:39 UTC, 8 replies.
- Re: [I] [Bug]: cloudpickle appears to incorrectly unpickle cloned combiners [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/10/29 14:37:36 UTC, 0 replies.
- [PR] SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/10/29 15:22:55 UTC, 2 replies.
- Re: [PR] Override BQ load job location when necessary [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/29 15:33:13 UTC, 0 replies.
- [I] [Task]: Documentation for SubProcess example [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/10/29 16:52:35 UTC, 0 replies.
- [PR] SolaceIO.Read: Make sure the messageReceiver is always initialized. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/10/29 17:30:13 UTC, 3 replies.
- [I] [Task]: Re-Enable testPy39embeddingsMLTransform in the Python Dependency Postcommit [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 18:01:04 UTC, 0 replies.
- [PR] Disable the Py39embeddingsMLTransform tests in the Dependency Postcommit [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 18:05:27 UTC, 4 replies.
- [PR] Parsing location from HTTPError response instead of initiate a query [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/29 18:37:12 UTC, 5 replies.
- [I] [Bug]: UnboundedSourceAsSDFWrapperFn caches readers per DoFn instance [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/29 19:44:46 UTC, 0 replies.
- [I] [Task]: Update Python SDK code base to PEP 585 standards [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 20:15:49 UTC, 0 replies.
- [PR] Update type hinting in Python examples to PEP 585 standards [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 20:16:15 UTC, 1 replies.
- [PR] Update MLTransform code to PEP 585 types [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/29 20:48:47 UTC, 4 replies.
- [PR] The motivation for this change is to support caching in Apache Beam. [beam] - posted by "kushmiD (via GitHub)" <gi...@apache.org> on 2024/10/29 23:22:11 UTC, 4 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/30 09:35:04 UTC, 1 replies.
- Re: [PR] Fix juliaset_test_it [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/30 12:45:57 UTC, 0 replies.
- [PR] Optimize proto PubsubMessage to/from conversion to beam PubsubMessage [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/30 14:36:53 UTC, 2 replies.
- [PR] Copy in correct requirements file [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 15:25:09 UTC, 4 replies.
- [PR] Add Kafka tag to review bot [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/30 15:44:04 UTC, 2 replies.
- [PR] Bump Flink and Spark job server container base imager to tumerin-11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/30 15:55:16 UTC, 5 replies.
- Re: [I] [Task]: Clean up logger handling in Python's boot.go script [beam] - posted by "willvo2004 (via GitHub)" <gi...@apache.org> on 2024/10/30 16:51:15 UTC, 0 replies.
- Re: [I] [Failing Test]: PostCommit Python and PostCommit Python Arm perma red [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 17:21:43 UTC, 1 replies.
- Re: [I] The PostCommit XVR Direct job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 17:23:48 UTC, 3 replies.
- Re: [I] [Failing Test]: org.apache.beam.runners.dataflow.worker.StreamingDataflowWorkerTest.testMaxThreadMetric [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 17:26:26 UTC, 1 replies.
- Re: [I] [Failing Test]: bigquery.StorageApiSinkCreateIfNeededIT.testCreateManyTables[1] [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 17:28:55 UTC, 1 replies.
- Re: [I] [Bug]: apache_beam.io.gcp.bigquery_read_it_test.ReadAllBQTests.test_read_queries is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/30 17:30:01 UTC, 1 replies.
- [PR] add generics support to AutoValueUtils helpers [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/10/30 19:00:30 UTC, 2 replies.
- [PR] Upgrade mypy to version 1.13.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/10/30 20:22:57 UTC, 2 replies.
- Re: [PR] Update the python deps [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/10/30 20:43:39 UTC, 3 replies.
- [PR] Support caching in Apache Beam by using relative co_filename paths. [beam] - posted by "kushmiD (via GitHub)" <gi...@apache.org> on 2024/10/30 23:06:46 UTC, 15 replies.
- [PR] Bump Hadoop versions for compatibility test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/31 01:37:46 UTC, 3 replies.
- [PR] Add Kafka 3 to and remove Kafka 0.x and 1.x from compatibility test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/31 01:46:13 UTC, 4 replies.
- [PR] Clean up creating StreamingWorkerHarness and dependencies [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/10/31 06:14:26 UTC, 1 replies.
- Re: [PR] Replace StorageV1 client with GCS client - Draft [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/10/31 12:45:55 UTC, 0 replies.
- [PR] Revert "Bump Flink and Spark job server container base imager to tumerin-11" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 13:52:53 UTC, 4 replies.
- Re: [I] [Flaky]: apache_beam/runners/portability/portable_runner_test.py::PortableRunnerTestWithSubprocesses::test_pardo_state_with_custom_key_coder [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:09:44 UTC, 1 replies.
- Re: [I] [Flake]: Spark batch flakes in ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElement and ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundle [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:09:52 UTC, 1 replies.
- Re: [I] Flaky timeout in github Python unit test action StatefulDoFnOnDirectRunnerTest.test_dynamic_timer_clear_then_set_timer [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:10:12 UTC, 1 replies.
- Re: [I] apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT.test_streaming_wordcount_it flakey [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:10:21 UTC, 1 replies.
- Re: [I] Flaky: apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:10:32 UTC, 1 replies.
- Re: [I] apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized.test_flink_metrics is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:10:42 UTC, 1 replies.
- Re: [I] Flink streaming flakes in ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundleStateful and ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElementStateful [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 14:10:49 UTC, 1 replies.
- Re: [PR] Add equals/hashcode to test data class to avoid direct runner coder warning [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/10/31 14:44:56 UTC, 1 replies.
- [PR] Reapply disable Gradle cache for expansion service [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/31 14:59:15 UTC, 3 replies.
- [PR] fix JDBC providers [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/10/31 17:25:02 UTC, 2 replies.
- [PR] [KafkaIO] Decouple consumer threads from harness threads [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/10/31 17:48:54 UTC, 0 replies.
- [PR] playground precommit move to selfhosted and update [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/10/31 17:57:36 UTC, 3 replies.
- [PR] [JdbcIO] Adding disableAutoCommit flag [beam] - posted by "cwashcraft (via GitHub)" <gi...@apache.org> on 2024/10/31 18:03:37 UTC, 3 replies.
- [PR] Swallow errors removing awaiting triage label [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/10/31 19:30:08 UTC, 2 replies.
- [I] [Bug]: FnHarness.main not thread-safe on JvmInitializer calls [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/31 21:14:32 UTC, 0 replies.
- [PR] Suppress errors in JvmInitializer#beforeProcessing if successfully initialized before [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/10/31 21:46:18 UTC, 0 replies.
- Re: [PR] Kafka SDF add Poll Latency Metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/10/31 21:50:49 UTC, 1 replies.
- Re: [PR] Managed BigQueryIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/10/31 22:42:17 UTC, 1 replies.