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

---

- Re: [PR] Update cython requirement from <1 to <4 in /sdks/python [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/01 00:15:18 UTC, 8 replies.
- Re: [PR] Change FnApiDoFnRunner to skip trySplit checkpoint requests if not draining and nothing has yet been claimed by the tracker. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/01 00:24:32 UTC, 15 replies.
- Re: [PR] Add ErrorHandler DLQ API to Python [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/01 00:36:32 UTC, 8 replies.
- Re: [I] [Feature Request]: [beam-sdks-java-core]: Create method SerializableComparator.comparing(SerialiableFunction) [beam] - posted by "imvtsl (via GitHub)" <gi...@apache.org> on 2024/08/01 01:25:44 UTC, 3 replies.
- Re: [PR] [yaml] Add tests for provider schema validation [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/01 01:59:06 UTC, 6 replies.
- Re: [PR] Support metrics at Source.split for Direct Runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/01 02:00:44 UTC, 0 replies.
- Re: [PR] Add Lineage metrics to PubsubIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/01 02:07:14 UTC, 1 replies.
- Re: [I] [Bug]: CoGroupByKey throws with large (10K+) output groups on Flink runner [beam] - posted by "yolgun (via GitHub)" <gi...@apache.org> on 2024/08/01 09:16:18 UTC, 1 replies.
- Re: [PR] Change the gradle task definition in quickstart. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/01 10:54:26 UTC, 0 replies.
- Re: [PR] Bump torch from 1.13.1 to 2.2.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/01 12:14:08 UTC, 2 replies.
- Re: [PR] Add logging for DataChangeRecord and ChangeStreamQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/01 12:14:09 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/08/01 12:14:11 UTC, 4 replies.
- Re: [PR] fix playground scio issues [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/08/01 12:42:37 UTC, 1 replies.
- Re: [PR] StateWatcher watches and reports changed Pipeline State [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 16:51:11 UTC, 1 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 25.0.6+incompatible [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/01 17:19:51 UTC, 1 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 25.0.6+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/01 17:22:09 UTC, 2 replies.
- Re: [PR] Add WorkProvider interfaces and implementations [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/08/01 17:27:20 UTC, 15 replies.
- Re: [I] [Prism][Task]: A State Publisher notifies listeners of changes to PipelineResult.State. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 18:10:42 UTC, 0 replies.
- [I] [Failing Test]: testE2EBigtableWriteWith[...]Failures flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/01 18:13:27 UTC, 0 replies.
- [PR] Skip bigtableIO write error handling test on Dataflow runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/01 18:23:39 UTC, 3 replies.
- [PR] Handle rc container in _update_container_image_for_dataflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/01 19:22:56 UTC, 2 replies.
- [I] [Bug]: IcebergIO opens a writer using the table's schema, which can cause data loss [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/01 20:07:03 UTC, 3 replies.
- [PR] Adds null checks when reading operational limits config. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/08/01 20:24:22 UTC, 1 replies.
- [PR] Managed Iceberg hive support and integration tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/01 20:38:00 UTC, 8 replies.
- [PR] Adds null checks when accessing OperationalLimits in config. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/08/01 20:46:00 UTC, 2 replies.
- Re: [PR] Filter empty distribution metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/08/01 20:50:05 UTC, 11 replies.
- Re: [PR] [CsvIO] Create CsvIOParse Class [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 20:56:30 UTC, 0 replies.
- Re: [I] [CsvIO]: CsvIOParse::expand implementation and class completion [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 20:56:31 UTC, 0 replies.
- [I] [Prism][Task]: Enable ExternalWorkerService during Prism Runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 21:07:22 UTC, 1 replies.
- [I] [Prism][Task]: Enable ArtifactStagingService during Prism Runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 21:07:47 UTC, 0 replies.
- [I] [Prism][Task]: Enable JobService gRPC client during Prism runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 21:08:31 UTC, 1 replies.
- [PR] [Prism]: Enable ExternalWorkerService during Prism Runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/01 22:58:28 UTC, 3 replies.
- [PR] [Prism] Enable an ArtifactResolver for the Prism runner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/02 00:57:25 UTC, 4 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 27.1.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/02 04:31:39 UTC, 8 replies.
- Re: [I] Update Go protobuf package to new version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/02 08:56:52 UTC, 5 replies.
- [PR] SolaceIO write connector [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/08/02 09:59:08 UTC, 3 replies.
- [I] [Bug]: Request Response IO for python SDK pickle error [beam] - posted by "zaibon (via GitHub)" <gi...@apache.org> on 2024/08/02 10:49:38 UTC, 0 replies.
- Re: [PR] Beam Website Updates for 2.58.0 Release [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/02 12:13:57 UTC, 4 replies.
- Re: [PR] add ExternalTransformProvider example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/02 12:42:46 UTC, 7 replies.
- [PR] Fix load test dataproc cluster name exceeded allowed length [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/02 14:51:50 UTC, 4 replies.
- Re: [PR] Add some large model troubleshooting steps [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/02 15:04:39 UTC, 2 replies.
- [PR] Add warning + doc callout when encountering ri pickling errors [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/02 15:34:55 UTC, 5 replies.
- Re: [PR] Override BQ load job location when necessary [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/02 15:46:21 UTC, 1 replies.
- [I] [prism] Java PerKeyOrderingTest - test failures (likely state) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/02 16:56:17 UTC, 1 replies.
- Re: [PR] Added support for the TOKENLIST type in Spanner [beam] - posted by "atask-g (via GitHub)" <gi...@apache.org> on 2024/08/02 17:12:44 UTC, 3 replies.
- [PR] [#32064] Keep elements heap in sequence order. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/02 17:38:49 UTC, 2 replies.
- [PR] Exclude a not yet implemented pandas op. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/02 17:50:50 UTC, 1 replies.
- Re: [PR] Exclude a not yet implemented pandas op from dataframe tests. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/02 17:52:20 UTC, 2 replies.
- [PR] Adds an ORDERED_LIST_STATE capability to the Java SDK. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/08/02 18:11:43 UTC, 15 replies.
- [PR] Add Lineage metrics for BigtableIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/02 18:43:16 UTC, 11 replies.
- Re: [PR] Update go protobuf package to new version [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/02 19:00:44 UTC, 16 replies.
- [I] [Failing Test]: apache_beam.io.gcp.bigquery_test.PipelineBasedStreamingInsertTest is flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/02 19:38:55 UTC, 3 replies.
- Re: [PR] [#32064][prism] Keep elements heap in sequence order. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/02 20:47:31 UTC, 2 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/08/02 22:14:22 UTC, 1 replies.
- Re: [PR] Cachi [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/03 00:21:35 UTC, 2 replies.
- [I] [Bug]: BigtableIO integration tests not actually testing [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/03 01:56:40 UTC, 0 replies.
- [I] The LoadTests Python ParDo Flink Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/03 18:35:28 UTC, 2 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/08/03 22:12:50 UTC, 1 replies.
- [PR] Fixes GitHub issue #30257 [beam] - posted by "kirupha2000 (via GitHub)" <gi...@apache.org> on 2024/08/04 04:31:38 UTC, 14 replies.
- Re: [PR] Update top_wikipedia_sessions to be more idiomatic with beam.Map. [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/08/04 05:06:14 UTC, 0 replies.
- [I] [Bug]: Illegal Argument Exception even though the type is matching [beam] - posted by "avkarthk (via GitHub)" <gi...@apache.org> on 2024/08/04 14:17:51 UTC, 0 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/08/04 22:13:19 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.58.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 04:49:13 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.57.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 04:49:16 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.57.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 04:49:18 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.58.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 04:49:19 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.58.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 04:49:20 UTC, 1 replies.
- Re: [PR] Fix/Refactor GetData interfaces for Direct Path integration [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/08/05 07:32:16 UTC, 2 replies.
- [PR] Fix error when ActiveWorkRefresher processed empty heartbeat map. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/05 08:49:34 UTC, 3 replies.
- Re: [PR] Add jobLabelsMap parameter to BigQueryOptions [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/08/05 09:17:52 UTC, 1 replies.
- Re: [PR] Support withFormatRecordOnFailureFunction() for BigQuery STORAGE_WRITE_API and STORAGE_API_AT_LEAST_ONCE methods [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/08/05 09:18:39 UTC, 6 replies.
- [I] [Feature Request]: SQL Shell Google Pub/Sub subscription external table [beam] - posted by "ndopj (via GitHub)" <gi...@apache.org> on 2024/08/05 09:54:25 UTC, 1 replies.
- Re: [PR] [flink] #31529 UnboundedSourceWrapper removal [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 12:43:50 UTC, 2 replies.
- Re: [PR] Enable to handle NotFound and AccessDenied errors in the streaming insert of `BigQueryIO` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 12:43:51 UTC, 1 replies.
- [I] [Task]: Remove exclusion for requests `2.32.*` in Python SDK [beam] - posted by "potiuk (via GitHub)" <gi...@apache.org> on 2024/08/05 13:54:32 UTC, 1 replies.
- Re: [PR] Replace StateTag.StateBinder to top level StateBinder in SparkStateInternals [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/05 14:43:59 UTC, 1 replies.
- [PR] make FieldValueTypeInformation creators take a TypeDescriptor parameter [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/08/05 15:18:30 UTC, 11 replies.
- [PR] Imporve BatchElements documentation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/05 15:28:17 UTC, 0 replies.
- [PR] Enforce java.nio.charset.StandardCharsets against guava Charsets [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/05 16:05:24 UTC, 7 replies.
- Re: [PR] Improve BatchElements documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/05 16:37:13 UTC, 14 replies.
- Re: [PR] [Python] Managed Transforms API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/05 16:40:35 UTC, 1 replies.
- Re: [PR] Minor optimization for the common case of merging empty string sets. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/05 16:49:57 UTC, 0 replies.
- Re: [PR] [Prism] Enable an artifact resolver for the Prism runner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/05 17:25:39 UTC, 0 replies.
- [PR] [Prism] Enable artifact staging during Prism Runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/05 17:30:03 UTC, 4 replies.
- Re: [PR] Managed BigQueryIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/05 18:22:06 UTC, 4 replies.
- Re: [PR] [prism] Remove the xlang cogbk test [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/05 20:00:05 UTC, 0 replies.
- [I] [prism] PrismRunnerTest::test_windowing - session windowing failing. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/05 22:22:00 UTC, 1 replies.
- [PR] [#32085][prism] Fix session windowing. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/05 23:00:29 UTC, 2 replies.
- Re: [I] [Bug]: Writing partitioned data with Managed IcebergIO fails [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/06 00:17:29 UTC, 2 replies.
- [I] [Bug]: Latest version (2.57) version of apache beam java sdk has dependecy on an old version of mongo driver (3.12) [beam] - posted by "anish-poulose-maersk (via GitHub)" <gi...@apache.org> on 2024/08/06 08:47:56 UTC, 0 replies.
- [I] [Bug]: arm64 container image has the wrong arch for Google Cloud Profiler [beam] - posted by "vaikas (via GitHub)" <gi...@apache.org> on 2024/08/06 09:18:15 UTC, 0 replies.
- Re: [PR] Backlog metrics do not showing up in FlinkRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/06 12:43:09 UTC, 2 replies.
- [PR] Add Lineage metrics to FileSystems [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/06 15:14:48 UTC, 9 replies.
- Re: [I] [Prism][Task]: Enable artifact staging during Prism Runner lifecycle [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/06 16:48:49 UTC, 0 replies.
- [PR] [Prism] Enable Job management for the Prism runner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/06 17:01:45 UTC, 3 replies.
- [PR] [prism] Use non-deprecated docker types in environment. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/06 18:43:56 UTC, 3 replies.
- [PR] [yaml] Fix PubSub error message [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/06 22:09:42 UTC, 5 replies.
- [I] [CsvIO]: Create CsvIOParseLoadIT class [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/08/06 23:47:20 UTC, 0 replies.
- Re: [PR] Bump google.golang.org/grpc from 1.64.0 to 1.65.0 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 00:22:22 UTC, 1 replies.
- [PR] Fix Beam Schema to Iceberg Schema ID conversion logic [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/07 02:13:15 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.18 to 1.17.27 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 04:23:07 UTC, 2 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.13.1 to 1.16.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 04:23:14 UTC, 2 replies.
- [PR] Bump golang.org/x/text from 0.16.0 to 0.17.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 04:23:19 UTC, 2 replies.
- Re: [PR] Initial Iceberg Sink [beam] - posted by "sarinasij (via GitHub)" <gi...@apache.org> on 2024/08/07 05:32:31 UTC, 0 replies.
- [I] Ujjkj [beam] - posted by "alexia534 (via GitHub)" <gi...@apache.org> on 2024/08/07 07:34:27 UTC, 1 replies.
- Re: [I] [Bug]: Trouble building Beam Streaming Job with ZetaSQL Query planner [beam] - posted by "pranjal5215 (via GitHub)" <gi...@apache.org> on 2024/08/07 08:07:51 UTC, 0 replies.
- Re: [I] [Bug]: ClickHouseIO - wrong JDBC dependency import [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/07 09:19:22 UTC, 1 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.57.0 to 2.58.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 09:31:09 UTC, 1 replies.
- Re: [PR] Add correct shutdown mechanics for direct path [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/07 12:01:39 UTC, 20 replies.
- Re: [PR] Bump tensorflow from 2.11.1 to 2.12.1 in /sdks/python/apache_beam/examples/ml-orchestration/tfx [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 12:14:30 UTC, 3 replies.
- [PR] Bump apache-beam from 2.57.0 to 2.58.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/07 12:42:11 UTC, 1 replies.
- Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.12 to 2.10.17 in /sdks [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/07 14:38:50 UTC, 3 replies.
- [PR] Fix classifier dropped in artifact pom.xml [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/07 15:28:02 UTC, 3 replies.
- Re: [PR] [#21515][Go SDK] Update go protobuf package to new version [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/07 16:54:17 UTC, 1 replies.
- [PR] Make BQ file load limit controls public [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/07 17:57:26 UTC, 4 replies.
- [PR] Upgrade version to 2.58.0 [beam-starter-java] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/07 19:35:39 UTC, 2 replies.
- [PR] [Managed Iceberg] Support writing partitioned data [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/07 21:41:51 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/08 04:43:13 UTC, 3 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.16.0 to 1.16.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/08 04:43:21 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.25.0 to 1.28.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/08 04:43:41 UTC, 2 replies.
- [PR] Bump github.com/proullon/ramsql from 0.1.3 to 0.1.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/08 04:43:45 UTC, 2 replies.
- [I] [Feature Request]: expose SolaceIO watermark policy and parameters [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/08/08 08:16:01 UTC, 5 replies.
- Re: [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/08 12:13:56 UTC, 13 replies.
- [I] [Bug]: SolaceIO.Read - SEMP API queries fail for queue that has "/" in its name [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/08/08 13:41:10 UTC, 2 replies.
- [PR] Expose watermarkIdleDurationThreshold parameter to the user in SolaceIO read connector [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/08/08 14:06:56 UTC, 4 replies.
- [PR] Revert "Update cython requirement from <1 to <4 in /sdks/python (#320… [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/08 14:52:04 UTC, 5 replies.
- Re: [PR] Support portable pipeline dot graph rendering [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/08 15:58:47 UTC, 0 replies.
- [PR] [Go SDK] s3 filesystem: Fix nilable content length, update deps. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/08 16:15:57 UTC, 2 replies.
- [PR] Upgrade Apache Beam to use Cython 3.x. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/08 17:22:31 UTC, 6 replies.
- [I] [Bug]: FileBasedSink seems to not work on streaming [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/08 17:23:49 UTC, 1 replies.
- [I] Redis IO Doesn't Support Selecting DB Index [beam] - posted by "MuhammedMahrous (via GitHub)" <gi...@apache.org> on 2024/08/08 17:27:13 UTC, 0 replies.
- [I] [prism] Timer Clearing [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/08 17:39:03 UTC, 2 replies.
- [PR] Add Lineage metrics to Python BigQueryIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/08 18:08:02 UTC, 3 replies.
- [PR] [yaml] explicitly define beam imports for callables in docs [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/08 19:36:00 UTC, 0 replies.
- Re: [PR] [yaml] Doc improvements [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/08 20:07:39 UTC, 6 replies.
- [PR] Add support for setting an HTTP read timeout for BigQueryIO [beam] - posted by "jonathan-lemos (via GitHub)" <gi...@apache.org> on 2024/08/08 20:22:11 UTC, 4 replies.
- [PR] [#32115] Fix timer support, support timer clears. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/08 22:05:09 UTC, 5 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/08/08 22:13:59 UTC, 1 replies.
- [I] [prism] Support interval windows/prep for custom windows. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/08 22:38:01 UTC, 1 replies.
- [PR] Fix Lineage name breaking change [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/09 04:18:15 UTC, 2 replies.
- [I] [Feature Request]: Include keyrings.google-artifactregistry-auth in Python SDK container [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/08/09 04:33:43 UTC, 0 replies.
- [PR] Bump github.com/fsouza/fake-gcs-server from 1.47.7 to 1.49.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 05:05:20 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/profiler from 0.4.0 to 0.4.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 05:05:37 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.64.0 to 1.66.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 05:05:53 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.27.0 to 0.28.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 05:05:59 UTC, 2 replies.
- [PR] Bump golang.org/x/oauth2 from 0.21.0 to 0.22.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 05:06:05 UTC, 3 replies.
- [I] [Task]: Replace JacksonFactory references with GsonFactory [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/09 08:53:29 UTC, 5 replies.
- [PR] Extract background poll thread from KafkaUnboundedReader [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/09 09:34:59 UTC, 1 replies.
- [PR] Generate python dependencies [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/09 10:02:19 UTC, 3 replies.
- [PR] SolaceIO.read: Encode url parameters in REST requests. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/08/09 12:33:19 UTC, 4 replies.
- [PR] Fix configuration of ReadFromKafkaViaSDF which was always enabling redistribute and allowing duplicates instead of basing it on configuration. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/09 13:39:37 UTC, 16 replies.
- [PR] Bump up google-cloud-storage version to fix data corruption issue [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/09 13:53:01 UTC, 7 replies.
- [PR] Add callback to with_exception_handling [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/09 13:54:29 UTC, 9 replies.
- [I] [Feature Request]: Add timeout to RunInference operations [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/09 13:56:49 UTC, 2 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 "mattfarkas (via GitHub)" <gi...@apache.org> on 2024/08/09 14:08:11 UTC, 0 replies.
- Re: [PR] Add schema to SpannerIO read [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 15:35:01 UTC, 16 replies.
- [PR] Bump to Java11 for GHA runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/09 16:02:49 UTC, 13 replies.
- [I] [prism] Support Stateful SDFs (state and timers) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/09 17:01:26 UTC, 1 replies.
- [PR] [#32139] Fail pipelines with Stateful SDFs. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/09 17:40:31 UTC, 2 replies.
- Re: [PR] Create Beam YAML Join documentation [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/09 19:06:05 UTC, 0 replies.
- [PR] Add basic testing for yaml join docs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/09 20:33:53 UTC, 3 replies.
- Re: [PR] Added insertion and enrichment pipeline [beam] - posted by "itsayushpandey (via GitHub)" <gi...@apache.org> on 2024/08/09 20:54:39 UTC, 1 replies.
- [PR] [CsvIO]: Implement CsvIOParse.withCustomRecordParsing [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/08/09 21:49:25 UTC, 0 replies.
- Re: [PR] [CsvIO]: Implement CsvIOParse::withCustomRecordParsing method [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/09 22:35:27 UTC, 1 replies.
- Re: [I] [CsvIO]: Implement CsvIOParse::withCustomrecordParsing method [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/09 23:12:25 UTC, 0 replies.
- [PR] initial draft prism docs [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/09 23:28:31 UTC, 1 replies.
- [I] The PerformanceTests WordCountIT PythonVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/10 03:35:20 UTC, 2 replies.
- [PR] Fix broken Beam Quest URL in README.md [beam] - posted by "jonathan-lemos (via GitHub)" <gi...@apache.org> on 2024/08/10 04:29:26 UTC, 7 replies.
- Re: [PR] Rag opensearch [beam] - posted by "itsayushpandey (via GitHub)" <gi...@apache.org> on 2024/08/10 04:44:50 UTC, 10 replies.
- Re: [I] Parsing datetime string with 0 to 6 decimal points for BigQuery [beam] - posted by "proost (via GitHub)" <gi...@apache.org> on 2024/08/10 08:52:18 UTC, 2 replies.
- [PR] fix: cover bigquery datetime fraction 1 to 6 or absent [beam] - posted by "proost (via GitHub)" <gi...@apache.org> on 2024/08/10 13:44:08 UTC, 2 replies.
- Re: [I] [Feature Request]: Add examples for using metrics with Python to Beam Website [beam] - posted by "VETREA (via GitHub)" <gi...@apache.org> on 2024/08/10 17:29:37 UTC, 1 replies.
- [PR] Replacing jackson factory (#32130) [beam] - posted by "cutiepie-10 (via GitHub)" <gi...@apache.org> on 2024/08/11 10:35:57 UTC, 3 replies.
- Re: [PR] Remove SnakeYaml dependency [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/11 12:41:55 UTC, 2 replies.
- [PR] Rep[lacing Jackson Factory with Gson Factory [beam] - posted by "cutiepie-10 (via GitHub)" <gi...@apache.org> on 2024/08/11 19:14:13 UTC, 0 replies.
- Re: [PR] Replacing Jackson Factory with Gson Factory [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/11 20:35:06 UTC, 8 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.40.0 to 1.41.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 04:54:05 UTC, 3 replies.
- [PR] Bump golang.org/x/sys from 0.23.0 to 0.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 04:54:14 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.28.0 to 1.29.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 04:54:41 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.189.0 to 0.191.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 04:54:49 UTC, 4 replies.
- [PR] Allow setting BigQuery endpoint [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/08/12 06:49:06 UTC, 8 replies.
- Re: [I] [Feature Request]: Allow setting BigQuery endpoint, for example to use bigquery emulator [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/08/12 06:51:42 UTC, 1 replies.
- [I] [Bug]: beam word count example is failing on the flink runner deployed at dedicated flink cluster using beam java SDK [beam] - posted by "siddhanta-rath (via GitHub)" <gi...@apache.org> on 2024/08/12 10:06:55 UTC, 3 replies.
- Re: [PR] Remove expensive shuffle of read data in KafkaIO when using sdf and commit offsets [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/12 11:09:31 UTC, 9 replies.
- [I] [Bug]: Errors when switching from streaming_inserts to Storage_Write_API when using repeated Struct or Record fields [beam] - posted by "TobiasBredow (via GitHub)" <gi...@apache.org> on 2024/08/12 13:21:28 UTC, 6 replies.
- Re: [I] [Task]: Replace deprecated StateTag.StateBinder in SparkStateInternals. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/08/12 13:35:38 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] V2.58.0 rc2 validations [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/12 14:38:03 UTC, 1 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/12 14:38:10 UTC, 11 replies.
- [PR] fix BeamQuest link on ReadMe [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/08/12 14:40:27 UTC, 3 replies.
- [PR] Revert "Fix broken Beam Quest URL in README.md (#32145)" [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/08/12 14:41:20 UTC, 1 replies.
- [PR] Replacing Jackson Factory with Gson Factory and further code updation [beam] - posted by "cutiepie-10 (via GitHub)" <gi...@apache.org> on 2024/08/12 18:41:22 UTC, 16 replies.
- [I] [Bug]: upload_graph option does not work with Dataflow Java Runner v2 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/12 20:23:34 UTC, 13 replies.
- [PR] Update names.py with container image tag [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/12 21:19:18 UTC, 1 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 21:33:56 UTC, 5 replies.
- [PR] Kafka poll interval [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/08/12 21:35:20 UTC, 2 replies.
- Re: [I] [Feature Request]: Enable withFormatRecordOnFailureFunction() equivalent for BigQuery STORAGE_WRITE_API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/12 21:52:57 UTC, 0 replies.
- Re: [I] Writing string to pubsub on Python SDK [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/08/12 21:54:03 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/08/12 22:14:15 UTC, 3 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/12 22:14:25 UTC, 1 replies.
- [I] The PerformanceTests Kafka IO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/13 00:48:28 UTC, 5 replies.
- [PR] Fix upload_graph on v2 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/13 13:15:27 UTC, 11 replies.
- [PR] Added a data corruption known issue to CHANGES.md and release blogs. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/13 14:40:40 UTC, 6 replies.
- [I] Use the worker-id GRPC metadata [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/13 15:11:18 UTC, 0 replies.
- [I] [Bug]: BigQueryIO: unnecessary GCP project name validation in table spec regexp [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/08/13 15:26:17 UTC, 0 replies.
- [I] [Bug]: [Python SDK] Data Corruption on GCS read in 2.53.0 - 2.58.0 SDKs. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/13 16:01:32 UTC, 1 replies.
- [PR] Add Lineage metrics to KafkaIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/13 16:09:36 UTC, 10 replies.
- Re: [I] The LoadTests Go Combine Flink Batch job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/13 16:31:42 UTC, 3 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/13 17:20:38 UTC, 10 replies.
- [PR] Fix PostCommit Python sklearn on Python3.12 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/13 17:36:59 UTC, 5 replies.
- [PR] [WIP] Gemma Sentiment and Summarization Example Notebook [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/13 18:38:58 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/13 22:13:30 UTC, 1 replies.
- Re: [PR] [Managed Iceberg] Support writing to partitioned tables [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/13 23:34:59 UTC, 13 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.36.0 to 1.37.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 04:58:54 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.191.0 to 0.192.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 04:59:05 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 27.1.1+incompatible to 27.1.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 04:59:17 UTC, 2 replies.
- [I] [Feature Request]: Add a pipeline pattern that enriches data with a cache using the shared class [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/08/14 05:44:44 UTC, 3 replies.
- Re: [I] [Bug]: DirectRunner fails after grouping into batches, and applying flat map with assertion error [beam] - posted by "keunhong (via GitHub)" <gi...@apache.org> on 2024/08/14 06:20:27 UTC, 0 replies.
- [PR] Loose BigQuery GCP project ID regex restrictions [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/08/14 07:02:28 UTC, 12 replies.
- Re: [PR] Add JobServerOption for `--jar_cache_dir` [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/14 09:41:12 UTC, 6 replies.
- Re: [PR] [CsvIO] Create CsvIOSplitFile Class [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/14 09:41:51 UTC, 1 replies.
- Re: [PR] Add throttling counters in gcsio. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 12:43:36 UTC, 2 replies.
- Re: [PR] Add random suffix to IT resource IDs to avoid collision [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 12:43:39 UTC, 1 replies.
- Re: [PR] Fix flaky test suite beam_PostCommit_XVR_Direct [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 12:43:42 UTC, 0 replies.
- Re: [PR] [yaml] Add UDF docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 12:43:44 UTC, 0 replies.
- Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 12:43:46 UTC, 0 replies.
- Re: [PR] Gemma Sentiment and Summarization Example Notebook [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/14 13:50:19 UTC, 0 replies.
- Re: [I] Add ValueProvider support for MqttIO [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/14 15:11:07 UTC, 0 replies.
- [I] Write-Warning -Verbose "Installation failed! (msiexec error code $($process.ExitCode))" [beam] - posted by "alexia534 (via GitHub)" <gi...@apache.org> on 2024/08/14 15:59:12 UTC, 0 replies.
- [PR] [#32121] Support timers in interval windows. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/14 16:25:45 UTC, 2 replies.
- [PR] added methods for support ValueProvider [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/14 16:47:14 UTC, 0 replies.
- Re: [PR] added methods for support ValueProvider in `MqttIO` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 17:34:27 UTC, 2 replies.
- [PR] [prism] Skip tests that require an expansion service at this time. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/14 17:55:08 UTC, 0 replies.
- [PR] Fix verifyJavaVersion wrong filter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/14 18:26:36 UTC, 12 replies.
- [PR] [#31927,#31928][prism] Support StringSet and Gauge metrics. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/14 19:13:59 UTC, 4 replies.
- Re: [PR] [prism] Skip python tests that require an expansion service at this time. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 20:06:05 UTC, 5 replies.
- Re: [PR] Fix verifyJavaVersion in a few places [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/14 21:36:06 UTC, 1 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 22:14:08 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/14 22:14:31 UTC, 2 replies.
- [PR] Add a pattern for using a shared object as a cache [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/08/14 22:40:36 UTC, 29 replies.
- [PR] Copy editing the Gemma notebook [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/08/15 00:05:12 UTC, 3 replies.
- [I] [Failing Test]: Tests involve hive-exec has to run on Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/15 01:45:52 UTC, 1 replies.
- [PR] Fix tests after GHA runner Java11 migration [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/15 02:42:14 UTC, 6 replies.
- [PR] Bump commons-cli:commons-cli from 1.8.0 to 1.9.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/15 04:06:30 UTC, 15 replies.
- [PR] Bump github.com/aws/smithy-go from 1.20.3 to 1.20.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/15 04:48:48 UTC, 3 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.7.3 to 1.8.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/15 04:48:57 UTC, 2 replies.
- [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/08/15 04:49:11 UTC, 1 replies.
- [I] [Feature Request]: Add Topic Information to `MqttIO` Return Value [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/15 07:55:06 UTC, 1 replies.
- [I] [Bug]: ReadFromKafkaViaSDF ignores configuration from redistribute and allow duplicates and always enables them [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/15 08:42:02 UTC, 4 replies.
- [PR] Increase snapshot publish timeout [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/15 15:06:16 UTC, 2 replies.
- Re: [I] [prism] Support Attempted Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 15:45:46 UTC, 1 replies.
- [PR] [#31926] [java] call provision service when creating external workers. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 15:52:23 UTC, 3 replies.
- [I] [Bug]: ProtoMessageSchema.getSchema fails on proto3 messages with optional fields [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2024/08/15 16:48:21 UTC, 4 replies.
- [PR] Update Gemma 2 Notebook [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/15 17:21:47 UTC, 3 replies.
- [I] [Feature Request]: `kms_key` should be used in making `temp_dataset`'s. [beam] - posted by "GaryPWhite (via GitHub)" <gi...@apache.org> on 2024/08/15 17:26:25 UTC, 0 replies.
- [PR] Cherry pick #32134 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/15 17:51:41 UTC, 1 replies.
- [PR] Update dataflow container versions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/15 17:53:18 UTC, 1 replies.
- [PR] Protect release branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/15 17:54:13 UTC, 1 replies.
- [PR] Update website for 2.58.1 release [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/15 18:43:37 UTC, 3 replies.
- [I] [Failing Test]: SparkVersionTest 3.4.0+ fails on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/15 20:01:23 UTC, 0 replies.
- [I] [Failing Test]: Java Samza runner tests failing on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/15 20:11:29 UTC, 2 replies.
- Re: [I] [Bug]: KafkaIO documentation gap [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/08/15 20:22:39 UTC, 0 replies.
- [PR] More Java11 test fix [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/15 20:38:45 UTC, 8 replies.
- [PR] [prism] Catch panics in primary execution goroutines. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 20:52:27 UTC, 4 replies.
- [I] OnWindowExpiry [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 21:16:50 UTC, 0 replies.
- [PR] [Java11 Migration] Migrate Go testing to use Java11 container image for xlang [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 21:51:02 UTC, 5 replies.
- Re: [I] [prism] Support StringSet Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/15 22:59:51 UTC, 0 replies.
- [PR] feat: optimize Spanner changestream metadata table [beam] - posted by "thiagotnunes (via GitHub)" <gi...@apache.org> on 2024/08/16 05:46:53 UTC, 8 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.10 to 1.17.11 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/16 05:58:40 UTC, 2 replies.
- [PR] V2.58.1 rc1 validations [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/16 06:53:37 UTC, 1 replies.
- [PR] fix failing ProtoSchemaTranslator on proto3 optional fields [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2024/08/16 09:57:08 UTC, 7 replies.
- [I] [Task]: build_wheels workflow takes too long for release candidates [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/16 13:55:00 UTC, 1 replies.
- [PR] Include Hive and GCS runtime dependencies in main Iceberg jar [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/16 15:31:27 UTC, 6 replies.
- [PR] Remove executable non-python blocks from Gemma 2 notebook [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/16 17:12:34 UTC, 3 replies.
- [PR] update runner image [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/16 19:04:29 UTC, 3 replies.
- [I] [prism] Java timer families cannot be looked up SDK side (prism re-write issue) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/16 19:57:38 UTC, 4 replies.
- [I] [prism] Resolve endless timer test org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/16 21:49:20 UTC, 0 replies.
- [PR] [#32221] [prism] Terminate streams for each timerfamily+transform pair. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/16 21:57:46 UTC, 4 replies.
- Re: [I] [prism] Support Gauge Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/16 23:04:15 UTC, 0 replies.
- Re: [I] [Prism] Support Bundle Finalization [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/16 23:13:44 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow V2 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/17 06:35:48 UTC, 1 replies.
- [I] [Feature Request]: Support `SetState` in SparkRunner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/17 07:57:00 UTC, 2 replies.
- Re: [PR] Default translation for SchemaTransforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/17 12:41:16 UTC, 2 replies.
- Re: [PR] [Python][Pipeline Options] Recursively Get All Subclasses [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/17 12:41:19 UTC, 2 replies.
- [PR] Add SetState support for SparkRunner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/17 15:32:31 UTC, 3 replies.
- [I] The PreCommit Integration and Load Test Framework job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/18 09:33:42 UTC, 2 replies.
- Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/18 12:42:37 UTC, 2 replies.
- Re: [PR] Call `DateTime(long)` instead of `DateTime(Object)`. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/18 12:42:38 UTC, 3 replies.
- [I] [Task]: Update ClickHouseIO to use the latest version of the ClickHouse JDBC driver [beam] - posted by "mzitnik (via GitHub)" <gi...@apache.org> on 2024/08/18 14:13:57 UTC, 1 replies.
- [PR] Update ClickHouseIO to use the latest version of the ClickHouse JDBC driver (0.6.4) [beam] - posted by "mzitnik (via GitHub)" <gi...@apache.org> on 2024/08/18 14:17:00 UTC, 3 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/18 15:34:40 UTC, 9 replies.
- [I] [Feature Request]: Exclusive DataFrame API for Java SDK [beam] - posted by "DebajitKumarPhukan (via GitHub)" <gi...@apache.org> on 2024/08/18 16:06:21 UTC, 0 replies.
- [I] [Bug]: TextIO.read() runs in only one executor when using SparkStructuredStreamingRunner but runs in distributed manner with SparkRunner [beam] - posted by "DebajitKumarPhukan (via GitHub)" <gi...@apache.org> on 2024/08/18 16:11:55 UTC, 0 replies.
- [PR] Include Iceberg Hive runtime dependencies in IO expansion service container [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/18 18:13:21 UTC, 2 replies.
- [PR] [prism] rename watermarRefreshs concept to changed stages. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/18 23:12:38 UTC, 0 replies.
- Re: [PR] [prism] rename watermarkRefreshs concept to changedStages. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/18 23:35:03 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.66.0 to 1.67.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/19 04:45:08 UTC, 2 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/19 06:37:47 UTC, 7 replies.
- [I] [Task]: Remove version restriction on `requests` in python SDK [beam] - posted by "axelmagn (via GitHub)" <gi...@apache.org> on 2024/08/19 09:08:42 UTC, 2 replies.
- [PR] [#32080] Remove restriction on requests package [beam] - posted by "axelmagn (via GitHub)" <gi...@apache.org> on 2024/08/19 09:48:17 UTC, 4 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.58.0 to 2.58.1 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/19 10:24:52 UTC, 1 replies.
- [PR] [WIP] Add timeout to runinference [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:11:50 UTC, 0 replies.
- [PR] Add hard delete function to multi_process_shared [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:26:25 UTC, 2 replies.
- [PR] Bump apache-beam from 2.58.0 to 2.58.1 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/19 12:31:34 UTC, 1 replies.
- [PR] Upgrade to 2.58.1 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:34:34 UTC, 0 replies.
- Re: [PR] Bump maven-compiler-plugin from 3.10.1 to 3.11.0 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:35:18 UTC, 1 replies.
- Re: [PR] Bump actions/checkout from 3.5.3 to 4.1.0 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:35:18 UTC, 1 replies.
- Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.46.0 to 2.51.0 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:35:19 UTC, 3 replies.
- Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.46.0 to 2.51.0 [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/19 12:35:19 UTC, 3 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/08/19 13:08:56 UTC, 4 replies.
- [PR] Add BatchElements overview doc to Beam Website [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/19 14:47:18 UTC, 6 replies.
- [PR] Update beam-master to 20240819 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/19 16:48:31 UTC, 2 replies.
- [I] [Bug]: Google Ads Connector broken, needs to be updated to latest version of the Google Ads API [beam] - posted by "bcoryat (via GitHub)" <gi...@apache.org> on 2024/08/19 18:02:13 UTC, 1 replies.
- Re: [PR] Bump to Java17 for GHA runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/19 19:03:26 UTC, 1 replies.
- [PR] [Managed Iceberg] Support BigQuery Metastore catalog [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/19 19:23:08 UTC, 8 replies.
- [PR] Fix it-mongo compile fail on Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/19 19:56:15 UTC, 3 replies.
- [PR] Bump google-ads API to v17 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/19 20:48:38 UTC, 5 replies.
- [I] [Bug]: [Go SDK]: State API writes may become corrupted with Go 1.23 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/19 23:18:12 UTC, 2 replies.
- [PR] [#32245][Go SDK] Copy bytes sent over the State API Writer. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/19 23:32:42 UTC, 5 replies.
- [PR] Portable runner fixes [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/20 00:44:45 UTC, 6 replies.
- [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/08/20 01:04:05 UTC, 0 replies.
- [PR] Bump actions/setup-java from 3 to 4 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:04:08 UTC, 0 replies.
- [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/08/20 01:33:58 UTC, 0 replies.
- [PR] Bump org.hamcrest:hamcrest from 2.2 to 3.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:34:01 UTC, 0 replies.
- [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/08/20 01:34:02 UTC, 1 replies.
- [PR] Bump org.apache.maven.plugins:maven-compiler-plugin from 3.10.1 to 3.13.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:42:34 UTC, 0 replies.
- [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.4.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:42:37 UTC, 2 replies.
- [PR] Bump org.apache.maven.plugins:maven-assembly-plugin from 3.6.0 to 3.7.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:42:39 UTC, 0 replies.
- [PR] Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.4.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 01:42:41 UTC, 0 replies.
- [PR] Bump com.gradle.develocity from 3.17.6 to 3.18 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 04:41:46 UTC, 1 replies.
- [I] [Bug]: IndexOutOfBoundsException in TextIO.Read with non-default delimiter [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/08/20 04:45:13 UTC, 0 replies.
- [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/08/20 04:46:05 UTC, 1 replies.
- [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/08/20 06:53:48 UTC, 2 replies.
- [I] [Feature Request]: Add to ClickHouseIO dedicated useragnet [beam] - posted by "mzitnik (via GitHub)" <gi...@apache.org> on 2024/08/20 07:11:03 UTC, 1 replies.
- [PR] Add to ClickHouseIO dedicated useragnet [beam] - posted by "mzitnik (via GitHub)" <gi...@apache.org> on 2024/08/20 07:26:51 UTC, 2 replies.
- [PR] Attach file extension to Iceberg writes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/20 14:17:03 UTC, 5 replies.
- Re: [PR] Add iceberg load test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 15:36:39 UTC, 2 replies.
- [PR] Bump nltk from 3.8.1 to 3.9 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/20 16:33:18 UTC, 3 replies.
- Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:05 UTC, 2 replies.
- Re: [I] The LoadTests Python Combine Flink Streaming job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:05 UTC, 2 replies.
- Re: [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:06 UTC, 2 replies.
- Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:06 UTC, 2 replies.
- Re: [I] The Dask Runner Tests job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:07 UTC, 2 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:07 UTC, 2 replies.
- Re: [I] The PostCommit Java Sickbay job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:07 UTC, 2 replies.
- Re: [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:08 UTC, 4 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:08 UTC, 3 replies.
- Re: [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:09 UTC, 0 replies.
- Re: [I] The PostCommit Python Arm job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:09 UTC, 0 replies.
- Re: [I] The PreCommit Python Coverage job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:10 UTC, 0 replies.
- Re: [I] The PostCommit Sickbay Python job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:10 UTC, 2 replies.
- Re: [I] The PreCommit Java Examples Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:11 UTC, 0 replies.
- Re: [I] The Python tests job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:11 UTC, 0 replies.
- Re: [I] The Cancel Stale Dataflow Jobs job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:12 UTC, 0 replies.
- Re: [I] The Clean Up GCP Resources job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:12 UTC, 4 replies.
- Re: [I] The build_release_candidate job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:13 UTC, 0 replies.
- Re: [I] The StressTests Java BigQueryIO job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:14 UTC, 0 replies.
- Re: [I] The TypeScript Tests job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:15 UTC, 2 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:15 UTC, 0 replies.
- Re: [I] The PostCommit Java ValidatesRunner Flink job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:16 UTC, 0 replies.
- Re: [I] The LoadTests Go GBK Flink Batch job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:16 UTC, 2 replies.
- Re: [I] The PostCommit Java PVR Spark Batch job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:17 UTC, 2 replies.
- Re: [I] The PostCommit Java InfluxDbIO Integration Test job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:17 UTC, 0 replies.
- Re: [I] The LoadTests Go SideInput Flink Batch job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:18 UTC, 2 replies.
- Re: [I] The Clean Up Prebuilt SDK Images job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:18 UTC, 2 replies.
- Re: [I] The PostCommit XVR Direct job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:19 UTC, 4 replies.
- Re: [I] The LoadTests Go CoGBK Flink Batch job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:27 UTC, 2 replies.
- Re: [I] The PostCommit Java ValidatesRunner Flink Java11 job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/20 16:40:28 UTC, 0 replies.
- [PR] Update nltk version to 3.9.1 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/20 17:30:45 UTC, 3 replies.
- [PR] [WIP] Fix TextSource checking of custom delimiters [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/20 18:55:48 UTC, 2 replies.
- [PR] WIP to improve custom delimiter to support overlapping and spanning buffers without exception. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/08/20 20:34:14 UTC, 0 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/20 20:40:57 UTC, 2 replies.
- [I] [Feature Request]: extensions/protobuf does not support google.protobuf.Struct [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/20 20:48:06 UTC, 0 replies.
- [PR] Better error message when trying to get Beam Schema from proto schema with Struct [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/20 21:15:46 UTC, 4 replies.
- [PR] [Go SDK] Resolve dependecy bump (pubsub,fake-gcs-server) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/21 00:55:04 UTC, 1 replies.
- [PR] Fixes a breakage related to Kafka upgrade [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/21 01:02:00 UTC, 3 replies.
- [I] [Bug][Prism]: Java Prism Runner tests always pass despite Job failure [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/21 02:58:14 UTC, 0 replies.
- [PR] Finalize Java Prism Runner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/21 02:58:15 UTC, 7 replies.
- Re: [PR] Rag opensearch usecase with Beam's MLTransform [beam] - posted by "itsayushpandey (via GitHub)" <gi...@apache.org> on 2024/08/21 03:01:36 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.59.0 to 1.60.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/21 04:30:39 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.11 to 1.17.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/21 04:31:38 UTC, 2 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.32.0 to 0.33.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/21 04:31:47 UTC, 6 replies.
- [I] Sorry, only users with push access can use that command. [beam] - posted by "shahine44 (via GitHub)" <gi...@apache.org> on 2024/08/21 10:35:33 UTC, 3 replies.
- Re: [PR] Add timeout to runinference [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/21 12:55:14 UTC, 8 replies.
- [PR] Better error when Python xlang download jar not available [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/21 15:01:21 UTC, 7 replies.
- [PR] Update requests package to 2.32.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/21 16:08:35 UTC, 2 replies.
- [PR] Revert "Portable runner fixes" [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/21 17:04:00 UTC, 4 replies.
- [PR] Do not create new Executor everytime createRunner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/21 18:52:09 UTC, 16 replies.
- Re: [PR] [WIP] Update upper bound for protobuf to support < 6.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/21 20:11:01 UTC, 1 replies.
- [PR] [WIP] Support Protobuf 5.x [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/21 20:11:52 UTC, 0 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/21 22:14:00 UTC, 2 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/21 22:14:06 UTC, 1 replies.
- [PR] [prism] Add an idle shutdown timout to prism binary. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/21 23:32:31 UTC, 6 replies.
- [PR] Bump google.golang.org/api from 0.192.0 to 0.193.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/22 04:26:36 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/datastore from 1.17.1 to 1.18.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/22 04:27:12 UTC, 3 replies.
- [PR] [WIP] Remove Python 3.8 Support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/22 15:14:10 UTC, 1 replies.
- [PR] Cherrypick #32276 to 2.59.0 release branch. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/22 15:21:26 UTC, 3 replies.
- [PR] Move RunInference GC to finalize_bundle [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/22 16:24:53 UTC, 3 replies.
- Re: [I] MQTT IO connector for Python [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/22 16:47:50 UTC, 1 replies.
- [PR] Download BQMS catalog jar at build time [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/22 16:54:32 UTC, 3 replies.
- [PR] [WIP] Remove Python 3.8 targets from Actions [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/22 16:57:38 UTC, 1 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/22 17:21:21 UTC, 1 replies.
- [PR] Check experiment for hotkey logging [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/22 17:28:04 UTC, 5 replies.
- [PR] Add enrichment transform to Beam YAML [beam] - posted by "reeba212 (via GitHub)" <gi...@apache.org> on 2024/08/22 17:41:40 UTC, 0 replies.
- [PR] [CHANGES.md] Add 2.60.0 section. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/22 17:43:28 UTC, 4 replies.
- Re: [I] [Task]: Migrate to build with Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/22 17:46:33 UTC, 0 replies.
- [PR] Add examples for Spanner IO in YAML [beam] - posted by "reeba212 (via GitHub)" <gi...@apache.org> on 2024/08/22 17:52:50 UTC, 0 replies.
- [PR] Add use-cases for Enrichment transform in YAML [beam] - posted by "reeba212 (via GitHub)" <gi...@apache.org> on 2024/08/22 18:19:31 UTC, 0 replies.
- [PR] Cherry pick: Check experiment for hotkey logging (#32285) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/22 19:05:24 UTC, 1 replies.
- Re: [PR] [yaml] Add examples for Spanner IO in YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/22 19:56:39 UTC, 2 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/08/22 20:34:37 UTC, 2 replies.
- Re: [PR] [yaml] Add enrichment transform to Beam YAML [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/22 20:34:48 UTC, 1 replies.
- [PR] Build rc wheels in parallel to main wheels [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/22 22:12:38 UTC, 2 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/22 22:16:36 UTC, 1 replies.
- Re: [I] [Task][Prism]: Create a PrismRunner [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/22 22:18:57 UTC, 0 replies.
- [PR] Make autosharding test more robust [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/22 23:27:13 UTC, 3 replies.
- [PR] Implement Java TestPrismRunner and PrismRunner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/23 00:02:53 UTC, 5 replies.
- Re: [I] Portable runners should be able to issue checkpoints to Splittable DoFn [beam] - posted by "hemavenkatarangan-2 (via GitHub)" <gi...@apache.org> on 2024/08/23 00:14:03 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.60.0 to 1.60.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/23 04:45:33 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.192.0 to 0.194.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/23 04:48:40 UTC, 3 replies.
- [PR] Parallelize building wheels per language version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/23 07:36:27 UTC, 3 replies.
- [PR] Fix TextIO.read() split with non-default delimiter [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/08/23 09:50:05 UTC, 9 replies.
- [PR] Disable sickbay scheduled runs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/23 12:46:44 UTC, 4 replies.
- [PR] Remove some setup steps we don't need anymore [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/23 15:05:53 UTC, 3 replies.
- [PR] Rename delimiter to sep to pass to pandas. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/23 16:54:31 UTC, 2 replies.
- Re: [I] [Bug]: Java SDK BigQueryIO's RowMutationInformation class is not backward compatible with previous releases [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/23 19:58:28 UTC, 0 replies.
- Re: [PR] [yaml] Adding Spanner IO Providers for Beam YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/23 20:07:10 UTC, 7 replies.
- [I] [Feature Request]: Protobuf 5+ support [beam] - posted by "steerlink (via GitHub)" <gi...@apache.org> on 2024/08/23 20:28:54 UTC, 1 replies.
- [PR] Preserve numeric string literals when reading from json. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/23 21:26:27 UTC, 5 replies.
- [PR] Cherry Pick #32294 (Java PrismRunner and TestPrismRunner) to the release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/23 22:32:10 UTC, 3 replies.
- [PR] Add WindowedvalueParam option to DoFns. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/23 22:35:59 UTC, 3 replies.
- Re: [I] [Task][Prism]: Create a PrismRunnerRegistrar [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/23 23:17:02 UTC, 0 replies.
- Re: [I] [Task][Prism]: Create a PipelineResult implementation [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/23 23:17:03 UTC, 0 replies.
- [I] [Bug]: Issue with the script for adding execute task in "Convert from Maven to Gradle" section [beam] - posted by "KomiB-Atsou (via GitHub)" <gi...@apache.org> on 2024/08/24 01:32:27 UTC, 1 replies.
- [I] [Feature Request]: Running Word-Count with Gradle for PowerShell [beam] - posted by "KomiB-Atsou (via GitHub)" <gi...@apache.org> on 2024/08/24 01:50:49 UTC, 1 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/24 12:42:41 UTC, 0 replies.
- [PR] 2.59.0 Beam site updates. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/08/24 17:01:29 UTC, 1 replies.
- [I] [Bug]: Beam Interactive Tour Mismatch [beam] - posted by "MrYanMYN (via GitHub)" <gi...@apache.org> on 2024/08/24 18:22:57 UTC, 0 replies.
- Re: [I] Add support for dynamic destinations when writing to MQTT [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/25 07:54:52 UTC, 0 replies.
- [I] [Feature Request]: Add A Freature to get bigquery schema dynamically from a POJO class. [beam] - posted by "nivedha1 (via GitHub)" <gi...@apache.org> on 2024/08/25 16:39:55 UTC, 0 replies.
- [PR] Add predicate to control which columns are propagated when propagating successful rows [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2024/08/25 18:35:30 UTC, 10 replies.
- [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/08/26 04:39:38 UTC, 1 replies.
- [PR] Cherry Pick #32178: Loose BigQuery GCP project ID regex restrictions [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/08/26 06:17:28 UTC, 6 replies.
- [I] [Failing Test]: [beam] - posted by "Lucky777178 (via GitHub)" <gi...@apache.org> on 2024/08/26 09:41:38 UTC, 3 replies.
- [I] [Task]: Fix invalid links in `Beam Programming Guide` [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/26 13:35:45 UTC, 2 replies.
- [PR] Fixed invalid links on `programming-guide.md` [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/08/26 13:40:00 UTC, 2 replies.
- [PR] Add patch release docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/26 16:35:05 UTC, 2 replies.
- [PR] Refactor PubsubIO Lineage metrics to work with all runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/26 18:51:06 UTC, 4 replies.
- [PR] Add beam summit banner [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/26 21:16:09 UTC, 3 replies.
- [PR] Fix BQMS jar download error [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/26 23:34:49 UTC, 5 replies.
- [I] [Feature Request]: Auto-detect Schema for Parquet Sink [beam] - posted by "gbsDojo (via GitHub)" <gi...@apache.org> on 2024/08/27 01:34:57 UTC, 0 replies.
- [PR] Move beam summit banner to top of swiper slide [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/27 08:44:48 UTC, 3 replies.
- [I] The PreCommit GoPortable job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/27 09:33:59 UTC, 4 replies.
- [PR] Update direct_runner.py [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/08/27 12:53:23 UTC, 9 replies.
- [PR] WIP: Ordered list state python [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/27 14:36:49 UTC, 0 replies.
- [PR] Revert "Download BQMS catalog jar at build time" [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/27 15:06:32 UTC, 2 replies.
- [PR] Fix remote execution test flakiness in tearDown [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/27 15:13:50 UTC, 5 replies.
- [PR] [DO NOT MERGE] Python 3.8 deprecation workflow validation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/08/27 15:35:51 UTC, 2 replies.
- [PR] Use proper coders in interactive cache. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/27 16:24:21 UTC, 2 replies.
- [PR] Remove beam summit banner [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/27 17:00:36 UTC, 0 replies.
- Re: [I] [Feature Request]: Support writing to a Solace message broker [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/08/27 17:17:33 UTC, 0 replies.
- [I] [Bug]: Support error handling in PyTransform [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/27 17:51:13 UTC, 0 replies.
- [I] [Bug]: Better error message for specifying inputs on chain pipeline in Beam YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/27 18:10:06 UTC, 0 replies.
- [I] [Feature Request]: Emit warnings when pcollection elements approach or exceed 2GB limits. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/27 18:36:51 UTC, 0 replies.
- [I] [Bug]: BigQueryIO storage write api dynamic destination conflicts if multiple transforms set same destination key [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/27 18:54:54 UTC, 0 replies.
- [PR] Colab Notebook with Unit Tests in Beam [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/08/27 18:55:16 UTC, 2 replies.
- [PR] Add doc string and signature to generated Python wrappers [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/27 18:56:54 UTC, 4 replies.
- [PR] Document dynamic destination key should be unique over the pipeline [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/27 18:58:25 UTC, 7 replies.
- [I] [Bug]: Add check for self-referencing input in YAML transform [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/27 19:01:03 UTC, 0 replies.
- [PR] Fix BigtableIO.write() client sharing [beam] - posted by "igorbernstein2 (via GitHub)" <gi...@apache.org> on 2024/08/27 19:37:31 UTC, 9 replies.
- [PR] [YAML] Better errors for unconsumed error outputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/27 20:16:56 UTC, 2 replies.
- [PR] Fix writing raw messages to pubsub [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/27 20:19:31 UTC, 5 replies.
- [PR] Fix Kafka with Redistribute [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/08/28 00:13:23 UTC, 6 replies.
- [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.5.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/28 01:22:49 UTC, 0 replies.
- [PR] docs: modernize py dependencies docs and example [beam] - posted by "nitobuendia (via GitHub)" <gi...@apache.org> on 2024/08/28 04:10:39 UTC, 8 replies.
- Re: [I] [Parent issue] Support for Apache Pulsar [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 12:42:19 UTC, 0 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/28 12:44:39 UTC, 0 replies.
- [PR] Add quality warnings to pulsar [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 12:50:46 UTC, 3 replies.
- Re: [PR] Colab Notebook for Unit Tests in Beam [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 13:14:49 UTC, 1 replies.
- [PR] Filter out old actions runs from dashboard [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 13:36:47 UTC, 3 replies.
- [PR] Fix pr building of wheels [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 14:09:44 UTC, 7 replies.
- [I] [Feature Request]: Support Zstd codec in SerializableAvroCodecFactory [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/08/28 14:33:17 UTC, 0 replies.
- Re: [I] [Bug]: Using WriteToBigQuery FILE_LOADS in a streaming pipeline does not remove temporary tables [beam] - posted by "shresthapradip (via GitHub)" <gi...@apache.org> on 2024/08/28 15:28:28 UTC, 0 replies.
- [PR] Try deflaking test timing [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/08/28 19:24:02 UTC, 4 replies.
- [PR] Support Zstd codec in SerializableAvroCodecFactory [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/08/28 19:25:24 UTC, 3 replies.
- [PR] Pause delete images in public AR [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/28 19:37:33 UTC, 2 replies.
- [PR] Fix rawtype warning in Watch and CoGroup [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/28 20:27:34 UTC, 1 replies.
- [PR] Fix Dataflow ARM Java Example PostCommit bad gradle cache [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/28 20:32:19 UTC, 6 replies.
- Re: [PR] Portable Dynamic Destinations [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/08/28 21:27:54 UTC, 0 replies.
- Re: [I] [Bug]: WriteToFiles(output_fn=...) is seemingly unused [beam] - posted by "tsafacjo (via GitHub)" <gi...@apache.org> on 2024/08/28 21:42:50 UTC, 1 replies.
- Re: [I] [Bug]: Python GCSFileSystem.delete does not recursively delete [beam] - posted by "tsafacjo (via GitHub)" <gi...@apache.org> on 2024/08/28 21:44:54 UTC, 3 replies.
- Re: [I] Python SDK BigQuery `schemaUpdateOptions` [beam] - posted by "tsafacjo (via GitHub)" <gi...@apache.org> on 2024/08/28 21:49:24 UTC, 0 replies.
- [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/08/29 05:06:28 UTC, 1 replies.
- [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/08/29 05:07:46 UTC, 1 replies.
- [PR] Update groupbykey.py [beam] - posted by "cgrotz (via GitHub)" <gi...@apache.org> on 2024/08/29 07:56:09 UTC, 1 replies.
- Re: [PR] implementation equals and hashCode of FlinkOrderedListState [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/29 12:44:16 UTC, 0 replies.
- [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/08/29 13:13:56 UTC, 4 replies.
- Re: [PR] Support ordered list states in python sdk and fnapi runner [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/08/29 13:56:26 UTC, 1 replies.
- [I] [Bug]: Using `GcsIO` in Python with a `DoFn` fails [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/08/29 17:36:12 UTC, 3 replies.
- [PR] Fix using `GcsIO` from a `DoFn`in Python [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/08/29 17:49:22 UTC, 5 replies.
- [PR] Relocate guava in shaded hive-exec [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/29 18:14:20 UTC, 4 replies.
- [I] [Prism][Task]: Register Java Prism Runner pipeline options [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/08/29 18:23:39 UTC, 0 replies.
- [I] [Task]: Add utilities to easily implement portable dynamic destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/29 19:16:00 UTC, 0 replies.
- [PR] Add RowFilter utility [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/29 19:18:55 UTC, 3 replies.
- [PR] Add RowStringInterpolator utility [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/29 19:28:09 UTC, 4 replies.
- [PR] Cherrypicking 32363 hive-exec shading fix [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/29 19:46:45 UTC, 2 replies.
- [PR] Updates Python SDK harness HEAD container for Dataflow. [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/08/29 21:24:54 UTC, 4 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/29 22:14:29 UTC, 1 replies.
- [I] [Bug]: Flink Job manager metaspace classloader leak [beam] - posted by "gli-marc-hurabielle (via GitHub)" <gi...@apache.org> on 2024/08/30 09:28:11 UTC, 0 replies.
- Re: [PR] Optimize Datastream for batch [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/08/30 09:36:40 UTC, 0 replies.
- [PR] Improve Datastream for batch performances [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/08/30 09:39:43 UTC, 0 replies.
- [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 "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/30 11:10:43 UTC, 1 replies.
- [PR] Bump micromatch from 4.0.2 to 4.0.8 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/08/30 11:26:44 UTC, 2 replies.
- [PR] Fix BQ storage stream split [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/08/30 12:57:32 UTC, 5 replies.
- [PR] [yaml] Move js2py package to yaml deps [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/08/30 14:26:28 UTC, 3 replies.
- [PR] Fix juliaset_test_it [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/30 14:57:53 UTC, 0 replies.
- [PR] Memoize toString() for MetricKey and MetricName [beam] - posted by "FuRyanf (via GitHub)" <gi...@apache.org> on 2024/08/30 16:39:47 UTC, 7 replies.
- [I] [Feature Request]: Expand --extra_package option to allow passing a directory containing the package and deprecate the --setup_file option [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/30 16:56:46 UTC, 1 replies.
- [PR] Move PubsubIO source Lineage report to MapElements [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/08/30 17:02:08 UTC, 2 replies.
- [PR] Revert "docs: modernize py dependencies docs and example" [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/08/30 17:51:22 UTC, 3 replies.
- [PR] Allow ib.collect to work with non-interactive runners. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/30 18:34:51 UTC, 2 replies.
- [PR] Clarify error handling parameter in yaml docs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/08/30 19:17:35 UTC, 2 replies.
- [PR] Add portable Mqtt source and sink transforms [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/30 20:29:05 UTC, 2 replies.
- [PR] Temporarily remove BQMS catalog until it is opend-sourced [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/08/30 22:07:11 UTC, 5 replies.
- Re: [PR] Integrate direct path/fan out logic [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/31 12:42:38 UTC, 0 replies.
- Re: [PR] Replace StorageV1 client with GCS client - Draft [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/08/31 12:42:41 UTC, 0 replies.
- [I] [Feature Request]: Docker images with both runtime and launch environments [beam] - posted by "amardeep (via GitHub)" <gi...@apache.org> on 2024/08/31 12:52:54 UTC, 0 replies.
- Re: [I] [Bug]: ReadFromKafka not forwarding in streaming mode version on portable runners [beam] - posted by "MrYanMYN (via GitHub)" <gi...@apache.org> on 2024/08/31 15:19:49 UTC, 1 replies.