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

---

- Re: [PR] Terraform module to provision a kafka proxy [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 00:21:20 UTC, 4 replies.
- Re: [PR] Set backlog in gauge metric for Kafka Reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 00:21:24 UTC, 10 replies.
- [PR] Move all elasticsearch testing to elasticsearch testing job [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/01 00:48:51 UTC, 12 replies.
- Re: [I] [Bug]: .xs() method on DeferredSeries and DeferredDataFrame doesn't work right when returning single items [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/01 00:52:01 UTC, 0 replies.
- Re: [PR] Revert addition of Redistribute and tests to Java SDK, and translations from runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/01 00:54:39 UTC, 7 replies.
- Re: [PR] [Draft] Return methods in a lexicographical order from ReflectUtils.getMethods() [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/01 00:57:14 UTC, 0 replies.
- Re: [PR] [Python][Pipeline Options] Recursively Get All Subclasses [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 01:31:43 UTC, 0 replies.
- Re: [PR] add computation state cache, config loaders, and status pages [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/01 02:58:30 UTC, 48 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 04:25:18 UTC, 3 replies.
- Re: [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 04:25:21 UTC, 1 replies.
- Re: [PR] Clean up stale code in BigtableService [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 12:13:44 UTC, 5 replies.
- [PR] Pin tensorflow version in notebook [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/01 12:28:24 UTC, 4 replies.
- Re: [PR] DO NOT SUBMIT Direct path test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 12:40:57 UTC, 1 replies.
- Re: [PR] Default max Parallelism should not apply all UnBoundedSource. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 12:41:00 UTC, 1 replies.
- Re: [PR] Replace StorageV1 client with GCS client - Draft [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/01 12:41:01 UTC, 1 replies.
- Re: [PR] Add `.python-version` to .gitignore [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/01 13:45:20 UTC, 0 replies.
- [PR] Fix spotbug warning in KafkaIO PreCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/01 14:46:37 UTC, 5 replies.
- [PR] Add controlling multiple models across processes to CHANGES [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/01 14:51:25 UTC, 3 replies.
- [PR] use work processing context in work processing [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/01 15:49:54 UTC, 10 replies.
- Re: [PR] FnAPI proto changes for ordered list state. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/01 15:58:44 UTC, 8 replies.
- Re: [PR] Add docs/blog for release [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/01 16:36:07 UTC, 6 replies.
- Re: [PR] Optimise View.asList() side inputs for iterating rather than for indexing. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/01 17:05:27 UTC, 4 replies.
- Re: [PR] Add support for int gauge metrics in DataflowRunner [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/05/01 17:08:15 UTC, 4 replies.
- [PR] Fix ISM-expecting tests by explicilty requisting random access. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/01 17:33:49 UTC, 3 replies.
- [I] [Task]: Stop using GCR in Beam [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/01 17:51:02 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/01 18:21:37 UTC, 3 replies.
- Re: [PR] [YAML] Increase re-use of providers with implicitly overlapping transforms. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/01 18:23:35 UTC, 6 replies.
- Re: [PR] Pass original message down through conversion for storage write api [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/05/01 18:50:04 UTC, 31 replies.
- [PR] ElasticsearchIO: handle org.elasticsearch.client.ResponseException gracefully [beam] - posted by "andyzhangdialpad (via GitHub)" <gi...@apache.org> on 2024/05/01 19:36:46 UTC, 28 replies.
- [I] [Bug][Python]: ReadFromCsv with the dtype argument is very slow [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/01 20:23:25 UTC, 4 replies.
- [I] [Bug]: PaneInfo not populated in Go SDK [beam] - posted by "camphillips22 (via GitHub)" <gi...@apache.org> on 2024/05/01 21:57:55 UTC, 4 replies.
- [PR] Add random suffix to IT resource IDs to avoid collision [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/05/01 22:25:45 UTC, 3 replies.
- [PR] Highlight per-worker BigQuery metrics enablement in Changes.md [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/05/02 00:18:44 UTC, 3 replies.
- [PR] Reapply "Add Redistribute transform to Java SDK" [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/02 00:21:00 UTC, 9 replies.
- Re: [PR] Revert "Docker - Remove Deprecated Types" [beam] - posted by "evan-burrell (via GitHub)" <gi...@apache.org> on 2024/05/02 09:39:49 UTC, 6 replies.
- [PR] Bump github.com/apache/beam/sdks/v2 from 2.55.1 to 2.56.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 09:53:04 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/05/02 12:13:53 UTC, 5 replies.
- Re: [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1713054671 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 12:13:54 UTC, 1 replies.
- Re: [PR] Display current threshold for GC thrashing logs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 12:40:50 UTC, 2 replies.
- [PR] Bump apache-beam from 2.55.1 to 2.56.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 12:58:37 UTC, 1 replies.
- Re: [PR] Limit elasticsearch testing to basic tests when core SDK is modified [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/02 13:48:34 UTC, 0 replies.
- Re: [PR] Implement ordered list state for FnApi. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/02 14:00:00 UTC, 17 replies.
- [PR] Fix bomupgrader naming [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 14:07:05 UTC, 3 replies.
- [PR] Update gcp bom [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 14:07:52 UTC, 3 replies.
- [PR] Update beam version [beam-starter-java] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 14:10:33 UTC, 2 replies.
- Re: [PR] [Prism] Connect Web UI cancel requests with backend [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/02 16:45:21 UTC, 1 replies.
- Re: [PR] [YAML] Add the ability to pre-process yaml files with jinja2. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 17:16:03 UTC, 3 replies.
- Re: [PR] (testing, no need to review) update libraries-bom to 26.37.0 [beam] - posted by "suztomo (via GitHub)" <gi...@apache.org> on 2024/05/02 17:56:08 UTC, 4 replies.
- [PR] Revert View.asList() side inputs optimizations. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/02 17:56:40 UTC, 0 replies.
- [PR] Fix blog typo [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 18:32:30 UTC, 3 replies.
- Re: [PR] [Prism] Enable Java validatesRunner tests on Prism [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/02 18:40:45 UTC, 0 replies.
- [I] [Failing Test]: PostCommit Java Dataflow V1 [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/02 18:55:14 UTC, 0 replies.
- Re: [PR] Rollback View.asList() side inputs optimizations. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 19:05:43 UTC, 2 replies.
- Re: [PR] Re-enable schedule trigger for PostCommit Java IO Performance Tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 19:15:47 UTC, 4 replies.
- Re: [I] [Task]: Re-enable schedule trigger for PostCommit Java IO Performance Tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/02 20:32:16 UTC, 0 replies.
- [PR] Adds Managed I/O / Iceberg to 2.56.0 blog and the I/O connectors catalog [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/02 23:09:47 UTC, 4 replies.
- [PR] Add a workaround for BEAM-20873 for optimized list side inputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/02 23:20:14 UTC, 7 replies.
- [PR] Add jinja2 as a dependency for yaml preprocessing. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/03 01:12:15 UTC, 6 replies.
- [PR] Add ordered processing transform to changes/blog [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/03 02:38:21 UTC, 3 replies.
- [PR] Stop using KV as the Key for Histogram Metrics [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/05/03 05:06:21 UTC, 3 replies.
- [I] [Bug]: Cannot use python ReadFromKafka via DirectRunner in CI [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2024/05/03 10:17:28 UTC, 2 replies.
- Re: [PR] Don't re-encode byte[] values in SortValues transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 12:13:36 UTC, 7 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 12:39:56 UTC, 3 replies.
- [PR] Fix flink versioning issues [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/03 13:36:31 UTC, 15 replies.
- [PR] Revert "[YAML] Increase re-use of providers with implicitly overlapping transforms." [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/03 14:57:39 UTC, 4 replies.
- [PR] Fix trivial inference tests for Python 3.12 support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/03 15:14:29 UTC, 15 replies.
- [PR] Pass location for Vertex endpoint retrieval [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/03 15:23:24 UTC, 2 replies.
- [PR] Support Kafka Managed IO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/03 15:47:18 UTC, 12 replies.
- [I] [Feature Request]: Vertex AI Triton Inference Server Support [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/03 15:53:31 UTC, 0 replies.
- [PR] WIP: pane [beam] - posted by "camphillips22 (via GitHub)" <gi...@apache.org> on 2024/05/03 16:16:38 UTC, 0 replies.
- Re: [PR] WIP: [Go SDK] Handle PaneInfo correctly [beam] - posted by "camphillips22 (via GitHub)" <gi...@apache.org> on 2024/05/03 16:24:15 UTC, 2 replies.
- Re: [PR] Implement Web API connector interfaces [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/03 17:14:15 UTC, 6 replies.
- [PR] Avoid excessive flushing in DataflowWorkerLoggingHandler. [beam] - posted by "an2x (via GitHub)" <gi...@apache.org> on 2024/05/03 18:16:49 UTC, 6 replies.
- [I] [Failing Test]: PreCommit Java failures: org.apache.beam.runners.spark.CacheTest > cacheCandidatesUpdaterTest [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/03 18:30:55 UTC, 2 replies.
- [I] [Feature Request]: Prism Support for Timer and ProcessingTime [beam] - posted by "SamStentz (via GitHub)" <gi...@apache.org> on 2024/05/03 20:09:39 UTC, 5 replies.
- [PR] Avoid json Unmarshal on proto CancelJobRequest [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/03 20:53:06 UTC, 2 replies.
- [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py38 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 21:59:56 UTC, 5 replies.
- [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py39 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 22:00:38 UTC, 3 replies.
- [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 22:00:40 UTC, 2 replies.
- [PR] Bump tqdm from 4.66.2 to 4.66.3 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 22:01:39 UTC, 3 replies.
- [I] [Failing Test]: TypeScript Tests continually failing [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/03 22:08:07 UTC, 0 replies.
- [PR] Update hack to make Spark runner happy as well. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/03 22:47:23 UTC, 2 replies.
- [PR] Upgrade Pandas dependency to 2.1 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/04 00:16:10 UTC, 5 replies.
- Re: [I] [Bug]: RunInference with automatic refresh using a global window side inputs takes too long to update sometimes [beam] - posted by "aaltay (via GitHub)" <gi...@apache.org> on 2024/05/04 03:42:31 UTC, 3 replies.
- [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 12:39:09 UTC, 1 replies.
- Re: [PR] SQLTransform DDL support havent exposed to python sdk. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 12:39:11 UTC, 2 replies.
- Re: [PR] [OLD with links] Duet AI training - AI/ML data processing prompts [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 12:39:11 UTC, 1 replies.
- Re: [PR] [OLD - with links] Data encoding prompts for Duet AI [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 12:39:12 UTC, 1 replies.
- Re: [PR] Direct path E2E DO NOT SUBMIT [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/05 12:39:27 UTC, 2 replies.
- Re: [I] Tracking issue for gaps in Python Direct Runner streaming implementation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/06 00:46:26 UTC, 0 replies.
- [PR] add support for unaligned checkpoint for flink runner [beam] - posted by "AyWa (via GitHub)" <gi...@apache.org> on 2024/05/06 08:46:36 UTC, 4 replies.
- Re: [PR] Add direct path code path [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 12:13:44 UTC, 4 replies.
- Re: [PR] Bump github.com/cloudevents/sdk-go/v2 from 2.6.1 to 2.15.2 in /playground/backend [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 12:40:56 UTC, 3 replies.
- [PR] Add guidance on fixing cloud build triggers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/06 13:09:49 UTC, 4 replies.
- Re: [I] [Failing Test]: PostCommit Java Dataflow V1 - testFhirIO_Import & SpannerWriteIT > testSequentialWrite [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/05/06 13:36:36 UTC, 2 replies.
- [PR] flink portable client configurations [beam] - posted by "AyWa (via GitHub)" <gi...@apache.org> on 2024/05/06 14:01:14 UTC, 9 replies.
- [PR] Update CHANGES.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/06 14:37:39 UTC, 1 replies.
- Re: [PR] Suppress BigQuery read stream splitAtFraction when API busy call or timeout [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/06 14:40:56 UTC, 5 replies.
- Re: [I] [Bug]: Reshuffle.viaRandomKey timeout since version 2.54.0 [beam] - posted by "djaneluz (via GitHub)" <gi...@apache.org> on 2024/05/06 14:42:34 UTC, 7 replies.
- [I] [Bug]: Interactive runner not correctly creating flink cluster [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/06 14:58:41 UTC, 2 replies.
- [PR] Bump jinja2 from 2.11.3 to 3.1.4 in /.test-infra/jenkins/metrics_report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 16:49:14 UTC, 2 replies.
- [I] [Task]: Sunset Python 3.8 support [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 18:24:22 UTC, 0 replies.
- [I] [Feature Request]: Add `with_exception_handling()` for PTransforms in Python [beam] - posted by "jd185367 (via GitHub)" <gi...@apache.org> on 2024/05/06 18:27:18 UTC, 3 replies.
- [PR] Move dependency compatibility tests to from py38 to py39 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 18:28:41 UTC, 0 replies.
- Re: [PR] Move dependency tests from PreCommit Coverage to PostCommit [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 19:02:50 UTC, 2 replies.
- [PR] Move lint, yapf, whitespace and dependency compat tests to from py38 to py39 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 19:15:03 UTC, 5 replies.
- Re: [I] Add support for pandas 1.5 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 19:16:10 UTC, 0 replies.
- Re: [PR] Bump google.golang.org/grpc from 1.62.1 to 1.63.2 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 19:35:12 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.15 in /sdks [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/06 19:40:54 UTC, 4 replies.
- Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.26.0 to 0.30.0 in /sdks [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/06 19:42:52 UTC, 4 replies.
- [I] [Feature Request]: Add an example that uses Iceberg I/O via ManagedIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/06 19:52:29 UTC, 0 replies.
- Re: [I] [Feature Request]: Add an example that uses Iceberg I/O via the Managed API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/06 19:53:02 UTC, 0 replies.
- [PR] Fix lint warning: JobId vs JobID [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/06 20:11:52 UTC, 3 replies.
- [I] [Task]: Support Pandas 2.1 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/06 20:39:26 UTC, 2 replies.
- [PR] Move hardcoded version number as default version for setup-environment-action [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/06 21:30:34 UTC, 12 replies.
- [I] [Bug]: Dataflow runner Flatten() yields no output [beam] - posted by "ndopj (via GitHub)" <gi...@apache.org> on 2024/05/06 22:23:03 UTC, 0 replies.
- [I] [Failing Test]: PostCommit Java Dataflow V2 intermittently fails for inconsistent reasons [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/07 00:16:28 UTC, 0 replies.
- [I] [Failing Test]: beam_PostCommit_Java_ValidatesRunner_Dataflow_V2 - consistent intermittant failures [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/07 00:29:51 UTC, 0 replies.
- [I] [Failing Test]: PostCommit Python and PostCommit Python Arm perma red [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/07 00:38:34 UTC, 2 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.13.1 to 1.15.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/07 04:18:58 UTC, 1 replies.
- Re: [I] [Bug]: Dataflow runner - Flatten() yields no output [beam] - posted by "ndopj (via GitHub)" <gi...@apache.org> on 2024/05/07 06:58:35 UTC, 3 replies.
- Re: [I] [Bug]: Watermarks and Windowing Not Working with FlinkRunner and KinesisIO Read Transform [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/07 08:03:00 UTC, 34 replies.
- Re: [PR] [#30789] Add support for Flink 1.18 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/07 08:26:58 UTC, 15 replies.
- Re: [PR] Call `DateTime(long)` instead of `DateTime(Object)`. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/07 12:13:59 UTC, 14 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/07 12:14:02 UTC, 4 replies.
- Re: [PR] Avoid system exit during `PipelineOptions` instantiation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/07 12:40:52 UTC, 2 replies.
- Re: [PR] [Draft] Change Multiple dataframe transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/07 12:40:53 UTC, 2 replies.
- [PR] Update website runner sections [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/07 14:36:21 UTC, 5 replies.
- Re: [I] [Feature Request]: Support for Apache Flink 1.18 in Beam Runners [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/07 14:57:04 UTC, 1 replies.
- [PR] PubsubIO: setNeedsAttributes(true) when readMessagesWithCoderAndParseFn [beam] - posted by "llamallamaduck (via GitHub)" <gi...@apache.org> on 2024/05/07 15:13:15 UTC, 9 replies.
- [I] [Failing Test]: apache_beam.io.requestresponse_test::TestCaller::test_default_throttler possibly flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/07 15:14:37 UTC, 2 replies.
- Re: [I] Support unaligned checkpoints [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/07 15:48:16 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/07 17:37:44 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/07 17:38:18 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/07 17:40:18 UTC, 1 replies.
- [PR] Updates the error message related to schema-transform discovery [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/07 17:54:12 UTC, 2 replies.
- [PR] Targeted dependency update for Pandas 2.1 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/07 18:31:41 UTC, 3 replies.
- [PR] Update yaml to non-beta link [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/07 19:14:13 UTC, 5 replies.
- [PR] Fix version issue [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/07 19:29:50 UTC, 3 replies.
- [PR] Use already-existing and more appropriately alarmist experiment in Python [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/07 19:32:35 UTC, 4 replies.
- [PR] Restore pandas version constraint. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/07 20:14:27 UTC, 1 replies.
- [PR] Raise upper bound for jinja2. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/07 20:19:20 UTC, 1 replies.
- [PR] [YAML] Add tests for yaml main. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/07 20:40:35 UTC, 4 replies.
- [PR] Add a container for Python 3.12. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/07 22:22:39 UTC, 8 replies.
- [PR] [flink] Add documentation for Flink runner versions updates [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/08 08:44:15 UTC, 13 replies.
- [I] [Feature Request]: Enhance Error Handling in FileSystem Imports to Improve Troubleshooting [beam] - posted by "RyuSA (via GitHub)" <gi...@apache.org> on 2024/05/08 12:03:46 UTC, 5 replies.
- Re: [PR] Created method SerializableComparator.comparing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 12:42:00 UTC, 2 replies.
- Re: [PR] Beam wasm job execution [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 12:42:05 UTC, 2 replies.
- [PR] Logging loading filesystems failures. [beam] - posted by "RyuSA (via GitHub)" <gi...@apache.org> on 2024/05/08 14:23:45 UTC, 11 replies.
- [PR] Add IcebergIO integration tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/08 17:19:26 UTC, 8 replies.
- [PR] Fix python_test broke by #31199 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/08 17:50:09 UTC, 3 replies.
- Re: [PR] Beam SQL Extension raised an error when the input row contained iterable fields [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/08 19:20:27 UTC, 0 replies.
- [PR] Don't hardcode python version in tox.ini for lint, mypy and docs. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/08 21:38:31 UTC, 4 replies.
- Re: [I] [Task]: Support Python 3.12 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 00:16:14 UTC, 2 replies.
- [PR] Add a tox unit test suite for Python 3.12. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 00:28:12 UTC, 4 replies.
- Re: [I] [Feature Request]: Support Type Inference on Python 3.12 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 00:29:19 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.16 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/09 04:19:53 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.53.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/09 04:27:04 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.53.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/09 04:27:06 UTC, 1 replies.
- Re: [PR] Initial Iceberg Sink [beam] - posted by "jbonofre (via GitHub)" <gi...@apache.org> on 2024/05/09 04:48:29 UTC, 1 replies.
- [I] [Bug]: Improve handling of 'not found' BigQuery dataset/table errors with appropriate retry policy [beam] - posted by "yu-iskw (via GitHub)" <gi...@apache.org> on 2024/05/09 06:00:51 UTC, 0 replies.
- [I] [Bug]: Python expansion with multiple SqlTransforms is extremely slow [beam] - posted by "gergely-g (via GitHub)" <gi...@apache.org> on 2024/05/09 06:36:52 UTC, 7 replies.
- [PR] Avoid oversizing batch sizes with size estimation function [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/09 13:51:13 UTC, 3 replies.
- Re: [I] The StressTests Java KafkaIO job is flaky [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/05/09 13:59:31 UTC, 1 replies.
- [PR] Turn off abandoned node enforcement in some Reshuffle unit tests where it is not needed [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/09 14:38:13 UTC, 6 replies.
- [PR] Fix nullness errors in TestPipeline [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/09 15:12:42 UTC, 5 replies.
- [I] [Bug]: Portable translation or SDK harness appears to have a bug in GBK coders [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/09 15:29:49 UTC, 0 replies.
- [PR] Add in-memory variants of side inputs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/09 15:41:29 UTC, 3 replies.
- [PR] Fix #31212 by removing the extra space in option string. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/09 19:15:43 UTC, 4 replies.
- [I] [Bug]: Portable Spark 3 Streaming runner appears to have GBK bugs, cannot execute Redistribute composite correctly [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/09 20:55:23 UTC, 2 replies.
- [PR] clean up some grpc error handling for windmill streams [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/09 22:24:31 UTC, 5 replies.
- [PR] Remove a deprecated test helper. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 22:52:24 UTC, 2 replies.
- Re: [PR] Remove usages of assert dict contains subset [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 22:54:43 UTC, 1 replies.
- [PR] Publish snapshots for Python 3.12 container images. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 23:11:02 UTC, 5 replies.
- [I] [Task]: Upgrade to Pandas 2.2.3 or above once available [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 23:32:57 UTC, 0 replies.
- [I] [Task]: Support newer versions of Pyarrow in Beam [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/09 23:42:47 UTC, 3 replies.
- [PR] Exclude a test that doesn't pass due to an upstream issue. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 00:47:09 UTC, 2 replies.
- [PR] Add new BigQueryIO stress tests for AT_LEAST_ONCE writing method [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2024/05/10 00:57:44 UTC, 2 replies.
- [I] Update ExternalJavaProvider.available method to support Windows systems [beam] - posted by "eug (via GitHub)" <gi...@apache.org> on 2024/05/10 02:41:44 UTC, 0 replies.
- [PR] Bump github.com/docker/docker from 25.0.5+incompatible to 26.1.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/10 04:21:35 UTC, 3 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.26.0 to 0.31.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/10 04:22:22 UTC, 1 replies.
- [I] The IcebergIO Unit Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/10 09:33:31 UTC, 0 replies.
- Re: [I] Add support for Protobuf and JSON Schema on KafkaIO + Confluent Schema Registry [beam] - posted by "zachariahyoung (via GitHub)" <gi...@apache.org> on 2024/05/10 12:29:11 UTC, 1 replies.
- Re: [PR] Automatically format build.gradle throughout project [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/10 12:40:27 UTC, 0 replies.
- Re: [I] [Bug]: apache_beam.transforms.util.BatchElements allows creating batches that exceed max_batch_size [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/10 14:12:19 UTC, 0 replies.
- [PR] Fix Python 3.12 python hinting errors on MacOS [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/10 14:14:47 UTC, 5 replies.
- Re: [I] [Failing Test]: Remove usages of a deprecated test helper assertDictContainsSubset in Beam codebase. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 16:42:26 UTC, 0 replies.
- [PR] [Python] Add retries for flaky test - requestresponse_test.py::TestCaller::test_default_throttler [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/10 16:55:11 UTC, 7 replies.
- [PR] Update version tag for dataflow dev containres. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 17:59:32 UTC, 2 replies.
- [PR] Implement the hash_words TFT operation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/10 18:27:15 UTC, 5 replies.
- Re: [I] pipeline.run() blocks when using FlinkRunner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/10 18:47:23 UTC, 1 replies.
- Re: [I] [Feature Request]: Enable display of @Description annotations in generated Javadocs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/10 18:56:05 UTC, 0 replies.
- [PR] Disclaim direct runner result can be different with remote runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/10 18:57:23 UTC, 1 replies.
- [I] [Failing Test]: Vulnerabilities showing up for many versions [beam] - posted by "allamsudha (via GitHub)" <gi...@apache.org> on 2024/05/10 19:28:44 UTC, 0 replies.
- [I] [Feature request]: Support XGBoost 2.x [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 19:40:02 UTC, 0 replies.
- Re: [PR] Update version tag for dataflow dev containers. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/10 19:58:41 UTC, 1 replies.
- [PR] Enable BigQueryIO write throttling detection [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/10 20:05:00 UTC, 15 replies.
- Re: [PR] Disclaimer - direct runner result can be different from remote runners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/10 20:05:47 UTC, 2 replies.
- [I] [Failing Test]: Onnx inference unit tests are failing. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 20:58:56 UTC, 1 replies.
- Re: [I] [Feature Request]: Support ONNX runtime in RunInference API [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 21:08:28 UTC, 1 replies.
- [PR] Add a subsuite of unit tests for ML package [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 22:46:48 UTC, 0 replies.
- [PR] [DO NOT MERGE] [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/10 23:36:29 UTC, 2 replies.
- Re: [I] Support recursive structs as concrete types in Go SDK [beam] - posted by "petrkotek (via GitHub)" <gi...@apache.org> on 2024/05/11 01:42:55 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/05/11 02:39:15 UTC, 1 replies.
- [PR] Update try-apache-beam-yaml.ipynb [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/11 14:41:58 UTC, 1 replies.
- [I] Java Apache Beam, allow fake external Clients initialized in @Setup method of DoFn with Constructors variables [beam] - posted by "AerialSky93 (via GitHub)" <gi...@apache.org> on 2024/05/12 19:08:44 UTC, 0 replies.
- [I] Question : What type should I use to read a numeric from bigquery with the go SDK ? [beam] - posted by "ancogamer (via GitHub)" <gi...@apache.org> on 2024/05/12 22:44:40 UTC, 0 replies.
- Re: [PR] Add a subsuite of unit tests for ML package and remove them from 'coverage' GHA workflow. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/12 22:57:54 UTC, 14 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.17 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 04:28:17 UTC, 3 replies.
- [PR] Bump com.gradle.enterprise from 3.17.2 to 3.17.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 05:08:09 UTC, 3 replies.
- [PR] Revert "[#30789] Add support for Flink 1.18 (#31062)" [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/13 06:51:24 UTC, 2 replies.
- Re: [PR] Akarys shorabek spanner stress test [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/05/13 09:53:22 UTC, 0 replies.
- Re: [I] Use a provider to create JMS ConnectionFactory and avoid Serialization issues [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/05/13 10:59:46 UTC, 0 replies.
- Re: [PR] Bump google.golang.org/protobuf from 1.30.0 to 1.33.0 in /playground/backend [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 12:41:18 UTC, 3 replies.
- Re: [PR] Bump google.golang.org/protobuf from 1.28.1 to 1.33.0 in /learning/tour-of-beam/backend [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 12:41:19 UTC, 3 replies.
- [PR] Avoid side input issue where Latest.globally produces 2 elements in a window [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/13 13:13:24 UTC, 4 replies.
- [PR] add support for ConnectionFactory ProviderFn in JmsIO [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/05/13 14:26:42 UTC, 6 replies.
- [PR] [Python] Use BufferedLogger instead of logger to log in boot.go [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/13 14:26:49 UTC, 7 replies.
- [PR] Beam YAML day zero notebook save file fix [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/05/13 15:42:07 UTC, 3 replies.
- [PR] Fix a typo in skip condition. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/13 15:45:08 UTC, 4 replies.
- [PR] Reapply "Add direct Dataflow translation of Redistribute transform" [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/13 16:39:34 UTC, 3 replies.
- [I] [Failing Test]: YAML integration tests are flaky as a result of failing to start expansion service [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/13 17:06:37 UTC, 1 replies.
- [PR] Reapply "Add Redistribute translation to Samza runner" [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/13 18:10:26 UTC, 3 replies.
- [PR] Reapply "Add Redistribute translation to FlinkRunner" [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/13 18:10:28 UTC, 0 replies.
- [PR] Reapply "Add Redistribute translation to Spark runner" [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/13 18:10:30 UTC, 0 replies.
- [PR] [Python] Use retry decorator for retrying [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/13 18:15:04 UTC, 4 replies.
- [PR] [Test only] Run validation on Flink 1.17 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/13 18:32:53 UTC, 2 replies.
- [PR] trim the beam_ off the beginnings of job names [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/13 19:07:25 UTC, 0 replies.
- [PR] Add a test for sql dialect. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/13 19:11:57 UTC, 3 replies.
- [I] [Feature Request]: Optimize the number of shards for FileIO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/13 20:18:05 UTC, 0 replies.
- [PR] Expansion service updates [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/13 20:33:32 UTC, 1 replies.
- Re: [PR] Revert Flink 1.18 support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/13 20:33:49 UTC, 11 replies.
- [PR] Copy edit the code contribution guide [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/05/13 21:19:43 UTC, 4 replies.
- [I] [Feature Request]: provide option for explicit schema data types for batch input sources and callable functions [beam] - posted by "ewanzhang-google (via GitHub)" <gi...@apache.org> on 2024/05/13 21:52:06 UTC, 0 replies.
- [PR] Add Backlog to Kafka Splittable DoFn Implementation [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/05/13 22:22:25 UTC, 0 replies.
- Re: [I] [Task]: Split up the beam_PreCommit_Python_Coverage test suite [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/13 22:37:41 UTC, 1 replies.
- Re: [PR] Add Backlog Metrics to Kafka Splittable DoFn Implementation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 23:35:08 UTC, 4 replies.
- [PR] Use default Python 3 interpreter, when precise minor version is not s… [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/13 23:44:14 UTC, 0 replies.
- [PR] Revert "Don't specify an unnecessary config given that tox task and gradle config already defines the Python version." [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/13 23:48:45 UTC, 2 replies.
- Re: [PR] Use default Python 3 interpreter, when precise minor version is not specified. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/13 23:57:30 UTC, 2 replies.
- [PR] Better mixed Java/Python error messages for external transforms. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/14 00:16:06 UTC, 7 replies.
- Re: [PR] Break out work processing logic from StreamingDataflowWorker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/14 12:41:37 UTC, 2 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/14 12:41:39 UTC, 7 replies.
- Re: [PR] Log a warning, if the process method of DoFn returns None [beam] - posted by "timgrein (via GitHub)" <gi...@apache.org> on 2024/05/14 15:22:46 UTC, 0 replies.
- [PR] Exclude testRedistributePreservesMetadata from Spark PVR batch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/14 15:43:26 UTC, 3 replies.
- [I] [Failing Test]: Pip fails to install apache-beam[gcp]==2.56.0 with tensorflow-transform on Python 3.11 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 16:38:03 UTC, 3 replies.
- Re: [PR] Use default Python 3 interpreter, when precise minor version is not specified to gradle. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 16:59:09 UTC, 1 replies.
- [PR] Don't install TFT on Python 3.11+ [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 17:05:59 UTC, 2 replies.
- [I] [Failing Test]: Some GHA actions running tox suites because a requested python interpreter is not found [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 17:10:21 UTC, 0 replies.
- [PR] Don't build sdist or create a venv for tox tasks. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 17:15:30 UTC, 3 replies.
- [PR] Add ApplyBucketsWithInterpolation TFTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/14 17:51:45 UTC, 14 replies.
- [PR] Fix post release revert leftover from #31274 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/14 18:31:41 UTC, 3 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Java_PVR_Flink_Batch stuck [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/14 19:01:35 UTC, 0 replies.
- Re: [I] The PostCommit Java PVR Spark Batch job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/14 19:04:21 UTC, 0 replies.
- [PR] remove unused field [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/14 19:12:12 UTC, 4 replies.
- Re: [PR] Create option to specify temp query project, and wire into source tab… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/14 19:35:57 UTC, 2 replies.
- Re: [I] [Failing Test]: Some GHA actions fail when running tox suites because a requested python interpreter is not found [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 20:16:50 UTC, 1 replies.
- [I] [Failing Test]: Beam ML unit tests fail with Keras 3.3.3 and TF 2.16.1 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 20:18:27 UTC, 2 replies.
- [PR] [Python] BigQuery handler for enrichment transform [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/14 21:14:56 UTC, 12 replies.
- Re: [I] [Failing Test]: Beam ML unit test suite fails on Python 3.11 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/14 21:55:15 UTC, 2 replies.
- [I] [Bug]: TextIO.read().withEmptyMatchTreatment(EmptyMatchTreatment.ALLOW) still fails if no file is found [beam] - posted by "arkadioz (via GitHub)" <gi...@apache.org> on 2024/05/14 22:32:05 UTC, 4 replies.
- Re: [I] The IcebergIO Unit Tests job is permared [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/14 23:50:47 UTC, 2 replies.
- [I] [Failing Test]: PreCommit YAML Xlang Direct fails on GHA [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/15 00:01:38 UTC, 1 replies.
- Re: [PR] Skip tests using TFT in Beam ML unit test suite on Python 3.11+ [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/15 00:02:59 UTC, 2 replies.
- [PR] move heartbeat processor to where it is being used [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/15 01:09:13 UTC, 2 replies.
- [I] [Feature Request]: Include job name in GCS custom audit info [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/15 04:01:07 UTC, 0 replies.
- [PR] Add job name to GCS custom audit info in Python [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/15 04:03:10 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 05:03:48 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.54.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 05:05:43 UTC, 3 replies.
- [I] [Bug]: windmillServiceCommitThreads option can lead to ConcurrentModificationException and stuck commits [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/15 08:54:54 UTC, 0 replies.
- Re: [PR] Return methods in a lexicographical order from ReflectUtils.getMethods() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 12:14:25 UTC, 3 replies.
- Re: [PR] [WIP] try new protobuf [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 12:41:49 UTC, 3 replies.
- [PR] Make GrpcCommitWorkStream thread-safe as documented by moving batcher out of it. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/15 15:06:05 UTC, 14 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 15:33:24 UTC, 5 replies.
- [PR] Support newer versions of Pyarrow in Beam. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/15 17:46:01 UTC, 6 replies.
- Re: [PR] [Python] Add job name to GCS custom audit info [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/15 18:23:57 UTC, 9 replies.
- Re: [I] Portable runners should be able to issue checkpoints to Splittable DoFn [beam] - posted by "portikCoder (via GitHub)" <gi...@apache.org> on 2024/05/15 18:30:29 UTC, 2 replies.
- [PR] Fix permared Iceberg unit tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/15 19:11:41 UTC, 1 replies.
- [PR] Implement DeduplicateTensorPerRow in MLTransform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/05/15 19:15:28 UTC, 6 replies.
- [PR] Install Beam from wheels in Dependency Compat Test Suite. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/15 19:58:38 UTC, 7 replies.
- [PR] Update hamcrest dependency documentation version [beam] - posted by "MV-GH (via GitHub)" <gi...@apache.org> on 2024/05/15 22:16:50 UTC, 2 replies.
- [PR] Enable to handle NotFound and AccessDenied errors in the streaming insert of `BigQueryIO` [beam] - posted by "yu-iskw (via GitHub)" <gi...@apache.org> on 2024/05/16 01:24:24 UTC, 9 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 03:33:54 UTC, 2 replies.
- [I] The PostCommit XVR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 03:33:57 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.19 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 04:23:45 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.54.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 04:27:47 UTC, 3 replies.
- Re: [PR] PubsubIO: add readMessagesWithAttributesWithCoderAndParseFn [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/16 11:14:59 UTC, 5 replies.
- [I] [Bug]: KinesisIO source on FlinkRunner initializes the same splits twice [beam] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2024/05/16 11:31:56 UTC, 10 replies.
- [PR] Fix iceberg unit tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/16 14:43:58 UTC, 2 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/16 14:51:20 UTC, 0 replies.
- [I] [Failing Test]: :sdks:python:test-suites:direct:py38:tensorflowInferenceTest fails in Python 3.8 postcommit suite [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/16 17:35:05 UTC, 0 replies.
- [PR] [Java] Add job name to GCS custom audit info [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/16 18:14:19 UTC, 4 replies.
- [PR] remove processing/scheduling logic from StreamingDataflowWorker [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/16 18:47:31 UTC, 77 replies.
- Re: [PR] Update Guava version to match the libraries-bom 26.38.0 [beam] - posted by "suztomo (via GitHub)" <gi...@apache.org> on 2024/05/16 19:09:47 UTC, 1 replies.
- [PR] Upgrade GCP BOM to 26.39.0 [beam] - posted by "suztomo (via GitHub)" <gi...@apache.org> on 2024/05/16 20:18:38 UTC, 3 replies.
- Re: [I] [Task]: Document compatibility asipirations & test coverage policies for optional Beam dependencies [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/16 21:26:20 UTC, 0 replies.
- [PR] [Go SDK] Don't swallow data errors on timer errors. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/16 22:03:39 UTC, 0 replies.
- [PR] [Go SDK] Additional state coder tests for Go SDK [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/16 22:39:54 UTC, 0 replies.
- [PR] Upgrade cibuildwheel version. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/16 23:02:16 UTC, 2 replies.
- Re: [PR] [Go SDK] Make it clearer that timers and data don't interact negatively in element batches. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 23:05:50 UTC, 1 replies.
- [PR] start/close streams in parallel on new worker metadata [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/05/17 00:18:28 UTC, 2 replies.
- [PR] Refactor RowMutationInformation to use string type [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/17 01:18:17 UTC, 15 replies.
- [PR] [Java] Disable soft delete policy when creating a default bucket for a project. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/17 03:08:58 UTC, 11 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.16.20 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/17 04:56:46 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.54.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/17 05:01:42 UTC, 3 replies.
- [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/05/17 05:03:58 UTC, 1 replies.
- [PR] Reapply "[#30789] Add support for Flink 1.18 (#31062)" [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/17 07:12:06 UTC, 6 replies.
- [I] [Bug]: Using WriteToBigQuery FILE_LOADS in a streaming pipeline does not remove temporary tables [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/17 12:35:38 UTC, 0 replies.
- [I] [Feature Request]: Manage GCS soft delete policy in temp location [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/17 13:41:42 UTC, 1 replies.
- [PR] add category where missing in aggregation transforms [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/05/17 15:11:42 UTC, 4 replies.
- Re: [I] Add Apache Iceberg IO connector [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/05/17 15:24:13 UTC, 2 replies.
- [I] [Bug]: JmsIOTests don't actually verify that the queue is empty [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/05/17 15:28:49 UTC, 2 replies.
- [PR] Update code-change-guide.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/17 15:59:48 UTC, 1 replies.
- Re: [I] [Bug]: RedisIO#readKeyPatterns failing with OutOfMemory on version 2.39.0 [beam] - posted by "djaneluz (via GitHub)" <gi...@apache.org> on 2024/05/17 16:03:53 UTC, 1 replies.
- [PR] start the connection before calling receive in JmsIOTest [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/05/17 16:16:04 UTC, 5 replies.
- [I] [Feature Request]: Enable BigQueryIO to support _CHANGE_SEQUENCE_NUMBER fixed hex string pseudo column [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/17 17:07:29 UTC, 1 replies.
- [I] [Bug][Prism]: panic: unknown coder urn key: beam:coder:nullable:v1 [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/17 18:14:13 UTC, 1 replies.
- [PR] Upgrade cibuildwheel in another place as well. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/17 18:16:25 UTC, 3 replies.
- [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/05/17 18:29:06 UTC, 0 replies.
- [I] [Bug][Prism]: panic: unsupported StateKey Get type: *fnexecution_v1.StateKey_MultimapKeysSideInput_ [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/17 21:32:10 UTC, 0 replies.
- [PR] [Prism]: Fix unknown coder urn key: beam:coder:nullable:v1 [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/18 00:02:25 UTC, 2 replies.
- Re: [I] Google Cloud Storage TextIO read fails with gz-files having Content-Encoding: gzip header [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/18 10:30:45 UTC, 0 replies.
- [PR] Update beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Imagenet_Cla… [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/18 10:50:37 UTC, 2 replies.
- Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/18 11:35:46 UTC, 0 replies.
- Re: [PR] Initial Commit for AvroPayloadSerializer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/18 12:40:30 UTC, 0 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/19 22:14:00 UTC, 0 replies.
- [PR] [Python] Disable soft delete policy when creating new default bucket. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/20 01:42:45 UTC, 14 replies.
- [PR] Bump com.gradle.enterprise from 3.17.2 to 3.17.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/20 04:07:00 UTC, 3 replies.
- Re: [PR] [DO NOT MERGE] Reapply "[#30789] Add support for Flink 1.18 (#31062)" [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/20 09:06:18 UTC, 0 replies.
- [I] The PreCommit Java Debezium IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/20 12:42:22 UTC, 0 replies.
- Re: [I] Non-insertion errors in BigQueryIO.Write cause infinite loop [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/20 14:04:18 UTC, 0 replies.
- [PR] [WIP] Add in redistribute option for Kafka Read [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/05/20 18:03:54 UTC, 5 replies.
- [PR] Iceberg catalog validation fix [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/20 19:14:03 UTC, 1 replies.
- [PR] Fix iceberg catalog validation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/20 19:30:20 UTC, 4 replies.
- [PR] Retry when the BQ job error can be retried [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/20 19:55:10 UTC, 5 replies.
- [PR] Upgrade jetty to latest 9.x for dataflow legacy worker [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/20 20:09:19 UTC, 4 replies.
- [PR] Updates the Java Expansion Service container to support Google ALTS authentication [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/20 23:01:19 UTC, 4 replies.
- [I] [Bug]: Add consistent schema format for TypedSchemaTransformProvider [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/21 00:15:36 UTC, 0 replies.
- [I] [Feature Request]: Enable withFormatRecordOnFailureFunction() equivalent for BigQuery STORAGE_WRITE_API [beam] - posted by "sarinasij (via GitHub)" <gi...@apache.org> on 2024/05/21 04:32:20 UTC, 0 replies.
- [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 "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 05:32:33 UTC, 1 replies.
- [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/21 08:50:52 UTC, 7 replies.
- Re: [PR] Enable writing JSON type to BQ for Python FILE_LOADS [beam] - posted by "pwiecek (via GitHub)" <gi...@apache.org> on 2024/05/21 11:40:02 UTC, 0 replies.
- Re: [PR] Adding Iceberg Support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 12:41:17 UTC, 2 replies.
- [I] [Failing Test]: Python Precommit failing due to RRIO test failures [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/21 14:49:53 UTC, 2 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "pavleec (via GitHub)" <gi...@apache.org> on 2024/05/21 14:55:38 UTC, 0 replies.
- [PR] Add warning to gcpTempLocation when its bucket has soft delete enabled [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/21 15:30:22 UTC, 0 replies.
- [PR] [Python] Skip requests version 2.32.0,2.32.1 from package dependencies [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/05/21 15:48:36 UTC, 2 replies.
- Re: [PR] [Java] Add warning to gcpTempLocation when its bucket has soft delete enabled [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/21 16:56:32 UTC, 5 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 17:13:52 UTC, 2 replies.
- [I] [Feature Request]: Add `withoutValidation` option added to `BigtableIO.ReadChangeStream` [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/05/21 19:34:38 UTC, 1 replies.
- [PR] Bump pymysql from 1.1.0 to 1.1.1 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 19:54:47 UTC, 1 replies.
- [PR] Kafka SchemaTransform translation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/21 19:58:14 UTC, 4 replies.
- [PR] Emit a warning when large elements are detected. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/21 20:21:33 UTC, 5 replies.
- Re: [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/21 20:45:28 UTC, 2 replies.
- [PR] added pytest.mark.flaky for test_big_query_write_temp_table_append_sc… [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/21 20:49:37 UTC, 6 replies.
- [PR] Fix DebeziumIO testWrongHost trying to connect real external address [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/21 21:05:27 UTC, 2 replies.
- Re: [I] [Bug]: Datastore's Read fails Pipeline validation and throws on DataflowRunner [beam] - posted by "donallmc (via GitHub)" <gi...@apache.org> on 2024/05/21 22:12:38 UTC, 0 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 22:12:42 UTC, 0 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 22:12:48 UTC, 0 replies.
- [PR] [#29697] Add prism artifact building workflow. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/21 23:29:43 UTC, 12 replies.
- [PR] Don't set SETUPTOOLS_USE_DISTUTILS=stdlib [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/21 23:42:04 UTC, 2 replies.
- [I] [Feature Request]: Transaction and Request Tags on SDK connecting to Spanner [beam] - posted by "iyertalks (via GitHub)" <gi...@apache.org> on 2024/05/22 00:23:44 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Jackson 2.15 [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/22 01:12:26 UTC, 2 replies.
- [I] [Bug]: Python SDK chain after WriteToBigQuery example is incorrect for file_loads method [beam] - posted by "tangsiwei0831 (via GitHub)" <gi...@apache.org> on 2024/05/22 01:43:26 UTC, 1 replies.
- Re: [PR] [Test only] check python compatibility tests run on test suites [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/22 12:41:40 UTC, 1 replies.
- [I] [Bug]: Dataflow Runner V2 does not support BigueryIO STORAGE_WRITE_API when configured withAutoSharding [beam] - posted by "damnMeddlingKid (via GitHub)" <gi...@apache.org> on 2024/05/22 15:14:50 UTC, 2 replies.
- Re: [PR] Change ManagedSchemaTransformProvider to take a Row config [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/22 16:25:38 UTC, 0 replies.
- [PR] Default SchemaTransform configs to snake_case [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/22 16:28:21 UTC, 10 replies.
- Re: [PR] #26395 Disabling possibly unnecessary prefetching during GroupIntoBatches by using an experimental flag [beam] - posted by "nbali (via GitHub)" <gi...@apache.org> on 2024/05/22 16:54:00 UTC, 1 replies.
- [I] [Feature Request]: Improve Managed API to avoid redundant `PCollectionRowTuple` calls [beam] - posted by "VeronicaWasson (via GitHub)" <gi...@apache.org> on 2024/05/22 17:20:40 UTC, 1 replies.
- Re: [PR] Updates the Java Expansion Service container to support gRPC ALTS authentication [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/22 18:01:46 UTC, 1 replies.
- Re: [PR] Add Python 3.12 support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/22 21:06:42 UTC, 8 replies.
- [PR] Add option to disable validation of cloud bigtable change stream IO [beam] - posted by "tonytanger (via GitHub)" <gi...@apache.org> on 2024/05/22 21:11:12 UTC, 8 replies.
- [PR] Memoize some dataframes analysis operations. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/23 00:28:51 UTC, 5 replies.
- [I] [Bug]: Flink 1.17 cannot be selected on the apache-beam package v2.56.0 [beam] - posted by "jaehyeon-kim (via GitHub)" <gi...@apache.org> on 2024/05/23 00:40:50 UTC, 2 replies.
- [PR] Add Histogram transform and combiner [beam] - posted by "dilnazanlid (via GitHub)" <gi...@apache.org> on 2024/05/23 06:52:19 UTC, 1 replies.
- [PR] Update README.md (fix typo) [beam] - posted by "paulk-asert (via GitHub)" <gi...@apache.org> on 2024/05/23 07:07:53 UTC, 2 replies.
- [I] [Bug]: Teardown method is never called [beam] - posted by "boolangery (via GitHub)" <gi...@apache.org> on 2024/05/23 08:06:54 UTC, 0 replies.
- [PR] Fixed the extension name in Java SDK Ordered Processing extension [beam] - posted by "slilichenko (via GitHub)" <gi...@apache.org> on 2024/05/23 14:24:04 UTC, 2 replies.
- [PR] Fix beam quest link [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/05/23 17:43:12 UTC, 1 replies.
- [PR] move playground ci nightly to highmem due to mem exaustion [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/05/23 20:08:17 UTC, 2 replies.
- [I] [Failing Test]: Python 3.12 ML Precommit suite is failing [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/23 23:51:57 UTC, 1 replies.
- [PR] Don't install TF on Python 3.12, since there is no compatible version atm. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/24 00:06:59 UTC, 4 replies.
- [PR] Bump commons-cli:commons-cli from 1.6.0 to 1.8.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/24 04:32:01 UTC, 1 replies.
- [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/05/24 05:13:25 UTC, 1 replies.
- [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/05/24 05:20:08 UTC, 1 replies.
- Re: [I] [yaml]: Normalize BigtableIO [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/05/24 08:28:20 UTC, 0 replies.
- [I] [Bug]: FlinkRunner does not emit watermark with empty source [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/24 09:50:48 UTC, 2 replies.
- [PR] [flink] #31390 emit watermark with empty source [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/24 09:52:28 UTC, 7 replies.
- [PR] Add iceberg load test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/24 13:34:43 UTC, 10 replies.
- Re: [I] Support SetState in Dataflow runner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/24 13:46:57 UTC, 0 replies.
- Re: [I] Support MapState in DataflowRunner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/24 13:47:46 UTC, 0 replies.
- [PR] Update beam-master version to 20240524. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/24 14:23:08 UTC, 5 replies.
- [PR] 31112 drop flink 1.14 [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/24 14:33:57 UTC, 5 replies.
- [PR] Fix an incompatibility with hamcrest 2.2 [beam] - posted by "cushon (via GitHub)" <gi...@apache.org> on 2024/05/24 16:04:00 UTC, 2 replies.
- [PR] Add try-excepts around data sampler encoding [beam] - posted by "rohdesamuel (via GitHub)" <gi...@apache.org> on 2024/05/24 17:44:40 UTC, 5 replies.
- [I] [Bug]: error when trying to serialize headers with LongString [beam] - posted by "alexxfreitag (via GitHub)" <gi...@apache.org> on 2024/05/24 17:58:30 UTC, 0 replies.
- [PR] [ManagedIO] pass underlying transform URN to annotation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/24 18:34:04 UTC, 0 replies.
- Re: [PR] [ManagedIO] pass underlying transform URN as an annotation [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/05/24 20:52:08 UTC, 6 replies.
- [I] [Bug]: ReadFromKafka does not work without max_num_records parameter [beam] - posted by "gomerudo (via GitHub)" <gi...@apache.org> on 2024/05/24 21:05:11 UTC, 0 replies.
- [PR] Add Iceberg workflows [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/24 21:10:29 UTC, 2 replies.
- [I] Have java wrapper check and download released prism binary if available. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/24 22:14:23 UTC, 0 replies.
- [I] Have python wrapper check and download released prism binary if available. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/24 22:14:26 UTC, 0 replies.
- Re: [I] [Task] Publish Prism binary (os + architecture combos) artifacts on Beam Release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/24 22:27:09 UTC, 1 replies.
- Re: [PR] retry test_big_query_write_temp_table_append_schema_update up to 3 times [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/24 22:34:10 UTC, 2 replies.
- [PR] enable BigQueryIO read throttling detection for Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/24 22:49:30 UTC, 4 replies.
- [I] [Bug]: Parse YAML ExpansionService configs directly using SnakeYAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/25 01:43:00 UTC, 0 replies.
- [PR] Parse YAML ExpansionService configs directly using SnakeYAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/25 01:58:02 UTC, 10 replies.
- Re: [PR] add ExternalTransformProvider example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/25 12:40:19 UTC, 0 replies.
- Re: [PR] Revert #28614: Add UseDataStreamForBatch option to Flink runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/25 12:40:21 UTC, 1 replies.
- Re: [I] [Task]: Remove Flink 1.14 and cleanup [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/05/25 15:31:05 UTC, 0 replies.
- [PR] Changed the retry order for test_big_query_write_temp_table_append_schema_update [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/25 19:16:27 UTC, 4 replies.
- [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/26 09:33:28 UTC, 1 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/26 22:13:40 UTC, 0 replies.
- [PR] Improve javadoc in ParquetIO [beam] - posted by "fb64 (via GitHub)" <gi...@apache.org> on 2024/05/27 08:06:05 UTC, 1 replies.
- [PR] Add options to specify read and write http timeout for gcs as well as lower batching limit for rewrite operations which are copying. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/05/27 13:24:24 UTC, 3 replies.
- [I] [Bug]: SpannerIO creates "under the hood" new Pipeline optoins [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/05/27 15:10:30 UTC, 1 replies.
- Re: [PR] Add Histogram combiner [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2024/05/27 15:27:39 UTC, 1 replies.
- [PR] Remove pipeline options override from inside connector [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2024/05/27 16:32:35 UTC, 0 replies.
- Re: [PR] Remove pipeline options override from SpannerIO readChangeStream connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/27 17:34:20 UTC, 2 replies.
- [PR] Fix one small typo in build script. [beam] - posted by "VineetRamuk (via GitHub)" <gi...@apache.org> on 2024/05/27 17:49:31 UTC, 8 replies.
- [I] [Bug]: apache_beam.io.gcp.bigquery_tools.py uses logging.info instead of _LOGGER [beam] - posted by "tomaslink (via GitHub)" <gi...@apache.org> on 2024/05/27 19:07:39 UTC, 2 replies.
- [PR] Include Python 3.12 in release validation steps. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/27 22:50:54 UTC, 8 replies.
- [PR] Update Python version in the dev environment script. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/27 23:05:56 UTC, 2 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/27 23:57:20 UTC, 6 replies.
- [PR] retry test_big_query_legacy_sql [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/28 00:32:45 UTC, 3 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/28 00:48:00 UTC, 0 replies.
- Re: [I] [Bug]: Python BQ directrunner postcommits flake with KeyError: '__pyx_vtable__' [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/28 02:00:57 UTC, 0 replies.
- [I] [Bug]: Using string in PartitionColumn throws error, tries to convert it to string [beam] - posted by "ssaurav-redhat (via GitHub)" <gi...@apache.org> on 2024/05/28 10:54:19 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/05/28 12:41:21 UTC, 1 replies.
- [PR] Add SDK capability to detect if the SDK Fn Harness data channel is busy or not [beam] - posted by "priyansndesai (via GitHub)" <gi...@apache.org> on 2024/05/28 15:02:55 UTC, 23 replies.
- [I] [Failing Test]: Wordcounts in preCommitLegacyWorkerImpersonate portion of beam_PreCommit_Java_Examples_Dataflow are permared [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/28 17:16:54 UTC, 6 replies.
- [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] - posted by "clongnguyen6 (via GitHub)" <gi...@apache.org> on 2024/05/28 17:32:18 UTC, 3 replies.
- [PR] Revert "Clean up stale code in BigtableService" [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/28 17:51:53 UTC, 2 replies.
- Re: [PR] [#30083] Add processing time to prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/28 18:27:02 UTC, 0 replies.
- Re: [PR] [#30083] Add synthetic processing time to prism. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/28 18:30:09 UTC, 6 replies.
- [PR] Add trigger file paths to Iceberg integration and performance tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/28 20:14:48 UTC, 2 replies.
- [PR] pin the lower bound for typing-extensions [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/28 20:47:40 UTC, 6 replies.
- [PR] Add pull_request_target event to Iceberg tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/28 21:11:40 UTC, 2 replies.
- [PR] [YAML] Fix simple YAML mappings type hinting [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/05/28 21:29:03 UTC, 7 replies.
- Re: [PR] Add in redistribute option for Kafka Read [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/05/28 21:33:43 UTC, 10 replies.
- [PR] Add test of Select type inference. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/28 22:12:08 UTC, 2 replies.
- [PR] Remove bad dialect option. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/28 22:18:36 UTC, 4 replies.
- [I] [Feature Request]: Update Java ExpansionService container to support upgrading schema-transforms [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/28 22:32:30 UTC, 2 replies.
- Re: [PR] enable BigQueryIO Storage Read throttling detection for Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/05/28 23:48:46 UTC, 1 replies.
- [I] [Feature Request]: Modernize content on supplying a pipeline as a package [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/29 00:10:27 UTC, 0 replies.
- [I] The PreCommit Java Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/29 00:48:07 UTC, 0 replies.
- [PR] [prism] Report prism changes. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/29 03:25:06 UTC, 4 replies.
- [I] [Bug]: Pub/Sub sources incompatible with Python MapToFields [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/05/29 04:03:43 UTC, 1 replies.
- [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/05/29 06:35:25 UTC, 1 replies.
- Re: [PR] SpannerIO: support max commit delay [beam] - posted by "kberezin-nshl (via GitHub)" <gi...@apache.org> on 2024/05/29 08:21:54 UTC, 8 replies.
- Re: [I] [Feature Request]: prBot should allow the author to request a new reviewer [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/05/29 08:56:57 UTC, 0 replies.
- [PR] Allow pr-bot to re-assign reviewers when stopped [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/05/29 12:24:12 UTC, 2 replies.
- [I] [Feature Request]: PrBot should have a workflow to re-assign reviewers if stopped [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2024/05/29 12:28:26 UTC, 0 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/05/29 12:38:30 UTC, 1 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/05/29 12:41:40 UTC, 0 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/05/29 12:41:41 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/05/29 12:41:44 UTC, 0 replies.
- [I] Triggers [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/05/29 12:57:35 UTC, 0 replies.
- [PR] Change configurations for stress tests. Fix BigQueryIOST [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2024/05/29 13:18:27 UTC, 2 replies.
- [I] [Feature Request]: Support Reading from Solace message broker [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/05/29 14:29:05 UTC, 3 replies.
- [I] [Feature Request]: Allow users to override retry policy when using gcsio to open files [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/29 16:18:08 UTC, 0 replies.
- [PR] Add SDK capability to detect if the SDK Fn Harness data channel is busy [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/29 16:37:52 UTC, 1 replies.
- [PR] Update bigquery.py [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/29 16:40:29 UTC, 0 replies.
- [PR] Update bigquery_tools.py [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/29 16:50:39 UTC, 2 replies.
- Re: [PR] Add SDK protocol to detect if the SDK Fn Harness data channel is busy [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/29 17:28:38 UTC, 0 replies.
- Re: [PR] Update bigquery.py documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/29 17:34:54 UTC, 4 replies.
- [I] [Bug]: Asynchronous callback FutureT is broken from beam 2.54.0 [beam] - posted by "amalrajsolomon (via GitHub)" <gi...@apache.org> on 2024/05/29 17:56:44 UTC, 0 replies.
- [PR] [YAML] mark Combine transform as stable [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/05/29 18:39:47 UTC, 3 replies.
- [PR] Cleanup TableRow of unknowns for good structs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/29 20:36:07 UTC, 2 replies.
- Re: [I] [Bug]: ClassCastException with REPEATED RECORD and STORAGE_WRITE_API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/29 20:49:08 UTC, 0 replies.
- Re: [I] [Bug]: Python 3.10 installing `apache-beam==2.43.0` with `multiprocess>=0.70.12` has incompatibility for `dill` [beam] - posted by "henrytomsf (via GitHub)" <gi...@apache.org> on 2024/05/29 21:01:50 UTC, 1 replies.
- [PR] Add docs for YAML AssertThat. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/29 22:08:09 UTC, 3 replies.
- [PR] Pass through docs (and configs) for SqlProviders. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/29 23:02:58 UTC, 6 replies.
- [PR] Plumb Redistribute Transform's AllowDuplicates Property to Job Definition [beam] - posted by "celeste-zeng (via GitHub)" <gi...@apache.org> on 2024/05/30 04:17:04 UTC, 4 replies.
- [PR] Updates Expansion Service Container to support upgrading using the schema-transform ID [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/05/30 04:23:00 UTC, 12 replies.
- Re: [I] [Bug]: Python JDBC IO Try To Connect RDB Before Deploying [beam] - posted by "mataralhawiti (via GitHub)" <gi...@apache.org> on 2024/05/30 09:52:45 UTC, 0 replies.
- [PR] fix playground scio issues [beam] - posted by "volatilemolotov (via GitHub)" <gi...@apache.org> on 2024/05/30 11:49:56 UTC, 0 replies.
- [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/05/30 12:44:52 UTC, 1 replies.
- [PR] Update JdbcIO.java [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/05/30 14:43:16 UTC, 1 replies.
- [PR] [YAML] Allow constants and simple comparisons in generic expressions. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/30 16:03:25 UTC, 3 replies.
- [I] [Bug]: TypeScript Unit Tests failing [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/30 16:53:54 UTC, 0 replies.
- [PR] Use bytes instead of mibs. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/30 17:50:08 UTC, 5 replies.
- [PR] Allow context managers to be used for setup/teardown. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/05/30 17:51:36 UTC, 2 replies.
- [PR] Slightly more informative message. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/05/30 18:45:16 UTC, 6 replies.
- [I] [Bug][Prism]: unsupported URN beam:transform:redistribute_(arbitrarily|bykey):v1:Redistribute.Redistribute* [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/30 20:32:58 UTC, 0 replies.
- Re: [I] [Feature Request]: In Python how to assign types to multi-output tags? [beam] - posted by "robmoore (via GitHub)" <gi...@apache.org> on 2024/05/30 22:54:38 UTC, 2 replies.
- [I] [Bug][Prism]: unsupported feature "WindowingStrategy.Trigger" set with value (never|always) [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/30 23:29:17 UTC, 0 replies.
- [I] [Bug][Prism]: unsupported feature "WindowStrategy.OutputTime" set with value (LATEST|EARLIEST)_IN_PANE [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/30 23:43:06 UTC, 0 replies.
- [I] [Bug][Prism]: unsupported feature "WindowStrategy.AllowedLateness" [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/05/30 23:59:28 UTC, 0 replies.
- Re: [I] [Feature Request]: Add examples for using metrics with Python to Beam Website [beam] - posted by "TrackAir (via GitHub)" <gi...@apache.org> on 2024/05/31 05:45:35 UTC, 0 replies.
- [PR] Updating Commons Compress to 1.26.2 [beam] - posted by "coheigea (via GitHub)" <gi...@apache.org> on 2024/05/31 06:55:47 UTC, 4 replies.
- [I] [Feature Request]: Add metric counting the number of bytes read/written from/to a GCS bucket [beam] - posted by "alxd112 (via GitHub)" <gi...@apache.org> on 2024/05/31 10:14:18 UTC, 1 replies.
- [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/05/31 10:21:14 UTC, 1 replies.
- [I] Auto Inference of JdbcIO#NumPartitions seems to be dead code. [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2024/05/31 11:17:46 UTC, 0 replies.
- Re: [I] [Feature Request]: Override retry policy when using gcsio to open files to write. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/31 14:12:16 UTC, 0 replies.
- [PR] Set retry policy to DEFAULT_RETRY when initializing BlobWriter. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/05/31 14:14:32 UTC, 9 replies.
- Re: [PR] Support unknown nested repeated STRUCTs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/31 14:18:57 UTC, 2 replies.
- [PR] Remove excess space from Programming Guide (typo fix) [beam] - posted by "vstollen (via GitHub)" <gi...@apache.org> on 2024/05/31 18:08:35 UTC, 1 replies.
- [PR] Simplify Managed API to avoid dealing with PCollectionRowTuple [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/31 22:34:24 UTC, 2 replies.
- [PR] Enable KafkaIO Java integration tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/05/31 23:57:28 UTC, 0 replies.