github@beam.apache.org, 2024-01

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

- Re: [PR] [Security] Bump ActiveMQ version due to CVE-2023-46604 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/01 12:40:26 UTC, 2 replies.
- Re: [PR] Upgrade Beam to Cython 3.0.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/01 12:40:29 UTC, 2 replies.
- Re: [PR] Add support for tuple ClickHouse [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 01:18:15 UTC, 5 replies.
- [I] [Bug]: Flink Job manager metaspace classloader leak caused by not releasing PipelineOptionFactory DESERIALIZATION_CONTEXT [beam] - posted by "jinyangzhen (via GitHub)" <gi...@apache.org> on 2024/01/02 07:16:42 UTC, 2 replies.
- Re: [I] Mismatch in event publish_time [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/01/02 11:44:04 UTC, 0 replies.
- Re: [PR] Make Neo4JIO streamed (Fixes #29762) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/02 12:13:42 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.26.1 to 1.26.2 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/02 12:13:47 UTC, 1 replies.
- Re: [PR] Allow pulling default beam services from an environment variable. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/02 12:13:52 UTC, 1 replies.
- Re: [I] [Bug]: TextIO read record twice for large delimited files [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/02 14:00:23 UTC, 12 replies.
- Re: [PR] Add withAutosharding flag to textio transform [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/01/02 14:59:07 UTC, 28 replies.
- Re: [PR] Record mean for underflow/overflow values in HistogramData. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 15:20:59 UTC, 2 replies.
- Re: [PR] Support logical types with arguments in Python SDK [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/02 15:30:28 UTC, 24 replies.
- Re: [PR] Bump com.gradle.enterprise from 3.15.1 to 3.16 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 15:31:48 UTC, 0 replies.
- [PR] Revert "Bump com.gradle.enterprise from 3.15.1 to 3.16" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 15:32:39 UTC, 3 replies.
- Re: [I] [Bug]: Neo4JIO ReadAll memoizes full results [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 15:35:26 UTC, 0 replies.
- Re: [PR] Typescript SDK fixes [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/02 15:45:40 UTC, 1 replies.
- Re: [PR] Feature/bigtable error handling [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/02 16:04:51 UTC, 20 replies.
- [PR] Make cloudpickle as default pickler [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/02 17:00:32 UTC, 1 replies.
- Re: [I] [Bug]: Go SDK uses PTransform UniqueName as key instead of the global PID for a transform. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/02 18:06:20 UTC, 0 replies.
- Re: [PR] [#29848][Go SDK] Fix exec side transform identification. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/02 18:06:20 UTC, 0 replies.
- [PR] Add notebooks for text embeddings [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/02 18:12:47 UTC, 13 replies.
- [PR] Clean up java PreCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 18:20:13 UTC, 14 replies.
- Re: [PR] Clean up settings.kts [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 18:24:26 UTC, 2 replies.
- [I] [Bug]: Fix lints in timers.go [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/02 18:40:01 UTC, 2 replies.
- Re: [PR] [Blog Post] Scaling a Dataflow streaming workload [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/01/02 19:22:41 UTC, 5 replies.
- [PR] [#29895][Go SDK] Update timer test function names. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/02 19:27:06 UTC, 5 replies.
- Re: [I] Upgrade vendored beam-vendor-grpc-1_54_0 to eliminate vulnerability from shaded Netty [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 19:52:05 UTC, 4 replies.
- Re: [I] [Bug]: cloudpickle appears to incorrectly unpickle cloned combiners [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/02 19:54:36 UTC, 2 replies.
- [I] [Failing Test]: BeamFnDataInboundObserverTest flaky "Inbound observer closed" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/02 19:55:47 UTC, 0 replies.
- Re: [PR] Implementing lull reporting at bundle level processing [beam] - posted by "arvindram03 (via GitHub)" <gi...@apache.org> on 2024/01/02 21:06:46 UTC, 24 replies.
- Re: [I] [Bug]: SpannerIO.readChangeStream() stops forwarding change records and starts continuously throwing (large number) of Operation ongoing errors [beam] - posted by "anip-patel-exa (via GitHub)" <gi...@apache.org> on 2024/01/02 22:06:03 UTC, 1 replies.
- [PR] Proto changes for WASM-based DoFn execution [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/02 22:54:48 UTC, 0 replies.
- [PR] Add `svetakvsundhar` to Healthcare reviewer pool [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/03 00:00:43 UTC, 3 replies.
- [PR] [#29772][prism] Handle EventTime Timers. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/03 01:47:18 UTC, 22 replies.
- [PR] WIP: Go Expansion Service [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/03 01:53:17 UTC, 5 replies.
- [I] [Bug]: Messages are not ACK on Pubsub starting Beam 2.52.0 on Flink Runner in detached mode [beam] - posted by "gfalcone (via GitHub)" <gi...@apache.org> on 2024/01/03 08:42:08 UTC, 7 replies.
- Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] - posted by "tandelDipak (via GitHub)" <gi...@apache.org> on 2024/01/03 10:15:41 UTC, 0 replies.
- Re: [PR] Allows Java SDK to pass through external coders during proto translation without fully interpretting them [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:14:00 UTC, 10 replies.
- Re: [PR] Support key iteration in Python ULR. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:14:03 UTC, 1 replies.
- Re: [PR] Improve varint encoding throughput with unrolled loop [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:14:07 UTC, 12 replies.
- Re: [PR] added custom watermark for kinesis reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:14:09 UTC, 6 replies.
- Re: [PR] Comment trigger postcommit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:40:43 UTC, 1 replies.
- Re: [PR] [WIP] Add a De-ID transform for Dicom IO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 12:40:44 UTC, 2 replies.
- [PR] update node image to 18 and use slim [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/03 14:57:49 UTC, 0 replies.
- Re: [I] Failures in ULR execution of EntrySet for portable map side inputs [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/03 15:34:51 UTC, 0 replies.
- Re: [PR] Fix Reshuffle implementation in Java SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/03 15:41:26 UTC, 1 replies.
- [PR] update bq docs on stable schemas [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/03 15:43:16 UTC, 4 replies.
- Re: [PR] Worker message plumbing [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/03 15:52:01 UTC, 25 replies.
- [PR] fix indent [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/03 15:56:34 UTC, 0 replies.
- Re: [PR] fix indent in reviewers file [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/03 16:00:57 UTC, 0 replies.
- Re: [I] [Failing Test]: dataflow runner worker project test stuck causing Java PreCommit time out [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/03 16:06:28 UTC, 0 replies.
- Re: [PR] [Dataflow Streaming] Make SideInputCache bytes and expiry configurable [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/03 16:10:31 UTC, 3 replies.
- Re: [PR] Fix DaskRunner GBK by bumping `dask` lower bound [beam] - posted by "TheNeuralBit (via GitHub)" <gi...@apache.org> on 2024/01/03 17:46:25 UTC, 0 replies.
- Re: [PR] Knowledge lookup prompts: [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 18:35:11 UTC, 12 replies.
- [I] [Task]: Upgrade Parquet to 0.13.1 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/01/03 19:04:14 UTC, 0 replies.
- [PR] Switch to use self hosted runners for linux unit tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/03 20:34:02 UTC, 3 replies.
- [I] [Bug]: Direct Runner doesn't use coder registered in registry? [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/01/03 20:36:48 UTC, 4 replies.
- Re: [I] [Bug]: SparkRunner log plumbing for Python SDK not working properly [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/03 21:11:05 UTC, 0 replies.
- [PR] raise error if transforms are provided while read mode in MLTransform [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/03 21:41:09 UTC, 3 replies.
- Re: [PR] WIP Start Go RequestResponseIO implementation [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/03 22:14:14 UTC, 1 replies.
- [PR] Update MLTransform docs [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/03 22:22:17 UTC, 7 replies.
- Re: [PR] Windowing Support for the DaskRunner [beam] - posted by "cisaacstern (via GitHub)" <gi...@apache.org> on 2024/01/04 00:59:28 UTC, 2 replies.
- [PR] Beam wasm job execution [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/04 02:02:21 UTC, 1 replies.
- [I] [Bug]: floatValueExtractor judge float and double equality directly [beam] - posted by "gabrywu (via GitHub)" <gi...@apache.org> on 2024/01/04 03:46:40 UTC, 0 replies.
- [PR] Bump google.golang.org/protobuf from 1.31.0 to 1.32.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 04:29:54 UTC, 1 replies.
- [PR] Bump com.github.spotbugs.snom:spotbugs-gradle-plugin from 5.0.14 to 6.0.5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 04:50:55 UTC, 3 replies.
- Re: [PR] Bump com.github.spotbugs.snom:spotbugs-gradle-plugin from 5.0.14 to 6.0.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 04:51:00 UTC, 1 replies.
- Re: [I] Records including datetime to be saved as DATETIME or TIMESTAMP in BigQuery [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/01/04 10:09:19 UTC, 3 replies.
- Re: [I] [Bug]: Beam jars include many copied classes, break compilation of user code [beam] - posted by "honnix (via GitHub)" <gi...@apache.org> on 2024/01/04 12:09:41 UTC, 1 replies.
- Re: [PR] Use MillisInstant by default when Python JdbcIO is used [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 12:40:34 UTC, 1 replies.
- [I] [Feature Request]: Typescript async user functions [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/04 12:42:04 UTC, 0 replies.
- Re: [PR] feat: support clustering without partitioning [beam] - posted by "GStravinsky (via GitHub)" <gi...@apache.org> on 2024/01/04 12:57:22 UTC, 0 replies.
- Re: [PR] Fix: creating templates with the Typescript SDK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/04 14:55:58 UTC, 4 replies.
- [PR] [yaml] Replace pipeline_spec with yaml_pipeline in main.py [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/04 15:09:37 UTC, 3 replies.
- Re: [PR] [release] 2.53.0 Website Updates [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 15:38:43 UTC, 4 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 15:49:45 UTC, 3 replies.
- Re: [PR] [DO NOT MERGE] V2.53.0 rc2 validations [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 15:49:59 UTC, 0 replies.
- [I] TestStream [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/04 17:56:34 UTC, 0 replies.
- Re: [I] [Bug]: Typescript SDK dataflow classic template issues [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/04 18:09:16 UTC, 1 replies.
- [PR] Update finalize_release.yml [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 18:17:42 UTC, 2 replies.
- [PR] [release] Update Release Guide Instructions [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 18:40:30 UTC, 2 replies.
- [PR] [release] Add extra context for release branch cut action input [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 18:56:16 UTC, 2 replies.
- [PR] Update scaling-streaming-workload.md [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2024/01/04 19:44:03 UTC, 4 replies.
- [PR] Bump GCP Libraries BOM to v26.29.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 20:00:46 UTC, 6 replies.
- Re: [I] Make non-portable Splittable DoFn the only option when executing Java "Read" transforms [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/04 20:14:31 UTC, 0 replies.
- [PR] Upgrade version to 2.53.0 [beam-starter-java] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/04 20:30:03 UTC, 2 replies.
- Re: [I] [Bug]: Cannot use Json type with BigQueryIO and write method FILE_LOAD, avro [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/04 21:08:34 UTC, 2 replies.
- [PR] Allow JSON type in TableSchema for BigQuery FILE_LOAD [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/04 21:21:59 UTC, 16 replies.
- [PR] Merge runners-core-construction into sdks-java-core [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/04 21:26:36 UTC, 1 replies.
- [PR] [Typescript] allow Dofn to return promise [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/04 21:36:06 UTC, 7 replies.
- Re: [PR] Typescript Worker improvements [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 21:48:26 UTC, 0 replies.
- Re: [PR] [Typescript] SDK fixes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/04 22:02:57 UTC, 20 replies.
- Re: [PR] [Typescript] Worker improvements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/04 22:06:01 UTC, 13 replies.
- [I] [Bug]: FileIO: lack of timeouts may cause the pipeline to get stuck indefinitely [beam] - posted by "an2x (via GitHub)" <gi...@apache.org> on 2024/01/04 22:27:37 UTC, 1 replies.
- [I] [Bug]: Type specification for generate_user_type_from_bq_schema has not been updated after adding selected_fields [beam] - posted by "potiuk (via GitHub)" <gi...@apache.org> on 2024/01/04 22:40:40 UTC, 1 replies.
- [PR] [Typescript] creating dataflow job template fix [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/04 23:29:19 UTC, 11 replies.
- [PR] [Typescript] stop service when done [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/05 01:30:51 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 04:27:16 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 04:27:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.47.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 04:28:20 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.47.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 04:28:24 UTC, 1 replies.
- Re: [PR] Creating a Fully Managed Beam Streaming System with Flink Runner on Kubernetes - Part 3 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 12:13:47 UTC, 3 replies.
- Re: [PR] [YAML] - Kafka Proto String schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 12:13:49 UTC, 14 replies.
- Re: [PR] Generalize file based source output capabilities [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 12:13:51 UTC, 6 replies.
- [PR] Bump apache-beam from 2.52.0 to 2.53.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/05 12:39:39 UTC, 1 replies.
- [PR] Re-enable checker for files excluded to due bug (now fixed) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/05 15:37:00 UTC, 9 replies.
- [PR] Automatically format build.gradle throughout project [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/05 17:43:07 UTC, 2 replies.
- [PR] Install beam from pypi instead of github in mltransform notebooks [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/05 19:01:25 UTC, 2 replies.
- Re: [I] [Bug]: Coder cannot be resolved after `WithKeys.of().withKeyType()` for @DefaultSchema(JavaBeanSchema.class) types [beam] - posted by "mouyang (via GitHub)" <gi...@apache.org> on 2024/01/05 19:27:32 UTC, 0 replies.
- [PR] Remove TODO in the notebook [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/05 19:47:27 UTC, 3 replies.
- [PR] Update pmc finalization in release-guide.md [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/05 19:47:57 UTC, 3 replies.
- Re: [PR] [RRIO] Build RequestResponseIO and related dependency changes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/05 20:14:35 UTC, 6 replies.
- [PR] Preparing the data processing notebooks for import to devsite [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/01/05 21:08:38 UTC, 3 replies.
- [PR] Support DLQ in MLTransform [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/05 21:49:23 UTC, 10 replies.
- [I] [Feature Request]: Upgrade Beam Flink Runner to Flink 1.17 [beam] - posted by "karubian (via GitHub)" <gi...@apache.org> on 2024/01/05 22:32:26 UTC, 6 replies.
- [PR] Final edit on data preprocessing notebooks [beam] - posted by "rszper (via GitHub)" <gi...@apache.org> on 2024/01/06 00:40:48 UTC, 3 replies.
- [PR] Updated the doc with Security Fixes for 2.53.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/01/06 16:02:04 UTC, 3 replies.
- [PR] [Typescript] upgrade prettier [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/06 19:23:25 UTC, 3 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/01/06 22:13:53 UTC, 3 replies.
- [PR] [Typescript] no serialization Pardo [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/07 02:34:26 UTC, 7 replies.
- [PR] [Typescript] get main from command [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2024/01/07 10:58:39 UTC, 1 replies.
- Re: [I] [Task]: Enable to set timeout for Python TestPipeline [beam] - posted by "GautamGottipati (via GitHub)" <gi...@apache.org> on 2024/01/07 13:05:11 UTC, 0 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/01/07 22:14:12 UTC, 2 replies.
- [PR] Centralize exec stage urn string [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/01/08 02:37:03 UTC, 4 replies.
- [PR] Remove INFO from playground python logger [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/01/08 03:14:20 UTC, 5 replies.
- [PR] Bump com.github.spotbugs.snom:spotbugs-gradle-plugin from 5.0.14 to 6.0.6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/08 04:33:20 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.11 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/08 05:05:03 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.48.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/08 05:07:03 UTC, 3 replies.
- Re: [I] [Bug]: beam (even word count example) on flink ( session mode job submission in flink) results in memory leak when submitting job multiple times [beam] - posted by "jinyangzhen (via GitHub)" <gi...@apache.org> on 2024/01/08 08:08:03 UTC, 1 replies.
- Re: [PR] Yaml API: Day Zero tutorial notebook [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/01/08 09:23:31 UTC, 0 replies.
- [PR] fix memory leak caused by ThreadLocal in PipelineOptionFactory [beam] - posted by "jrthe42 (via GitHub)" <gi...@apache.org> on 2024/01/08 09:29:42 UTC, 7 replies.
- [PR] Upgrade Parquet to 0.13.1 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/01/08 15:32:58 UTC, 5 replies.
- Re: [PR] Generate external transform wrappers using a script [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/08 15:51:27 UTC, 19 replies.
- [PR] Vendor grpc 1.60.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/08 16:37:26 UTC, 10 replies.
- [I] [Feature Request]: Differentiate between batchSize and minBatchSize in JDBCIO Write [beam] - posted by "scott-strong (via GitHub)" <gi...@apache.org> on 2024/01/08 18:10:57 UTC, 0 replies.
- Re: [PR] [Python BQ] Retry get_table for quota errors [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/08 20:00:59 UTC, 7 replies.
- [PR] Increase granularity of DICOM IO Unit Tests [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/08 20:02:32 UTC, 6 replies.
- Re: [I] [Bug][prism]: Unregistered Go functions cause prism execution to hang sometimes. [beam] - posted by "ronoaldo (via GitHub)" <gi...@apache.org> on 2024/01/09 00:26:47 UTC, 4 replies.
- Re: [PR] WIP: Add DefaultProjectId, DefaultDatasetID and Parameters QueryOptions to go bigqueryio. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/09 12:41:46 UTC, 2 replies.
- Re: [PR] [TESTING] Update protobuf timestamp limit for protobuf 4.26 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/09 14:35:09 UTC, 4 replies.
- Re: [PR] [Python] Enrichment Transform v1 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/09 15:02:46 UTC, 6 replies.
- [PR] [IT] Pub/Sub RM should delete subscriptions that were created by Beam [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2024/01/09 15:11:50 UTC, 3 replies.
- [PR] [YAML] Better support for inline PyTransforms. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/09 15:48:43 UTC, 7 replies.
- Re: [I] [Task]: Clean up logger handling in Python's boot.go script [beam] - posted by "Anuragt1104 (via GitHub)" <gi...@apache.org> on 2024/01/09 17:01:36 UTC, 4 replies.
- [PR] Bump spotless gradle plugin to 6.23.3 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/09 17:29:30 UTC, 3 replies.
- Re: [PR] Bump org.checkerframework:checkerframework-gradle-plugin from 0.6.34 to 0.6.37 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/09 17:34:20 UTC, 0 replies.
- [PR] Downgrade artifact version in build_wheels [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/09 17:42:19 UTC, 4 replies.
- [PR] Upgrade checkerframeworkt to 3.42.0 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/09 17:51:51 UTC, 2 replies.
- [I] [Task]: Build with newer Java to keep up Gradle plugins and build health (still target Java 8 compatibility for released artifacts) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/09 17:53:24 UTC, 0 replies.
- Re: [I] [Task]: [RRIO] RequestResponseIO transform [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/09 18:19:28 UTC, 0 replies.
- Re: [I] [Failing Test]: rrio. CallTest. givenTeardownTimeout_throwsError flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/09 18:19:29 UTC, 0 replies.
- [PR] Heartbeats [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/01/09 19:22:38 UTC, 51 replies.
- [PR] Bump timeout to 120 minutes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/09 19:44:46 UTC, 3 replies.
- [PR] Bump runner v2 beam-master to 20240109 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/09 20:52:41 UTC, 3 replies.
- [I] [Bug]: Error: Error processing result file: CData section too big found, ... FROM EnricoMi/publish-unit-test-result-action [beam] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2024/01/09 22:01:56 UTC, 0 replies.
- [PR] DO NOT SUBMIT for testing [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/01/09 23:41:22 UTC, 1 replies.
- Re: [I] Dataflow GCS streaming file sink uses runner determined sharding [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/01/09 23:50:40 UTC, 1 replies.
- [PR] [prism] Return total element count to progress loop. Split less aggre… [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/10 00:33:54 UTC, 0 replies.
- [PR] [YAML] Add AssignTimestamps transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/10 01:25:17 UTC, 2 replies.
- [PR] Additional tests for windmill OrderedListState implementation. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/10 10:27:57 UTC, 3 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/01/10 12:41:23 UTC, 1 replies.
- Re: [PR] Add support for pandas 2.0 [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/10 14:42:27 UTC, 3 replies.
- [I] [Bug]: FixedWindows not working for large Kafka topic [beam] - posted by "oemergenc (via GitHub)" <gi...@apache.org> on 2024/01/10 15:17:17 UTC, 0 replies.
- [I] [Bug]: testHotKeyCombineWithSideInputs permared on Spark SparkStructuredStreaming runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/10 16:21:05 UTC, 2 replies.
- [I] [Failing Test]: testReshufflePreservesMetadata not working for some runners [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/10 16:22:27 UTC, 3 replies.
- Re: [I] [Failing Test]: PythonPostCommit is Extremely Flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/10 16:26:00 UTC, 2 replies.
- Re: [I] Support Pandas==2.x in Apache Beam. [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/10 16:51:21 UTC, 0 replies.
- [PR] Generate updated python dependencies(includes pandas 2.0) [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/10 17:29:31 UTC, 3 replies.
- [I] [Bug]: Python SchemaRegistry is not properly populated when calling `add` [beam] - posted by "mlhamel (via GitHub)" <gi...@apache.org> on 2024/01/10 21:19:00 UTC, 2 replies.
- [PR] [Do not merge] Test vendored grpc-1.60.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/10 21:41:42 UTC, 2 replies.
- [PR] Update python container tag(contains Pandas 2.0) [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/10 22:58:34 UTC, 4 replies.
- [PR] Add InferenceAPIEmbeddings to huggingface embeddings module [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/10 23:00:41 UTC, 4 replies.
- [PR] make getProcessingDistributionsForWorkId synchronized [beam] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/01/10 23:12:15 UTC, 7 replies.
- Re: [I] [Feature Request]: Allow merging consecutive external transforms in Java SDK [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/11 00:38:45 UTC, 0 replies.
- [PR] Bump actions/upload-artifact from 3 to 4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 04:11:37 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.53.1 to 1.55.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 04:34:15 UTC, 3 replies.
- Re: [PR] Bump cloud.google.com/go/spanner from 1.53.1 to 1.54.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 04:34:20 UTC, 1 replies.
- [I] Tutorials issue [beam] - posted by "prosaikrish (via GitHub)" <gi...@apache.org> on 2024/01/11 12:11:05 UTC, 0 replies.
- [PR] update CHANGES.md with error handling for fileIO and bigtableIO [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/11 15:11:40 UTC, 2 replies.
- [PR] fix: filter on 'public' schema [beam] - posted by "olavloite (via GitHub)" <gi...@apache.org> on 2024/01/11 15:51:24 UTC, 0 replies.
- [I] [Bug]: Cloud Spanner PostgreSQL databases could contain more schemas than currently assumed [beam] - posted by "olavloite (via GitHub)" <gi...@apache.org> on 2024/01/11 16:01:33 UTC, 1 replies.
- [PR] Update 02_io_pubsub.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/01/11 16:23:24 UTC, 3 replies.
- [I] [Bug]: potential race condition in Google Cloud Dataflow Runner throws exception [beam] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/01/11 16:39:52 UTC, 1 replies.
- [PR] add #29987 to 2.53 known issues in CHANGES.md [beam] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/01/11 16:53:53 UTC, 6 replies.
- Re: [PR] fix: Spanner PostgreSQL should filter on 'public' schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 17:06:11 UTC, 2 replies.
- [PR] [yaml] Revise yaml user label [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/11 17:54:09 UTC, 5 replies.
- [PR] Bump jinja2 from 2.11.3 to 3.1.3 in /.test-infra/jenkins/metrics_report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 17:54:57 UTC, 3 replies.
- [PR] Add a logging message when creating a file-based source. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/11 18:07:08 UTC, 5 replies.
- [PR] Add Java 17 to docker image for self-hosted runners [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/11 19:12:46 UTC, 25 replies.
- [PR] Revert #28614: Add UseDataStreamForBatch option to Flink runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/11 20:09:38 UTC, 4 replies.
- Re: [PR] Upgrade checkerframework to 3.42.0 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/11 20:25:57 UTC, 5 replies.
- [PR] sickbay new reshuffle test on runners that do not support it [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/11 20:29:25 UTC, 7 replies.
- [PR] Only auth and push on master branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/11 20:47:29 UTC, 3 replies.
- [PR] Try fix build runner image [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/11 20:59:37 UTC, 2 replies.
- Re: [I] [Bug][prism]: Excessive Splitting [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/11 23:24:40 UTC, 4 replies.
- Re: [PR] [#29180][prism] Return total element count to progress loop. Split less aggressively. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 23:34:28 UTC, 3 replies.
- [PR] Add a ReadFromTsv example. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/11 23:54:13 UTC, 3 replies.
- [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] - posted by "damnMeddlingKid (via GitHub)" <gi...@apache.org> on 2024/01/12 00:59:06 UTC, 0 replies.
- [PR] Update pytorch_inference.py [beam] - posted by "bfcrampton (via GitHub)" <gi...@apache.org> on 2024/01/12 01:08:48 UTC, 0 replies.
- Re: [PR] Add support for M1/M2 mac in PytorchModelHandlerTensor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/12 02:17:24 UTC, 6 replies.
- Re: [I] Unnesting with large schema causes error [beam] - posted by "Play-AV (via GitHub)" <gi...@apache.org> on 2024/01/12 04:51:16 UTC, 0 replies.
- [I] FlinkRunner - SEVERE: Failed to submit a listener notification task. Event loop shut down? [beam] - posted by "thailb-developer (via GitHub)" <gi...@apache.org> on 2024/01/12 10:39:36 UTC, 1 replies.
- Re: [I] [Bug]: Python WriteToBigtable get stuck for large jobs due to client dead lock [beam] - posted by "ee07dazn (via GitHub)" <gi...@apache.org> on 2024/01/12 14:17:23 UTC, 2 replies.
- [PR] Enrichment v1 bigtable [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/01/12 16:15:01 UTC, 3 replies.
- [PR] [YAML] Add MLTransform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/12 18:36:54 UTC, 3 replies.
- Re: [PR] [YAML] More complete schema validation. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/12 18:50:16 UTC, 0 replies.
- Re: [PR] Enrichment Transform with BigTable handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/12 18:50:41 UTC, 31 replies.
- [PR] [yaml] Add Beam YAML Examples and Getting started docs [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/12 19:36:52 UTC, 8 replies.
- [I] [Doc Bug]: `fileio.ReadAll()` on integration test [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/12 20:22:43 UTC, 3 replies.
- [PR] [YAML] Better logging. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/12 21:16:18 UTC, 7 replies.
- [PR] Change colab links [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/12 21:32:38 UTC, 2 replies.
- [PR] [YAML] Improve docs on create. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/12 22:25:12 UTC, 0 replies.
- [PR] Correct Examples of utilizing `UploadToDicomStore` [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/12 22:30:18 UTC, 3 replies.
- [I] [Bug]: WriteToFiles(output_fn=...) is seemingly unused [beam] - posted by "dlwh (via GitHub)" <gi...@apache.org> on 2024/01/12 22:41:56 UTC, 2 replies.
- [PR] test commit 1 [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/12 22:51:45 UTC, 1 replies.
- Re: [I] [Task]: Support embeddings using ML models in `MLTransform` [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/12 22:56:34 UTC, 0 replies.
- [PR] [Go SDK] Use distroless:debian12 (no-ssl) as base image. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/12 23:36:25 UTC, 1 replies.
- Re: [PR] [YAML] Several improvements to the documentation. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/12 23:52:24 UTC, 5 replies.
- [PR] Add a enum for the new value capture type NEW_ROW_AND_OLD_VALUES. Als… [beam] - posted by "ChangyuLi28 (via GitHub)" <gi...@apache.org> on 2024/01/13 00:42:54 UTC, 3 replies.
- [PR] [YAML] Support comment and delimiter attributes on CSV IO. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/13 00:55:07 UTC, 8 replies.
- [I] [Task]: Enable outputting scalars instead of numpy arrays using a parameter in MLTransform [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/13 01:17:53 UTC, 0 replies.
- Re: [I] [Task]: Create MLTransform notebooks for each transform [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/13 01:18:54 UTC, 0 replies.
- [PR] [Python BQ] Substitute final destination schema when no input schema is specified [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/13 15:36:14 UTC, 8 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 6.24.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/15 04:32:27 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 6.24.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/15 04:32:33 UTC, 3 replies.
- Re: [PR] Add a read timeout and cache BigQueryIOMetadata [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/15 09:58:14 UTC, 4 replies.
- [PR] Tw all ups [beam] - posted by "jesse-triplewhale (via GitHub)" <gi...@apache.org> on 2024/01/15 14:00:52 UTC, 1 replies.
- [I] [Bug]: AttributeError: 'UnionConstraint' object has no attribute 'inner_type'. Did you mean: 'inner_types'? [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/01/15 16:19:16 UTC, 1 replies.
- Re: [I] [Bug]: BigQuery streaming insert stuck for ~15 min in GceMetadataUtil.fetchMetadata [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/16 08:56:14 UTC, 0 replies.
- Re: [I] [Task]: Migrate Jenkins Workflows to Github Actions [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/16 09:33:45 UTC, 0 replies.
- Re: [I] [Task]: Build comment triggers replacement [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/16 09:33:58 UTC, 0 replies.
- Re: [I] [Task]: Create a GitHub Actions workflow for publishing nightly Beam snapshots [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/16 09:34:33 UTC, 0 replies.
- Re: [I] [Bug]: When using beam.io.kinesis.ReadDataFromKinesis, a java error is raised in DataFlowRunner [beam] - posted by "benvit92 (via GitHub)" <gi...@apache.org> on 2024/01/16 11:12:33 UTC, 1 replies.
- [I] [Bug]: typescript SDK - DirectRunner - readFromPubSub does not work [beam] - posted by "jesse-triplewhale (via GitHub)" <gi...@apache.org> on 2024/01/16 12:28:14 UTC, 3 replies.
- Re: [PR] Investigate python coverage issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/16 12:41:26 UTC, 1 replies.
- Re: [PR] Intentionally shut down worker-created grpc channels. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/16 12:41:28 UTC, 2 replies.
- Re: [PR] Added jacoco plugin to GitHub Actions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/16 12:41:31 UTC, 2 replies.
- Re: [PR] Initial Commit for AvroPayloadSerializer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/16 12:41:36 UTC, 0 replies.
- [PR] typo in docs [beam] - posted by "issacg (via GitHub)" <gi...@apache.org> on 2024/01/16 13:40:58 UTC, 3 replies.
- [PR] Update GKE autopilot terraform [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/16 17:57:18 UTC, 2 replies.
- [PR] split write rename and temp table deletion into to dofns with a shuffle [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/16 17:59:29 UTC, 4 replies.
- [PR] [YAML] Add ability to specify JDBC type to read/write [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/16 20:25:19 UTC, 14 replies.
- Re: [I] [Feature Request]: [Dataflow Streaming] Make SideInputCache sizes configurable [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/01/16 20:37:22 UTC, 1 replies.
- Re: [PR] [YAML] add js2py to apache_beam[yaml] [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/17 00:28:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/17 04:40:00 UTC, 3 replies.
- [PR] Fix an edge case of getting duplicated records when using TextIO. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/17 04:47:10 UTC, 5 replies.
- Re: [I] [Bug]: Cannot read partitions metadata table from bigquery [beam] - posted by "ding-qin (via GitHub)" <gi...@apache.org> on 2024/01/17 05:46:53 UTC, 0 replies.
- Re: [PR] Delete directories and objects instead of only objects for a given path [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/17 12:41:32 UTC, 0 replies.
- Re: [PR] Test matching on file names with wildcards in LocalFileSystem [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/17 12:41:34 UTC, 2 replies.
- Re: [PR] [Test only][Do not merge] Draft PR for testing remote runs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/17 12:41:43 UTC, 1 replies.
- [PR] Update `google_api_services_healthcare` [01/24] [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/17 14:07:08 UTC, 4 replies.
- [PR] Update to libraries-bom 26.30.0 [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/01/17 18:32:23 UTC, 4 replies.
- Re: [I] [Task]: Update the minor version of protobuf library in the upper bound prior to Beam release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/17 21:19:41 UTC, 0 replies.
- Re: [I] [Task]: Update the minor version of cloudpickle library prior to Beam release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/17 21:21:00 UTC, 0 replies.
- Re: [I] [Task]: Update the minor version of google-cloud-storage library prior to Beam release. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/17 21:22:33 UTC, 11 replies.
- Re: [I] [Bug]: Usage of logical types breaks Beam YAML Sql [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/17 21:25:43 UTC, 2 replies.
- Re: [I] [Bug]: Go SDK Dataflow jobs fail on DataSampling disabled [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/17 21:26:24 UTC, 0 replies.
- [PR] Remove extraneous dependency from runners-core-java [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/17 22:20:25 UTC, 1 replies.
- [PR] Exclude newly added failing validation runner tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/17 23:24:51 UTC, 5 replies.
- Re: [I] Key only reads from Google Datastore [beam] - posted by "sosimon (via GitHub)" <gi...@apache.org> on 2024/01/18 00:15:17 UTC, 0 replies.
- [I] [Bug]: BigQuery transforms cannot be upgraded from 2.53.0 to 2.54.0 due to a schema field change [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/18 01:55:24 UTC, 1 replies.
- [PR] Fixes an upgrade compatibility breakage for the BQ write transform [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/18 02:09:51 UTC, 10 replies.
- [PR] Bump actions/cache from 3 to 4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/18 04:33:12 UTC, 4 replies.
- Re: [I] [Feature Request]: Allow a flag so that "with pipeline" will not wait_until_finish so that this paradigm can be used for streaming jobs [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/01/18 13:25:40 UTC, 3 replies.
- [PR] Use official jamm [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/18 16:02:40 UTC, 9 replies.
- [PR] [YAML] add time unit suffix to windowing [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/18 17:06:32 UTC, 13 replies.
- [I] [Bug]: ElasticsearchIO should use RetryPolicy in case of connectivity issues [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2024/01/18 17:23:29 UTC, 1 replies.
- [I] [Feature Request]: Modify ParquetIO.Read/Parse(Files) to use additional outputs pattern with a deadletter PCollection [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/18 17:30:58 UTC, 0 replies.
- [I] [Bug]: Fix ParquetIO.Read/Parse(Files) where ParquetFileReader has row groups of zero rows [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/18 17:39:32 UTC, 0 replies.
- [PR] Fix BigtableConfigTranslator [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/01/18 17:39:52 UTC, 5 replies.
- [I] [Bug]: Dataflow throw "java.lang.NoClassDefFoundError: org/apache/beam/vendor/grpc/v1p54p0/io/grpc/Channel" [beam] - posted by "yasser-chihab (via GitHub)" <gi...@apache.org> on 2024/01/18 18:19:39 UTC, 0 replies.
- [PR] Time at max threads fix [beam] - posted by "edman124 (via GitHub)" <gi...@apache.org> on 2024/01/18 20:10:52 UTC, 4 replies.
- [I] [Bug]: Dataflow runner should avoid starting and stop active processing of work that will not commit successfully [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/18 21:31:52 UTC, 2 replies.
- [PR] [YAML] add ability to set logging level [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/18 21:56:06 UTC, 3 replies.
- [PR] [YAML] add required parameters and required windowing to providers [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/18 23:43:18 UTC, 4 replies.
- [PR] Support dynamic destinations with Python Storage API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/19 01:38:01 UTC, 17 replies.
- [PR] Update windmill proto definition [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/01/19 02:30:53 UTC, 9 replies.
- Re: [I] OrderedListState [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/01/19 03:59:00 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.13 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/19 04:21:24 UTC, 3 replies.
- [PR] Add support for current active work budget. [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2024/01/19 04:25:05 UTC, 11 replies.
- [PR] Undeprecate reshuffle [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/19 16:11:09 UTC, 3 replies.
- [I] [Bug]: FlinkRunner: KafkaIO emits MAX_WATEMARK [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/19 17:11:14 UTC, 5 replies.
- [PR] Fix buildx always been true [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/19 17:21:19 UTC, 9 replies.
- [PR] Add logging to help understand errors from #28131. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/19 17:45:05 UTC, 2 replies.
- [I] [Bug]: Unable to use @FieldAccess in DoFn for fetching Nullable Schema Fields [beam] - posted by "R1421 (via GitHub)" <gi...@apache.org> on 2024/01/19 18:19:07 UTC, 0 replies.
- [I] [Bug]: JMSIO drops messages when autoscaling down. [beam] - posted by "jlampek (via GitHub)" <gi...@apache.org> on 2024/01/19 19:05:52 UTC, 0 replies.
- [PR] [YAML] Allow windowing to be done in Java or Python. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/19 19:57:06 UTC, 6 replies.
- [I] [Failing Test]: GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer stuck [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/19 20:06:33 UTC, 0 replies.
- [PR] [YAML] Expose flatten implementation from Java. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/19 20:38:26 UTC, 9 replies.
- [I] [Bug]: BigQueryIO Write does not work using Storage_write_api on DataflowRunner with unbounded data and autosharding [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/20 00:14:52 UTC, 0 replies.
- [PR] [YAML] Require numStreams for unbounded BigQueryStorageWriteApiSchemaTransform xlang transform [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/20 01:25:53 UTC, 4 replies.
- [I] [Feature Request]: Automatically enable Dataflow Runner v2 for pipelines that use the transform upgrade feature [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/20 02:11:11 UTC, 1 replies.
- [PR] Automatically enable Dataflow Runner v2 for pipeliens that use the transform upgrade feature [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/01/20 02:15:53 UTC, 3 replies.
- Re: [PR] Bugfix/update avro version [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/20 12:40:06 UTC, 0 replies.
- [I] [Bug]: MLTransform read_artifact_location does only accept local paths [beam] - posted by "LaurenzReitsam (via GitHub)" <gi...@apache.org> on 2024/01/20 17:28:42 UTC, 6 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/20 22:12:54 UTC, 0 replies.
- [PR] Address Feedback from Beam Website Feedback Form. [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/22 00:06:09 UTC, 3 replies.
- Re: [I] [Failing Test]: Python Github actions tests are failing due to update of pip [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/22 14:23:34 UTC, 1 replies.
- Re: [I] [Feature Request]: In Python how to assign types to multi-output tags? [beam] - posted by "lazarillo (via GitHub)" <gi...@apache.org> on 2024/01/22 14:50:35 UTC, 1 replies.
- [PR] Fix https://github.com/apache/beam/actions/workflows/beam_PostCommit_XVR_GoUsingJava_Dataflow.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/22 15:07:53 UTC, 1 replies.
- [PR] [runner-flink] Fix watermark generation for empty UnboundedSource [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/22 16:36:16 UTC, 0 replies.
- Re: [PR] [flink] Fix watermark generation for empty UnboundedSource [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/22 16:37:54 UTC, 9 replies.
- [PR] Fix BigQuerySinkMetrics constants and increment metrics in more places. [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/22 18:43:06 UTC, 3 replies.
- [PR] Add more descriptive resource hint failure message [beam] - posted by "tadeegan (via GitHub)" <gi...@apache.org> on 2024/01/22 20:00:54 UTC, 3 replies.
- [PR] Use vendored grpc 1.60.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/22 21:22:34 UTC, 6 replies.
- [PR] add remaining metrics [beam] - posted by "edman124 (via GitHub)" <gi...@apache.org> on 2024/01/22 21:33:32 UTC, 3 replies.
- [PR] Bump pillow from 10.0.1 to 10.2.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/22 22:02:23 UTC, 2 replies.
- [PR] [#29917][prism] Initial TestStream support [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/22 22:05:44 UTC, 2 replies.
- [PR] Fix Dicom IO Integration Tests [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/22 23:24:13 UTC, 11 replies.
- [PR] Periodically send perworkermetric updates on the WorkerMessages api. [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/22 23:55:44 UTC, 1 replies.
- [PR] Fix Cassandra Test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/23 00:02:27 UTC, 3 replies.
- Re: [I] [Bug]: beam-sdks-java-io-kafka:2.52.0 - Causes SLF4J Failure : Error loading StaticLoggerBinder: org.slf4j.impl.StaticLoggerBinder [beam] - posted by "hekk-kazuki-hasegawa (via GitHub)" <gi...@apache.org> on 2024/01/23 01:02:58 UTC, 1 replies.
- [PR] Bump pillow from 9.2.0 to 10.2.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/23 02:11:35 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.14 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/23 04:46:00 UTC, 3 replies.
- Re: [I] GCP DataFlow not cleaning up GCP BigQuery temporary datasets [beam] - posted by "akshatmahesh0110 (via GitHub)" <gi...@apache.org> on 2024/01/23 05:10:47 UTC, 0 replies.
- [I] [Bug]: PubsubIO.readMessagesWithAttributesAndMessageIdAndOrderingKey is not working with Direct and Dataflow Runner [2.53.0] [beam] - posted by "nrj179 (via GitHub)" <gi...@apache.org> on 2024/01/23 08:30:24 UTC, 2 replies.
- [PR] fix for #30078 [PubsubIO.readMessagesWithAttributesAndMessageIdAndOrderingKey not working] [beam] - posted by "nrj179 (via GitHub)" <gi...@apache.org> on 2024/01/23 09:55:16 UTC, 2 replies.
- [I] How to Convert the data fetched from Query to a Pandas Dataframe? [beam] - posted by "Keerthesre1 (via GitHub)" <gi...@apache.org> on 2024/01/23 10:11:58 UTC, 0 replies.
- Re: [I] BigqueryIO.Write should support clustering without partitioning [beam] - posted by "GStravinsky (via GitHub)" <gi...@apache.org> on 2024/01/23 15:35:17 UTC, 0 replies.
- [PR] Feature/add error handling for bqio [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/23 16:22:12 UTC, 1 replies.
- [PR] Use FileSystems.exist to check the remote the path [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/23 16:25:09 UTC, 4 replies.
- [I] Advance Processing Time handling [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/23 18:08:18 UTC, 0 replies.
- Re: [I] [prism] Timer Handling (Event Time) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/23 18:11:24 UTC, 1 replies.
- [PR] Add converter class to convert metrics to PerStepNamespaceMetrics [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/23 18:44:07 UTC, 6 replies.
- [PR] [MLTransform]Throw a warning when specifiend columns are not present in the input data [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/23 19:19:11 UTC, 0 replies.
- Re: [PR] [yaml] Add generic expression to filter [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/23 19:25:35 UTC, 3 replies.
- Re: [I] [prism] TestStream support (Elements + Watermarks) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/23 20:14:27 UTC, 0 replies.
- Re: [PR] [MLTransform]Throw an error when specifiend columns are not present in the input data [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/23 20:34:46 UTC, 6 replies.
- [PR] [YAML] Use default logging level for main.py [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/23 21:36:25 UTC, 3 replies.
- [PR] [Python] Retain timestamp returned from the BigTable row [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/01/23 21:46:23 UTC, 7 replies.
- [PR] Add StreamingStepMetricsContainer::extractPerWorkerMetrics method. [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/23 22:01:32 UTC, 12 replies.
- [PR] Update container build version to Go 1.21.6 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/24 00:24:23 UTC, 3 replies.
- Re: [I] [Feature Request]: Upgrade or provide ETA on dill [beam] - posted by "siddharthab (via GitHub)" <gi...@apache.org> on 2024/01/24 03:36:09 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 6.25.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/24 05:04:46 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 6.25.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/24 05:05:01 UTC, 3 replies.
- [PR] Bump com.github.spotbugs.snom:spotbugs-gradle-plugin from 5.0.14 to 6.0.7 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/24 05:05:10 UTC, 3 replies.
- [PR] Decoupple [beam] - posted by "GStravinsky (via GitHub)" <gi...@apache.org> on 2024/01/24 08:31:02 UTC, 0 replies.
- Re: [PR] BigQuery: Decouple clustering from time partitioning when writing [beam] - posted by "GStravinsky (via GitHub)" <gi...@apache.org> on 2024/01/24 09:58:59 UTC, 6 replies.
- [I] [Bug]: Python PostCommit test suite is failing for BigQueryIO read tests [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/01/24 14:14:08 UTC, 8 replies.
- Re: [I] [Task]: Upgrade bigdataoss version without breaking use_grpc_for_gcs experiment [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/24 14:36:08 UTC, 1 replies.
- Re: [I] (Java BigQueryIO) Copy job and temp table deletion occurs in the same DoFn, making the operation vulnerable during retries [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/01/24 15:47:48 UTC, 1 replies.
- Re: [PR] [Python] Add an option to retain timestamp returned from the BigTable row [beam] - posted by "riteshghorse (via GitHub)" <gi...@apache.org> on 2024/01/24 16:40:30 UTC, 4 replies.
- [PR] Ignore DicomMetadataRead tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/24 16:45:01 UTC, 4 replies.
- [PR] Remove/Reserve PerStepNamespaceMetrics fields from GlobalGetDataRequest [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/24 18:05:00 UTC, 0 replies.
- Re: [I] Timers exception on "Job Drain" while using stateful beam processing in global window [beam] - posted by "anip-patel-exa (via GitHub)" <gi...@apache.org> on 2024/01/24 18:43:05 UTC, 0 replies.
- [I] [Feature Request]: Upgrade numpy version bound in Python SDK [beam] - posted by "siddharthab (via GitHub)" <gi...@apache.org> on 2024/01/24 19:09:23 UTC, 2 replies.
- [PR] Fix failing python BQ test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/24 19:54:31 UTC, 5 replies.
- [PR] [WIP] Fix DicomIO Integration Test Failure on Dataflow Runner V2. [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/24 21:08:43 UTC, 2 replies.
- [PR] [Post Release Cut] CHANGES.md - Add section for 2.55.0, cleanup 2.54.0 due to cut. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/24 22:42:39 UTC, 2 replies.
- [PR] Rename ExternalSchemaTransform to ExternalTransform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/24 22:50:17 UTC, 2 replies.
- [PR] Don't run DicomIO Integration Tests on GCP DF Runner [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/01/24 22:51:03 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.13.8 to 1.15.15 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/25 04:14:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.42.2 to 1.48.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/25 04:16:52 UTC, 1 replies.
- Re: [I] [Bug]: [Go SDK] Memory seems to be leaking on 2.49.0 with Dataflow [beam] - posted by "boolangery (via GitHub)" <gi...@apache.org> on 2024/01/25 10:19:24 UTC, 7 replies.
- [I] [Task]: Implement load and stress tests for streaming cases [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/25 10:24:55 UTC, 1 replies.
- [I] [Task]: Author new knowledge lookup prompts for DuetAI [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/25 10:30:57 UTC, 0 replies.
- [I] [Task]: Develop a reporting mechanism to notify about flaky test cases [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/25 10:53:33 UTC, 1 replies.
- [I] [Task]: Improve Beam code coverage analysis [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/25 11:45:21 UTC, 0 replies.
- [I] [Task]: Create a workflow to run Nightly Playground examples CI checks [beam] - posted by "andreydevyatkin (via GitHub)" <gi...@apache.org> on 2024/01/25 11:49:27 UTC, 0 replies.
- Re: [I] [Bug]: OnTimer("loopingTimer") not triggered on 2.52.0 [beam] - posted by "sigalite (via GitHub)" <gi...@apache.org> on 2024/01/25 13:35:30 UTC, 0 replies.
- [I] [Task]: Clean up remaining Jenkins resources [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/25 14:28:53 UTC, 0 replies.
- [PR] Decommission all remaining jenkins jobs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/25 14:30:06 UTC, 3 replies.
- [PR] Cherry pick ExternalTransform rename (#30102) [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/25 15:44:13 UTC, 2 replies.
- [PR] [Proposal] Improve DisplayData support in PTransform API [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/01/25 17:54:18 UTC, 5 replies.
- [PR] Cherry pick fix for Python postcommits [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/25 19:05:50 UTC, 3 replies.
- [PR] [YAML] Add support for callable kwargs for Combine, PyTransform and custom providers [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/01/25 20:56:20 UTC, 1 replies.
- Re: [PR] [YAML] Add support for callable kwargs for Combine, PyTransform and custom python transform providers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/25 20:57:45 UTC, 10 replies.
- [PR] Don't use '-' as a delimiter in BigQuerySinkMetrics [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/25 23:01:03 UTC, 5 replies.
- Re: [PR] [#28142][Go SDK] Evict closed readers from the cache. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/26 00:19:17 UTC, 1 replies.
- Re: [PR] [Go SDK] Don't depend on the go 1.21 standard lib yet [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/26 00:43:48 UTC, 0 replies.
- [PR] Side Input Prompt for Duet AI [beam] - posted by "olehborysevych (via GitHub)" <gi...@apache.org> on 2024/01/26 00:44:39 UTC, 1 replies.
- [PR] Don't depend on the go 1.21 standard lib yet [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/26 00:46:23 UTC, 1 replies.
- [PR] [RRIO] [Throttle] transform that slows down element transmission without an external resource [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/26 03:04:10 UTC, 5 replies.
- [PR] Bump Dataflow dev container version [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 04:02:33 UTC, 4 replies.
- [I] [Task]: Add a default watermark emit interval to FlinkUnboundedSourceReaeder [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/26 14:30:45 UTC, 2 replies.
- [PR] Update update_python_dependencies.yml with all python versions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/26 15:11:16 UTC, 3 replies.
- [PR] Check the issue number type [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/01/26 15:13:27 UTC, 1 replies.
- Re: [PR] Per DoFn latency instrumentation [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 15:14:14 UTC, 0 replies.
- [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1706284351 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/26 15:52:36 UTC, 2 replies.
- [PR] [YAML] - PubSubLite proto [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/01/26 16:14:54 UTC, 7 replies.
- [PR] Update project root documentations reflecting Jenkins shutdown [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 17:25:09 UTC, 3 replies.
- Re: [PR] Upgrade numpy dependency [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/26 17:25:53 UTC, 3 replies.
- [I] [Feature Request]: Expose GroupIntoBatches Parameters for WriteFiles Autosharding transform [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/01/26 18:02:17 UTC, 0 replies.
- Re: [PR] Roll forward "Read API Source v2 (#25392)" fix data loss [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 18:22:47 UTC, 1 replies.
- [PR] Fix clean up stale container workflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 18:27:08 UTC, 10 replies.
- [PR] [Cherry Pick #30119] [Go SDK] Evict closed readers from the cache. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/26 19:02:48 UTC, 3 replies.
- Re: [I] [Task]: fix the javadoc which indicate that fileload doesnt support json type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/26 19:39:08 UTC, 0 replies.
- Re: [I] There should be single source of truth for the project version [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/01/26 19:57:39 UTC, 1 replies.
- [PR] Respect gcloud active configuration, if any, rather than always using default. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/26 20:14:24 UTC, 6 replies.
- [PR] Periodically send perWorkerMetrics on the WorkerMessages API [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2024/01/26 21:31:06 UTC, 3 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/26 22:12:29 UTC, 0 replies.
- [PR] Fix a misspelling [beam] - posted by "chrismgrayftsinc (via GitHub)" <gi...@apache.org> on 2024/01/26 23:11:12 UTC, 3 replies.
- [PR] [Testing]Add InferenceAPIEmbeddings to huggingface [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/27 04:52:59 UTC, 1 replies.
- Re: [PR] check for cachetoken representing a retry before activating and completing work [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/27 12:37:36 UTC, 1 replies.
- [I] [Task]: [flink] EncodedValueComparator can use deserialzed bytes for deterministic Coders [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/27 12:55:07 UTC, 2 replies.
- Re: [PR] Upgrade flink to 1.17 [beam] - posted by "tandelDipak (via GitHub)" <gi...@apache.org> on 2024/01/27 16:26:45 UTC, 0 replies.
- [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1706401804 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/28 00:30:09 UTC, 2 replies.
- Re: [PR] Interpolate console URL properly in error case [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/28 12:38:01 UTC, 0 replies.
- [PR] Adding a default watermark emit interval for FlinkUnboundedSourceReader [beam] - posted by "hardshah (via GitHub)" <gi...@apache.org> on 2024/01/29 00:19:03 UTC, 4 replies.
- [PR] Bump com.gradle.enterprise from 3.15.1 to 3.16.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/29 05:00:16 UTC, 1 replies.
- Re: [PR] Bump com.gradle.enterprise from 3.16 to 3.16.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/29 05:00:20 UTC, 1 replies.
- Re: [PR] [TESTPR] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/29 12:39:18 UTC, 0 replies.
- Re: [PR] Generating Unique ID within function so that it's unique for every run. [beam] - posted by "DerRidda (via GitHub)" <gi...@apache.org> on 2024/01/29 14:51:13 UTC, 0 replies.
- [PR] Add info on getting started contributing [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/29 18:03:15 UTC, 3 replies.
- Re: [PR] Add InferenceAPIEmbeddings to huggingface [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/29 18:25:25 UTC, 7 replies.
- Re: [PR] make getProcessingDistributionsForWorkId threadsafe [beam] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/01/29 18:33:06 UTC, 1 replies.
- [PR] [Cherry Pick #29979] Fix race condition in Dataflow sampler. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/29 19:15:35 UTC, 4 replies.
- Re: [I] [Feature Request]: External transforms should be able to ignore optional params of unknown type. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/29 19:28:10 UTC, 0 replies.
- [I] [Task]: Improve project documentation on apache-beam pypi page. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/29 20:03:15 UTC, 0 replies.
- [PR] Remove CoGBK in MLTransform's TFTProcessHandler [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/29 21:07:11 UTC, 8 replies.
- [PR] fix: fix error handling in segment reader and add an integration test [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/01/29 22:40:17 UTC, 10 replies.
- [PR] Volatile heartbeat [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/01/29 22:59:04 UTC, 2 replies.
- [PR] Update environments.md [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/29 23:30:43 UTC, 2 replies.
- [PR] Instrument SDK container launcher to start SDK harness with memray profiler. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/29 23:40:37 UTC, 1 replies.
- [PR] Instrument SDK container launcher to start SDK harness with memray profiler. #30150 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/30 00:00:01 UTC, 0 replies.
- Re: [PR] Instrument SDK container launcher to start SDK harness with memray profiler [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/01/30 00:00:15 UTC, 0 replies.
- Re: [I] [Bug]: Change reflection-based schema generation to generate deterministic schemas [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/01/30 13:33:41 UTC, 0 replies.
- [I] [Bug]: [beam] - posted by "ton3r (via GitHub)" <gi...@apache.org> on 2024/01/30 14:23:21 UTC, 0 replies.
- [PR] Allow stale_bq_datasets_cleaner.sh to run to completion, even when there are failures [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/01/30 14:53:00 UTC, 0 replies.
- Re: [PR] MlTransform notebooks [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/30 16:19:19 UTC, 0 replies.
- [PR] Fix Dataproc cleanup race condition [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/30 16:56:42 UTC, 3 replies.
- [I] [Task]: Add drain method to Job Management proto [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/01/30 19:06:12 UTC, 0 replies.
- Re: [PR] [sdks-java-core] Test for Reiterator outside loop in CoGbkResult [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/01/31 09:03:40 UTC, 0 replies.
- Re: [PR] [WIP] Flink unified translation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/31 12:39:13 UTC, 0 replies.
- Re: [PR] Add Drain to Job Management proto [beam] - posted by "randymaldonado (via GitHub)" <gi...@apache.org> on 2024/01/31 13:29:43 UTC, 0 replies.
- Re: [PR] Make ReadFromBigQueryRequest id more randomized [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/01/31 15:47:02 UTC, 3 replies.
- [PR] Add retry to VertexAI embeddings call [beam] - posted by "AnandInguva (via GitHub)" <gi...@apache.org> on 2024/01/31 16:42:59 UTC, 4 replies.
- [I] [Bug]: Need to update outdated node before website tools break. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/31 17:19:09 UTC, 0 replies.
- Re: [I] [Failing Test]: PostCommit Python Xlang Gcp Direct and Dataflow failing due to #30059 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/31 17:31:31 UTC, 0 replies.
- [I] [Bug]: GCSIO `delete_batch` breaks dataflow pipeline in 2.53 [beam] - posted by "lgeiger (via GitHub)" <gi...@apache.org> on 2024/01/31 18:06:01 UTC, 1 replies.
- [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] - posted by "ianb-pomelo (via GitHub)" <gi...@apache.org> on 2024/01/31 18:28:18 UTC, 0 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.16.13 to 1.16.16 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/01/31 18:36:15 UTC, 0 replies.
- [PR] Fix stale dataflow prebuilt image cleaner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/31 18:43:27 UTC, 2 replies.
- Re: [PR] Fix Fhir IO Search IT [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/31 19:26:28 UTC, 1 replies.
- [I] Merge runners-core-construction into core Java SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/31 19:47:44 UTC, 0 replies.
- [PR] Move the code from sdks-java-fn-execution to sdks-java-core [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/01/31 19:52:15 UTC, 3 replies.
- [PR] Fix git trusted directory errors in website build. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/01/31 20:22:02 UTC, 2 replies.
- [PR] Clean up stale code in BigtableService [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2024/01/31 20:38:10 UTC, 1 replies.
- [I] [Bug]: Test cntainer leak [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/01/31 21:00:39 UTC, 0 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/31 22:13:36 UTC, 0 replies.
- [PR] Bump github.com/opencontainers/runc from 1.1.5 to 1.1.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/01/31 22:55:52 UTC, 2 replies.
- [PR] Fix script typos for validating docker licenses. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/01/31 23:16:50 UTC, 0 replies.
- [I] [Bug]: BigQuery streaming throwing OutOfRangeException [beam] - posted by "nukemichaels (via GitHub)" <gi...@apache.org> on 2024/01/31 23:17:37 UTC, 0 replies.