github@beam.apache.org, 2024-09

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

- Re: [PR] 2.59.0 Beam site updates. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/01 12:14:04 UTC, 3 replies.
- Re: [PR] Revert "Download BQMS catalog jar at build time" [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/01 12:17:54 UTC, 1 replies.
- Re: [PR] Eliminate testRuntimeMigration for extensions-avro project dependency [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/01 12:42:52 UTC, 2 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/01 12:42:58 UTC, 1 replies.
- Re: [I] [Feature Request]: Docker images with both runtime and launch environments [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/02 01:14:34 UTC, 1 replies.
- Re: [I] [Bug]: TextIO.read() with non-default delimiter doesn't split at the right position [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/02 02:18:57 UTC, 1 replies.
- Re: [PR] Fix TextIO.read() split with non-default delimiter [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/02 02:20:31 UTC, 0 replies.
- Re: [PR] Address a data race on numMessages in DirectStreamObserver.java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/02 12:44:59 UTC, 2 replies.
- Re: [I] [Feature Request]: Add examples for using metrics with Python to Beam Website [beam] - posted by "shreyakri026 (via GitHub)" <gi...@apache.org> on 2024/09/03 11:01:18 UTC, 7 replies.
- [I] [Bug]: Java generated RowCoder doesn't use encodingPositions when encoding/decoding the null set [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/03 11:19:15 UTC, 1 replies.
- Re: [I] [Bug]: Schema inference is non-deterministic [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/03 11:25:47 UTC, 1 replies.
- Re: [PR] added methods for support ValueProvider in `MqttIO` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/03 12:14:08 UTC, 11 replies.
- Re: [PR] [yaml] Add tests for provider schema validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/03 12:14:11 UTC, 1 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/09/03 12:14:15 UTC, 24 replies.
- [PR] Fix RowCoderGenerator to use the encodingPositions when encoding and decoding the bit set representing null fields. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/03 12:55:01 UTC, 10 replies.
- Re: [PR] Colab Notebook for Unit Tests in Beam [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/09/03 15:35:48 UTC, 7 replies.
- Re: [PR] Cherrypicking 32363 hive-exec shading fix [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/03 16:05:21 UTC, 2 replies.
- Re: [PR] Fix BQ storage stream split [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/09/03 16:50:42 UTC, 0 replies.
- Re: [PR] Integrate direct path/fan out logic [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/09/03 18:08:24 UTC, 0 replies.
- Re: [PR] Add WindowedValueParam option to DoFns. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/03 18:33:48 UTC, 0 replies.
- Re: [PR] [YAML] Better errors for unconsumed error outputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/03 18:38:25 UTC, 0 replies.
- Re: [PR] Use proper coders in interactive cache. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/03 18:39:30 UTC, 0 replies.
- Re: [PR] Kafka poll interval [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/09/03 20:19:52 UTC, 1 replies.
- Re: [PR] [yaml] Adding Spanner IO Providers for Beam YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/09/03 20:44:59 UTC, 11 replies.
- Re: [PR] Fix writing raw messages to pubsub [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/03 22:38:28 UTC, 4 replies.
- Re: [PR] Allow ib.collect to work with non-interactive runners. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/03 22:39:24 UTC, 0 replies.
- [PR] Bump actions/download-artifact from 3 to 4.1.7 in /.github/workflows [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/03 22:42:52 UTC, 5 replies.
- [PR] Upgrade artifact actions to v4 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/03 23:50:17 UTC, 2 replies.
- [PR] Allow ib.collect(...) to take multiple PCollections. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/04 00:22:35 UTC, 4 replies.
- [PR] Bump cryptography from 43.0.0 to 43.0.1 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 00:37:37 UTC, 3 replies.
- Re: [I] [Bug]: Python 3.10 installing `apache-beam==2.43.0` with `multiprocess>=0.70.12` has incompatibility for `dill` [beam] - posted by "BigBird01 (via GitHub)" <gi...@apache.org> on 2024/09/04 04:27:16 UTC, 0 replies.
- [PR] Bump google.golang.org/api from 0.192.0 to 0.196.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 04:29:20 UTC, 3 replies.
- Re: [PR] Bump google.golang.org/api from 0.192.0 to 0.195.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 04:29:22 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.60.0 to 1.61.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 04:36:19 UTC, 4 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.60.0 to 1.61.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 04:36:22 UTC, 1 replies.
- [PR] Bump actions/download-artifact from 4.1.7 to 4.1.8 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 04:46:11 UTC, 2 replies.
- Re: [PR] Add jobLabelsMap parameter to BigQueryOptions [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/09/04 06:52:46 UTC, 3 replies.
- Re: [I] [Bug]: Unable to use KafkaIO with Flink Runner [beam] - posted by "prakhar-clarity (via GitHub)" <gi...@apache.org> on 2024/09/04 07:58:04 UTC, 0 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/04 08:32:32 UTC, 11 replies.
- Re: [I] BigQueryIO.read(SerializableFunction): Collect records that could not be parsed into the custom-typed object into a PCollection of TableRows [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/04 09:12:02 UTC, 1 replies.
- Re: [I] Add BigQuery Avro logical type support on read [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/04 09:21:16 UTC, 1 replies.
- Re: [PR] SolaceIO write connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 12:14:11 UTC, 84 replies.
- Re: [PR] [Python] Add a couple quality-of-life improvemenets to `testing.util.assert_that` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/04 12:14:13 UTC, 2 replies.
- Re: [I] [Failing Test]: [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/04 17:58:10 UTC, 1 replies.
- Re: [I] Add Utility BiTemporalStreamJoin [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/09/04 20:22:44 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.60.0 to 1.61.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 04:56:44 UTC, 3 replies.
- [PR] [WIP] Use a finite state machine for delimiter search in TextIO [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/05 06:27:23 UTC, 0 replies.
- Re: [PR] Use a finite state machine for delimiter search in TextIO [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/05 07:59:23 UTC, 2 replies.
- [PR] Set a UUID when building a Schema object. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/05 10:43:24 UTC, 9 replies.
- Re: [PR] Bump commons-cli:commons-cli from 1.8.0 to 1.9.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 12:14:03 UTC, 1 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/09/05 12:14:05 UTC, 4 replies.
- Re: [PR] make FieldValueTypeInformation creators take a TypeDescriptor parameter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 12:14:06 UTC, 5 replies.
- Re: [PR] Add logging for DataChangeRecord and ChangeStreamQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 12:14:08 UTC, 1 replies.
- Re: [PR] implementation equals and hashCode of FlinkOrderedListState [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 12:44:48 UTC, 1 replies.
- [PR] SolaceIO: refactor to allow inheritance of BasicAuthSempClient [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/09/05 14:18:50 UTC, 1 replies.
- Re: [I] [Failing Test]: Python BigQuery Test - PipelineBasedStreamingInsertTest::tes_batch_size_with_auto_sharding_0 is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/05 15:27:07 UTC, 1 replies.
- Re: [PR] Rag opensearch usecase with Beam's MLTransform [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/05 15:46:36 UTC, 5 replies.
- [PR] Undo part of artifact action upgrade to fix workflow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/05 16:32:31 UTC, 2 replies.
- Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/05 16:38:46 UTC, 1 replies.
- Re: [PR] Support Zstd codec in SerializableAvroCodecFactory [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/09/05 17:25:20 UTC, 6 replies.
- [PR] Kafka metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/09/05 19:30:04 UTC, 10 replies.
- Re: [I] [Feature Request]: Upgrade or provide ETA on dill [beam] - posted by "poffdeluxe (via GitHub)" <gi...@apache.org> on 2024/09/05 20:28:59 UTC, 0 replies.
- [PR] Bump jinja2 version to resolve vulnerability [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/06 00:41:53 UTC, 4 replies.
- Re: [PR] Use Knuth–Morris–Pratt algorithm for delimiter search in TextIO [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/06 02:54:58 UTC, 14 replies.
- Re: [I] [Feature Request]: Include keyrings.google-artifactregistry-auth in Python SDK container [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/06 06:36:07 UTC, 1 replies.
- [PR] Add keyrings.google-artifactregistry-auth [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/09/06 06:51:28 UTC, 9 replies.
- Re: [PR] Bump webpack from 5.76.1 to 5.94.0 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/06 12:14:03 UTC, 1 replies.
- Re: [PR] Bump jinja2 to 3.1.4 to resolve vulnerability issue [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/06 15:53:39 UTC, 0 replies.
- [PR] Bump typescript to version 5.5.4. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/06 16:20:40 UTC, 0 replies.
- [PR] SolaceIO: separate auth and session settings [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/09/06 17:47:52 UTC, 1 replies.
- Re: [I] [Bug]: Python GCSFileSystem.delete does not recursively delete [beam] - posted by "tsafacjo (via GitHub)" <gi...@apache.org> on 2024/09/06 22:22:52 UTC, 2 replies.
- [PR] [Dataflow Streaming] Move `throwExceptionOnLargeOutput` out of OperationalLimits [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/06 23:36:06 UTC, 4 replies.
- [PR] [WIP] [Dataflow Streaming] Add support to read user worker settings from backend [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/07 02:13:33 UTC, 0 replies.
- Re: [PR] Bump micromatch from 4.0.2 to 4.0.8 in /website/www [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/07 12:13:52 UTC, 2 replies.
- Re: [PR] Add RowStringInterpolator utility [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/07 12:13:53 UTC, 12 replies.
- Re: [PR] Add RowFilter utility [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/07 12:13:55 UTC, 17 replies.
- Re: [PR] Fix Kafka with Redistribute [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/07 12:13:55 UTC, 11 replies.
- [PR] [Python] Add the "no_wait_until_finish" option without waiting [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/08 01:26:43 UTC, 2 replies.
- Re: [PR] Update RowJsonUtils.java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/08 12:42:44 UTC, 2 replies.
- Re: [PR] [Dataflow Streaming] Add support to read user worker settings from backend [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/08 20:59:30 UTC, 22 replies.
- [PR] [WIP] Do not merge: Vllm model handler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/09 00:21:35 UTC, 0 replies.
- Re: [I] [Bug]: IndexOutOfBoundsException in TextIO.Read with non-default delimiter [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/09 08:04:01 UTC, 0 replies.
- Re: [PR] Unit Testing in Beam Blog Post [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/09 12:45:10 UTC, 12 replies.
- [PR] Bump spanner max bound back to <4 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/09 14:30:08 UTC, 3 replies.
- Re: [PR] [yaml] Move js2py package to yaml deps [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/09 14:37:35 UTC, 0 replies.
- Re: [I] Bigquery import/export should transfer dataflow labels to load job [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/09 15:14:07 UTC, 0 replies.
- Re: [I] [Feature Request]: BigQueryIO.TypedRead should have setLabel function to set labels for BigQuery commands [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/09 15:14:07 UTC, 0 replies.
- Re: [I] [Bug]: Python sdk data plane can become stuck on instructions that had an exception while calling BundleProcessor setup [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/09 15:48:49 UTC, 0 replies.
- Re: [PR] [yaml] Add examples for Spanner IO in YAML [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/09/09 15:54:11 UTC, 5 replies.
- Re: [I] Can not publish pubsub message with ordering key [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/09 16:03:10 UTC, 1 replies.
- Re: [PR] Move PubsubIO source Lineage report to MapElements [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/09 16:20:25 UTC, 2 replies.
- Re: [I] [Feature Request]: Support Zstd codec in SerializableAvroCodecFactory [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/09 16:53:14 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/09 16:54:51 UTC, 1 replies.
- Re: [I] [Bug]: Write to bigquery python SDK [beam] - posted by "altonotch (via GitHub)" <gi...@apache.org> on 2024/09/09 18:36:27 UTC, 0 replies.
- [PR] Upgrade gcp-bom to 26.45.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/09 19:07:14 UTC, 5 replies.
- Re: [I] [Feature Request]: Support Beam Python on macos arm64. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/09 19:26:50 UTC, 2 replies.
- Re: [I] adding extra_header causing issue while reading GCS file in colab [beam] - posted by "matiasblancor (via GitHub)" <gi...@apache.org> on 2024/09/09 20:40:22 UTC, 0 replies.
- [PR] [Prism] Remove unused code [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/09 22:10:07 UTC, 8 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.41.0 to 1.43.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/10 04:20:49 UTC, 3 replies.
- Re: [PR] Bump cloud.google.com/go/pubsub from 1.41.0 to 1.42.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/10 04:20:52 UTC, 1 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/10 06:38:02 UTC, 3 replies.
- [I] [Bug]: How to run YAML pipeline from Python SDK rather than from command line [beam] - posted by "diptenduLF (via GitHub)" <gi...@apache.org> on 2024/09/10 12:48:55 UTC, 2 replies.
- [PR] [yaml] Add Beam YAML Examples [beam] - posted by "eder001 (via GitHub)" <gi...@apache.org> on 2024/09/10 15:16:38 UTC, 20 replies.
- [I] [RRIO] [Task]: Add withErrorHandler to accept ErrorHandler.BadRecordErrorHandler [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/10 16:12:01 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/10 16:45:12 UTC, 0 replies.
- [PR] Dont run flaky test on windows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/10 17:05:30 UTC, 3 replies.
- Re: [I] The PostCommit XVR Direct job is flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/10 18:22:18 UTC, 3 replies.
- Re: [PR] Remove beam summit banner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/10 19:05:46 UTC, 3 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/10 21:33:42 UTC, 2 replies.
- [PR] Disable permared go xlang tests. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/10 22:11:36 UTC, 3 replies.
- [PR] [DO NOT REVIEW] Run GHA tests off master branch. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/10 23:00:24 UTC, 1 replies.
- [PR] [Prism] Support BundleFinalization DoFn parameter [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/11 01:32:29 UTC, 12 replies.
- [PR] Bump google.golang.org/api from 0.192.0 to 0.197.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/11 04:17:32 UTC, 3 replies.
- [PR] Bump com.gradle.develocity from 3.17.6 to 3.18.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/11 04:47:48 UTC, 1 replies.
- Re: [PR] Bump com.gradle.develocity from 3.17.6 to 3.18 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/11 04:47:50 UTC, 1 replies.
- [PR] Gcsio throttling counter [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/11 04:51:48 UTC, 0 replies.
- Re: [PR] Add throttling counter in gcsio [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/11 05:36:25 UTC, 2 replies.
- Re: [PR] Update postgresql to 42.7.3 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/11 12:45:07 UTC, 2 replies.
- Re: [I] Have a --wait_until_finish=[True|False] pipeline option [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/11 14:03:23 UTC, 0 replies.
- [PR] Remove Python 3.8 GitHub Actions Runs [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/11 14:11:17 UTC, 12 replies.
- [PR] Add Lineage metrics to Python PubsubIO, BigtableIO, FileIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/11 16:57:19 UTC, 9 replies.
- [I] [Task]: Use the latest version of pip instead of a pinned version [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/11 17:08:43 UTC, 1 replies.
- [PR] Pin pip version to 24.1 so pip check wont't fail [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/11 18:00:07 UTC, 2 replies.
- [PR] [do not review ] - poking at postcommit permared suite [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/11 18:20:09 UTC, 2 replies.
- [PR] Accept runner and options in ib.collect. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/11 18:30:13 UTC, 3 replies.
- Re: [I] [Task]: Deprecate Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/11 20:16:05 UTC, 0 replies.
- Re: [I] [Task]: Migrate to build with Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/11 20:17:38 UTC, 0 replies.
- Re: [I] [Task]: Remove archaic PubSubSource and PubSubSink [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/11 21:26:57 UTC, 1 replies.
- [PR] Fixes link typo in 2.59, and fixes archive links. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/11 22:55:10 UTC, 3 replies.
- [PR] Add missing test to test added commit stage is added if enabled. [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/09/11 23:47:59 UTC, 6 replies.
- [PR] Ts patch [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/12 00:44:45 UTC, 0 replies.
- [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/09/12 01:14:55 UTC, 3 replies.
- Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.58.0 to 2.58.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/12 01:14:58 UTC, 3 replies.
- Re: [PR] Temporarily fix pip check failure on xgboost and grpcio [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/12 01:32:45 UTC, 7 replies.
- [PR] Bump org.apache.beam:beam-runners-direct-java from 2.58.0 to 2.59.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/12 01:43:23 UTC, 2 replies.
- Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.58.0 to 2.58.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/12 01:43:25 UTC, 1 replies.
- Re: [I] [Bug]: Flink runner fails with "The job graph is cyclic." [beam] - posted by "sdcys-github (via GitHub)" <gi...@apache.org> on 2024/09/12 07:37:53 UTC, 3 replies.
- Re: [PR] Improve Datastream for batch performances [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/09/12 09:17:09 UTC, 0 replies.
- [PR] Julient/batch datastream [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/09/12 09:18:55 UTC, 0 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.58.1 to 2.59.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/12 09:24:13 UTC, 1 replies.
- [PR] Bump apache-beam from 2.58.1 to 2.59.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/12 12:55:45 UTC, 1 replies.
- Re: [PR] Add correct shutdown mechanics for direct path [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/12 13:07:14 UTC, 40 replies.
- Re: [I] [Bug]: Golang SDK doesn't work with bigquery.NullDate [beam] - posted by "stefan-ceparu-fy (via GitHub)" <gi...@apache.org> on 2024/09/12 16:05:44 UTC, 0 replies.
- [PR] Update beam-starter-java to use Beam 2.59.0 [beam-starter-java] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/12 17:21:34 UTC, 1 replies.
- Re: [I] [Feature Request]: Set quota project in `beam.io.ReadFromBigQuery` [beam] - posted by "eminik (via GitHub)" <gi...@apache.org> on 2024/09/12 17:32:52 UTC, 1 replies.
- [I] [Bug]: Playground needs to be updated to use a more recent version of Go (minimum Go 1.21) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/12 18:01:26 UTC, 1 replies.
- [PR] Rollback Bigtable throttling counter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/12 18:04:22 UTC, 10 replies.
- [PR] Don't override existing consumer config values KafkaIO xlang [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/09/12 18:05:51 UTC, 3 replies.
- [PR] Update Playground and other location usage of Go to use latest released version by default. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/12 18:22:00 UTC, 5 replies.
- [PR] Add various utility meta-transforms to Beam. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/12 19:48:52 UTC, 4 replies.
- Re: [I] The PreCommit GoPortable job is flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/12 21:22:48 UTC, 4 replies.
- [PR] [do not review] downgrade grpc [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/12 21:31:29 UTC, 1 replies.
- [PR] [do not review] beam_PreCommit_GoPortable - downgrade grpc [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/12 21:36:38 UTC, 1 replies.
- [I] [Bug]: `TestPipeline` Behavior Different on Windows vs Linux [beam] - posted by "jd185367 (via GitHub)" <gi...@apache.org> on 2024/09/12 21:51:32 UTC, 0 replies.
- [PR] downgrade grpc [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/12 23:23:22 UTC, 5 replies.
- [PR] `@JsonIgnore` causes emulator endpoint to be missing in DoFn's [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/09/13 07:42:53 UTC, 7 replies.
- Re: [PR] [flink-runner] Improve Datastream for batch performances [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/13 10:37:27 UTC, 3 replies.
- [PR] Support Managed Iceberg streaming writes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/13 15:31:33 UTC, 10 replies.
- [PR] fix: use threadsafe data structure thats shared between threads [beam] - posted by "igorbernstein2 (via GitHub)" <gi...@apache.org> on 2024/09/13 17:19:47 UTC, 1 replies.
- [PR] Bump Python SDK container for Dataflow [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/09/13 17:55:11 UTC, 2 replies.
- [PR] fix: ensure that all outstanding future have completed in FinishBundle [beam] - posted by "igorbernstein2 (via GitHub)" <gi...@apache.org> on 2024/09/13 18:25:25 UTC, 10 replies.
- [PR] fix: ensure that non ApiExceptions in handleMutationException are not… [beam] - posted by "igorbernstein2 (via GitHub)" <gi...@apache.org> on 2024/09/13 18:28:04 UTC, 1 replies.
- [PR] Kafka fix [beam] - posted by "Dippatel98 (via GitHub)" <gi...@apache.org> on 2024/09/13 20:20:50 UTC, 0 replies.
- Re: [PR] ReadFromKafkaDoFn: handle failed seek [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/13 22:05:50 UTC, 25 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/09/13 22:16:03 UTC, 1 replies.
- Re: [PR] Bump cloud.google.com/go/datastore from 1.17.1 to 1.19.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/13 22:23:22 UTC, 1 replies.
- [I] [Bug]: Incorrect Output for Beam SQL MONTH and YEAR window queries [beam] - posted by "experiencedProcrastinator (via GitHub)" <gi...@apache.org> on 2024/09/14 11:05:59 UTC, 0 replies.
- Re: [PR] (beam-31896) Upgrade gcs-connector to 3.0.1, Hadoop to 3.3.6 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/14 12:43:12 UTC, 2 replies.
- [PR] fix docker compose command [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/09/14 18:05:17 UTC, 7 replies.
- [PR] Add the script to extract docs from the dev list [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/14 19:02:33 UTC, 4 replies.
- [I] [Bug]: PubsubIO on Flink Runner not acknowledging old messages [beam] - posted by "xzhang2sc (via GitHub)" <gi...@apache.org> on 2024/09/15 01:24:04 UTC, 8 replies.
- [I] [Bug]: Error when using ReadFromCsv to read non-utf8 encoding file [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/15 03:28:03 UTC, 2 replies.
- [PR] Fix non-utf8 encoding problem in ReadFromCsv and WriteToCsv. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/15 04:51:38 UTC, 16 replies.
- [PR] Add information on python metrics to the programming guide [beam] - posted by "boomanaiden154 (via GitHub)" <gi...@apache.org> on 2024/09/15 06:04:33 UTC, 5 replies.
- Re: [PR] Check and warn if soft delete policy is enabled for temporary bucket [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/15 12:43:36 UTC, 2 replies.
- [PR] feat: add topic existing validation [beam] - posted by "proost (via GitHub)" <gi...@apache.org> on 2024/09/15 15:11:43 UTC, 0 replies.
- Re: [PR] fix: add topic existing validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/15 16:38:30 UTC, 13 replies.
- [PR] Bump golang.org/x/text from 0.17.0 to 0.18.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/16 04:45:00 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.27.28 to 1.27.33 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/16 04:46:47 UTC, 3 replies.
- Re: [I] [Bug]: windmillServiceCommitThreads option can lead to ConcurrentModificationException and stuck commits [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/16 10:01:26 UTC, 0 replies.
- [I] [Feature Request]: Topic array support for MqttIO.Read [beam] - posted by "SamLeurink (via GitHub)" <gi...@apache.org> on 2024/09/16 13:49:36 UTC, 0 replies.
- [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/09/16 17:10:29 UTC, 0 replies.
- [PR] Add support for dynamic write in `MqttIO` [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/09/16 17:12:19 UTC, 9 replies.
- [PR] Update Dataflow internal client test [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/16 18:36:44 UTC, 14 replies.
- Re: [PR] Add throttling counter in gcsio and refactor retrying [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/16 18:44:07 UTC, 23 replies.
- [PR] Fix macos tox.ini definition [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/16 18:57:10 UTC, 2 replies.
- [I] [Feature Request]: Add soft-deadline before 1 minute hard-deadline to Spanner Change Stream IO connector [beam] - posted by "dedocibula (via GitHub)" <gi...@apache.org> on 2024/09/16 19:28:38 UTC, 1 replies.
- [PR] [feat 32473] Added soft deadline logic to Spanner Change Stream IO connector. [beam] - posted by "dedocibula (via GitHub)" <gi...@apache.org> on 2024/09/16 19:34:14 UTC, 4 replies.
- [PR] Restore mypy ignore[call-arg] in yaml_io.py [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/16 19:58:19 UTC, 5 replies.
- [PR] do not review [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/16 20:10:21 UTC, 0 replies.
- [PR] Bump dompurify from 2.3.3 to 2.5.6 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/16 20:57:17 UTC, 1 replies.
- Re: [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] - posted by "xzhang2sc (via GitHub)" <gi...@apache.org> on 2024/09/16 22:07:55 UTC, 0 replies.
- Re: [I] [Bug]: cloudpickle appears to incorrectly unpickle cloned combiners [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/16 22:14:22 UTC, 1 replies.
- [PR] Better error message for incorrect pipeline options flags. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/16 22:29:24 UTC, 5 replies.
- [PR] Bump golang.org/x/sys from 0.24.0 to 0.25.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/17 04:26:46 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.27.28 to 1.27.34 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/17 04:27:57 UTC, 2 replies.
- [I] [Bug]: tour of beam content cannot be scrolled on ipad [beam] - posted by "captainhunt (via GitHub)" <gi...@apache.org> on 2024/09/17 06:08:27 UTC, 0 replies.
- Re: [PR] Initial Commit for AvroPayloadSerializer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/17 12:45:25 UTC, 2 replies.
- [PR] Improve BQ avro handling [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/17 13:15:46 UTC, 0 replies.
- Re: [PR] [WIP] Remove Python 3.8 targets from Actions [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/17 14:29:17 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] Python 3.8 deprecation workflow validation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/17 14:29:27 UTC, 0 replies.
- Re: [PR] [WIP] Remove Python 3.8 Support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/17 14:29:46 UTC, 0 replies.
- [I] [Bug]: NPE on JmsIO [beam] - posted by "flo076 (via GitHub)" <gi...@apache.org> on 2024/09/17 15:05:05 UTC, 2 replies.
- Re: [PR] Improve BQ <-> Avro conversions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/17 15:05:55 UTC, 10 replies.
- [PR] Warn when using Beam with Python 3.8 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/17 16:00:16 UTC, 3 replies.
- [I] [CsvIO]: Support non-UTF8 text encoding for parse/reads and writes [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/17 16:39:58 UTC, 0 replies.
- [PR] Upgrade default kafka from 2.4.1 to 3.1.2 [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/09/17 17:39:20 UTC, 3 replies.
- [PR] Update python SDK container [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/17 18:38:52 UTC, 5 replies.
- [PR] Update run_inference_huggingface.ipynb [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/17 18:59:05 UTC, 1 replies.
- Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/17 19:10:38 UTC, 0 replies.
- [PR] Fix JmsIO NPE [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/17 19:13:07 UTC, 4 replies.
- [I] [Feature Request]: Add option to set maximum Storage API streams when using autosharding [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/17 21:09:35 UTC, 0 replies.
- [PR] Publish Java Expansion Service SNAPSHOT containers [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/09/17 22:50:50 UTC, 3 replies.
- [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/18 00:38:17 UTC, 0 replies.
- [PR] Disable a permared suite. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/18 00:47:26 UTC, 15 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.32 to 1.17.33 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 04:59:58 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 27.1.2+incompatible to 27.2.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 05:00:08 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.18 to 2.10.20 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 05:00:23 UTC, 3 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.16.1 to 1.17.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 05:00:30 UTC, 2 replies.
- Re: [PR] Fix MongoDB connector to handle out-of-range dates [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 12:44:47 UTC, 2 replies.
- [I] [Bug]: minimal wordcount golang example is freezeing on gcs reading [beam] - posted by "LeoCBS (via GitHub)" <gi...@apache.org> on 2024/09/18 12:59:04 UTC, 8 replies.
- Re: [I] Populate labels and custom metadata on VMs that serves Dataflow [beam] - posted by "tahsib-optimizely (via GitHub)" <gi...@apache.org> on 2024/09/18 13:25:49 UTC, 0 replies.
- [PR] Restore release-essential references to 3.8 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/18 14:07:43 UTC, 2 replies.
- Re: [I] [Feature Request]: Improve performance of generating successful writes in Java's BigqueryIO connector [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/18 14:46:16 UTC, 1 replies.
- Re: [PR] Clarify error handling parameter in yaml docs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/18 17:10:32 UTC, 1 replies.
- [PR] Emit warning when Matt waiting for connection for extended period of time [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/18 18:19:46 UTC, 3 replies.
- [I] [Bug]: Pipeline may stuck after error thrown in transform due to racing condition in CancellableQueue [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/18 22:53:27 UTC, 0 replies.
- Re: [PR] Emit warning when Mqtt waiting for connection for extended period of time [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/18 23:06:24 UTC, 1 replies.
- [PR] [WIP] [Dataflow Streaming] Use separate heartbeat streams based on job settings [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/19 02:55:18 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.12 to 1.17.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/19 04:54:52 UTC, 3 replies.
- Re: [I] Clickhouse test failures [beam] - posted by "kusut (via GitHub)" <gi...@apache.org> on 2024/09/19 08:31:33 UTC, 0 replies.
- [PR] Change PeriodicSequence to report backlog accurately [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/19 09:48:50 UTC, 6 replies.
- [I] [Bug]: PeriodicSequence reports large amount of remaining work / size when used with infinite stop time [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/19 10:35:48 UTC, 2 replies.
- Re: [I] MqttIOTest.testRead is flaky (sickbayed) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/19 14:11:48 UTC, 0 replies.
- [PR] Add runners/prism/java to java PreCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/19 14:47:03 UTC, 3 replies.
- Re: [PR] [yaml] Add enrichment transform to Beam YAML [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/19 16:06:53 UTC, 3 replies.
- [I] [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew [beam] - posted by "ns-shua (via GitHub)" <gi...@apache.org> on 2024/09/19 18:13:50 UTC, 15 replies.
- [I] [Bug]: Unable to Restart Google Spanner Change Streams Consumer due to tableExists(table_name) bug [beam] - posted by "NimzyMaina (via GitHub)" <gi...@apache.org> on 2024/09/19 19:30:21 UTC, 9 replies.
- [PR] Fix tableExists() method [beam] - posted by "NimzyMaina (via GitHub)" <gi...@apache.org> on 2024/09/19 19:58:00 UTC, 4 replies.
- Re: [PR] [Go SDK] Resolve dependecy bump (pubsub,fake-gcs-server) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/19 20:41:32 UTC, 0 replies.
- Re: [PR] Support Map and Arrays of Maps in BQ for StorageWrites for Beam Rows [beam] - posted by "JohnZZGithub (via GitHub)" <gi...@apache.org> on 2024/09/20 01:03:24 UTC, 2 replies.
- [PR] [Dataflow Streaming] Use separate heartbeat streams based on job settings [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/20 04:20:09 UTC, 12 replies.
- Re: [PR] [Dataflow Streaming] Use isolated windmill streams based on job settings [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/09/20 05:30:37 UTC, 13 replies.
- [PR] Support Map and Arrays of Maps in BQ for StorageWrites API for Beam Rows [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/09/20 06:28:16 UTC, 4 replies.
- [PR] [WIP] fix backlog bytes periodicsequence in python and go sdks to not include future outputs [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/20 12:17:30 UTC, 1 replies.
- [PR] BigQuery trim schema with selected fields [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/20 13:24:07 UTC, 8 replies.
- [PR] BigQuey fix invalid null checks in io translation [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/09/20 13:43:48 UTC, 1 replies.
- [PR] [Python] Allow ints to be considered as floats/complexes and floats as complexes [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/20 14:15:49 UTC, 4 replies.
- [PR] Fix bug where WorkerHandlerManager.close_all re-initialized state with incorrect dict type [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/20 14:44:07 UTC, 0 replies.
- Re: [PR] [Python] Fix bug where WorkerHandlerManager.close_all re-initialized state with incorrect dict type [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/20 15:06:18 UTC, 1 replies.
- Re: [I] Dataflow runner does not respect ParDo's lifecycle on case of exceptions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/20 16:36:59 UTC, 0 replies.
- [PR] Fix internal unit test failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/20 17:15:17 UTC, 5 replies.
- [I] [Bug]: ParDoLifeCycleTest in Stateful DoFn fails on Samza PVR runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/20 19:18:59 UTC, 0 replies.
- [PR] Include jamm as runtime dependency in expansion-service [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/09/20 19:24:14 UTC, 4 replies.
- [PR] Invoke teardown when DoFn throws in portable runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/20 19:24:38 UTC, 13 replies.
- [PR] [WIP] Enable CDC configuration for cross language StorageWrite API usage [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/09/20 19:44:38 UTC, 4 replies.
- Re: [PR] [GCSIO] Fix internal unit test failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/20 21:28:16 UTC, 7 replies.
- [PR] Remove debug leftover [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/20 21:34:01 UTC, 4 replies.
- [PR] Add schrodinger logo [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/20 21:48:55 UTC, 4 replies.
- [PR] [#32498][prism] Add split / progress back off + catch-up. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/20 21:54:53 UTC, 6 replies.
- [I] [Feature Request]: Enable CDC configuration for cross language StorageWrite API usage [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/09/20 22:51:09 UTC, 1 replies.
- [I] [Feature Request]: vLLM model handler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/21 03:24:19 UTC, 0 replies.
- Re: [PR] [BEAM-3194] Fail if @RequiresStableInput is used on runners that don't supoort it [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/09/21 06:01:13 UTC, 1 replies.
- [PR] [WIP] Enable BigQuery CDC configuration for Python BigQuery sink [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/09/21 07:26:47 UTC, 3 replies.
- [PR] Move assert into pipeline [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/21 15:55:27 UTC, 4 replies.
- Re: [I] [Prism] Support Bundle Finalization [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/21 16:41:49 UTC, 0 replies.
- Re: [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/21 17:10:45 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/09/21 19:07:46 UTC, 0 replies.
- [I] [Feature Request][Java]:filesToStage should support the gcs file path [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/21 19:39:28 UTC, 0 replies.
- Re: [I] Remove oauth2client dependency [beam] - posted by "fpopic (via GitHub)" <gi...@apache.org> on 2024/09/22 09:34:12 UTC, 2 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/22 18:38:08 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.12 to 1.17.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 04:12:31 UTC, 3 replies.
- [PR] Bump github.com/fsouza/fake-gcs-server from 1.49.2 to 1.50.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 04:12:46 UTC, 1 replies.
- Re: [PR] Bump github.com/fsouza/fake-gcs-server from 1.49.2 to 1.49.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 04:12:49 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.32 to 1.17.34 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 04:18:56 UTC, 3 replies.
- [PR] Bump com.pswidersk.terraform-plugin from 1.0.0 to 1.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 04:42:24 UTC, 3 replies.
- Re: [PR] [Beam-26692] Add implementation and tests for bypassFilesToStage option [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 12:45:45 UTC, 0 replies.
- Re: [I] The Clean Up Prebuilt SDK Images job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/23 13:33:22 UTC, 0 replies.
- Re: [I] [Bug]: ParDo#with_exception_handling(use_subprocess=True) doesn't work because of missing _context.process_instruction_id [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/09/23 13:57:58 UTC, 0 replies.
- Re: [PR] Fix backlog reported by periodicsequence in python and go sdks to not include future outputs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 14:06:03 UTC, 5 replies.
- [PR] Tour of Beam markdown touchups [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/23 14:37:15 UTC, 6 replies.
- [I] [Task]: Optimize Spark Runner parDo transform evaluator [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/09/23 14:58:59 UTC, 3 replies.
- [I] [prism] Smarter "globally" aware splits. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/23 16:23:07 UTC, 0 replies.
- [PR] Set np printoptions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/23 17:49:37 UTC, 6 replies.
- Re: [PR] Vllm model handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/23 19:05:56 UTC, 4 replies.
- [PR] Add support for global sequence processing to the "ordered" extension in Java SDK [beam] - posted by "slilichenko (via GitHub)" <gi...@apache.org> on 2024/09/23 22:09:54 UTC, 1 replies.
- Re: [I] [Bug]: Dependency resolution is happening when installing latest version of apache-beam[gcp] [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/23 23:26:57 UTC, 0 replies.
- Re: [I] [Feature Request]: Issue the warning messages when the `process` method in `DoFn` does not return anything [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2024/09/24 02:14:52 UTC, 1 replies.
- Re: [PR] Support ordered list states in python sdk and fnapi runner [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/09/24 03:30:32 UTC, 1 replies.
- [PR] Bump com.pswidersk.terraform-plugin from 1.0.0 to 1.1.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/24 04:44:36 UTC, 7 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.32 to 1.17.35 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/24 04:57:25 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.12 to 1.17.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/24 05:03:25 UTC, 6 replies.
- Re: [PR] Enable BigQuery CDC configuration for Python BigQuery sink [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/24 06:40:04 UTC, 18 replies.
- [I] [Bug]: [Python] BatchElements and ToList website examples are broken [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/24 12:00:09 UTC, 9 replies.
- [PR] Log Warning if process function return None [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2024/09/24 12:32:29 UTC, 0 replies.
- Re: [PR] Log warning if process function return None [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2024/09/24 13:08:28 UTC, 4 replies.
- Re: [I] The PerformanceTests Kafka IO job is flaky [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/24 16:10:36 UTC, 0 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/24 16:11:50 UTC, 0 replies.
- [PR] Optimized SparkRunner ParDo Operation [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/09/24 16:23:37 UTC, 1 replies.
- [PR] Update build.gradle to use 3.12 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/24 16:38:34 UTC, 0 replies.
- [I] [Bug]: SolaceIO Unit Test testRead flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/24 17:15:24 UTC, 3 replies.
- [PR] [website][Go SDK]Add Go testing advice to test your pipeline. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/24 17:32:19 UTC, 0 replies.
- Re: [PR] Update build.gradle to use 3.12 for metrics report [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/24 18:08:58 UTC, 3 replies.
- Re: [PR] [website][Go SDK] Add Go testing advice to test your pipeline. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/24 18:15:02 UTC, 5 replies.
- [PR] Update Python Inference Benchmark Test to Python 3.10 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/09/24 18:22:52 UTC, 6 replies.
- [PR] Revert "Bump com.pswidersk.terraform-plugin from 1.0.0 to 1.1.1" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/24 19:19:24 UTC, 2 replies.
- [I] [Bug]: ToList python examples are broken [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/09/24 22:07:49 UTC, 2 replies.
- [PR] Bump github.com/docker/docker from 27.2.1+incompatible to 27.3.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/25 04:54:02 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.62.0 to 1.63.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/25 04:54:21 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.31.0 to 1.33.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/25 04:54:34 UTC, 1 replies.
- [PR] SolaceIO: deduplicate records in the integration test [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/09/25 09:06:19 UTC, 4 replies.
- Re: [I] [Bug]: Fail to retrieve rowcount for first arrow chunk: null. [beam] - posted by "turb (via GitHub)" <gi...@apache.org> on 2024/09/25 14:03:00 UTC, 0 replies.
- [PR] [Draft] KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/09/25 15:07:27 UTC, 1 replies.
- [I] [Bug]: Windowing Causes Panics [beam] - posted by "SamStentz (via GitHub)" <gi...@apache.org> on 2024/09/25 16:41:13 UTC, 0 replies.
- Re: [I] [Bug]: Windowing Causes Panics In Timer and State [beam] - posted by "SamStentz (via GitHub)" <gi...@apache.org> on 2024/09/25 17:14:31 UTC, 7 replies.
- Re: [I] Validate Pubsub Topic exists when reading [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/25 17:29:24 UTC, 0 replies.
- [PR] Remove unused testinfra pipelines module [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/25 19:33:22 UTC, 0 replies.
- [PR] Report Lineage metrics for SpannerIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/25 20:11:11 UTC, 6 replies.
- [I] Include Prism on the Beam Website [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/25 20:55:45 UTC, 0 replies.
- [PR] [#32562] Incorporate Prism into the Beam Website. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/25 21:07:02 UTC, 4 replies.
- [I] [prism] Good Non-Go Beam developer experience [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/25 21:17:22 UTC, 0 replies.
- [PR] iceberg dynamic destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/25 22:15:33 UTC, 0 replies.
- [PR] fix NPE and other exceptions thrown when work fails to process before work execution [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/09/25 23:11:51 UTC, 11 replies.
- Re: [PR] Managed Iceberg dynamic destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/25 23:18:41 UTC, 2 replies.
- [PR] Bump actions/checkout from 3.5.3 to 4.2.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/26 01:19:35 UTC, 0 replies.
- Re: [PR] Bump actions/checkout from 3.5.3 to 4.1.7 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/26 01:19:37 UTC, 1 replies.
- [PR] Fixes a transform upgrade compatibility issue related to BigqueryIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/09/26 02:09:40 UTC, 3 replies.
- Re: [I] [Bug]: In Beam Dataframe api, the fillna operation doesn't work when applied on individual columns [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2024/09/26 07:38:37 UTC, 0 replies.
- Re: [PR] [Dataflow Streaming Engine] Turn on `--useWindmillIsolatedChannels` and `--useSeparateWindmillHeartbeatStreams` by default [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/26 11:03:34 UTC, 1 replies.
- Re: [I] [Bug]: Python KafkaIO read transform is inefficient when using the commit_offsets_in_finalize option [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/26 12:49:26 UTC, 1 replies.
- Re: [I] Kafka commitOffsetsInFinalize OOM on Flink [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/26 12:51:14 UTC, 1 replies.
- [PR] Update CHANGES for recent fixes, improvements. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/09/26 12:55:18 UTC, 4 replies.
- [PR] [WIP]: Do not merge, trying to repro failure [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/26 14:13:56 UTC, 0 replies.
- [PR] Add info log between executing work failed and cleanup [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/26 17:16:10 UTC, 3 replies.
- Re: [PR] [prism] Initial Deep Dive Documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/26 17:37:28 UTC, 1 replies.
- [PR] Make parent thread state sampler available in child thread when runni… [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/09/26 18:00:54 UTC, 0 replies.
- [PR] Revert "fix: add topic existing validation" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/26 18:33:05 UTC, 1 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/26 19:03:10 UTC, 0 replies.
- [PR] Build release candidate with Java 11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/09/26 19:12:01 UTC, 2 replies.
- [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/09/26 20:51:25 UTC, 0 replies.
- [PR] [Go] Update Go version used by Beam repo to go1.23.1 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/26 20:59:25 UTC, 2 replies.
- Re: [PR] Fix counter metrics for ParDo#with_exception_handling(timeout). [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/09/26 21:26:08 UTC, 2 replies.
- [PR] Update Release guide with new github release guidance. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/09/26 21:39:42 UTC, 2 replies.
- [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 "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/26 22:13:22 UTC, 0 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/09/26 22:13:27 UTC, 0 replies.
- Re: [I] [Prism][Task]: Register Java Prism Runner pipeline options [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/09/26 22:29:37 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.23 to 1.17.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/27 04:43:12 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.18 to 2.10.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/09/27 04:49:23 UTC, 1 replies.
- Re: [I] BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS [beam] - posted by "matthieucham (via GitHub)" <gi...@apache.org> on 2024/09/27 07:06:39 UTC, 0 replies.
- Re: [PR] Allow setting BigQuery endpoint [beam] - posted by "wattache (via GitHub)" <gi...@apache.org> on 2024/09/27 07:18:58 UTC, 4 replies.
- Re: [PR] Integrate direct path [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/09/27 07:25:38 UTC, 1 replies.
- [I] [Bug]: Latest Java SpannerIO ChangeStream Can't Use the same metadata database for multiple pipelines [beam] - posted by "bangau1 (via GitHub)" <gi...@apache.org> on 2024/09/27 10:09:17 UTC, 0 replies.
- Re: [PR] [Beam-31234] Add tests for Redistribute class and fix Redistribute function integration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/27 12:45:47 UTC, 0 replies.
- Re: [PR] Allow GlobalWindows to be encoded as IntervalWindows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/27 12:51:14 UTC, 7 replies.
- Re: [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] - posted by "bangau1 (via GitHub)" <gi...@apache.org> on 2024/09/27 14:08:04 UTC, 0 replies.
- Re: [I] [Task]: [flink] EncodedValueComparator can use serialzed bytes for deterministic Coders [beam] - posted by "kirupha2000 (via GitHub)" <gi...@apache.org> on 2024/09/27 14:53:54 UTC, 0 replies.
- [PR] feat: add pubsub topic validation [beam] - posted by "proost (via GitHub)" <gi...@apache.org> on 2024/09/27 15:06:02 UTC, 1 replies.
- [PR] Always write to BQ from global window [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/27 17:14:11 UTC, 4 replies.
- [PR] Force BQIO to output elements in the correct row [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/09/27 20:00:59 UTC, 3 replies.
- Re: [I] Avro/BigQuery disagreement on DATE type representation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/09/27 21:50:05 UTC, 0 replies.
- [PR] Keep string FQN as a way to add lineage information [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/09/27 22:10:37 UTC, 3 replies.
- [PR] [yaml] Preserve windowing for unbounded input when using WriteToJson Java provider [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/09/27 22:11:38 UTC, 2 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/27 22:15:58 UTC, 0 replies.
- Re: [PR] [yaml] Preserve windowing for unbounded input when using FileIO Java providers [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/09/27 23:17:31 UTC, 0 replies.
- [PR] represenation->representation [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/09/28 02:41:11 UTC, 2 replies.
- [PR] Update python KafkaIO docstring to add the use_deprecated_read option [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/09/28 05:14:40 UTC, 3 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.0.1 to 2.0.2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/28 12:43:53 UTC, 0 replies.
- Re: [PR] Depend on non-shadow configuration of java core in schemaio expansion… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/28 12:43:56 UTC, 0 replies.
- Re: [PR] Interpolate console URL properly in error case [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/09/28 12:43:59 UTC, 0 replies.
- Re: [I] [Bug]: KafkaIO documentation gap [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/09/29 01:12:32 UTC, 0 replies.