You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [I] [Feature Request]: Support Jackson 2.15 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/01 00:37:45 UTC, 5 replies.
- Re: [PR] Parse YAML ExpansionService configs directly using SnakeYAML [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/01 00:40:07 UTC, 8 replies.
- [PR] Add Trigger_Never to Prepare features check [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/01 00:53:58 UTC, 5 replies.
- Re: [PR] Enable KafkaIO Java integration tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/01 01:32:07 UTC, 2 replies.
- Re: [I] [Failing Test]: Wordcounts in preCommitLegacyWorkerImpersonate portion of beam_PreCommit_Java_Examples_Dataflow are permared [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/01 01:49:07 UTC, 5 replies.
- Re: [PR] Set retry policy to DEFAULT_RETRY when initializing BlobWriter. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/01 02:35:24 UTC, 1 replies.
- Re: [I] [Feature Request]: Override retry policy when using gcsio to open files to write. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/01 02:41:51 UTC, 0 replies.
- [PR] Bump Jackson databind to 2.15 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/01 02:44:05 UTC, 7 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/06/01 12:13:54 UTC, 6 replies.
- Re: [PR] Remove excess space from Programming Guide (typo fix) [beam] - posted by "vstollen (via GitHub)" <gi...@apache.org> on 2024/06/01 12:38:49 UTC, 2 replies.
- Re: [PR] add ExternalTransformProvider example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/01 12:40:28 UTC, 2 replies.
- Re: [PR] Change ReflectUtils to sort the returned methods so that it is consistent across JVM instances [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/01 12:40:30 UTC, 2 replies.
- Re: [I] [Feature Request]: [beam-sdks-java-core]: Create method SerializableComparator.comparing(SerialiableFunction) [beam] - posted by "Mr-Magnificent (via GitHub)" <gi...@apache.org> on 2024/06/01 14:31:31 UTC, 0 replies.
- Re: [PR] Update JdbcIO.java [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/01 19:20:24 UTC, 2 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/02 00:33:53 UTC, 7 replies.
- [I] The PostCommit Go VR Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/02 06:35:27 UTC, 3 replies.
- Re: [PR] [Typescript] allow Dofn to return promise [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/02 12:40:09 UTC, 2 replies.
- Re: [I] [Feature Request]: Add examples for using metrics with Python to Beam Website [beam] - posted by "manishkumar23829928 (via GitHub)" <gi...@apache.org> on 2024/06/02 14:40:39 UTC, 1 replies.
- Re: [PR] add support for ConnectionFactory ProviderFn in JmsIO [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/06/03 10:48:11 UTC, 2 replies.
- Re: [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py38 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/03 12:13:59 UTC, 3 replies.
- Re: [PR] Allow context managers to be used for setup/teardown. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/03 12:25:52 UTC, 4 replies.
- [PR] Solace Read connector [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/03 12:33:21 UTC, 45 replies.
- Re: [PR] Bump pillow from 10.2.0 to 10.3.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/03 12:42:00 UTC, 3 replies.
- Re: [PR] Support Kafka Managed IO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/03 14:10:36 UTC, 0 replies.
- Re: [PR] Fix one small typo in build script. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 14:49:16 UTC, 0 replies.
- Re: [I] The PreCommit Java Debezium IO Direct job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 14:54:53 UTC, 0 replies.
- Re: [I] The PostCommit XVR Flink job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 15:01:41 UTC, 1 replies.
- Re: [I] The PostCommit XVR Samza job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 15:02:58 UTC, 1 replies.
- Re: [PR] [YAML] Allow constants and simple comparisons in generic expressions. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/03 15:21:39 UTC, 10 replies.
- Re: [PR] Add test of Select type inference. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/03 15:22:48 UTC, 1 replies.
- Re: [PR] Add a test for sql dialect. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/03 15:23:40 UTC, 2 replies.
- [I] [Bug]: BigtableIO doesn't close the stream after reading [beam] - posted by "justinuang (via GitHub)" <gi...@apache.org> on 2024/06/03 15:52:18 UTC, 1 replies.
- [PR] Ensure that BigtableIO closes the stream after reading [beam] - posted by "justinuang (via GitHub)" <gi...@apache.org> on 2024/06/03 15:53:33 UTC, 4 replies.
- Re: [PR] Default SchemaTransform configs to snake_case [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/06/03 16:28:02 UTC, 3 replies.
- [PR] Fix Python PostCommit XVR [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 17:50:14 UTC, 4 replies.
- Re: [PR] Updates Expansion Service Container to support upgrading using the schema-transform ID [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/03 17:55:07 UTC, 0 replies.
- Re: [PR] Simplify Managed API to avoid dealing with PCollectionRowTuple [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/06/03 18:22:43 UTC, 12 replies.
- [PR] Fix mangled license headers. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/03 18:55:47 UTC, 3 replies.
- Re: [I] [Bug]: Large PIPELINE_OPTIONS can lead to command line args list too long errors in SDK containers [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/03 19:05:30 UTC, 0 replies.
- [PR] Fix PreCommit Java Dataflow Example auth issue [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 19:10:18 UTC, 2 replies.
- [PR] [#27839][Go SDK] Write pipeline options to a file, instead reading from a flag. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/03 20:08:52 UTC, 9 replies.
- Re: [I] [Bug]: Parse YAML ExpansionService configs directly using SnakeYAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/06/03 20:14:02 UTC, 0 replies.
- [PR] Remove setup gcp credential step for beam_ workflows running on self-hosted runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/03 20:14:47 UTC, 4 replies.
- [PR] Add allowDuplicates property to GroupByKey transform [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/03 21:29:54 UTC, 4 replies.
- [PR] Pins SnakeYAML version to 1.33 for Hadoop Format tests [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/06/03 22:13:09 UTC, 4 replies.
- Re: [PR] move heartbeat processor to where it is being used [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/03 22:35:16 UTC, 22 replies.
- [PR] Supported BigQueryIO as a Managed Transform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/03 23:14:57 UTC, 2 replies.
- Re: [I] [Bug][Prism]: panic: nothing in progress and no refreshes with non zero pending elements [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/03 23:35:50 UTC, 3 replies.
- Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] - posted by "clongnguyen6 (via GitHub)" <gi...@apache.org> on 2024/06/04 02:16:18 UTC, 4 replies.
- [PR] Extract latest beam version directly from the request [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/04 02:18:22 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.54.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 04:52:55 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.54.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 04:52:59 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 04:56:39 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 04:56:41 UTC, 1 replies.
- [PR] Add a customized DataflowGroupByKey primitive transform to plumb Redistribute transform's property [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/04 07:38:56 UTC, 17 replies.
- [I] [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/06/04 08:13:29 UTC, 0 replies.
- Re: [PR] retry test_big_query_legacy_sql [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 12:13:57 UTC, 2 replies.
- Re: [PR] Remove pipeline options override from SpannerIO readChangeStream connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 12:13:59 UTC, 2 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 12:14:02 UTC, 2 replies.
- Re: [PR] [Test only] Introduce checkpointtimeout [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/04 12:41:56 UTC, 2 replies.
- Re: [I] [Feature Request]: RabbitMQ IO connector for python? [beam] - posted by "hamza-digitl (via GitHub)" <gi...@apache.org> on 2024/06/04 13:21:41 UTC, 2 replies.
- [I] [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/06/04 14:24:39 UTC, 1 replies.
- [PR] fix typescript syntax [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/04 14:44:14 UTC, 3 replies.
- [PR] Create Beam YAML Join documentation [beam] - posted by "itodotimothy6 (via GitHub)" <gi...@apache.org> on 2024/06/04 14:45:35 UTC, 4 replies.
- [PR] [Python] Managed Transforms API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/04 15:17:51 UTC, 3 replies.
- [PR] Update KafkaIO's docstring to match current implementation [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/04 15:24:47 UTC, 5 replies.
- [PR] Correct test name to HashStringsTest [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/04 15:30:53 UTC, 2 replies.
- [PR] Add counters for bytes read/written per gcs bucket [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/06/04 15:43:34 UTC, 11 replies.
- Re: [I] [Bug]: [Go SDK] periodic.impulse increases Dataflow Backlog time [beam] - posted by "victorrgez (via GitHub)" <gi...@apache.org> on 2024/06/04 18:32:56 UTC, 2 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/06/04 18:47:47 UTC, 2 replies.
- [I] [Feature Request]: Add support for Image Embedding generation to MLTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/04 19:04:22 UTC, 0 replies.
- [PR] Add base _ImageEmbeddingHandler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/04 19:06:51 UTC, 4 replies.
- Re: [PR] [YAML] mark Combine transform as stable [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/04 19:17:35 UTC, 0 replies.
- [PR] Delete RedistributeByKeyAllowingDuplicates from Redistribute [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/04 20:47:48 UTC, 2 replies.
- Re: [PR] Add in redistribute option for Kafka Read [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/06/04 20:51:11 UTC, 5 replies.
- Re: [PR] Fix iceberg catalog validation [beam] - posted by "VeronicaWasson (via GitHub)" <gi...@apache.org> on 2024/06/04 20:53:25 UTC, 2 replies.
- Re: [PR] Support unknown repeated STRUCTs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/04 22:09:06 UTC, 0 replies.
- Re: [I] [Bug]: ClassCastException with REPEATED RECORD and STORAGE_WRITE_API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/04 22:09:07 UTC, 0 replies.
- [I] [Task]: Migrate from the Gradle Enterprise plugin to Develocity [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/04 22:44:34 UTC, 0 replies.
- Re: [I] [Bug]: TypeScript Unit Tests failing [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/04 22:53:30 UTC, 0 replies.
- Re: [I] [Feature Request]: Improve Managed API to avoid redundant `PCollectionRowTuple` calls [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/04 23:02:03 UTC, 0 replies.
- [PR] Integrate direct path/fan out logic [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/06/04 23:32:39 UTC, 34 replies.
- [I] [Bug]: Exception from Downstream DoFn suppressed if upstream DoFn catches it on Dataflow Runner v2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 02:21:24 UTC, 0 replies.
- Re: [I] "Dead letter" handling for problem rows in BigQueryIO Storage Write API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 02:36:43 UTC, 0 replies.
- [PR] Do not suppress downstream Exception in BigQueryIO Storage write API FailedStorageApiInserts Handling [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 02:45:48 UTC, 4 replies.
- [I] [Bug]: [beam] - posted by "BohdanBilonoh (via GitHub)" <gi...@apache.org> on 2024/06/05 07:19:32 UTC, 0 replies.
- Re: [PR] Return methods in a lexicographical order from ReflectUtils.getMethods() [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/05 11:57:58 UTC, 1 replies.
- [PR] Update the transform label error message [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/05 12:13:04 UTC, 8 replies.
- Re: [PR] Call `DateTime(long)` instead of `DateTime(Object)`. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/05 12:14:00 UTC, 5 replies.
- Re: [PR] Reduce playground python log level to WARNING [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/05 12:41:49 UTC, 2 replies.
- Re: [PR] #19851: Proof-of-concept to implement deferred side inputs for combiners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/05 12:41:52 UTC, 1 replies.
- Re: [PR] Bump org.ajoberstar.grgit:grgit-gradle from 4.1.1 to 5.2.2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/05 12:41:54 UTC, 2 replies.
- [PR] [#31475] Filter out test stream using test from spark suite [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/05 12:48:31 UTC, 3 replies.
- Re: [PR] Feature add metrics counting the number of bytes read/written from/to GCS bucket per job [beam] - posted by "alxd112 (via GitHub)" <gi...@apache.org> on 2024/06/05 13:09:52 UTC, 8 replies.
- Re: [I] [Bug]: PubsubIO used in batch incorrect batch cutoff size [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 14:15:37 UTC, 0 replies.
- Re: [I] Direct Runner Does Not Work As Well As Google Dataflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 14:18:59 UTC, 1 replies.
- Re: [I] PubsubIO may exceed maximum payload size [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 14:21:07 UTC, 1 replies.
- [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/05 14:28:22 UTC, 0 replies.
- [PR] added the label option for ReadFromCsv [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/05 15:10:56 UTC, 5 replies.
- [PR] Remove SnakeYaml dependency [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 15:21:45 UTC, 5 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/05 15:37:19 UTC, 3 replies.
- Re: [I] [Failing Test]: GHA Java_GCP_IO_Direct is failing consistently at "Publish JUnit Test Results" step [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 15:43:20 UTC, 0 replies.
- [PR] Implement Vertex AI Image Embedding MLTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/05 16:08:59 UTC, 9 replies.
- Re: [PR] Kafka SchemaTransform translation [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/06/05 17:48:29 UTC, 3 replies.
- [PR] Update Go container build version to 1.21.11 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/05 18:05:54 UTC, 3 replies.
- [PR] [Cherrypick][#31515] Update Go container build version to 1.21.11 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/05 18:12:04 UTC, 3 replies.
- [PR] Fix Managed doc [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 18:15:43 UTC, 3 replies.
- [PR] Cherrypick (#31362) kafka schematransform translation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 18:33:48 UTC, 3 replies.
- [PR] Cherrypicking #31517 Managed doc fixes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 19:27:20 UTC, 1 replies.
- [PR] Cp 31517 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 19:29:12 UTC, 1 replies.
- [PR] Cherrypicking #31517 Managed doc fixes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/05 19:31:51 UTC, 3 replies.
- [PR] Fix issue where manual subsequent label designations were ignored. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/05 20:35:12 UTC, 2 replies.
- Re: [PR] [DO NOT MERGE YET] added the label option for ReadFromCsv [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/05 20:36:04 UTC, 3 replies.
- [PR] [YAML] Add MLTransform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/05 22:11:19 UTC, 3 replies.
- [I] [Feature Request]: Update docs about the dangers of auto_unique_labels. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/05 23:11:46 UTC, 1 replies.
- Re: [PR] Backlog metrics do not showing up in FlinkRunner [beam] - posted by "oswidan97 (via GitHub)" <gi...@apache.org> on 2024/06/05 23:26:43 UTC, 11 replies.
- [I] [Bug]: Spotless Precommit Fails for :sdks:java:io:kafka:compileTestJava [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/06 00:00:43 UTC, 1 replies.
- Re: [PR] Plumb Redistribute Transform's AllowDuplicates Property to Job Definition [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/06 04:26:18 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.55.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/06 04:36:36 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.4+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/06 04:43:57 UTC, 3 replies.
- Re: [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.3+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/06 04:44:00 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/06 04:48:45 UTC, 3 replies.
- [PR] Fix incorrect Work.java cast and logging [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/06/06 07:30:27 UTC, 8 replies.
- Re: [PR] Add streaming grpc settings for direct path and prevent dangling streams from holding up the watermark [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/06/06 07:31:05 UTC, 0 replies.
- [I] [Task]: [flink] portable runner is not ported on new Source API [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/06/06 08:50:47 UTC, 0 replies.
- [PR] [flink] #31529 UnboundedSourceWrapper removal [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/06/06 08:52:10 UTC, 0 replies.
- [PR] Upgrading testcontainer version to 1.19.7 [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/06 09:51:45 UTC, 11 replies.
- [I] Tre [beam] - posted by "Teady21 (via GitHub)" <gi...@apache.org> on 2024/06/06 10:23:37 UTC, 0 replies.
- Re: [I] [Bug]: KinesisIO source on FlinkRunner initializes the same splits twice [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/06/06 11:50:10 UTC, 1 replies.
- Re: [PR] Bump pydantic from 1.10.2 to 1.10.13 in /playground/infrastructure [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/06 12:14:12 UTC, 2 replies.
- [PR] Add missing import [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/06 12:50:13 UTC, 2 replies.
- [PR] Deduplicate Base Embedding Handler Code [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/06 16:18:05 UTC, 2 replies.
- Re: [I] The PostCommit Go VR Flink job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/06 16:21:28 UTC, 10 replies.
- [PR] Add RedistributeByKeyOverride to Plumb AllowDuplicates through DataflowRunner [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/06 16:51:55 UTC, 6 replies.
- [PR] Implement Hugging Face Image Embedding MLTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/06 17:37:21 UTC, 7 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/06 20:34:20 UTC, 2 replies.
- [PR] Add types to ReadFrom/WriteToBigQuery. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/07 00:19:46 UTC, 1 replies.
- [PR] Skip newly added TestStream VR tests for flink runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/07 01:17:18 UTC, 3 replies.
- Re: [PR] Implement ordered list state for FnApi. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/07 01:37:01 UTC, 53 replies.
- [PR] Solace Read connector: RetryCallable mechanism [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/07 09:18:36 UTC, 3 replies.
- [PR] BigQueryIOST: fix assert message, fix streaming mode [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/07 09:44:10 UTC, 4 replies.
- [PR] Solace Read connector: adding Basic Authentication support [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/07 09:50:53 UTC, 1 replies.
- [PR] Solace Read connector: adding implementations of SempClient and SempClientFactory [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/07 10:44:09 UTC, 1 replies.
- [PR] Solace Read connector: integration tests with testcontainers [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/07 10:56:28 UTC, 1 replies.
- [I] [Bug]: [Flink] JdbcIO metrics are always `NaN` when using the FlinkRunner [beam] - posted by "oswidan97 (via GitHub)" <gi...@apache.org> on 2024/06/07 11:41:47 UTC, 3 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/06/07 12:14:30 UTC, 5 replies.
- [I] [Bug]: BigQuery streaming at-least-once job missing records [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/07 12:30:51 UTC, 1 replies.
- [PR] Fix Python Linting Errors on Master [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/07 14:10:19 UTC, 3 replies.
- [PR] [Release-2.57.0] Chery-pick #31538 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/07 16:08:14 UTC, 4 replies.
- [PR] Escape literal tab in error message. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/07 17:52:47 UTC, 2 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/07 18:17:45 UTC, 2 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/07 18:19:16 UTC, 3 replies.
- Re: [I] [Feature Request]: Manage GCS soft delete policy in temp location [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/07 18:19:47 UTC, 6 replies.
- [PR] Allow flags to be used as jinja template variables. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/07 18:50:47 UTC, 5 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/07 22:16:06 UTC, 1 replies.
- [PR] [Python] Add warning to temp_location and staging_location when the bucket has soft delete enabled [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/08 00:39:00 UTC, 4 replies.
- Re: [PR] Windowing Support for the DaskRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/08 12:40:31 UTC, 2 replies.
- Re: [I] [Bug]: Using string in PartitionColumn throws error, tries to convert it to string [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/08 19:51:26 UTC, 0 replies.
- [PR] warn when using auto_unique_labels [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/08 20:10:30 UTC, 4 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/08 20:13:32 UTC, 6 replies.
- [PR] make the table name unique in ReadUsingStorageApiTests [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/08 20:20:57 UTC, 2 replies.
- Re: [PR] [wip]Add withFormatOnFailureFunction for BQ STORAGE_WRITE_API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/09 12:41:00 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/10 04:54:54 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.55.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/10 04:57:56 UTC, 3 replies.
- [PR] Fix usage of two different StateCache in StreamingDataflowWorker [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/06/10 12:36:27 UTC, 3 replies.
- Re: [PR] Bump transformers from 4.36.0 to 4.38.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/10 12:42:30 UTC, 3 replies.
- [PR] Fix scio playground [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/10 12:51:21 UTC, 0 replies.
- Re: [I] [Bug]: Asynchronous callback FutureT is broken from beam 2.54.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:29:21 UTC, 4 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:31:22 UTC, 0 replies.
- Re: [I] [Bug]: ReadFromKafka does not work without max_num_records parameter [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:33:41 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:34:41 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:35:16 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/10 14:36:19 UTC, 0 replies.
- [PR] Cherrypick #31555 onto release branch [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/06/10 15:52:20 UTC, 4 replies.
- Re: [I] [Bug]: SpannerIO creates "under the hood" new Pipeline optoins [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/10 16:19:34 UTC, 0 replies.
- Re: [PR] Add documentation and types to ReadFrom/WriteToBigQuery. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/10 16:44:32 UTC, 4 replies.
- Re: [PR] Allow pr-bot to re-assign reviewers when stopped [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/10 18:53:23 UTC, 0 replies.
- [PR] Default translation for SchemaTransforms [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/10 18:56:50 UTC, 9 replies.
- Re: [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/10 19:36:47 UTC, 0 replies.
- Re: [I] [Failing Test]: PostCommit Python and PostCommit Python Arm perma red [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/10 20:03:30 UTC, 0 replies.
- Re: [PR] SchemaTransformProviderTranslation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/10 21:04:58 UTC, 1 replies.
- [I] [Feature Request]: add a schema annotation to use LogicalType on POJO/JavaBeans porperties [beam] - posted by "martinopic (via GitHub)" <gi...@apache.org> on 2024/06/10 21:28:20 UTC, 0 replies.
- Re: [I] [Feature Request]: In Python how to assign types to multi-output tags? [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/10 23:01:54 UTC, 0 replies.
- [PR] Bump @grpc/grpc-js from 1.4.6 to 1.8.22 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/10 23:05:32 UTC, 4 replies.
- [PR] Remove notes now that Dataflow v2 supports BQ autosharding [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/06/11 09:15:25 UTC, 2 replies.
- Re: [PR] Fix Playground scio examples, fix playground lint [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/11 09:34:28 UTC, 1 replies.
- Re: [I] [Failing Test]: Playground PreCommit failing goLint [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/11 13:24:47 UTC, 0 replies.
- Re: [I] [Feature Request]: Allow metrics to be tagged or segmented [beam] - posted by "gbmarc1 (via GitHub)" <gi...@apache.org> on 2024/06/11 14:01:59 UTC, 0 replies.
- [PR] Cherrypick #31550 onto release branch [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/11 14:22:32 UTC, 9 replies.
- Re: [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/11 14:30:14 UTC, 1 replies.
- Re: [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/11 14:32:59 UTC, 0 replies.
- Re: [I] [Bug]: Pub/Sub sources incompatible with Python MapToFields [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/11 14:37:53 UTC, 0 replies.
- [PR] Cherrypick #31546 to 2.57.0 release branch [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/11 15:03:38 UTC, 2 replies.
- Re: [I] [Bug]: Beam Playground scio examples cannot run [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/06/11 15:16:25 UTC, 1 replies.
- Re: [I] [Task]: Implement load and stress tests for streaming cases [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/06/11 15:20:04 UTC, 0 replies.
- Re: [I] [Task]: Author new knowledge lookup prompts for DuetAI [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/06/11 15:20:18 UTC, 0 replies.
- Re: [I] [Task]: Improve Beam code coverage analysis [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/06/11 15:20:28 UTC, 0 replies.
- [PR] Add image embedding support to TFHub MLTransforms [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/11 15:23:28 UTC, 4 replies.
- Re: [PR] Update Python version in the dev environment script. [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/11 15:24:17 UTC, 0 replies.
- Re: [I] [Task]: Client-side throttling for BigQueryIO DIRECT_READ mode [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/11 16:01:20 UTC, 1 replies.
- [PR] Update documentation for new TFT Transforms [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/06/11 18:04:32 UTC, 3 replies.
- Re: [I] [Feature Request]: Support Reading from Solace message broker [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/11 18:30:26 UTC, 1 replies.
- [PR] Solace Read connector - project init [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/11 19:09:07 UTC, 3 replies.
- [PR] Adjust JVM heap size for extremely large memory machine [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/11 19:18:36 UTC, 11 replies.
- Re: [I] BigQuery DIRECT_READ does not validate pipeline's project ID and instead tries to read from a null project [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/11 20:14:29 UTC, 0 replies.
- Re: [I] JdbcIO.Write needs exception handling tests [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/11 20:19:28 UTC, 2 replies.
- Re: [PR] Add Histogram combiner [beam] - posted by "dilnazanlid (via GitHub)" <gi...@apache.org> on 2024/06/12 09:00:48 UTC, 13 replies.
- [PR] Revert "Updating Commons Compress to 1.26.2" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/12 09:55:37 UTC, 2 replies.
- [PR] Revert "Bump Jackson databind to 2.15" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/12 09:57:34 UTC, 1 replies.
- Re: [I] [Bug]: SpannerIO withQuery overrides withTable [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/12 11:24:17 UTC, 1 replies.
- [PR] Add validation that query and table cannot be specified at the same time for SpannerIO.read() [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/12 11:48:46 UTC, 6 replies.
- [I] [Bug]: Python sdk data plane can become stuck on instructions that had an exception while calling BundleProcessor setup [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/06/12 11:58:51 UTC, 0 replies.
- [PR] Revert "Updates Expansion Service Container to support upgrading using the schema-transform ID" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/12 13:30:32 UTC, 1 replies.
- Re: [I] subprocess_server.stop_process fails on Windows [beam] - posted by "jamesroseman (via GitHub)" <gi...@apache.org> on 2024/06/12 15:48:16 UTC, 1 replies.
- [PR] [Test only] clickhouse tests failures [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/12 15:54:23 UTC, 0 replies.
- [PR] Add try-except for process.send_signal so it can work on Windows. [beam] - posted by "jamesroseman (via GitHub)" <gi...@apache.org> on 2024/06/12 16:17:34 UTC, 5 replies.
- [PR] [CheryrPick of #31509] Filter out tests for unsupported features for Spark. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/12 16:35:11 UTC, 2 replies.
- [PR] Fix clickhouse tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/12 17:36:09 UTC, 6 replies.
- [PR] Migrate Gradle Enterprise Plugin to Develocity Plugin [beam] - posted by "clayburn (via GitHub)" <gi...@apache.org> on 2024/06/12 18:28:52 UTC, 7 replies.
- Re: [PR] [Cherrypick of #31509] Filter out tests for unsupported features for Spark. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/12 18:42:47 UTC, 0 replies.
- [PR] Call out enrichment in side input patterns [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/12 19:50:28 UTC, 4 replies.
- [PR] Avoid length-prefix-bytes substitutions for Flink boundaries. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/12 21:03:31 UTC, 1 replies.
- [PR] Fix StreamConstraintsException introduced in jackson 2.15 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/12 21:07:36 UTC, 7 replies.
- [PR] Limit the size of bundles of elements emitted by SDK into the data output stream. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/12 22:04:48 UTC, 6 replies.
- [PR] [#29697] Update the Release guide with currently manual GitHub release steps for prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/12 23:16:36 UTC, 5 replies.
- [PR] [#31403] Python wrapper to download, use, or build and run prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/12 23:59:37 UTC, 0 replies.
- [PR] Add throttling counters in gcsio. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/13 00:43:04 UTC, 8 replies.
- [PR] Bump com.gradle.enterprise from 3.17.4 to 3.17.5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/13 04:19:23 UTC, 2 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 27.0.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/13 05:03:29 UTC, 4 replies.
- [I] [Bug]: Pickling error in save_main_session with STORAGE_WRITE_API in Dataflow Python pipeline [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2024/06/13 06:27:10 UTC, 1 replies.
- Re: [I] [Bug]: Beam SQL Extension raised an error when the input row contained iterable fields [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/13 10:21:56 UTC, 1 replies.
- [PR] Support Row fields with type ITERABLE in Beam SQL Extension [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/13 10:32:02 UTC, 5 replies.
- Re: [PR] Export gcs options [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/06/13 10:46:20 UTC, 0 replies.
- Re: [PR] Beam SQL Extension raised an error when the input row contained iterable fields [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2024/06/13 13:53:16 UTC, 1 replies.
- Re: [I] [Bug]: [Java] Row equality not working as expected when ByteBuffer used as Map key [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/13 14:19:21 UTC, 1 replies.
- [PR] [Release-2.57.0] Cheery-pick #31580 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/13 14:51:51 UTC, 4 replies.
- [I] [Failing Test]: Java PreCommit UnboundedScheduledExecutorServiceTest testThreadsAreAddedOnlyAsNeededWithContention flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/13 17:18:08 UTC, 0 replies.
- [PR] Clone dataflow containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/13 17:30:47 UTC, 3 replies.
- [I] [Feature Request]: Add fuzz tests to ordered list states. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/13 18:16:47 UTC, 1 replies.
- [I] [Bug]: Correctly handle Int64_MAX as a key in ordered list state [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/13 18:35:57 UTC, 1 replies.
- [PR] Solace Read connector: SolaceIO PTransform init [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/13 19:18:11 UTC, 6 replies.
- [PR] Solace Read connector: watermark-calculation related classes [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/13 19:42:25 UTC, 4 replies.
- [I] [Failing Test]: A recently added GCS IO IT test_create_default_bucket, seems to be flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/13 20:18:39 UTC, 2 replies.
- [PR] Use the original way of validating Bigtable Change Stream table existance to improve compatibility with testing [beam] - posted by "tonytanger (via GitHub)" <gi...@apache.org> on 2024/06/13 20:22:07 UTC, 4 replies.
- [PR] [release-2.57.0] Cherrypick #31581 into the release branch. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/13 20:39:58 UTC, 7 replies.
- [PR] [Prism] Terminate Job with CancelFn instead of panic [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/13 23:05:51 UTC, 7 replies.
- Re: [PR] [Release-2.57.0] Cherry-pick #31580 into release branch [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/13 23:59:57 UTC, 0 replies.
- [PR] Add warning about using Schema.FieldType.BYTES keys in a Map [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/14 05:46:14 UTC, 9 replies.
- [PR] Allow compression of Elasticsearch requests [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/14 07:26:22 UTC, 10 replies.
- Re: [PR] Improve javadoc in ParquetIO [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:55:46 UTC, 0 replies.
- Re: [PR] Bump pymysql from 1.1.0 to 1.1.1 in /sdks/python/container/py311 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:57:01 UTC, 2 replies.
- Re: [PR] Bump requests from 2.31.0 to 2.32.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:57:28 UTC, 2 replies.
- Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.26.0 to 0.31.0 in /sdks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:58:29 UTC, 2 replies.
- Re: [PR] Bump go.mongodb.org/mongo-driver from 1.13.1 to 1.15.0 in /sdks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:58:33 UTC, 2 replies.
- Re: [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py310 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:58:50 UTC, 2 replies.
- Re: [PR] Bump golang.org/x/net from 0.9.0 to 0.23.0 in /playground/backend [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 11:59:48 UTC, 2 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 1.12.1 to 2.0.1 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:00:17 UTC, 2 replies.
- Re: [PR] Bump transformers from 4.30.0 to 4.38.0 in /sdks/python/apache_beam/ml/inference [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:01:05 UTC, 2 replies.
- Re: [PR] Bump protobufjs from 6.11.3 to 6.11.4 in /sdks/typescript [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:01:09 UTC, 2 replies.
- Re: [PR] Bump org.sonarqube from 3.0 to 5.0.0.4638 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:01:14 UTC, 2 replies.
- Re: [PR] Bump commons-cli:commons-cli from 1.6.0 to 1.8.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:03:06 UTC, 0 replies.
- Re: [PR] Add random suffix to IT resource IDs to avoid collision [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:03:40 UTC, 1 replies.
- Re: [PR] [Python][Pipeline Options] Recursively Get All Subclasses [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:08:06 UTC, 2 replies.
- Re: [I] [Failing Test]: PreCommit YAML Xlang Direct fails on GHA [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/06/14 12:09:58 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/06/14 12:50:05 UTC, 0 replies.
- Re: [PR] [yaml] Add UDF docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/14 12:50:07 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/06/14 12:50:09 UTC, 0 replies.
- [PR] Fix internal test failure caused by PR 31550 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/14 15:03:14 UTC, 4 replies.
- Re: [PR] Cherrypick #31550 and #31602 onto release branch [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/14 17:02:15 UTC, 2 replies.
- Re: [I] [Feature Request]: Allow compression of Elasticsearch requests [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/14 19:01:55 UTC, 1 replies.
- [PR] Add try-except block to guard against NotFound exception from GCS delete [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/14 19:32:34 UTC, 6 replies.
- [PR] [YAML] Allow explicitly including external provider lists. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/06/15 00:24:46 UTC, 5 replies.
- [I] [Feature Request]: Disable soft delete policy when creating a default bucket in Go SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/15 01:08:04 UTC, 0 replies.
- [I] [Feature Request]: Add warning if temp location bucket has soft delete enabled for Go SDK. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/06/15 01:10:40 UTC, 1 replies.
- [I] [Bug]: Beam Python pipeline sometimes fail with Exception serializing message: Elements exceeds maximum protobuf size of 2GB [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/15 02:10:34 UTC, 2 replies.
- [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/15 02:21:38 UTC, 10 replies.
- Re: [I] Add ability to Write to GCP PubSub with an orderingKey [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/15 02:23:46 UTC, 0 replies.
- [PR] Update changes.md with a recent improvement. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/15 02:23:57 UTC, 4 replies.
- Re: [I] [Feature Request]: Enable withFormatRecordOnFailureFunction() equivalent for BigQuery STORAGE_WRITE_API [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/15 11:54:05 UTC, 2 replies.
- Re: [PR] Generalize file based source output capabilities [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/15 12:41:04 UTC, 2 replies.
- [PR] Added a new KV in example CoGroupByKeyExample.java [beam] - posted by "dinu2020 (via GitHub)" <gi...@apache.org> on 2024/06/16 04:33:33 UTC, 1 replies.
- Re: [I] Add support for Protobuf and JSON Schema on KafkaIO + Confluent Schema Registry [beam] - posted by "iemejia (via GitHub)" <gi...@apache.org> on 2024/06/16 16:54:59 UTC, 0 replies.
- Re: [I] [Feature Request][Go SDK]: Allow setting Log Level for pipelines. [beam] - posted by "Bizetremi (via GitHub)" <gi...@apache.org> on 2024/06/16 18:51:39 UTC, 0 replies.
- [I] The Playground CI Nightly job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 03:34:43 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.12 to 2.10.16 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 04:59:46 UTC, 1 replies.
- [PR] Bump github.com/spf13/cobra from 1.8.0 to 1.8.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 04:59:57 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.8 to 1.17.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 05:00:50 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.24.0 to 0.26.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 05:00:59 UTC, 1 replies.
- [PR] Bump golang.org/x/sync from 0.6.0 to 0.7.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 05:01:05 UTC, 1 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.0.1 to 2.0.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 05:03:32 UTC, 1 replies.
- Re: [I] [Feature Request]: Expose GroupIntoBatches Parameters for WriteFiles Autosharding transform [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/17 08:24:32 UTC, 0 replies.
- [PR] Expose GroupIntoBatches parameters for WriteFiles auto-sharding transform [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/17 08:47:59 UTC, 4 replies.
- Re: [I] [Bug]: error when trying to serialize headers with LongString [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/17 10:24:31 UTC, 0 replies.
- [PR] RabbitIO: fix serialization for list type headers [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/17 10:45:34 UTC, 7 replies.
- Re: [PR] Update KeysExample [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 12:42:12 UTC, 2 replies.
- [PR] PubsubMessageWithTopicCoder.of() is returning wrong coder [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/06/17 13:11:48 UTC, 2 replies.
- [PR] Update bigquery.py [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/06/17 14:36:37 UTC, 2 replies.
- Re: [PR] Plumb Redistribute "allow duplicates" property to Dataflow [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/17 17:40:29 UTC, 0 replies.
- [PR] Solace Read connector: checkpoint-related classes [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/17 19:15:10 UTC, 5 replies.
- [I] [Bug]: CassandraIO creates bad query with ValueProvider query string [beam] - posted by "georgecma (via GitHub)" <gi...@apache.org> on 2024/06/17 19:24:38 UTC, 2 replies.
- [PR] CassandraIO: Fix generic SelectAll clauses provided by ValueProvider causing CassandraIO.read to fail [beam] - posted by "georgecma (via GitHub)" <gi...@apache.org> on 2024/06/17 19:33:42 UTC, 6 replies.
- [I] [Bug]: Some Beam playground code snippets fail to load. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/17 20:16:42 UTC, 1 replies.
- [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 "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 21:05:32 UTC, 1 replies.
- [PR] [release-2.57.0] Cherrypick #31490 into the release branch. [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/06/17 21:25:01 UTC, 3 replies.
- [PR] Bump urllib3 from 2.2.1 to 2.2.2 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/17 23:02:12 UTC, 1 replies.
- [I] Map Side Input Keys [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/17 23:41:40 UTC, 0 replies.
- [PR] Bump scikit-learn from 1.0.2 to 1.5.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/18 00:01:40 UTC, 2 replies.
- [I] [Bug]: MetricUpdates.isEmpty check does not check for gaugeUpdates [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/06/18 00:02:18 UTC, 1 replies.
- [I] [Task]: Single dockerhub repository for Flink job server container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/18 00:05:11 UTC, 0 replies.
- [PR] Handle MultimapKeysSideInput in State GetRequests [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/18 00:21:46 UTC, 0 replies.
- Re: [PR] Add iceberg load test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/06/18 00:45:36 UTC, 3 replies.
- [PR] Bump github.com/linkedin/goavro/v2 from 2.12.0 to 2.13.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/18 04:50:46 UTC, 1 replies.
- [I] [Bug]: ClickHouseIO - wrong JDBC dependency import [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2024/06/18 11:49:17 UTC, 0 replies.
- Re: [I] [Bug]: apache.calcite CannotPlanException: All the inputs have relevant nodes, however the cost is still infinite. [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/18 13:09:57 UTC, 0 replies.
- [PR] Solace Read connector: interfaces for communication with broker [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/18 16:18:58 UTC, 3 replies.
- [PR] Solace Read connector: UnboundedSource and UnboundedReader [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/18 16:24:47 UTC, 4 replies.
- [PR] Solace Read connector: data classes and mapper [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/06/18 17:04:40 UTC, 4 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/06/18 17:33:42 UTC, 0 replies.
- [PR] Update build_release_candidate.yml to resolve an ordering issue WRT prism dev artifacts. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/18 17:36:48 UTC, 3 replies.
- Re: [PR] [#30789] Add support for Flink 1.18 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/18 20:26:11 UTC, 1 replies.
- [PR] Use intended version for elasticsearch tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/18 22:05:18 UTC, 4 replies.
- [I] [Bug]: elastic search tests not run on intended version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/06/18 22:07:10 UTC, 0 replies.
- Re: [PR] Use correct name for tox doc task. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/21 14:21:42 UTC, 1 replies.
- Re: [I] [Bug]: build_release_candidate fails with `py38-docs is misconfigured` [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/06/21 14:21:42 UTC, 0 replies.
- [PR] [#31403] Relax prism constraints to allow python wordcount to execute. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/06/21 14:21:50 UTC, 2 replies.
- [PR] Add ordering key size validation to validatePubsubMessageSize [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/06/21 14:22:15 UTC, 2 replies.
- [PR] Update the list of reviewers. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/06/21 14:22:35 UTC, 4 replies.
- Re: [PR] Publish a blog post - deploy-python-pipeline-on-flink-runner [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/06/23 06:30:52 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.27.2 to 1.30.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/24 04:39:56 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.63.2 to 1.64.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/24 04:40:26 UTC, 1 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.7.0 to 1.7.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/06/24 04:40:53 UTC, 1 replies.
- Re: [I] [Bug]: PubsubMessage should be renamed to PubSubMessage to reduce confusion [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/06/24 07:28:07 UTC, 0 replies.
- [I] [Feature Request]: Support int32 for properties of Cross lang transformations written in Java [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/06/24 14:12:00 UTC, 0 replies.
- Re: [PR] Removing deprecated TestRule in TestPipeline [beam] - posted by "myhau (via GitHub)" <gi...@apache.org> on 2024/06/24 14:15:11 UTC, 1 replies.