beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
### What happened? See e.g. https://ge.apache.org/s/fqs6k37b63yko/tests/task/:runners:spark:3:job-server:validatesPortableRunnerStreaming/details/org.apache.beam.sdk.transforms.RedistributeTest?top-execution=1 There is no output from the test. ### Issue Priority Priority: 2 (default) ### Issue Components - [ ] Component: Python SDK - [...
### What needs to happen? A known issue in Pandas might affect Python 3.12 users: https://github.com/pandas-dev/pandas/issues/57500. Once a fix is released, we should upgrade. As part of the upgrade, we...
### What would you like to happen? As far as I can tell, there's no way to access the Pub/Sub message publish time / publish_time in [ReadFromPubSub](https://beam.apache.org/releases/yamldoc/current/#readfrompubsub) for the purposes...
**Please** add a meaningful description for your change here This PR addresses #33041, a blocker for Neo4jIO in the Neo4j Flex template. It fixes WriteUnwindWithResultsFn to emit Neo4jWriteStats, resolving compilation...
Addresses https://github.com/apache/beam/issues/19878 Added flag for overriding artifact hostname ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention...
**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...
### What would you like to happen? In Beam YAML, There have risk if the program always using the latest version of beam, I want to control by myself, are...
- Add docencoding UTF-8 option to Javadoc configuration in BeamModulePlugin - Replace U+2019 (RIGHT SINGLE QUOTATION MARK) with ASCII apostrophe in source files - Fixes rendering issue where Unicode apostrophes...
1. Adds ability to map BQ TIMESTAMP(12) columns to either Timestamp.MILLIS, Timestamp.MICROS, Timestamp.NANOS or string for picosecond precision. This is used in the direct read path where a user specifies...
Addresses #35637 Adds the following features: ## Modify a catalog's properties ```sql ALTER CATALOG my_catalog [ RESET ('prop1', 'prop2', ...) ] [ SET ('prop5'='val5', 'prop6'='val6', ...) ] ``` ## Modify...
