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

---

- Re: [PR] Update typecheck err msg [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/11/01 00:19:18 UTC, 2 replies.
- Re: [PR] add shutdown and start mechanics to windmill streams [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/11/01 01:00:22 UTC, 93 replies.
- Re: [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/11/01 01:02:11 UTC, 21 replies.
- [PR] fix typo: self.gaguge->self.gauge [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/11/01 01:49:16 UTC, 2 replies.
- Re: [PR] Suppress errors in JvmInitializer#beforeProcessing if successfully initialized before [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/01 03:46:45 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.63.1 to 1.64.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/01 04:46:10 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.2 to 1.32.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/01 04:47:38 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.66.0 to 1.66.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/01 04:49:10 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.41 to 1.17.42 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/01 04:50:37 UTC, 2 replies.
- Re: [I] [Feature Request]: Topic array support for MqttIO.Read [beam] - posted by "SamLeurink (via GitHub)" <gi...@apache.org> on 2024/11/01 11:54:57 UTC, 2 replies.
- Re: [PR] Changes to reduce memory pinned while iterating through state backed iterable [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/01 12:36:39 UTC, 7 replies.
- [I] [Bug]: Non Retained Messages missing after MqttIO.Read checkpoint restore [beam] - posted by "SamLeurink (via GitHub)" <gi...@apache.org> on 2024/11/01 13:28:50 UTC, 0 replies.
- Re: [PR] Update type hinting in Python examples to PEP 585 standards [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/01 13:30:21 UTC, 0 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/01 14:19:44 UTC, 14 replies.
- [I] [Bug]: OnnxModelHandlerNumpy broken with latest onnx version [beam] - posted by "gariepyalex (via GitHub)" <gi...@apache.org> on 2024/11/01 14:36:27 UTC, 4 replies.
- [PR] Update base TensorRT test image [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/01 15:43:26 UTC, 5 replies.
- [PR] Remove usage of deprecated _serialize [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/01 16:06:08 UTC, 4 replies.
- [PR] Add option to adjust ReadChangeStream API timeout to allow longer timeout for longer checkpoint durations [beam] - posted by "tonytanger (via GitHub)" <gi...@apache.org> on 2024/11/01 16:11:44 UTC, 11 replies.
- Re: [PR] Support caching in Apache Beam by using relative co_filename paths. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/01 16:17:38 UTC, 0 replies.
- Re: [PR] [JdbcIO] Adding disableAutoCommit flag [beam] - posted by "cwashcraft (via GitHub)" <gi...@apache.org> on 2024/11/01 17:37:15 UTC, 19 replies.
- [PR] Temporarily disable TensorRT PostCommit suite [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/01 18:51:47 UTC, 4 replies.
- Re: [PR] Add a simple validation transform to yaml. [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/01 19:52:00 UTC, 5 replies.
- [I] [Distroless] GitHub action tests Python SDK (non ML) distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/02 00:48:09 UTC, 0 replies.
- [I] [Distroless] Fix Python SDK (non ML) image scan results CVE-2023-45853 [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/02 00:48:11 UTC, 2 replies.
- [I] [Distroless] Fix Python SDK (non ML) image scan results CVE-2023-52425 [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/02 00:48:14 UTC, 2 replies.
- Re: [PR] Distroless python sdk [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/02 02:27:23 UTC, 4 replies.
- [PR] Added replaceGcsFilesWithLocalFiles [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/02 03:07:01 UTC, 10 replies.
- Re: [PR] [Managed Iceberg] Cleanup SerializedDataFile; use ByteBuffer instead [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/02 12:14:06 UTC, 6 replies.
- Re: [PR] Add Managed Iceberg example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/02 12:14:08 UTC, 1 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/02 12:14:09 UTC, 1 replies.
- [I] The PostCommit Java Avro Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/03 18:37:31 UTC, 3 replies.
- [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.5.2 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/04 01:39:22 UTC, 0 replies.
- Re: [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.5.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/04 01:39:25 UTC, 1 replies.
- Re: [I] How to Convert the data fetched from Query to a Pandas Dataframe? [beam] - posted by "Keerthesre1 (via GitHub)" <gi...@apache.org> on 2024/11/04 06:09:16 UTC, 0 replies.
- Re: [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/11/04 09:37:40 UTC, 17 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/11/04 09:38:51 UTC, 3 replies.
- Re: [PR] SolaceIO.Read: Make sure the messageReceiver is always initialized. [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/11/04 10:13:44 UTC, 1 replies.
- Re: [PR] Integrate direct path with StreamingDataflowWorker code path [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/04 12:14:27 UTC, 16 replies.
- Re: [PR] [yaml] Add use cases for Enrichment transform in YAML [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/04 12:14:30 UTC, 3 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/11/04 12:25:26 UTC, 3 replies.
- Re: [PR] Remove beam logging in playground for Python [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/11/04 13:38:36 UTC, 1 replies.
- Re: [I] The PreCommit YAML Xlang Direct job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/04 13:51:34 UTC, 0 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/04 13:53:47 UTC, 1 replies.
- [PR] Update code-change-guide.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/04 14:55:19 UTC, 4 replies.
- Re: [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/04 15:27:29 UTC, 1 replies.
- Re: [PR] Parsing location from HTTPError response instead of initiate a query [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/04 15:52:42 UTC, 0 replies.
- Re: [PR] Bump Hadoop versions for compatibility test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/04 15:53:20 UTC, 3 replies.
- Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/04 16:23:54 UTC, 0 replies.
- Re: [PR] Remove extraneous/incorrect ValidatesRunner classification from examples unit tests [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/04 16:25:49 UTC, 0 replies.
- [PR] Add Flush Interval to default Buffered Logger in Python boot.go [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/04 17:30:29 UTC, 5 replies.
- [PR] Disable gradle cache for spark job server shadowjar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/04 17:50:57 UTC, 3 replies.
- Re: [I] Make cloudpickle the default pickle library [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/04 18:58:51 UTC, 0 replies.
- [PR] bump hadoop version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/04 19:32:53 UTC, 4 replies.
- Re: [PR] Clean up creating StreamingWorkerHarness and dependencies [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/11/04 19:39:08 UTC, 1 replies.
- Re: [I] Apache Beam Java Lib and ANTLR [beam] - posted by "ygw (via GitHub)" <gi...@apache.org> on 2024/11/04 21:01:53 UTC, 4 replies.
- [I] [Task]: Improve Enrichment docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/04 21:22:48 UTC, 1 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/04 21:34:14 UTC, 1 replies.
- [PR] Add ability to encode and decode histogram data to portable runners [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/05 00:42:03 UTC, 32 replies.
- [I] [Bug]: FlatMapTuple with certain callables can result in wrong type hints [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/11/05 01:00:12 UTC, 2 replies.
- [PR] Clean up logger handling for boot.go script in Python SDK [beam] - posted by "willvo2004 (via GitHub)" <gi...@apache.org> on 2024/11/05 02:43:24 UTC, 6 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 03:36:32 UTC, 2 replies.
- Re: [I] [Feature Request]: Update Python JDBC write transforms to support configuring the batch size [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/05 04:17:09 UTC, 6 replies.
- Re: [PR] SolaceIO write connector [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/11/05 08:59:27 UTC, 15 replies.
- Re: [PR] [feat 32473] Added soft deadline logic to Spanner Change Stream IO connector. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/05 09:28:10 UTC, 0 replies.
- Re: [PR] Proposal: Propagate gcs-connector options to GcsUtil [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/05 09:32:10 UTC, 7 replies.
- [PR] Upgrade antlr from 4.7 to 4.13.1 [beam] - posted by "idan-at (via GitHub)" <gi...@apache.org> on 2024/11/05 09:39:04 UTC, 2 replies.
- Re: [PR] Optimize proto PubsubMessage to/from conversion to beam PubsubMessage [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/05 09:43:47 UTC, 2 replies.
- Re: [PR] [flink-runner] Improve Datastream for batch performances [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/11/05 09:54:35 UTC, 2 replies.
- [PR] Portable Managed BigQuery destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/05 11:35:48 UTC, 8 replies.
- Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/05 11:43:06 UTC, 2 replies.
- Re: [PR] [Managed Iceberg] Allow updating partition specs at runtime [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/05 11:43:47 UTC, 1 replies.
- Re: [PR] Windowing Support for the Dask Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 12:14:22 UTC, 18 replies.
- Re: [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 "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 12:14:24 UTC, 4 replies.
- Re: [PR] Update CHANGES.md to include streaming NPE issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 12:14:25 UTC, 5 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/11/05 12:14:26 UTC, 4 replies.
- Re: [PR] Add logging for DataChangeRecord and ChangeStreamQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 12:44:41 UTC, 2 replies.
- [PR] Update snowflake-jdbc to 3.20 [beam] - posted by "turb (via GitHub)" <gi...@apache.org> on 2024/11/05 13:16:53 UTC, 2 replies.
- [PR] [java] Add Optional coder [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/11/05 13:32:34 UTC, 1 replies.
- Re: [I] [Bug]: In Beam Dataframe api, the fillna operation doesn't work when applied on individual columns [beam] - posted by "oyugicollins (via GitHub)" <gi...@apache.org> on 2024/11/05 13:59:59 UTC, 3 replies.
- Re: [PR] [Managed Iceberg] Allow updating partition specs during pipeline runtime [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/05 18:08:42 UTC, 0 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/11/05 18:08:43 UTC, 0 replies.
- [I] [Bug]: numpy.int64 types are not serialized correctly [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/05 19:00:20 UTC, 7 replies.
- Re: [PR] [Managed Iceberg] bubble up exceptions due to writer close [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/05 20:23:18 UTC, 0 replies.
- Re: [PR] Add Flush Interval to default Buffered Logger [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/05 21:34:31 UTC, 1 replies.
- [I] [Bug]: grouping with numpy.datetime64 keys gives silently incorrect behavior [beam] - posted by "shoyer (via GitHub)" <gi...@apache.org> on 2024/11/05 21:43:34 UTC, 1 replies.
- [I] [Feature Request]: Update Java ExpansionService to use arbitrary PipelineOptions set through an ExpansionRequest [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/11/05 21:47:38 UTC, 1 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 22:14:50 UTC, 1 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 22:14:55 UTC, 1 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/05 22:15:02 UTC, 1 replies.
- [PR] Update Java ExpansionService to use arbitrary PipelineOptions set through an ExpansionRequest [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/11/05 22:34:03 UTC, 13 replies.
- Re: [PR] Managed BigQueryIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/11/05 22:47:45 UTC, 20 replies.
- [PR] [yaml] Fix examples catalog tests [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/05 22:51:38 UTC, 7 replies.
- Re: [PR] Kafka SDF add Poll Latency Metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/05 23:21:10 UTC, 2 replies.
- Re: [PR] Bump typescript to version 5.5.4. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/06 12:45:37 UTC, 2 replies.
- Re: [I] [Feature Request]: SolaceIO - publishing to dynamic topics (like TopicNameMapper in JmsIO) [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/11/06 13:16:59 UTC, 4 replies.
- Re: [PR] Bump cloud.google.com/go/pubsub from 1.44.0 to 1.45.1 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/06 15:35:56 UTC, 1 replies.
- Re: [PR] [KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/11/06 15:38:35 UTC, 1 replies.
- Re: [PR] [KafkaIO] Remove unused property, assignment in finalize will not be observed [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/11/06 15:39:15 UTC, 0 replies.
- Re: [PR] [KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/11/06 15:40:19 UTC, 7 replies.
- Re: [PR] [KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/11/06 15:41:15 UTC, 8 replies.
- [PR] Revert "Upgrade antlr from 4.7 to 4.13.1" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/06 15:47:42 UTC, 4 replies.
- [PR] Add buildSrc to trigger path of Java PreCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/06 15:56:03 UTC, 3 replies.
- [PR] Remove antlr from dependency of jaca-core pom [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/06 17:16:25 UTC, 3 replies.
- Re: [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/11/06 17:54:11 UTC, 0 replies.
- Re: [PR] Remove antlr from dependency from java-core pom [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/06 17:59:19 UTC, 8 replies.
- [PR] Add logging to see which topic each split is reading from [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/07 00:39:03 UTC, 6 replies.
- Re: [PR] Update run_inference_vllm.ipynb [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/07 01:00:13 UTC, 3 replies.
- [PR] Use sys.executable to find python command. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/07 02:25:29 UTC, 4 replies.
- Re: [PR] Simplify budget distribution logic and new worker metadata consumption [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/07 03:05:55 UTC, 0 replies.
- [I] The PerformanceTests WordCountIT PythonVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 03:37:29 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.70.0 to 1.71.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 04:27:38 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.3 to 1.32.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 04:30:16 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.66.0 to 1.66.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 04:38:01 UTC, 3 replies.
- [PR] Fix cleanup timer timestamp to not exceed max allowed timestamp [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/11/07 04:57:20 UTC, 7 replies.
- [I] [Bug]: Field aliasing in Beam SQL with ZetaSQL causes original field to be inaccessible when using SELECT * [beam] - posted by "marton-sandor (via GitHub)" <gi...@apache.org> on 2024/11/07 10:42:47 UTC, 0 replies.
- Re: [PR] Add Kafka tag to review bot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 12:14:16 UTC, 4 replies.
- Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 12:14:18 UTC, 5 replies.
- [I] [Bug]: BigtableIO.Read can't retrive large row that exceeds 256MB [beam] - posted by "waterxjw (via GitHub)" <gi...@apache.org> on 2024/11/07 12:31:19 UTC, 6 replies.
- Re: [PR] Fix juliaset_test_it [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/07 12:46:01 UTC, 1 replies.
- [I] [Feature Request]: Expose user-agent in Neo4jIO [beam] - posted by "fbiville (via GitHub)" <gi...@apache.org> on 2024/11/07 13:37:34 UTC, 0 replies.
- [I] [Feature Request]: Make `Neo4jIO.WriteUnwind` output write statistics. [beam] - posted by "fbiville (via GitHub)" <gi...@apache.org> on 2024/11/07 13:42:17 UTC, 0 replies.
- [PR] Simplify MoreFutures.supplyAsync and MoreFutures.runAsync using a wrapper instead of chained stages and multiple completions. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/07 14:15:38 UTC, 7 replies.
- [PR] Add histogram to metrics container [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/07 20:18:16 UTC, 26 replies.
- [PR] [yaml] SpannerIO docs and minor improvments [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/07 22:22:45 UTC, 4 replies.
- [PR] Add kafka sdf poll metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/08 00:20:15 UTC, 0 replies.
- [PR] propogate descriptions for nested Beam Rows during schema translation [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/08 00:40:51 UTC, 4 replies.
- [PR] [yaml] Normalize error_handling docs on API catalog [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/08 00:42:26 UTC, 3 replies.
- [PR] Add a guide to build custom Beam Python SDK image [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/11/08 02:58:50 UTC, 10 replies.
- [PR] Bump golang.org/x/sys from 0.26.0 to 0.27.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/08 04:44:29 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.33 to 1.17.37 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/08 04:45:37 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/datastore from 1.19.0 to 1.20.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/08 04:45:53 UTC, 2 replies.
- Re: [I] [Bug]: Nullness and other validation checks not running on org.apache.beam.runners.dataflow.worker.windmill due to broad generatedClassPatterns [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/08 08:57:02 UTC, 0 replies.
- [PR] ignore overridden setters and getters in JavaBeanSchema [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/11/08 13:12:59 UTC, 3 replies.
- [PR] update 2.60.0 changelog to include a fix in Bigtable [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/11/08 14:15:19 UTC, 7 replies.
- [I] [Bug]: Mutable stringset race condition [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/08 15:44:42 UTC, 2 replies.
- [I] [Task]: Add experiments disable Lineage report [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/08 15:48:55 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.70.0 to 1.72.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/08 16:29:54 UTC, 3 replies.
- Re: [I] [Bug]: ByteBuddy doesn't do well with Map [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/08 16:37:39 UTC, 2 replies.
- [PR] Switch to use ConcurrentMap for StringSetData [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/08 18:16:43 UTC, 9 replies.
- [PR] Don't pin to latest tag [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/08 18:44:06 UTC, 5 replies.
- [PR] Introduce pipeline options to disable user counter and user stringset [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/08 21:01:15 UTC, 9 replies.
- [PR] [yaml] error_handling normalization follow-up [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/08 21:13:28 UTC, 6 replies.
- [PR] Fixed the broken beam python on flink with PortableRunner [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/08 21:46:47 UTC, 3 replies.
- [PR] Lineage support for JdbcIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/08 22:31:51 UTC, 6 replies.
- Re: [PR] [yaml] Add tests for provider schema validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/09 12:43:13 UTC, 2 replies.
- [I] [Feature Request]: Publish Apache Beam SDK as a .tar.gz Archive for Compatibility with `rules_oci` [beam] - posted by "ewianda (via GitHub)" <gi...@apache.org> on 2024/11/09 19:59:01 UTC, 0 replies.
- [I] The PostCommit Python ValidatesContainer Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 03:37:19 UTC, 3 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 03:37:21 UTC, 4 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 03:37:22 UTC, 3 replies.
- [I] The Flaky test detection job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 03:37:25 UTC, 3 replies.
- [I] The Community Metrics Prober job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 03:37:29 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.42 to 1.17.44 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 04:40:47 UTC, 3 replies.
- [PR] Bump golang.org/x/sync from 0.8.0 to 0.9.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 04:40:55 UTC, 1 replies.
- [PR] Bump distlib from 0.3.7 to 0.3.9 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 04:51:38 UTC, 3 replies.
- [PR] Bump mypy-protobuf from 3.5.0 to 3.6.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 04:51:42 UTC, 1 replies.
- [PR] Bump yapf from 0.29.0 to 0.40.2 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 04:51:48 UTC, 3 replies.
- Re: [PR] SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/11/11 08:50:36 UTC, 21 replies.
- Re: [I] [Bug]: FileIO: lack of timeouts may cause the pipeline to get stuck indefinitely [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/11 09:07:30 UTC, 1 replies.
- [PR] Read RabbitMQ messages with headers containing nested objects [beam] - posted by "jonomorris (via GitHub)" <gi...@apache.org> on 2024/11/11 09:58:13 UTC, 9 replies.
- [PR] Fix potential data race in ReadFromKafkaDoFn's AverageRecordSize [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/11 10:36:40 UTC, 0 replies.
- Re: [PR] [KafkaIO] Fix potential data race in ReadFromKafkaDoFn.AverageRecordSize [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/11 10:50:10 UTC, 11 replies.
- Re: [PR] Ts patch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/11 12:45:46 UTC, 2 replies.
- [I] [Bug]: Cross-language pipeline options are not picked up in DoFns [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/11 13:20:35 UTC, 0 replies.
- [I] [Failing Tests]: Many broken Python core tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/11 14:36:55 UTC, 3 replies.
- [PR] Fix exception sampling logic [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/11 14:56:29 UTC, 2 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/11/11 15:01:55 UTC, 1 replies.
- Re: [PR] Added support for reading from multiple topics in MqttIO [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/11/11 15:12:23 UTC, 4 replies.
- [PR] Revert "Update typecheck err msg" [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/11 15:26:03 UTC, 2 replies.
- Re: [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/11/11 15:30:41 UTC, 0 replies.
- [I] [Failing Test]: Fix and re-enable the TensorRT integration test [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/11 16:25:23 UTC, 0 replies.
- [PR] Add issue link to disabled TensorRT integration test [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/11 16:29:02 UTC, 6 replies.
- [PR] Fix antlr analyzeClassesDependencies [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/11 16:45:56 UTC, 4 replies.
- [PR] Update transforms module to PEP 585 type hints [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/11 17:22:13 UTC, 4 replies.
- [PR] Remove nondeterminism from expansion tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/11 17:28:00 UTC, 3 replies.
- [PR] Fix post-commit python failure. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/11/11 20:46:15 UTC, 3 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 2024/11/11 22:14:14 UTC, 1 replies.
- Re: [I] Timers exception on "Job Drain" while using stateful beam processing in global window [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/11/12 01:36:37 UTC, 0 replies.
- [PR] Introduce pipeline option to disable Lineage [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/12 04:32:21 UTC, 2 replies.
- Re: [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/11/12 10:36:54 UTC, 0 replies.
- Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/11/12 13:01:00 UTC, 4 replies.
- [PR] Avoid holding data elements alive via stack frame gc roots. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/12 13:24:23 UTC, 5 replies.
- [PR] Update Enrichment Handlers to PEP 585 typing [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/12 14:41:48 UTC, 2 replies.
- [PR] Fix postcommit python [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/11/12 15:12:51 UTC, 0 replies.
- [PR] Change dead partition detection to only look at the current topic [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/11/12 15:51:55 UTC, 6 replies.
- Re: [PR] Modernize python type hints for apache_beam. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/12 16:24:40 UTC, 11 replies.
- Re: [PR] Revert PR #32960 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/12 16:39:33 UTC, 3 replies.
- [I] [Feature Request]: Add per-worker labelled/histogram metrics to Kafka IO for a Portable Runner [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/12 18:55:57 UTC, 0 replies.
- [I] [Feature Request]: {Managed IO Iceberg} - Allow users to Create BigLake Iceberg External Table if it does not exist [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2024/11/12 19:57:53 UTC, 2 replies.
- [I] [Feature Request]: {Managed IO Iceberg} - Allow users to run streaming reads [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2024/11/12 20:01:16 UTC, 0 replies.
- [I] [Feature Request]: Refactor Histogram Implementation out of DF runner so it can be used by portable and other runners [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/11/12 20:07:36 UTC, 0 replies.
- Re: [I] [Feature Request]: {BIgQuery IO} - Allow users to Create BigQuery tables for Apache Iceberg if it does not exist [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2024/11/12 21:45:06 UTC, 0 replies.
- [PR] [YAML] Add a new StripErrorMetadata transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/12 22:55:03 UTC, 5 replies.
- Re: [PR] Enable configuration of a CDC mutation info Callable for CDC Writes into BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/12 23:35:10 UTC, 2 replies.
- [I] [Task]: Improve the example for PythonExternalTransform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/13 04:30:17 UTC, 0 replies.
- Re: [PR] SolaceIO: refactor to allow inheritance of BasicAuthSempClient [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/13 10:32:56 UTC, 17 replies.
- [I] [Bug]: KafkaIO metrics write per-partition values to per-split metrics [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/13 12:55:51 UTC, 6 replies.
- Re: [I] JdbcIO informix connection problem [beam] - posted by "cwashcraft (via GitHub)" <gi...@apache.org> on 2024/11/13 13:04:51 UTC, 1 replies.
- [I] [Bug]: KafkaIO maintains duplicate caches for record size and offset estimators caches [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/13 13:07:00 UTC, 7 replies.
- Re: [PR] SolaceIO: separate auth and session settings [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/13 13:53:20 UTC, 2 replies.
- [PR] Update dataframes to PEP 585 typing [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/13 15:19:42 UTC, 2 replies.
- [PR] Disable gradle cache for gcp expansion service [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/13 15:35:54 UTC, 1 replies.
- Re: [I] [Feature Request]: Support writing to a Solace message broker [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/13 16:11:40 UTC, 0 replies.
- [PR] Set streaming engine option to fix V1 tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/13 16:21:22 UTC, 4 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 18:39:26 UTC, 5 replies.
- Re: [PR] make FieldValueTypeInformation creators take a TypeDescriptor parameter [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 19:20:13 UTC, 2 replies.
- [PR] Make AvroUtils compatible with older versions of Avro [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 19:23:03 UTC, 2 replies.
- [I] [Feature Request]: Interactive Beam supports asynchronous computations. [beam] - posted by "ganesh4991 (via GitHub)" <gi...@apache.org> on 2024/11/13 19:56:39 UTC, 2 replies.
- Re: [I] [Bug]: search stops working in pydoc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/13 20:10:35 UTC, 0 replies.
- [I] [Bug]: SubProcess Kernel not able to find return file [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/11/13 20:29:27 UTC, 1 replies.
- [I] Dataflow streaming tests failing new AfterSynchronizedProcessingTime test [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 20:45:01 UTC, 1 replies.
- [PR] CP: Make AvroUtils compatible with older versions of Avro (#33102) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 20:48:21 UTC, 3 replies.
- Re: [PR] fix JDBC providers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 20:49:27 UTC, 0 replies.
- [PR] fix JDBC providers (#32985) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 20:50:59 UTC, 2 replies.
- [PR] Update names.py [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/13 21:26:41 UTC, 3 replies.
- [PR] Adds detailed instructions on how to execute ExampleEchoPipeline.java [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/11/13 21:38:55 UTC, 3 replies.
- Re: [PR] CP: fix JDBC providers (#32985) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/13 21:58:26 UTC, 0 replies.
- [I] [Bug]: vLLM inference with direct runner leaves a python process in the background after Beam program terminates [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/11/13 23:35:10 UTC, 1 replies.
- [PR] More complete error message for StripErrorMetadata. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/14 00:24:25 UTC, 4 replies.
- [PR] Bump golang.org/x/net from 0.30.0 to 0.31.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/14 04:11:46 UTC, 3 replies.
- [PR] Bump yapf from 0.29.0 to 0.43.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/14 04:23:23 UTC, 1 replies.
- [PR] Bump com.gradle.develocity from 3.17.6 to 3.18.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/14 04:48:42 UTC, 1 replies.
- [PR] Build docker RC on self-hosted [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 13:23:06 UTC, 3 replies.
- [PR] Add temp location to batch file loads [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/14 14:15:16 UTC, 5 replies.
- [PR] Add 2.62.0 to changes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 14:36:46 UTC, 2 replies.
- [PR] Update website for 2.61.0 release [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 14:46:03 UTC, 6 replies.
- [PR] Fix small typos in release email [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 14:49:07 UTC, 4 replies.
- [PR] Update metrics to PEP 585 typing [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/11/14 15:54:47 UTC, 1 replies.
- Re: [I] [Bug]: SolaceIO does not acknowledge messages [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/11/14 17:21:22 UTC, 1 replies.
- [PR] V2.61.0 rc1 validations [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 18:21:20 UTC, 3 replies.
- [PR] Make the warning about JSON BigQuery column type more precise [beam] - posted by "turb (via GitHub)" <gi...@apache.org> on 2024/11/14 18:50:52 UTC, 6 replies.
- [PR] Update vllm colab to work with asyncio requirements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 19:17:39 UTC, 5 replies.
- [PR] Pin notebook dependencies [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/14 20:24:04 UTC, 4 replies.
- [PR] [yaml] add mysql, oracle, postgres and sql server providers [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/14 21:12:32 UTC, 15 replies.
- [PR] Support creating BigLake managed tables [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/14 22:10:40 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.70.0 to 1.73.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/15 04:34:52 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.33 to 1.17.38 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/15 04:38:26 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.42 to 1.17.45 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/15 04:45:13 UTC, 3 replies.
- [PR] Update gcp-bom to 26.50.0 [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/11/15 16:58:15 UTC, 0 replies.
- Re: [PR] Update the python deps [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/15 17:20:02 UTC, 2 replies.
- Re: [PR] Update gcp-bom to 26.49.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/15 18:02:42 UTC, 4 replies.
- [PR] Disable gradle cache for transform service shadowJar [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/15 19:02:18 UTC, 3 replies.
- Re: [I] [Task]: Upgrade numpy to 2.x. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/15 19:13:30 UTC, 0 replies.
- [PR] Fix vllm typo [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/15 19:53:34 UTC, 2 replies.
- [I] [Bug]: Certain nullable type resolved to not null coder after #32705 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/15 20:38:51 UTC, 6 replies.
- Re: [I] The PostCommit Python Examples Flink job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/15 21:46:33 UTC, 12 replies.
- [PR] Revert "fix schema inference inside parameterized types" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/15 21:49:30 UTC, 2 replies.
- [PR] Enable Dataflow managed service for Python tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/16 00:45:49 UTC, 7 replies.
- [PR] Fix the broken flink tests by optimizing conf [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/16 04:16:59 UTC, 2 replies.
- Re: [PR] do not review [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/16 12:44:53 UTC, 2 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/17 00:38:30 UTC, 3 replies.
- [PR] numpy.int64 type is not serialized correctly in Python 3.11 and Python 3.12 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/17 01:25:14 UTC, 9 replies.
- Re: [PR] [DO NOT REVIEW] Run GHA tests off master branch. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/17 12:44:38 UTC, 2 replies.
- [PR] Use highmem for beam_PostCommit_Python_Examples_Flink.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/17 16:56:45 UTC, 2 replies.
- Re: [I] [Feature Request][Java]:filesToStage should support the gcs file path [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/18 02:02:04 UTC, 1 replies.
- [PR] Bump org.javacc.javacc from 3.0.2 to 3.0.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/18 04:13:32 UTC, 1 replies.
- [PR] Bump github.com/aws/smithy-go from 1.22.0 to 1.22.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/18 05:00:19 UTC, 1 replies.
- [PR] Bump golang.org/x/oauth2 from 0.23.0 to 0.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/18 05:00:27 UTC, 3 replies.
- [PR] Bump google.golang.org/protobuf from 1.35.1 to 1.35.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/18 05:00:32 UTC, 2 replies.
- [PR] add case study for yelp streaming [beam] - posted by "hspandher (via GitHub)" <gi...@apache.org> on 2024/11/18 06:37:05 UTC, 3 replies.
- [I] [Task]: Upgrade Avro to 1.11.4 to fix CVE-2024-47561 [beam] - posted by "fabriciorby (via GitHub)" <gi...@apache.org> on 2024/11/18 09:30:19 UTC, 4 replies.
- [I] [Task]: [flink] reuse StateNamespace#stringKey in state access [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/11/18 09:54:45 UTC, 1 replies.
- [PR] #33145 cache namespace string key in FlinkStateInternals [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/11/18 10:49:52 UTC, 6 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/18 12:46:05 UTC, 2 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 2024/11/18 12:46:08 UTC, 2 replies.
- [PR] CP: Revert "Merge pull request #32705: fix schema inference for parameterized types" (#33133) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 14:04:55 UTC, 3 replies.
- [PR] Catch forbidden errors as notfound [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 14:39:52 UTC, 6 replies.
- [PR] docs: missing word [beam] - posted by "wikey (via GitHub)" <gi...@apache.org> on 2024/11/18 15:03:58 UTC, 2 replies.
- Re: [PR] Fix ParDo#with_exception_handling(timeout) with custom thread class and thread scoped storage in state sampler. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:31:58 UTC, 0 replies.
- Re: [PR] create helper function [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:32:33 UTC, 0 replies.
- Re: [PR] Poll for backlog in background thread instead of inline [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:33:36 UTC, 1 replies.
- Re: [PR] KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:36:26 UTC, 4 replies.
- Re: [PR] [yaml] Add Beam YAML Examples [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:37:51 UTC, 2 replies.
- Re: [PR] Add Kafka 3.1.2 IT target [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:38:38 UTC, 2 replies.
- Re: [PR] Kafka poll interval [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 15:40:12 UTC, 0 replies.
- [PR] Plug transform annotations thru cross-lang interface [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/18 16:07:45 UTC, 3 replies.
- [PR] Use random gcs bucket name [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 16:18:59 UTC, 4 replies.
- [I] [Bug]: BigQuery SchemaUpdateOptions fails depending on dataset size [beam] - posted by "Shuyu-Current (via GitHub)" <gi...@apache.org> on 2024/11/18 16:29:44 UTC, 0 replies.
- [PR] Update BEAM_DEV_SDK_CONTAINER_TAG [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 17:04:50 UTC, 4 replies.
- [PR] Revert "Enable Dataflow managed service for Python tests" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 17:07:35 UTC, 4 replies.
- [PR] Use fallback reviewers for bot [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 18:24:01 UTC, 1 replies.
- [PR] CP: Plug transform annotations thru cross-lang interface (#33150) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 18:29:46 UTC, 4 replies.
- [PR] Don't use __getstate__ for picklign for objects with a custom __reduce__. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/18 19:20:29 UTC, 0 replies.
- [PR] CP: Use random gcs bucket name (#33151) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 19:35:52 UTC, 4 replies.
- Re: [PR] Don't use __getstate__ for pickling for objects with a custom __reduce__. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/18 20:33:43 UTC, 9 replies.
- Re: [PR] Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/18 20:57:15 UTC, 3 replies.
- [PR] Try upgrading to avro 12 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 21:06:44 UTC, 2 replies.
- Re: [PR] Bump avro, fix CVE-2024-47561 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/18 21:07:02 UTC, 3 replies.
- [PR] Create Python SDK Distroless variant [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/19 00:21:16 UTC, 9 replies.
- [PR] updated the yelp blog [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/19 01:40:33 UTC, 2 replies.
- [I] The build_release_candidate job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/19 03:41:45 UTC, 1 replies.
- [PR] Highmem22 runners [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/11/19 11:30:45 UTC, 3 replies.
- [PR] [java] BQ: use logical type in schema factory when enabled [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/11/19 13:17:03 UTC, 0 replies.
- Re: [PR] [java] BQ: use logical type in avro schema factory when enabled [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/19 13:38:56 UTC, 0 replies.
- [PR] test: update protobuf version [beam] - posted by "ldetmer (via GitHub)" <gi...@apache.org> on 2024/11/19 14:18:56 UTC, 0 replies.
- [PR] Add BigQuery enrichment bug to changes.md and blogs [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/19 14:27:14 UTC, 4 replies.
- [I] [Feature Request]: Republish released containers without vulnerabilites [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 14:41:45 UTC, 2 replies.
- [PR] Create workflow for republishing released containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 14:42:16 UTC, 2 replies.
- [PR] Add safe to ignore category to dashboard/alerting [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 14:55:55 UTC, 2 replies.
- [PR] Publish updated containers regularly [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 15:44:59 UTC, 4 replies.
- [PR] Revert "Update vllm colab to work with asyncio requirements" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 15:53:16 UTC, 3 replies.
- Re: [PR] [java] BQ: use logical type in avro schema factory on write [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/19 16:40:38 UTC, 5 replies.
- [PR] Revert "Revert "Update vllm colab to work with asyncio requirements"" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/19 16:46:30 UTC, 4 replies.
- Re: [I] [Bug]: beam_PostCommit_Java_ValidatesRunner_Flink is flakes in org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/19 18:16:20 UTC, 2 replies.
- Re: [PR] Bump zetasql version to 2024.08.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/19 21:28:01 UTC, 0 replies.
- Re: [PR] Bump zetasql version to 2024.11.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/19 22:09:59 UTC, 4 replies.
- Re: [I] The Dask Runner Tests job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/19 23:30:55 UTC, 3 replies.
- Re: [I] [Task]: Update the minor version of cloudpickle library prior to Beam release. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/19 23:46:25 UTC, 0 replies.
- [PR] use the tight range for dask [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/19 23:49:30 UTC, 2 replies.
- [PR] Enable Java SDK Distroless container image variants. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/20 00:17:15 UTC, 6 replies.
- Re: [I] The LoadTests Go GBK Flink Batch job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/20 00:21:26 UTC, 3 replies.
- Re: [I] Support ROW_NUMBER() over [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/20 01:34:09 UTC, 0 replies.
- [PR] Bump org.sonarqube from 3.0 to 6.0.0.5145 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/20 04:59:34 UTC, 6 replies.
- [PR] Change the Java sdk harness cache timeout for bundle processors to be an hour for streaming pipelines instead of 1 minute. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/20 10:08:01 UTC, 8 replies.
- [I] [Feature Request]: OpenTelemetry Support [beam] - posted by "Kludex (via GitHub)" <gi...@apache.org> on 2024/11/20 12:21:04 UTC, 1 replies.
- [PR] Update dask_runner_tests.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/20 12:59:18 UTC, 2 replies.
- [PR] Revert "Fixed the broken beam python on flink with PortableRunner" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/20 16:35:37 UTC, 1 replies.
- [PR] CP: Revert "Fixed the broken beam python on flink with PortableRunner" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/20 17:43:12 UTC, 4 replies.
- [I] [Task]: Add test to avoid Flink container issues [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/20 17:44:09 UTC, 1 replies.
- [PR] Add beam_PostCommit_Python_ValidatesDistrolessContainer_Dataflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/20 20:18:35 UTC, 3 replies.
- [PR] Fix the flink runner doc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/20 20:45:23 UTC, 3 replies.
- Re: [PR] Upgrade GCP-BOM to 26.49.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/20 21:47:31 UTC, 3 replies.
- Re: [I] [Bug]: Python JDBC IO Try To Connect RDB Before Deploying [beam] - posted by "hakimkac99 (via GitHub)" <gi...@apache.org> on 2024/11/21 12:49:29 UTC, 0 replies.
- [PR] Add input boxes for required user inputs [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/11/21 18:19:45 UTC, 4 replies.
- [PR] [yaml] remove PubSubLite from API docs [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/21 18:40:20 UTC, 5 replies.
- [PR] [yaml] add FileIO docs [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/21 19:17:14 UTC, 5 replies.
- [PR] [yaml] Enrichment transform doc improvements [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/11/21 19:41:36 UTC, 3 replies.
- [PR] use direct executor to deflake tests [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/11/21 21:05:14 UTC, 13 replies.
- Re: [PR] Enable external callers to start a WindmillStream [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/11/21 21:11:30 UTC, 0 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/21 22:13:55 UTC, 1 replies.
- [I] [Bug]: Test runner(Oython SDK) fails when generic type is specified as a type for pardo element [beam] - posted by "m-morozov-kw (via GitHub)" <gi...@apache.org> on 2024/11/22 15:18:55 UTC, 2 replies.
- [PR] Enable managed service in Python tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/22 15:23:15 UTC, 4 replies.
- Re: [I] [Bug]: Test runner(Python SDK) fails when generic type is specified as a type for pardo element [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/22 15:57:29 UTC, 2 replies.
- [PR] Remove the default machine types [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/22 17:42:19 UTC, 2 replies.
- [PR] Update gcp bom to 26.50.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/22 18:03:59 UTC, 0 replies.
- [PR] Revert "Bump org.sonarqube from 3.0 to 6.0.0.5145" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/22 18:09:55 UTC, 1 replies.
- Re: [PR] Upgrade to 2.58.1 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/22 18:14:09 UTC, 0 replies.
- [PR] Update beam [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/22 18:14:25 UTC, 1 replies.
- [PR] Update republish workflow with latest beam [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/22 18:15:11 UTC, 0 replies.
- [PR] Simplify metrics in preparation for adding another metric type. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/22 18:18:24 UTC, 4 replies.
- [PR] Add bounded Trie metric type to Python. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/22 18:40:59 UTC, 3 replies.
- [I] [Bug]: BigQueryAvroUtils don't handle Avro FLOAT type correcty. [beam] - posted by "an2x (via GitHub)" <gi...@apache.org> on 2024/11/22 18:45:18 UTC, 3 replies.
- Re: [PR] Integrate direct path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/11/22 19:10:26 UTC, 0 replies.
- [PR] Use --enable-component-gateway when creating the flink cluster [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/22 21:21:19 UTC, 3 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 2024/11/22 22:13:56 UTC, 3 replies.
- [PR] Remove leftover print statement in SpannerIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/22 22:20:01 UTC, 2 replies.
- Re: [I] [Distroless] Publish Python distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/22 23:22:59 UTC, 0 replies.
- [I] [Distroless] Publish Java SDK distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/22 23:24:05 UTC, 1 replies.
- [PR] [DO NOT MERGE] Update go_GBK_Flink_Batch_10b.txt [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/23 03:15:49 UTC, 2 replies.
- Re: [I] [Task]: Use "Distroless" Container Images to reduce potential vulnerabilities for Beam Python SDK containers [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/23 13:41:36 UTC, 1 replies.
- Re: [I] [YAML][Feature Request]: Integration and Usage of GCP Secret Manager with the different Apache Beam IOs [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/11/23 18:41:57 UTC, 0 replies.
- Re: [I] `beam.CombineValues` on DataFlow runner causes ambiguous failure with python SDK [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/23 18:42:17 UTC, 0 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/23 22:14:06 UTC, 1 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/23 22:14:16 UTC, 1 replies.
- [PR] jdbcio write batch config changes [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/24 00:39:27 UTC, 1 replies.
- [PR] Add a new precommit to test finl container [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/24 15:30:47 UTC, 0 replies.
- [PR] [DO NOT MERGE] Create beam_PreCommit_Flink_Container.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/24 15:41:36 UTC, 1 replies.
- Re: [PR] Add a new precommit workflow to test flink container [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/24 16:06:13 UTC, 4 replies.
- Re: [PR] Remove GlobalWindows for unbounded pcoll without a default global window [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/24 21:23:10 UTC, 1 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/24 21:33:52 UTC, 2 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/24 21:33:56 UTC, 10 replies.
- [I] The PostCommit XVR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/24 21:33:59 UTC, 3 replies.
- Re: [I] [Bug]: Add check for self-referencing input in YAML transform [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/24 23:52:26 UTC, 2 replies.
- [PR] Validate circular reference for yaml [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/25 00:00:23 UTC, 1 replies.
- Re: [I] [Bug]: Better error message for specifying inputs on chain pipeline in Beam YAML [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/25 06:41:45 UTC, 1 replies.
- [PR] Better error messaging for chain-type pipelines [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/25 06:43:38 UTC, 2 replies.
- [I] [Feature Request]: Support `OrderedListState` in SparkRunner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/11/25 10:45:56 UTC, 2 replies.
- [PR] Add OrderedListState support for SparkRunner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/11/25 11:19:52 UTC, 5 replies.
- [PR] ZetaSQL test Java version fixes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/25 16:38:46 UTC, 4 replies.
- Re: [I] [Bug]: [Go SDK] periodic.impulse increases Dataflow Backlog time [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/25 16:49:49 UTC, 0 replies.
- [PR] Remove sickbay GitHub Actions [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/25 18:02:56 UTC, 3 replies.
- Re: [I] The PostCommit Sickbay Python job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/25 18:27:45 UTC, 0 replies.
- Re: [I] The PostCommit Java Sickbay job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/25 18:27:46 UTC, 0 replies.
- Re: [I] [Failing Test]: Java Samza runner tests failing on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/25 18:28:54 UTC, 0 replies.
- [PR] [Accenture Baltics] Case Study [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/25 18:53:38 UTC, 3 replies.
- [PR] Make the model names unique [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/25 19:37:21 UTC, 0 replies.
- [PR] Fixed the new flink container precommit [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/25 20:16:21 UTC, 3 replies.
- [PR] Cleanup Iceberg test files [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/25 20:23:48 UTC, 6 replies.
- Re: [PR] Propagate gcs-connector options to GcsUtil [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/11/25 20:38:02 UTC, 4 replies.
- [PR] Fixed beam_PreCommit_Flink_Container.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/25 21:20:55 UTC, 2 replies.
- [I] The PreCommit Flink Container job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/26 03:41:20 UTC, 4 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.60.0 to 2.61.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/26 09:36:03 UTC, 1 replies.
- Re: [I] [Feature Request]: Access GCS bucket with requester pays [beam] - posted by "LeoCBS (via GitHub)" <gi...@apache.org> on 2024/11/26 11:50:41 UTC, 0 replies.
- [PR] [java] BQ: add missing avro conversions to BQ TableRow [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/11/26 11:51:57 UTC, 3 replies.
- Re: [I] [Bug]: Java BundleProcessorCache evicts all processors for a bundle descriptor id after 1 minute of idleness [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/11/26 12:07:25 UTC, 0 replies.
- [PR] Bump apache-beam from 2.60.0 to 2.61.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/26 12:25:05 UTC, 3 replies.
- Re: [PR] KafkaIO SDF: Fetch main data and the end position for each topic-partition tuple in a background thread, reusing consumers. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/11/26 13:08:24 UTC, 0 replies.
- [PR] Update versions of python we test against [beam-starter-python] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/11/26 13:24:14 UTC, 2 replies.
- [PR] updated the pic [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/26 15:42:41 UTC, 2 replies.
- Re: [I] [Bug]: KinesisIO processing-time watermarking can cause data loss [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/26 16:33:33 UTC, 0 replies.
- Re: [I] The TypeScript Tests job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/26 16:35:41 UTC, 1 replies.
- [PR] Increase Go test coverage run timeout to 25 minutes [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/26 16:44:23 UTC, 7 replies.
- Re: [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/26 16:46:02 UTC, 3 replies.
- Re: [I] The Go tests job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/11/26 16:52:15 UTC, 1 replies.
- Re: [I] [Failing Test]: :sdks:python:test-suites:direct:py38:tensorflowInferenceTest fails in Python 3.8 postcommit suite [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/26 17:26:57 UTC, 1 replies.
- [PR] Unpin Dataflow legacy worker container for Nexmark test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/26 17:33:03 UTC, 8 replies.
- Re: [I] [Task]: Document Jinja templatization for yaml [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/11/26 18:00:40 UTC, 2 replies.
- Re: [I] [Distroless] GitHub workflow runs checks on Python SDK (non ML) distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/26 18:04:33 UTC, 0 replies.
- [PR] Changes maxBufferingDuration payload to be taken from millis directly… [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/11/26 18:22:39 UTC, 3 replies.
- [I] [Distroless] GitHub workflow runs checks on Java SDK (non ML) distroless variants [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/26 19:50:40 UTC, 1 replies.
- [PR] Fix python distroless workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/26 20:21:06 UTC, 9 replies.
- Re: [PR] Make the model names unique and fix the tox package deps for tensorflow tests [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/26 21:23:30 UTC, 6 replies.
- [I] [Feature Request]: [beam] - posted by "CWrecker (via GitHub)" <gi...@apache.org> on 2024/11/26 21:24:47 UTC, 0 replies.
- Re: [I] [Feature Request]: Python-based Unbounded WebSocker IO Connector [beam] - posted by "CWrecker (via GitHub)" <gi...@apache.org> on 2024/11/26 21:26:13 UTC, 11 replies.
- [PR] Update beam_PreCommit_Flink_Container.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/26 22:11:07 UTC, 1 replies.
- [PR] Storage API Schema Update with dynamic destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/11/26 22:24:12 UTC, 0 replies.
- [PR] Add Java Distroless Github workflow check [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/26 23:35:26 UTC, 4 replies.
- [PR] fixed ML tests [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/27 01:27:35 UTC, 7 replies.
- [I] The PostCommit Python ValidatesDistrolessContainer Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/27 06:40:16 UTC, 3 replies.
- [PR] Adding Google Storage Requester pays feature to Golang SDK. [beam] - posted by "LeoCBS (via GitHub)" <gi...@apache.org> on 2024/11/27 13:10:15 UTC, 1 replies.
- [I] [Feature Request]: A [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/11/27 14:52:48 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Stateful Processing in Spark Runner (Without Timer Functionality) [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/11/27 14:53:36 UTC, 0 replies.
- [I] [Bug]: BigQueryIO Storage API Schema Update does not work with dynamic destinations [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/11/27 16:43:03 UTC, 0 replies.
- Re: [I] [Task]: Remove archaic PubSubSource and PubSubSink [beam] - posted by "CWrecker (via GitHub)" <gi...@apache.org> on 2024/11/27 17:54:17 UTC, 4 replies.
- [PR] Remove (long) obsolete declaration of unsupported features that are now supported. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/27 18:07:21 UTC, 4 replies.
- [PR] Add a pointer to java provider example. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/11/27 18:13:35 UTC, 2 replies.
- [PR] Update beam_LoadTests_Python_Combine_Flink_Streaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/27 21:35:30 UTC, 0 replies.
- Re: [I] [Task]: Implement CsvIO.Read [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/11/27 22:59:21 UTC, 1 replies.
- [PR] Tour of Beam: update GroupByKey example [beam] - posted by "thread-sleep (via GitHub)" <gi...@apache.org> on 2024/11/27 23:22:40 UTC, 2 replies.
- Re: [I] [CsvIO]: Support non-UTF8 text encoding for parse/reads and writes [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/27 23:23:36 UTC, 0 replies.
- [PR] Bump org.sonarqube from 3.0 to 6.0.1.5171 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/11/28 04:28:32 UTC, 1 replies.
- [I] [Bug]: PostCommit Java ValidatesDistrolessContainer Dataflow needs to set testJavaVersion gradle property [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/28 05:06:36 UTC, 0 replies.
- [PR] Fix java validatesdistrolesscontainer dataflow workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/11/28 07:03:34 UTC, 4 replies.
- [I] The PostCommit Java ValidatesDistrolessContainer Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/28 09:36:19 UTC, 0 replies.
- [PR] Refactor FnHarness and FinalizeBundleHandler to use ScheduledExecutorService instead of ExecutorService. [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/11/28 13:43:41 UTC, 1 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "serratedserenade (via GitHub)" <gi...@apache.org> on 2024/11/29 05:08:19 UTC, 2 replies.
- Re: [PR] poc: python translation phase that replaces GBK+CombineValue pairs with CombinePerKey [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/11/29 12:46:11 UTC, 0 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 2024/11/29 22:13:53 UTC, 0 replies.
- [PR] Tour of Beam: formatting/typos [beam] - posted by "thread-sleep (via GitHub)" <gi...@apache.org> on 2024/11/30 16:55:57 UTC, 1 replies.