You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [PR] Add Storage API max retries parameter for BigQueryOptions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 16:55:53 UTC, 0 replies.
- Re: [PR] Expose GroupIntoBatches parameters for WriteFiles auto-sharding transform [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 16:55:55 UTC, 1 replies.
- Re: [I] [Feature Request]: Expose GroupIntoBatches Parameters for WriteFiles Autosharding transform [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 16:55:56 UTC, 0 replies.
- [PR] Basic yaml-defined provider. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/02 16:55:59 UTC, 3 replies.
- Re: [PR] Add Storage API streaming max retries parameter for BigQueryOptions [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/02 16:57:17 UTC, 0 replies.
- [PR] Fixes a regression related to BQ read transform upgrad via the TransformService [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/07/02 16:57:37 UTC, 1 replies.
- Re: [PR] Fixes a regression related to BQ read transform upgrade via the TransformService [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/02 16:57:39 UTC, 0 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/07/02 16:58:16 UTC, 14 replies.
- [PR] Bump apache-beam from 2.56.0 to 2.57.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/02 17:01:02 UTC, 1 replies.
- Re: [PR] Enable MapState and SetState for dataflow streaming engine pipelines with legacy runner by building on top of MultimapState. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/07/02 17:02:15 UTC, 5 replies.
- Re: [I] [Bug]: Reshuffle.viaRandomKey timeout since version 2.54.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:23 UTC, 0 replies.
- Re: [PR] Properly close Storage API batch connections [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:29 UTC, 2 replies.
- Re: [PR] Add spark mapstate [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:34 UTC, 0 replies.
- Re: [I] [Feature Request]: Add MapState in SparkRunner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:34 UTC, 0 replies.
- Re: [I] [Bug]: Coder cannot be resolved after `WithKeys.of().withKeyType()` for @DefaultSchema(JavaBeanSchema.class) types [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:46 UTC, 0 replies.
- [PR] Set SchemaCoder for key in WithKeys transform [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:49 UTC, 0 replies.
- [PR] Add scaffold CsvIOParseHelpers [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/02 17:03:58 UTC, 0 replies.
- Re: [PR] [CsvIO] Create CsvIOParseConfiguration [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:01 UTC, 0 replies.
- Re: [PR] Remove excessive logging in test. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:01 UTC, 0 replies.
- Re: [I] [CsvIO]: Create a CsvIOParseConfiguration Class [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:01 UTC, 0 replies.
- [PR] Add options to control number of Storage API connections when using multiplexing [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:08 UTC, 23 replies.
- [PR] [CsvIO] Move CsvIOParseResult [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:08 UTC, 2 replies.
- Re: [PR] [CsvIO] Scaffold CsvIOParseHelpers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:21 UTC, 0 replies.
- Re: [I] [prism] Programmatic Cancel, and Drain [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/02 17:04:59 UTC, 1 replies.
- Re: [PR] [Dataflow Streaming] Enabled Heartbeat by Default [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/07/02 17:07:06 UTC, 0 replies.
- Re: [PR] Add a unit test for MakePipelineOptionsFileAndEnvVar [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 17:07:22 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Reading from Solace message broker [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/07/02 17:08:25 UTC, 17 replies.
- Re: [I] [Bug]: The Documentation of `@SchemaFieldNumber` has the wrong type [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/02 17:08:42 UTC, 1 replies.
- Re: [I] [Bug]: Using string in PartitionColumn throws error, tries to convert it to string [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:08:45 UTC, 0 replies.
- Re: [PR] Support custom JdbcReadWithPartitionsHelper [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:10:13 UTC, 0 replies.
- Re: [PR] Disable caching for one more workflow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/02 17:10:22 UTC, 0 replies.
- Re: [PR] Update joda-time to 2.10.14 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 17:10:23 UTC, 0 replies.
- [PR] Update Playground Python Dockerfile [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 17:10:55 UTC, 2 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 17:11:33 UTC, 1 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 17:11:34 UTC, 1 replies.
- [PR] Update Staticcheck to 2023.1.7 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 17:33:01 UTC, 3 replies.
- [PR] Updates Dataflow service API version. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/07/02 17:37:42 UTC, 3 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/07/02 17:39:54 UTC, 1 replies.
- Re: [PR] Disable SoftDeletePolicy when creating a default bucket [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/02 18:36:07 UTC, 1 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 19:12:22 UTC, 2 replies.
- [PR] Fix installation invocation for OpenJDK [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/02 19:24:59 UTC, 3 replies.
- Re: [I] Tre [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/02 19:26:02 UTC, 0 replies.
- Re: [I] [Feature Request]: Disable soft delete policy when creating a default bucket in Go SDK [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/02 19:34:13 UTC, 0 replies.
- Re: [I] [Feature Request]: Increase the test coverage of pipieline_options.go [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/02 21:24:18 UTC, 1 replies.
- Re: [PR] Use highmem runner for beam_PostRelease_NightlySnapshot.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/02 22:05:22 UTC, 2 replies.
- [PR] [prism] Remove the xlang cogbk test [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/02 22:17:14 UTC, 1 replies.
- [PR] Eliminate testRuntimeMigration for extensions-avro project dependency [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/02 22:22:28 UTC, 0 replies.
- [PR] Modernize type hints [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/02 22:26:51 UTC, 14 replies.
- Re: [I] [Bug][Prism]: panic: unsupported StateKey Get type: *fnexecution_v1.StateKey_MultimapKeysSideInput_ [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/02 22:39:56 UTC, 1 replies.
- Re: [I] [Bug]: Worker logs on Prism Stand-Alone Binary Not Appearing [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/02 22:43:56 UTC, 2 replies.
- [I] [Feature Request][Prism]: Add test for StateKey_MultimapSideInput in State in worker.go [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/02 23:11:47 UTC, 3 replies.
- Re: [PR] Solace Read connector: adding implementations of SempClient and SempClientFactory [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/03 02:41:03 UTC, 7 replies.
- Re: [PR] Solace Read connector: integration tests with testcontainers [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/03 02:45:48 UTC, 6 replies.
- [PR] [#31756][Prism] Add a test for getting state with MultimapSideInput StateKey [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/03 04:36:57 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/03 05:09:57 UTC, 3 replies.
- [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/07/03 05:13:24 UTC, 1 replies.
- Re: [PR] Pass-through IcebergIO catalog properties [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/03 06:13:15 UTC, 3 replies.
- [PR] Use GCP libraries-bom version for all grpc [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/07/03 08:30:41 UTC, 2 replies.
- Re: [I] [Feature Request]: Better assertion error message for PAssert.thatSingleton [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/03 10:02:39 UTC, 1 replies.
- Re: [PR] Unit Testing in Beam Blog Post [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/03 10:26:48 UTC, 10 replies.
- [PR] Better assertion error messages for PAssert.thatSingleton [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/03 10:34:02 UTC, 13 replies.
- Re: [PR] Solace Read connector: Use ByteBuffer instead of BytesString in the Record class [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/03 12:04:39 UTC, 1 replies.
- Re: [PR] Pass original message down through conversion for storage write api [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/03 12:13:58 UTC, 3 replies.
- Re: [I] [Feature Request]: Design and Implement I/O Connector Error Handling components [beam] - posted by "Bladieblah (via GitHub)" <gi...@apache.org> on 2024/07/03 14:27:49 UTC, 0 replies.
- [PR] Bump to Java17 for GHA runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/03 16:00:42 UTC, 2 replies.
- [PR] Address a data race on numMessages in DirectStreamObserver.java [beam] - posted by "t2h6 (via GitHub)" <gi...@apache.org> on 2024/07/03 16:56:12 UTC, 2 replies.
- [PR] Polish DoFn.Setup [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/07/03 18:13:01 UTC, 3 replies.
- [I] [Bug]: Some Beam playground code snippets fail to load. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/03 18:28:22 UTC, 4 replies.
- Re: [PR] Added insertion and enrichment pipeline [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/03 18:55:50 UTC, 12 replies.
- Re: [I] The PostCommit Java ValidatesRunner Samza job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/03 19:21:03 UTC, 3 replies.
- Re: [I] [Feature Request]: Add warning if temp location bucket has soft delete enabled for Go SDK. [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/03 21:06:09 UTC, 0 replies.
- [I] [Feature Request]: Remove LGPL dependencies from Go SDK [beam] - posted by "OliverCardoza (via GitHub)" <gi...@apache.org> on 2024/07/03 21:24:16 UTC, 2 replies.
- [PR] Add SerializableSupplier to the core package. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/03 21:31:42 UTC, 2 replies.
- [PR] Use go 1.22 for self-hosted GHAs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/03 21:47:02 UTC, 5 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/07/03 22:14:29 UTC, 1 replies.
- [PR] Replace LGPL dep in Go SDK with an MIT alternative [beam] - posted by "OliverCardoza (via GitHub)" <gi...@apache.org> on 2024/07/04 00:30:05 UTC, 2 replies.
- [PR] Fix CHANGES.md from #31769 which incorrectly added to a released version [beam] - posted by "OliverCardoza (via GitHub)" <gi...@apache.org> on 2024/07/04 03:02:31 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/04 05:10:58 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/storage from 1.41.0 to 1.43.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/04 05:11:22 UTC, 2 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/04 06:36:28 UTC, 1 replies.
- [PR] Fix PostCommit Java ValidatesRunner Samza job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/04 09:10:47 UTC, 10 replies.
- [I] Outdated version of apache-beam on npm registry [beam] - posted by "christophediprima (via GitHub)" <gi...@apache.org> on 2024/07/04 09:32:09 UTC, 1 replies.
- [I] [Feature Request]: Azure Event Hub [beam] - posted by "HarishHary (via GitHub)" <gi...@apache.org> on 2024/07/04 09:41:16 UTC, 0 replies.
- [I] [Feature Request]: AWS SQS [beam] - posted by "HarishHary (via GitHub)" <gi...@apache.org> on 2024/07/04 09:41:43 UTC, 0 replies.
- [I] [Feature Request]: AWS SNS? [beam] - posted by "HarishHary (via GitHub)" <gi...@apache.org> on 2024/07/04 09:42:01 UTC, 0 replies.
- Re: [I] Add readAll transform for pubsub [beam] - posted by "HarishHary (via GitHub)" <gi...@apache.org> on 2024/07/04 09:43:33 UTC, 0 replies.
- Re: [PR] Add SessionPoolOptions to SpannerConfig [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/04 12:14:05 UTC, 0 replies.
- Re: [PR] PubsubMessageWithTopicCoder.of() is returning wrong coder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/04 12:14:10 UTC, 4 replies.
- [PR] Fix playground snippets [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/04 13:57:10 UTC, 5 replies.
- [PR] Set Snowflake escape char to backslash [beam] - posted by "turb (via GitHub)" <gi...@apache.org> on 2024/07/04 17:56:56 UTC, 3 replies.
- [I] [Task]: Validate playground snippets in website documentation [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/04 18:22:02 UTC, 1 replies.
- [PR] Fix flaky StreamingDataflowWorkerTest which wasn't waiting for enough commits [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/07/04 19:01:09 UTC, 3 replies.
- Re: [I] [Feature Request][Go SDK]: Rewrite the `dot` runner in terms of a Portable pipeline. [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/04 22:37:21 UTC, 3 replies.
- Re: [I] [Bug][Go SDK]: Xlang Bigquery IO doesn't appear to support Time type fields. [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/05 00:39:32 UTC, 1 replies.
- [PR] Bump org.sonarqube from 3.0 to 5.1.0.4882 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/05 04:46:05 UTC, 1 replies.
- [PR] Check and warn if soft delete policy is enabled for temporary bucket [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/05 06:00:07 UTC, 3 replies.
- [PR] Fix/Refactor GetData interfaces for Direct Path integration [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/07/05 09:48:15 UTC, 63 replies.
- Re: [PR] Add SessionPoolOptions to SpannerAccessor [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/07/05 10:24:49 UTC, 0 replies.
- Re: [PR] Add SessionPoolOptions.setFailIfPoolExhausted in SpannerAccessor [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/07/05 11:35:32 UTC, 2 replies.
- Re: [PR] Bump cloud.google.com/go/storage from 1.41.0 to 1.42.0 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/05 12:13:52 UTC, 2 replies.
- Re: [PR] Bump ws from 6.2.2 to 6.2.3 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/07/05 12:13:53 UTC, 3 replies.
- Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.12 to 2.10.16 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/05 12:13:54 UTC, 3 replies.
- Re: [I] [Feature Request]: Support table schema field addition with Storage Write API autoSchemaUpdate [beam] - posted by "SumLare (via GitHub)" <gi...@apache.org> on 2024/07/05 15:52:37 UTC, 0 replies.
- [PR] Replace Class with TypeDescriptor in SchemaProvider implementations [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/07/05 15:56:26 UTC, 14 replies.
- [PR] [WIP] Add background thread and caching of consumers to Kafka SDF [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/07/05 21:09:47 UTC, 4 replies.
- Re: [PR] Disable soft delete when creating a default bucket [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/05 21:16:20 UTC, 0 replies.
- Re: [I] [Feature Request]:[Go SDK] Improve "bad return type" messaging [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/05 22:20:33 UTC, 0 replies.
- [PR] Support portable pipeline dot graph rendering [beam] - posted by "mls3odp (via GitHub)" <gi...@apache.org> on 2024/07/05 23:23:37 UTC, 2 replies.
- [I] [Feature Request]: Support StringSet Metrics in Beam for Dataflow [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/07/05 23:56:40 UTC, 1 replies.
- [PR] Add support for StringSet metric in Java SDK to track set of unique s… [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/07/06 01:23:48 UTC, 7 replies.
- [PR] Bump certifi from 2024.2.2 to 2024.7.4 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/06 01:30:57 UTC, 3 replies.
- Re: [PR] Move dependency compatibility tests to from py38 to py39 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/06 12:40:51 UTC, 2 replies.
- [PR] Add missing params to Python Bigtable MutationsBatcher [beam] - posted by "nguymin4 (via GitHub)" <gi...@apache.org> on 2024/07/07 11:00:48 UTC, 5 replies.
- Re: [PR] Raise upper bound for jinja2. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/07 12:40:59 UTC, 2 replies.
- [I] [Task][Prism]: A Java support class executes the Prism binary [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/07 22:00:12 UTC, 1 replies.
- [I] [Task][Prism]: Create a PrismRunner that extends PipelineRunner [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/07 22:00:48 UTC, 2 replies.
- [PR] Stage PrismRunner implementation and dependencies [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/07 22:20:23 UTC, 11 replies.
- [PR] A Java support class executes the Prism binary [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/07 22:36:16 UTC, 2 replies.
- [PR] DRAFT Locate and download Prism binary [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/07 22:44:05 UTC, 0 replies.
- Re: [PR] Allow pr-bot to re-assign reviewers when stopped [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/07/08 08:16:19 UTC, 5 replies.
- [I] [Task]: Replace deprecated StateTag.StateBinder in SparkStateInternals. [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/07/08 10:53:45 UTC, 1 replies.
- [PR] Replace state tag to top level [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/07/08 11:03:40 UTC, 0 replies.
- Re: [PR] Replace StateTag.StateBinder to top level StateBinder in SparkStateInternals [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/08 12:09:07 UTC, 6 replies.
- [I] [Task]: Remediate CVE-2024-28397 [beam] - posted by "markustoivonen (via GitHub)" <gi...@apache.org> on 2024/07/08 13:02:44 UTC, 2 replies.
- [I] [Bug]: PreparePubsubWriteDoFn does not guarantee that a message will not exceed hard request limits [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/07/08 14:43:37 UTC, 0 replies.
- [PR] correctly close the javadoc tag in JmsIO.Write [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/07/08 15:39:02 UTC, 5 replies.
- Re: [I] [Bug]: SnowflakeIO does not escape quote characters [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/08 15:54:44 UTC, 1 replies.
- Re: [PR] Locate and download Prism binary [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/08 20:34:26 UTC, 22 replies.
- [PR] [CsvIO] Implemented CsvIOParseHelpers:parseCell [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/08 20:55:04 UTC, 12 replies.
- [PR] Minor optimization for the common case of merging empty string sets. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/08 21:50:25 UTC, 1 replies.
- [I] [Feature Request]: Add support in BQ IO to emit dataset they are accessing for lineage tracking [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/07/08 22:09:49 UTC, 1 replies.
- [PR] Introduce support for emitting lineage in BQ Source [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/07/08 22:19:18 UTC, 6 replies.
- [PR] Add support for WindowStrategy Pane and AllowedLateness features [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/08 23:13:11 UTC, 2 replies.
- Re: [PR] Avoid length-prefix-bytes substitutions for Flink boundaries. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/08 23:13:18 UTC, 2 replies.
- [PR] Portable Dynamic Destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/08 23:15:59 UTC, 0 replies.
- Re: [PR] Support class executes the Prism binary [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/09 01:25:04 UTC, 4 replies.
- Re: [I] Eliminate nullability errors from :runners:direct-java [beam] - posted by "prateekrai1 (via GitHub)" <gi...@apache.org> on 2024/07/09 04:48:26 UTC, 0 replies.
- Re: [I] [Bug]: KinesisIO source on FlinkRunner initializes the same splits twice [beam] - posted by "dcasado (via GitHub)" <gi...@apache.org> on 2024/07/09 08:44:54 UTC, 0 replies.
- Re: [I] [Feature Request]: Allow Firestore project to be configurable [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/09 12:01:33 UTC, 1 replies.
- [PR] Allow Firestore project to be configurable [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/09 12:30:42 UTC, 2 replies.
- Re: [PR] WIP: [Go SDK] Handle PaneInfo correctly [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/09 12:43:19 UTC, 2 replies.
- [PR] Solace Read connector: switch flags to publish the package [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/09 13:37:14 UTC, 4 replies.
- [PR] Don't cache when building release candidates [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/09 14:34:51 UTC, 3 replies.
- [PR] Add link to security model [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/09 14:55:41 UTC, 3 replies.
- Re: [I] [Bug][Prism]: unsupported feature "WindowStrategy.AllowedLateness" [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/09 15:50:52 UTC, 0 replies.
- Re: [I] [Bug][Prism]: unsupported feature "WindowStrategy.OutputTime" set with value (LATEST|EARLIEST)_IN_PANE [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/09 15:50:52 UTC, 2 replies.
- [PR] Update Go Version to 1.22.5 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/09 17:19:27 UTC, 3 replies.
- [PR] [WIP] Update upper bound for protobuf to support < 6.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/09 18:03:44 UTC, 0 replies.
- Re: [PR] Add in redistribute option for Kafka Read [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/07/09 18:29:42 UTC, 0 replies.
- [I] [Failing Test]: ValidatesRunner tests failing due to StringSet counter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/09 18:43:50 UTC, 3 replies.
- [PR] Bump zipp from 3.18.1 to 3.19.1 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/09 19:13:33 UTC, 5 replies.
- Re: [I] [Bug]: PubsubMessage should be renamed to PubSubMessage to reduce confusion [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/09 19:57:35 UTC, 2 replies.
- [PR] Update RowJsonUtils.java [beam] - posted by "khaibuigoogle (via GitHub)" <gi...@apache.org> on 2024/07/09 20:15:08 UTC, 1 replies.
- Re: [I] [Feature Request]: PrBot should have a workflow to re-assign reviewers if stopped [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/09 20:22:48 UTC, 1 replies.
- Re: [PR] Managed BigQueryIO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/09 21:46:30 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.64.0 to 1.64.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/09 22:01:58 UTC, 2 replies.
- [PR] Excludestringset [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/09 22:10:47 UTC, 0 replies.
- [PR] Remove CsvIOParseResult [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/09 22:46:05 UTC, 4 replies.
- Re: [PR] Exclude StringSet tests from portable runners and Dataflow LegacyRunner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/10 00:15:42 UTC, 0 replies.
- [PR] Adds ordered list state to `getCacheFor` switch statement. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/07/10 00:22:17 UTC, 2 replies.
- [PR] Disable publish StringSet metrics for Dataflow Legacy worker [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/10 01:19:46 UTC, 3 replies.
- [PR] Validate commits in StreamingDataflowWorker [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/07/10 01:27:56 UTC, 27 replies.
- [PR] Add lineage information for BigQuery sinks. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/10 03:44:42 UTC, 13 replies.
- [PR] Bump google.golang.org/grpc from 1.64.0 to 1.65.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/10 04:22:58 UTC, 1 replies.
- [PR] Avoid publishing string set metrics on the Dataflow legacy runner. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/10 04:57:03 UTC, 4 replies.
- Re: [I] Fix ListOverMultiMapView's implementation of the Iterables interface [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/10 08:51:02 UTC, 0 replies.
- Re: [I] [Feature Request]: UDF supports lambda & RecordType parameter [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/10 10:11:35 UTC, 1 replies.
- [PR] Solace Read: add changelog notes regarding Solace read connector [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/10 12:01:38 UTC, 2 replies.
- Re: [PR] Automatically format build.gradle throughout project [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/10 12:43:00 UTC, 2 replies.
- [I] [Feature Request]: Update the default behaviour in `BigQueryIO.Write.Method.DEFAULT` to `STORAGE_API_AT_LEAST_ONCE` [beam] - posted by "borjavb (via GitHub)" <gi...@apache.org> on 2024/07/10 12:59:53 UTC, 1 replies.
- [I] [Feature Request]: Implement a GroupIntoBatches(.WithShardedKey) based sink for PubsubIO.Write [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/07/10 13:09:01 UTC, 0 replies.
- [PR] Dedup SerializableSupplier [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/10 15:14:48 UTC, 4 replies.
- [I] [Feature Request]: Iceberg Support for Python [beam] - posted by "asheeshgarg (via GitHub)" <gi...@apache.org> on 2024/07/10 15:45:10 UTC, 2 replies.
- [PR] Update CHANGES.md with 2.59.0 Section [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/10 15:55:46 UTC, 2 replies.
- Re: [PR] [DO NOT MERGE] [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/10 16:07:05 UTC, 0 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/10 16:17:49 UTC, 2 replies.
- [PR] Add doc advising against using IcebergIO directly [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/10 17:03:45 UTC, 3 replies.
- [PR] CP(#31833) Add doc warning against using icebergio directly [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/10 18:05:09 UTC, 3 replies.
- [PR] Change orphan file log to warning [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/10 18:18:07 UTC, 7 replies.
- Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] - posted by "felipecaputo (via GitHub)" <gi...@apache.org> on 2024/07/10 18:46:06 UTC, 0 replies.
- Re: [I] [Task][prism] Have java wrapper check and download released prism binary if available. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/10 22:47:27 UTC, 0 replies.
- [PR] Increase retry backoff for Storage API batch [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/11 00:26:26 UTC, 2 replies.
- [PR] Export string sets in monitoring infos. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/11 00:28:27 UTC, 7 replies.
- [I] [Bug]: KafkaIO documentation gap [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/07/11 00:44:14 UTC, 0 replies.
- Re: [PR] Increase retry backoff for Storage API batch to survive AppendRows quota refill [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/11 01:49:38 UTC, 11 replies.
- [PR] Improve performance of BigQueryIO connector when withPropagateSuccessfulStorageApiWrites(true) is used [beam] - posted by "slilichenko (via GitHub)" <gi...@apache.org> on 2024/07/11 03:40:16 UTC, 6 replies.
- [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/07/11 04:47:57 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/11 04:52:54 UTC, 3 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/11 06:36:12 UTC, 2 replies.
- [PR] playground python image update openjdk to 17 [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/07/11 08:27:30 UTC, 2 replies.
- [PR] SnowflakeIO: Use fileNameTemplate attribute for file prefix [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/11 09:27:27 UTC, 2 replies.
- Re: [I] [Bug]: Snowflake IO fileNameTemplate unused [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/11 14:23:46 UTC, 0 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/07/11 15:07:30 UTC, 2 replies.
- [PR] [Release-2.58.0] Cherry-pick #31835 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/11 15:26:08 UTC, 3 replies.
- [I] The Clean Up GCP Resources job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/11 15:33:50 UTC, 1 replies.
- [I] metrics.beam.apache.org timing out [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/07/11 15:58:08 UTC, 0 replies.
- [I] [Failing Test]: beam_CleanUpGCPResources failing with insufficient GCP permissions [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/07/11 16:11:10 UTC, 0 replies.
- Re: [I] [CsvIO]: Create CsvIOParseHelpers::parseCell(String, Schema.Field) [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/11 16:27:26 UTC, 0 replies.
- [PR] Export string sets in monitoring infos. (#31838) [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/11 16:47:18 UTC, 4 replies.
- [PR] Fix Python test auth [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/11 17:03:58 UTC, 6 replies.
- [I] [CsvIO]: Change CsvIOParseConfiguration to allow for DLQ output of Errors [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/11 17:18:15 UTC, 1 replies.
- [PR] [CsvIO] Changed CsvIOParseConfiguration to include DLQ [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/11 17:19:24 UTC, 5 replies.
- [PR] [CsvIO] Implement CsvIOParseHelpers::validate(CSVFormat) [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/11 18:27:58 UTC, 11 replies.
- [I] [CsvIO]: Create CsvIOStringToCsvRecord Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/11 20:07:07 UTC, 1 replies.
- Re: [I] [Failing Test]: beam_CleanUpPrebuiltSDKImages and beam_CleanUpGCPResources failing with invalid JWT signature [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/07/11 21:11:30 UTC, 2 replies.
- [I] [Bug]: In Beam Dataframe api, the fillna operation doesn't work when applied on individual columns [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/11 21:17:05 UTC, 1 replies.
- [PR] Add ErrorHandler DLQ API to Python [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/11 22:54:03 UTC, 3 replies.
- [PR] [CsvIO] Create CsIOStringToCsvRecord Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/11 22:55:36 UTC, 1 replies.
- [I] [Bug]: FirestoreIO read and write do not allow specifying the project or database id per transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/11 23:52:14 UTC, 1 replies.
- [I] The Cancel Stale Dataflow Jobs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/12 00:48:07 UTC, 0 replies.
- [PR] Callout beam-pyio [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/12 07:22:29 UTC, 3 replies.
- [PR] Add a little more info on snapshot containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/12 07:58:26 UTC, 7 replies.
- [PR] Add some large model troubleshooting steps [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/12 09:25:33 UTC, 4 replies.
- [I] [Bug]: WriteToFiles using a custom sink with compression type .bz2 flush errors. [beam] - posted by "jrecuerda (via GitHub)" <gi...@apache.org> on 2024/07/12 09:33:31 UTC, 0 replies.
- [PR] Spanner Read Schema Transform Provider [beam] - posted by "reeba212 (via GitHub)" <gi...@apache.org> on 2024/07/12 14:37:58 UTC, 2 replies.
- [PR] Update postgresql to 42.7.3 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/07/12 15:01:22 UTC, 1 replies.
- [PR] Switch to use self-hosted runner for build_wheels action [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/12 16:35:34 UTC, 5 replies.
- [I] [Feature Request]: Tour of Beam should use the beam.LogElements transform instead of defining `class Output(beam.PTransform):` [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/12 17:14:12 UTC, 0 replies.
- Re: [I] [CsvIO]: Create CsvIOParseHelpers::validate(CSVFormat) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/12 18:29:18 UTC, 0 replies.
- [PR] Cherrypicking #31721 to release 2.58.0 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/12 18:53:37 UTC, 3 replies.
- [PR] [CsvIO] implement CsvIOParseHelpers::validate(CSVFormat, Schema) [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/12 19:50:19 UTC, 4 replies.
- [PR] [CsvIO] Implement CsvParseHelpers::mapFieldPositions method [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 20:01:32 UTC, 8 replies.
- [I] [CsvIO]: Create scaffold CsvIOParseKV extends PTransform>, PCollection> class [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/12 20:21:23 UTC, 0 replies.
- [I] [Task]: Break up single pending stream commit into multiple commits [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/12 20:30:52 UTC, 1 replies.
- [I] [CsvIO]: Finalize CsvIOParseKV [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/12 20:52:41 UTC, 0 replies.
- [I] [CsvIO]: Create CsvIOParse scaffold [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 21:11:23 UTC, 1 replies.
- [I] [CsvIO]: Implement CsvIOParse::withCustomrecordParsing method [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 21:12:44 UTC, 0 replies.
- [I] [CsvIO]: Implement CsvIOParse::parseCell method [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 21:14:59 UTC, 0 replies.
- [I] [CsvIO]: CsvIOParse::expand implementation and class completion [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 21:16:27 UTC, 0 replies.
- [PR] [CsvIO] Create CsvIOParse scaffold [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/12 21:32:37 UTC, 3 replies.
- Re: [I] [Failing Test]: Many tests failing with invalid JWT signature [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/12 21:50:33 UTC, 2 replies.
- [I] [CsvIO]: Create CsvIOParseKV::withCustomRecordParsing [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/12 22:15:42 UTC, 0 replies.
- Re: [PR] [CsvIO] Create CsvIOStringToCsvRecord Class [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/12 22:29:16 UTC, 17 replies.
- [PR] [CsvIO] create scaffold CsvIOParseKV class. [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/13 00:01:30 UTC, 0 replies.
- Re: [I] [CsvIO]: Create CsvIOParseHelpers::validate(CSVFormat, Schema) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/13 00:12:51 UTC, 0 replies.
- [PR] Remove auth@1 in tests running on self hosted runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/13 00:29:01 UTC, 3 replies.
- [I] The Build python source distribution and wheels job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/13 00:48:12 UTC, 2 replies.
- Re: [PR] [CsvIO] Create scaffold CsvIOParseKV class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/13 00:49:53 UTC, 1 replies.
- Re: [PR] trim the beam_ off the beginnings of job names [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/13 12:40:49 UTC, 2 replies.
- Re: [PR] Reapply "Add Redistribute translation to Spark runner" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/13 12:40:50 UTC, 2 replies.
- [PR] Add WorkProvider interfaces [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/07/13 13:54:39 UTC, 1 replies.
- [I] Beam not populating "googclient_deliveryattempt" attribute in attributes map [beam] - posted by "Affan255 (via GitHub)" <gi...@apache.org> on 2024/07/13 14:50:35 UTC, 1 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 00:32:40 UTC, 7 replies.
- [PR] Bump braces from 3.0.2 to 3.0.3 in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 02:06:42 UTC, 2 replies.
- [I] The Clean Up Prebuilt SDK Images job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 03:35:56 UTC, 1 replies.
- [I] The PostCommit Java InfluxDbIO Integration Test job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 12:44:17 UTC, 1 replies.
- Re: [PR] Use default Python 3 interpreter, when precise minor version is not specified to gradle. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 12:46:12 UTC, 2 replies.
- Re: [PR] Reapply "Add Redistribute translation to FlinkRunner" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/14 12:46:14 UTC, 2 replies.
- Re: [I] [Task]: FilesToStage breaks Spark on YARN [beam] - posted by "Zawa-ll (via GitHub)" <gi...@apache.org> on 2024/07/14 22:17:58 UTC, 0 replies.
- [PR] [Beam-26692] Add implementation and tests for bypassFilesToStage option [beam] - posted by "Zawa-ll (via GitHub)" <gi...@apache.org> on 2024/07/15 04:21:02 UTC, 10 replies.
- [PR] Fix auth for clean up actions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/15 15:11:14 UTC, 4 replies.
- Re: [I] [CsvIO]: Create scaffold CsvIOParseKV class [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/15 16:43:56 UTC, 0 replies.
- [PR] [CsvIO] Create CsvIOParseHelpers::mapFieldPositions method [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/15 17:18:21 UTC, 6 replies.
- [PR] Fix MongoDB connector to handle out-of-range dates [beam] - posted by "haperski (via GitHub)" <gi...@apache.org> on 2024/07/15 17:24:15 UTC, 2 replies.
- [PR] [CsvIO]: update input Pcollection type arguments due to change in impl… [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/15 17:32:31 UTC, 4 replies.
- [I] [CsvIO]: Create CsvIOFileBasedSource class [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/15 17:41:16 UTC, 0 replies.
- [PR] Bump setuptools from 68.2.2 to 70.0.0 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/15 18:53:16 UTC, 4 replies.
- [I] [Task]: fix a potential bug in TimeRangeTracker [beam] - posted by "tianz101 (via GitHub)" <gi...@apache.org> on 2024/07/15 19:14:23 UTC, 1 replies.
- [PR] Fix ReadAllFromBigQuery leak temp dataset [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/15 19:30:30 UTC, 7 replies.
- Re: [PR] [Python] Managed Transforms API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/15 21:02:27 UTC, 11 replies.
- [I] [Task]: Upgrade gcs-connector libraries to 3.x [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/07/15 21:06:06 UTC, 1 replies.
- Re: [I] [CsvIO]: Create CsvIOParseHelpers::mapFieldPositions(CSVFormat, Schema) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/15 21:18:24 UTC, 0 replies.
- [I] The PostCommit Java SingleStoreIO IT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/16 00:48:18 UTC, 5 replies.
- [PR] remove listing topics when processing each element [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/07/16 00:55:29 UTC, 8 replies.
- [PR] (beam-31896) Upgrade gcs-connector to 3.0.1, Hadoop to 3.3.6 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/07/16 01:13:23 UTC, 5 replies.
- [PR] [Dataflow Streaming Engine] Turn on `--useWindmillIsolatedChannels` and `--useSeparateWindmillHeartbeatStreams` by default [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/07/16 06:16:37 UTC, 3 replies.
- [I] [Feature Request]: Support streaming inserts for bounded PCollections [beam] - posted by "Bladieblah (via GitHub)" <gi...@apache.org> on 2024/07/16 12:01:23 UTC, 0 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/16 12:41:50 UTC, 3 replies.
- [PR] Mt dp streams [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/07/16 13:48:01 UTC, 0 replies.
- Re: [PR] Add correct shutdown mechanics for direct path [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/16 14:34:57 UTC, 2 replies.
- [PR] Cp 31837 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/16 14:57:10 UTC, 1 replies.
- [PR] Cherrypicking #31837 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/16 15:00:29 UTC, 3 replies.
- [I] [Feature Request]: Support writing to a Solace message broker [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/16 17:02:49 UTC, 0 replies.
- Re: [I] Create SolaceIO [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/16 17:03:24 UTC, 0 replies.
- [PR] JCSMP properties providers for new SolaceIO write connector [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/16 17:05:02 UTC, 7 replies.
- Re: [I] [Bug]: Portable Spark 3 Streaming runner appears to have GBK bugs, cannot execute Redistribute composite correctly [beam] - posted by "Zawa-ll (via GitHub)" <gi...@apache.org> on 2024/07/16 17:18:55 UTC, 1 replies.
- [PR] Remove remaining use of setup-cloud@v0 action [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/16 18:12:46 UTC, 3 replies.
- [I] The Java Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/16 18:36:09 UTC, 2 replies.
- [PR] Fix generateYamlDocs gradle task [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/16 19:35:30 UTC, 3 replies.
- [I] [Bug]: Errors running Python command can cause Dataflow container to crash with no further details [beam] - posted by "zhoufek (via GitHub)" <gi...@apache.org> on 2024/07/16 21:17:21 UTC, 0 replies.
- Re: [I] [Bug][Prism]: unsupported feature "WindowStrategy.AllowedLateness" set with MaxTimestamp. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/16 21:58:05 UTC, 0 replies.
- [PR] Modify casing in workflow [beam] - posted by "pc-000 (via GitHub)" <gi...@apache.org> on 2024/07/16 22:01:28 UTC, 2 replies.
- [I] [prism] Support Bundle Finalization [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/17 00:14:52 UTC, 0 replies.
- [I] [Bug]: CVE-2024-24790 [beam] - posted by "kaushikabhishek87 (via GitHub)" <gi...@apache.org> on 2024/07/17 04:47:11 UTC, 3 replies.
- [I] [Bug]: [beam] - posted by "ppl122 (via GitHub)" <gi...@apache.org> on 2024/07/17 05:15:24 UTC, 0 replies.
- [PR] [Beam-31234] Add tests for Redistribute class and fix Redistribute function integration [beam] - posted by "Zawa-ll (via GitHub)" <gi...@apache.org> on 2024/07/17 05:51:45 UTC, 7 replies.
- Re: [PR] Remove GlobalWindows for unbounded pcoll without a default global window [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/17 12:42:51 UTC, 2 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "unography (via GitHub)" <gi...@apache.org> on 2024/07/17 13:54:30 UTC, 0 replies.
- [PR] [Cherrypick] Switch to use self-hosted runner for build_wheels action (#31866) [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/17 14:15:45 UTC, 3 replies.
- [PR] SolaceIO writer: add connector interface and some more classes [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/17 15:42:21 UTC, 4 replies.
- [I] [Feature Request]: Improve performance of generating successful writes in Java's BigqueryIO connector [beam] - posted by "slilichenko (via GitHub)" <gi...@apache.org> on 2024/07/17 16:55:45 UTC, 0 replies.
- [I] [CsvIO]: Fix method signature of StringToCsvRecord Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/17 17:55:49 UTC, 1 replies.
- [PR] [CsvIO] Change method signature of CsvIOStringToCsvRecord class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/17 18:06:39 UTC, 4 replies.
- [I] [prism] Support Custom WindowFns [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/17 18:27:58 UTC, 0 replies.
- [PR] Fnapi ordered list [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/07/17 18:37:58 UTC, 1 replies.
- [PR] Adds ordered list user state support to fnapi accessor cache. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/07/17 18:44:46 UTC, 3 replies.
- [PR] Generic throttling metrics namespace and BigtableIO write throttling counter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/17 19:52:13 UTC, 11 replies.
- [PR] Beam Website Updates for 2.58.0 Release [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/17 21:27:18 UTC, 9 replies.
- [I] [prism] Support Attempted Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/17 22:44:12 UTC, 0 replies.
- [I] [prism] Support StringSet Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/17 22:44:47 UTC, 0 replies.
- [I] [prism] Support Guage Metrics [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/17 22:51:35 UTC, 0 replies.
- [I] The PerformanceTests Kafka IO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/18 00:48:13 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.16 to 2.10.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/18 04:58:20 UTC, 3 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/18 06:36:42 UTC, 2 replies.
- Re: [PR] Add jobLabelsMap parameter to BigQueryOptions [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/07/18 10:02:20 UTC, 0 replies.
- Re: [PR] Initial Commit for AvroPayloadSerializer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/18 12:43:28 UTC, 0 replies.
- [PR] [DO NOT MERGE] V2.58.0 rc1 validations [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/18 15:23:56 UTC, 3 replies.
- [PR] Update Python artifact name in release process [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/18 16:01:39 UTC, 4 replies.
- [PR] Disable Dataflow run for java_test and python_test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/18 16:14:59 UTC, 3 replies.
- [I] [Task][Prism]: Create a PipelineResult implementation [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/18 18:04:50 UTC, 0 replies.
- [PR] Update Dataflow containers [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/18 18:08:08 UTC, 6 replies.
- [PR] [Prism] Implement PrismPipelineResult [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/18 18:18:32 UTC, 4 replies.
- Re: [PR] Poll for backlog in background thread instead of inline [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/07/18 18:37:26 UTC, 4 replies.
- [PR] Unify integration test manual run parameters [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/18 19:13:49 UTC, 1 replies.
- Re: [I] [Feature Request]: Allow customization of filename and sharding for dataframe IOs. [beam] - posted by "jconlon (via GitHub)" <gi...@apache.org> on 2024/07/18 21:25:34 UTC, 0 replies.
- Re: [PR] Clean up integration test manual run parameters [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/19 01:05:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/19 04:25:29 UTC, 3 replies.
- Re: [I] [Bug]: PubsubMessageWithTopicCoder.of() returns PubsubMessageWithAttributesAndMessageIdCoder [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/19 14:47:59 UTC, 0 replies.
- Re: [PR] Export gcs options [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/07/19 18:34:08 UTC, 2 replies.
- [PR] Use default auth for Iceberg integration tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/19 18:53:22 UTC, 3 replies.
- [I] Bug in Python SDK-s Enrichment transform client side throttling [beam] - posted by "kjaanson (via GitHub)" <gi...@apache.org> on 2024/07/20 11:48:23 UTC, 0 replies.
- Re: [PR] [Go SDK] Additional state coder tests for Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/20 12:41:06 UTC, 2 replies.
- [PR] Cachi [beam] - posted by "WontonSam (via GitHub)" <gi...@apache.org> on 2024/07/20 16:43:42 UTC, 1 replies.
- Re: [PR] Add WorkProvider interfaces and implementations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/21 12:13:51 UTC, 2 replies.
- [I] [Bug]: Writing partitioned data with Managed IcebergIO fails [beam] - posted by "arthurpessoa (via GitHub)" <gi...@apache.org> on 2024/07/22 13:55:48 UTC, 0 replies.
- [I] [Feature Request]: Add support for `GEOGRAPHY` data type in BigQuery Storge Write API in Python [beam] - posted by "unography (via GitHub)" <gi...@apache.org> on 2024/07/22 16:53:23 UTC, 0 replies.
- [I] [Bug]: Consider dropping TLS 1.0 support from webhook server [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/07/22 22:46:49 UTC, 1 replies.
- [PR] Add an Infrastructure option to issue template [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/07/22 22:52:46 UTC, 4 replies.
- Re: [I] [Bug]: unable to set up multiprocessing [beam] - posted by "cometta (via GitHub)" <gi...@apache.org> on 2024/07/23 01:46:09 UTC, 1 replies.
- [PR] Bump com.gradle.develocity from 3.17.5 to 3.17.6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/23 04:52:35 UTC, 2 replies.
- [PR] Correct details of Beam PyIO (Collection of Python IO connectors) [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/07/23 06:39:46 UTC, 2 replies.
- [PR] Reduce the maximum size of input splits in Flink to better distribute work in Datastream API [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2024/07/23 08:08:31 UTC, 0 replies.
- Re: [PR] [WIP] try new protobuf [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/23 12:42:53 UTC, 2 replies.
- [PR] Use correct device ordinal when GPU is detected [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/23 13:06:52 UTC, 3 replies.
- [PR] Add infra option for remaining templates + autolabel [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/23 13:23:18 UTC, 4 replies.
- Re: [I] [Bug]: Teardown method is never called [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/23 15:01:28 UTC, 1 replies.
- [PR] This is a followup PR to #31906, and part of the issue #31905 [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/07/23 15:12:55 UTC, 0 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/07/23 15:21:46 UTC, 0 replies.
- [I] The build_release_candidate job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/23 15:33:47 UTC, 1 replies.
- [PR] Move dataset cleanup to finishBundle for ReadAllFromBigQuery [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/23 15:43:40 UTC, 3 replies.
- Re: [PR] SolaceIO.Write: add data classes, connector interface [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/23 16:07:05 UTC, 6 replies.
- [PR] Add logging for DataChangeRecord and ChangeStreamQuery [beam] - posted by "tianz101 (via GitHub)" <gi...@apache.org> on 2024/07/23 17:57:54 UTC, 3 replies.
- [PR] [CsvIO]: Expand test coverage of CsvIOStringToCsvRecord [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/23 18:41:33 UTC, 3 replies.
- [PR] Improve IcebergIO utils [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/23 22:03:51 UTC, 12 replies.
- [I] [Feature Request]: [Go SDK] Add WriteOption for WriteDisposition [beam] - posted by "GusPrice (via GitHub)" <gi...@apache.org> on 2024/07/23 22:36:45 UTC, 0 replies.
- Re: [I] [Feature Request]: Add WriteOption for WriteDisposition in bigqueryio.Write() [beam] - posted by "GusPrice (via GitHub)" <gi...@apache.org> on 2024/07/23 22:42:43 UTC, 0 replies.
- [PR] Dedup Lineage and getTableToExtract call in BigQuerySourceBase [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 00:28:22 UTC, 7 replies.
- [PR] Requirements_cache shouldn't create a cache folder when skipped. [beam] - posted by "eddiep24 (via GitHub)" <gi...@apache.org> on 2024/07/24 03:57:45 UTC, 4 replies.
- [PR] Solace Read: Make the SolaceIO.Read constructor private. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/24 08:56:51 UTC, 4 replies.
- [I] [Bug]: `GEOGRAPHY` datatype breaks while using StorageWrite API in Python [beam] - posted by "unography (via GitHub)" <gi...@apache.org> on 2024/07/24 09:58:33 UTC, 0 replies.
- [I] [Bug]: KafkaIO Should not throw errors for empty topics. [beam] - posted by "damnMeddlingKid (via GitHub)" <gi...@apache.org> on 2024/07/24 13:59:50 UTC, 0 replies.
- [I] [Bug]: SolaceIO.Read: clients are not properly closed. [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/24 15:01:44 UTC, 2 replies.
- [PR] Auth with project id in our notebook [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/07/24 15:12:55 UTC, 3 replies.
- [I] [Task][Prism]: Create a PrismRunnerRegistrar [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/24 15:38:37 UTC, 0 replies.
- Re: [I] [Task]: Deprecate Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 16:26:35 UTC, 0 replies.
- Re: [I] Update throttling counters to use generic throttling-msecs metric and dedicated namespace [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 17:31:51 UTC, 0 replies.
- [I] The StressTests Java BigQueryIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/24 18:37:30 UTC, 0 replies.
- [PR] Add StringSet metrics to Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 19:25:36 UTC, 12 replies.
- [I] [Bug]: Beam YAML provider parsing breakage [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/07/24 20:20:48 UTC, 1 replies.
- [I] [prism] Metrics from runner expanded composites aren't mapped back to user terms. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/24 20:28:20 UTC, 0 replies.
- Re: [I] [Bug]: Prism runner gets stuck trying to read a file on GCS [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/24 21:41:04 UTC, 2 replies.
- Re: [I] [prism]: unsupported feature "WindowStrategy.OutputTime" set with value (LATEST|EARLIEST)_IN_PANE [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/24 22:09:58 UTC, 1 replies.
- [PR] [Release-2.58.0] Dedup Lineage and getTableToExtract call in BigQuerySourceBase (#31960) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 22:36:04 UTC, 3 replies.
- [PR] Note SpannerIO.read new validation in 2.58.0 breaking change section [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/24 22:42:37 UTC, 3 replies.
- [PR] [yaml] Fix yaml provider schema validation and merging [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/07/24 23:44:58 UTC, 4 replies.
- [PR] Jkinard/inline tests [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/07/24 23:46:16 UTC, 0 replies.
- [PR] Don't create a temp directory for requirements cache if users opted out. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/25 00:31:34 UTC, 4 replies.
- [PR] Use buffered loggers that periodically flush. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/25 00:41:46 UTC, 7 replies.
- Re: [PR] [#31438] [prism] Correctly chose earliest or latest in pane timestamps for aggregations. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/25 01:02:43 UTC, 1 replies.
- Re: [PR] [yaml] Add tests for provider schema validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 01:32:22 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 04:59:54 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 04:59:56 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 04:59:58 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.17.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 04:59:59 UTC, 1 replies.
- [I] [Bug]: CoGroupByKey throws with large (10K+) output groups on Flink runner [beam] - posted by "a-kazakov (via GitHub)" <gi...@apache.org> on 2024/07/25 06:14:13 UTC, 0 replies.
- Re: [I] Update Go protobuf package to new version [beam] - posted by "imvtsl (via GitHub)" <gi...@apache.org> on 2024/07/25 07:38:58 UTC, 2 replies.
- [PR] Solace Read connector: Explicitly close the FlowReceiver [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/07/25 09:40:20 UTC, 4 replies.
- [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 "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/25 10:45:47 UTC, 1 replies.
- [PR] [cherrypick][yaml] Fix yaml provider schema validation and merging (#31974) [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/25 13:53:10 UTC, 4 replies.
- [I] [Failing Test]: Python BigQuery Test - PipelineBasedStreamingInsertTest::tes_batch_size_with_auto_sharding_0 is flaky [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/25 14:33:45 UTC, 0 replies.
- [PR] Override BQ load job location when necessary [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/07/25 15:09:53 UTC, 3 replies.
- [PR] Adding Spanner IO Providers for Beam YAML [beam] - posted by "reeba212 (via GitHub)" <gi...@apache.org> on 2024/07/25 16:09:13 UTC, 4 replies.
- [I] [Feature Request]: add support for Datastore Database ID in Python SDK [beam] - posted by "blech75 (via GitHub)" <gi...@apache.org> on 2024/07/25 17:02:26 UTC, 0 replies.
- [PR] [CsvIO]: add Coder and FromRowFn to CsvIOParseConfiguration class. [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/25 17:31:10 UTC, 3 replies.
- [PR] Fix row ranges issue [beam] - posted by "ron-gal (via GitHub)" <gi...@apache.org> on 2024/07/25 17:51:16 UTC, 3 replies.
- [I] [prism] Java PipelineTest Mysteries: Unknown Urn "ProjectTag", "IdentityTransform" [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/25 22:04:56 UTC, 0 replies.
- [I] [prism] Preprocess failure - Expected Runner Flatten Node - but wasn't [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/25 22:05:29 UTC, 1 replies.
- [I] [Bug]: Java SDK BigQueryIO's RowMutationInformation class is not backward compatible with previous releases [beam] - posted by "slilichenko (via GitHub)" <gi...@apache.org> on 2024/07/25 23:23:48 UTC, 0 replies.
- [PR] Bump Iceberg Core version to add support for AWS Glue [beam] - posted by "raidancampbell (via GitHub)" <gi...@apache.org> on 2024/07/25 23:44:50 UTC, 1 replies.
- Re: [I] [Feature Request]: Support read from / write to AWS Glue catalog tables backed by AWS S3 data [beam] - posted by "raidancampbell (via GitHub)" <gi...@apache.org> on 2024/07/25 23:51:13 UTC, 0 replies.
- [I] [CsvIO]: Update class for representing date-times in CsvIOParseHelpers::parseCell(String, Schema.Field) [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/26 04:21:59 UTC, 1 replies.
- [PR] [CsvIO]: update class for representing date-time in CsvIOParseHelpers::parseCell(String, Schema.Field) [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/26 05:53:29 UTC, 2 replies.
- [PR] Regenerate Dataflow Python client [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 14:46:36 UTC, 3 replies.
- [I] [Failing Test]: testRedistributeAfterSlidingWindows incorrect [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 15:11:19 UTC, 4 replies.
- [PR] Revert "Exclude StringSet tests from portable runners and Dataflow LegacyRunner" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 15:24:52 UTC, 3 replies.
- [I] [Bug]: Failed to restore state on flink runnet [beam] - posted by "rubensacoustic (via GitHub)" <gi...@apache.org> on 2024/07/26 17:32:46 UTC, 0 replies.
- [I] [Bug]: Portable runner queryMetrics returns duplicate result [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 17:47:05 UTC, 0 replies.
- [PR] Revert "Avoid publishing string set metrics on the Dataflow legacy runner." [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 18:05:34 UTC, 4 replies.
- [I] [prism] Support Empty Flattens as Side Input - no way to make progress with pending elements [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/26 18:38:35 UTC, 3 replies.
- Re: [PR] Fix StringSet tests on portable runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/26 20:53:58 UTC, 4 replies.
- [I] [prism] Java SplittableDoFnTest & FlattenTest - invalid stream header (likely coders) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/26 20:57:23 UTC, 0 replies.
- [I] [CsvIO]: Add CsvIORecordToObjects Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/26 21:14:02 UTC, 1 replies.
- [PR] [CsvIO]: add CsvIORecordToObjects Class [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/26 21:14:29 UTC, 5 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/07/26 22:13:49 UTC, 1 replies.
- [PR] Add schema to SpannerIO read [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/07/26 22:31:49 UTC, 4 replies.
- Re: [I] [Bug]: Failed to restore state on Flink runner [beam] - posted by "rubensacoustic (via GitHub)" <gi...@apache.org> on 2024/07/26 23:56:53 UTC, 0 replies.
- Re: [I] [Bug]: Using WriteToBigQuery FILE_LOADS in a streaming pipeline does not remove temporary tables [beam] - posted by "ukt1997 (via GitHub)" <gi...@apache.org> on 2024/07/28 12:20:21 UTC, 0 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/07/29 12:43:23 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/07/29 12:43:26 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/07/29 12:43:28 UTC, 0 replies.
- [PR] Update Build Wheels to only build once on RCs [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/29 13:23:47 UTC, 4 replies.
- [PR] [Cherrypick] Update Build Wheels to only build once on RCs (#32009) [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/29 14:17:16 UTC, 3 replies.
- [PR] Fix Dataflow v2 test failed tag container if project contains colon [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/29 18:16:00 UTC, 4 replies.
- Re: [PR] [#31462] [prism] Correctly chose earliest or latest in pane timestamps for aggregations. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/29 18:19:24 UTC, 0 replies.
- [PR] [#32004] Ensure all pcollection coders are length prefixed if necessary. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/29 18:52:28 UTC, 5 replies.
- [PR] Adds ordered list user state support to fnapi accessor cache. (#31923) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/07/29 18:54:08 UTC, 6 replies.
- [PR] Revert "Update Build Wheels to only build once on RCs" [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/29 20:50:10 UTC, 2 replies.
- [PR] Revert "[Cherrypick] Update Build Wheels to only build once on RCs (#32009)" [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/29 20:50:54 UTC, 1 replies.
- [I] [CsvIO]: create CsvIOSplitFile class [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/30 01:04:00 UTC, 0 replies.
- [PR] [CsvIO] Create CsvIOSplitFile Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/30 01:05:45 UTC, 4 replies.
- [PR] Rag opensearch [beam] - posted by "itsayushpandey (via GitHub)" <gi...@apache.org> on 2024/07/30 06:06:30 UTC, 4 replies.
- [PR] beam-sql-udf-doc-mistake [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/07/30 14:28:24 UTC, 2 replies.
- [I] [Mistake in Doc]: beam SQL UDF Doc small mistake [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/07/30 14:30:38 UTC, 0 replies.
- [I] [Task]: Fill Runner Metrics support gap in Sources [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/30 15:20:12 UTC, 1 replies.
- Re: [I] [Mistake in Website]: beam SQL UDF Doc small mistake [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/07/30 15:44:18 UTC, 1 replies.
- [PR] Support metrics at Source.split for Direct Runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/30 15:53:47 UTC, 6 replies.
- [PR] [CsvIO]: Update error and result handling. [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/30 17:06:57 UTC, 3 replies.
- Re: [PR] beam-sql-udf-example-mistake [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/30 17:07:58 UTC, 0 replies.
- [PR] [#31991][prism] Allow Empty Composites [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/30 18:15:27 UTC, 4 replies.
- [PR] [DO NOT MERGE] V2.58.0 rc2 validations [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/07/30 19:23:19 UTC, 2 replies.
- Re: [I] [prism] Java PipelineTest: Unknown Urn "ProjectTag", "IdentityTransform" - Support "Empty" Composites without subtransforms. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/30 20:02:27 UTC, 0 replies.
- [PR] Bump tensorflow from 2.11.1 to 2.12.1 in /sdks/python/apache_beam/examples/ml-orchestration/tfx [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/30 21:17:22 UTC, 1 replies.
- [PR] Filter empty distribution metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/07/30 22:05:34 UTC, 3 replies.
- [PR] [CsvIO] Create CsvIOParse Class [beam] - posted by "lahariguduru (via GitHub)" <gi...@apache.org> on 2024/07/30 22:21:31 UTC, 1 replies.
- [PR] [#32003][prism] Support empty transform input sets, such as for flattens. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/30 22:49:07 UTC, 4 replies.
- [I] [Bug]: The `--impersonate_service_account` pipeline option may be accidentally used at runtime in Python BigQuery IO. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/30 23:31:10 UTC, 1 replies.
- Re: [I] [prism] Java and Python SplittableDoFnTests - invalid stream header (likely coders) [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/30 23:40:28 UTC, 0 replies.
- [PR] Remove `--impersonate_service_account` whenever PipelineOptions are serialized [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/30 23:50:01 UTC, 4 replies.
- [I] [Prism][Task]: A State Publisher notifies listeners of changes to PipelineResult.State. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/30 23:51:43 UTC, 0 replies.
- [PR] Add JobServerOption for `--jar_cache_dir` [beam] - posted by "s21lee (via GitHub)" <gi...@apache.org> on 2024/07/31 01:34:30 UTC, 1 replies.
- [PR] Update cython requirement from <1 to <4 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/07/31 04:23:40 UTC, 3 replies.
- Re: [PR] fix playground scio issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/31 12:43:27 UTC, 0 replies.
- [I] [Task]: Update the document for `AwsOptions` in `amazon-web-service2` [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/07/31 15:46:14 UTC, 2 replies.
- [PR] update document in `AwsOptions` [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/07/31 15:53:32 UTC, 2 replies.
- [PR] Add Lineage metrics to PubsubIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/07/31 17:18:54 UTC, 4 replies.
- [PR] Added support for the TOKENLIST type in Spanner [beam] - posted by "atask-g (via GitHub)" <gi...@apache.org> on 2024/07/31 19:07:36 UTC, 1 replies.
- [PR] [CsvIO] Update CsvIOStringToCsvRecord and expand test coverage. [beam] - posted by "francisohara24 (via GitHub)" <gi...@apache.org> on 2024/07/31 20:26:31 UTC, 3 replies.
- Re: [PR] Fix row ranges issue in Bigtable Read. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/31 20:27:25 UTC, 2 replies.
- [PR] StateWatcher watches for changed Pipeline State [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/07/31 21:12:42 UTC, 1 replies.
- [PR] Update top_wikipedia_sessions to be more idiomatic with beam.Map. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/07/31 21:19:24 UTC, 2 replies.
- [PR] [#31992][prism] Send side inputs for all SDF phases. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/07/31 21:20:39 UTC, 3 replies.
- Re: [PR] StateWatcher watches and reports changed Pipeline State [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/07/31 21:47:41 UTC, 0 replies.
- [PR] Change the gradle task definition in quickstart. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/07/31 22:30:59 UTC, 1 replies.
- [PR] Change FnApiDoFnRunner to skip trySplit checkpoint requests if not draining and nothing has yet been claimed by the tracker. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/07/31 22:35:25 UTC, 0 replies.
- [PR] Update go protobuf package to new version [beam] - posted by "imvtsl (via GitHub)" <gi...@apache.org> on 2024/07/31 23:25:48 UTC, 0 replies.