github@beam.apache.org, 2024-12

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

- Re: [PR] Fix java validatesdistrolesscontainer dataflow workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/01 06:36:39 UTC, 2 replies.
- Re: [I] Batch optimized translation for Spark Runner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/12/01 08:46:58 UTC, 1 replies.
- [I] [Task]: Investigate how to make large python_Combine_Flink_Streaming_2GB_Fanout*.txt working [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/01 18:16:18 UTC, 0 replies.
- [I] The PostCommit Java Hadoop Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 18:38:24 UTC, 1 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 18:38:25 UTC, 5 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 18:38:26 UTC, 3 replies.
- [I] The PreCommit Java HBase IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 21:33:56 UTC, 2 replies.
- Re: [PR] Update beam_LoadTests_Python_Combine_Flink_Streaming.yml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 21:35:04 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/01 22:13:58 UTC, 1 replies.
- Re: [PR] SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2024/12/02 08:09:53 UTC, 5 replies.
- Re: [PR] Validate circular reference for yaml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:14:45 UTC, 10 replies.
- Re: [PR] Add safe to ignore category to dashboard/alerting [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:14:47 UTC, 2 replies.
- Re: [PR] Bump golang.org/x/net from 0.30.0 to 0.31.0 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:14:51 UTC, 1 replies.
- Re: [PR] update 2.60.0 changelog to include a fix in Bigtable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:14:53 UTC, 4 replies.
- Re: [PR] Enable configuration of a CDC mutation info Callable for CDC Writes into BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:14:59 UTC, 6 replies.
- Re: [PR] [Managed Iceberg] Cleanup SerializedDataFile; use ByteBuffer instead [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 12:15:01 UTC, 0 replies.
- Re: [PR] Add issue link to disabled TensorRT integration test [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/02 13:30:59 UTC, 2 replies.
- Re: [I] [Bug]: Unable to Restart Google Spanner Change Streams Consumer due to tableExists(table_name) bug [beam] - posted by "krak3n (via GitHub)" <gi...@apache.org> on 2024/12/02 14:23:00 UTC, 4 replies.
- Re: [I] The build_release_candidate job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/02 14:51:54 UTC, 0 replies.
- Re: [PR] Propagate gcs-connector options to GcsUtil [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/02 15:32:05 UTC, 3 replies.
- Re: [I] The Go tests job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/02 15:44:02 UTC, 1 replies.
- Re: [I] [Bug]: ReadAllFiles does not fully read gzipped files from GCS [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/02 15:54:38 UTC, 4 replies.
- Re: [I] [Bug][Distroless]: PostCommit Java ValidatesDistrolessContainer Dataflow needs to set testJavaVersion gradle property [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/02 15:55:42 UTC, 0 replies.
- [PR] SolaceIO.Write: Convert the state and timers to GroupIntoBatches [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/12/02 16:19:34 UTC, 2 replies.
- [PR] Revert "bump hadoop version" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/02 16:24:40 UTC, 3 replies.
- [PR] Remove unnecessary branches on Python version in typehint code [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/02 16:25:01 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/12/02 16:32:40 UTC, 0 replies.
- Re: [PR] Bump cloud.google.com/go/spanner from 1.70.0 to 1.73.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/02 16:32:51 UTC, 0 replies.
- Re: [PR] Bump golang.org/x/sync from 0.8.0 to 0.9.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 16:33:32 UTC, 1 replies.
- Re: [PR] jdbcio write batch config changes [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/02 16:51:47 UTC, 4 replies.
- Re: [PR] SolaceIO write connector [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/12/02 16:59:25 UTC, 0 replies.
- [PR] Revert "SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed (#32962)" [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/12/02 17:05:00 UTC, 3 replies.
- [PR] Clean up changelog [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/02 18:03:14 UTC, 1 replies.
- Re: [PR] [KafkaIO] Decouple consumer threads from harness threads [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/12/02 18:46:10 UTC, 10 replies.
- Re: [PR] Tour of Beam: formatting/typos [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/02 19:29:27 UTC, 2 replies.
- Re: [PR] Revert "Revert "Update vllm colab to work with asyncio requirements"" [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/02 21:09:41 UTC, 1 replies.
- [PR] Remove dupe metadata [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/02 21:13:57 UTC, 2 replies.
- Re: [PR] Bump org.javacc.javacc from 3.0.2 to 3.0.3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/02 21:22:29 UTC, 0 replies.
- [PR] [CHANGES] Add prism note to 2.61 release blog and CHANGES.md [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/02 22:44:41 UTC, 3 replies.
- [PR] Update CHANGES.md with Python prism note. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/02 22:49:14 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.4 to 1.32.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 05:04:57 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.203.0 to 0.209.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 05:05:12 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/storage from 1.45.0 to 1.47.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 05:05:29 UTC, 3 replies.
- [PR] Added support for Spark streaming stateful ParDo [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/12/03 05:43:15 UTC, 0 replies.
- Re: [PR] Added support for Spark streaming stateful processing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 06:09:03 UTC, 2 replies.
- Re: [PR] Add OrderedListState support for SparkRunner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/12/03 07:33:52 UTC, 24 replies.
- Re: [PR] Add histogram to metrics container [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 12:14:21 UTC, 6 replies.
- [I] [Feature Request]: Add a DIRECT_READ method to bigqueryio go sdk using BigQuery Storage API [beam] - posted by "win845 (via GitHub)" <gi...@apache.org> on 2024/12/03 13:02:10 UTC, 1 replies.
- [PR] Reapply "SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed (#32962)" (#33259) [beam] - posted by "bzablocki (via GitHub)" <gi...@apache.org> on 2024/12/03 13:29:24 UTC, 9 replies.
- Re: [I] [Task]: Update Python SDK code base to PEP 585 standards [beam] - posted by "Kludex (via GitHub)" <gi...@apache.org> on 2024/12/03 14:26:58 UTC, 0 replies.
- Re: [PR] Bump golang.org/x/oauth2 from 0.23.0 to 0.24.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/03 15:05:26 UTC, 0 replies.
- Re: [PR] Bump github.com/aws/smithy-go from 1.22.0 to 1.22.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 15:05:55 UTC, 1 replies.
- Re: [PR] Update republish workflow with latest beam [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/03 15:54:54 UTC, 2 replies.
- Re: [I] The PostCommit Java ValidatesDistrolessContainer Dataflow job is flaky [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/03 17:39:39 UTC, 1 replies.
- [PR] [#32222] Actually maintain the heap invariant for timers. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/03 18:04:00 UTC, 8 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/03 18:20:41 UTC, 4 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/03 22:14:22 UTC, 1 replies.
- Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/03 23:41:54 UTC, 0 replies.
- Re: [PR] [yaml] remove PubSubLite from API docs [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/03 23:49:03 UTC, 3 replies.
- [I] [Bug]: Beam YAML pipeline fails when using ReadFromPubSub with downstream Join transform [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/04 00:07:33 UTC, 1 replies.
- [PR] [yaml] Fix YAML join with upstream ReadFromPubSub [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/04 00:08:09 UTC, 5 replies.
- [PR] [YAML] Better docs for Filter and MapToFields. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/04 00:23:15 UTC, 8 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.45.1 to 1.45.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 04:25:02 UTC, 3 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.8.1 to 1.8.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 04:25:17 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.67.1 to 1.68.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 04:25:55 UTC, 3 replies.
- Re: [I] [Feature Request]: OpenTelemetry Support [beam] - posted by "Kludex (via GitHub)" <gi...@apache.org> on 2024/12/04 10:03:21 UTC, 9 replies.
- Re: [PR] Changes maxBufferingDuration payload to be taken from millis directly… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:25 UTC, 1 replies.
- Re: [PR] [java] BQ: add missing avro conversions to BQ TableRow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:26 UTC, 5 replies.
- Re: [PR] Update transforms module to PEP 585 type hints [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:29 UTC, 5 replies.
- Re: [PR] Read RabbitMQ messages with headers containing nested objects [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:34 UTC, 4 replies.
- Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:39 UTC, 5 replies.
- Re: [PR] Added support for reading from multiple topics in MqttIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:45 UTC, 4 replies.
- Re: [PR] BigQueryIO : control StorageWrite parallelism in batch, by reshuffling before write on the number of streams set for BigQueryIO.write() using .withNumStorageWriteApiStreams(numStorageWriteApiStreams) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:51 UTC, 6 replies.
- Re: [PR] Update CHANGES.md to include streaming NPE issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:55 UTC, 4 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:14:58 UTC, 4 replies.
- Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 12:15:00 UTC, 4 replies.
- Re: [PR] Add a pointer to java provider example. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/04 14:06:46 UTC, 0 replies.
- [PR] Use standard sql for BigQuery read schematransform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/04 15:56:56 UTC, 1 replies.
- Re: [PR] Add bounded Trie metric type to Python. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/04 16:26:15 UTC, 2 replies.
- Re: [PR] [yaml] error_handling normalization follow-up [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/04 16:27:37 UTC, 0 replies.
- Re: [PR] [yaml] add FileIO docs [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 17:12:05 UTC, 4 replies.
- [I] [Bug]: `TypeError: 'type' object is not subscriptable`. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/04 18:11:30 UTC, 1 replies.
- [PR] Fix TypeError: 'type' object is not subscriptable [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/04 18:12:53 UTC, 1 replies.
- [PR] Add iceberg gcp dependency [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/04 18:27:13 UTC, 3 replies.
- Re: [PR] [YAML] Make datetime available for jinja templatization. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/04 18:52:41 UTC, 3 replies.
- [PR] [YAML] Document the yaml provider include syntax. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/04 19:04:17 UTC, 3 replies.
- Re: [PR] Added support for SparkRunner streaming stateful processing [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/04 19:26:56 UTC, 10 replies.
- [PR] [Do not merge] Change Reify.asIterable to GBK in BigQueryIO File loads [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/04 20:24:58 UTC, 2 replies.
- Re: [I] [prism] Resolve endless timer test org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/04 22:04:27 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/12/04 22:15:29 UTC, 2 replies.
- [I] [Failing Test]: [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/04 23:07:56 UTC, 0 replies.
- [PR] [YAML] Document jinja templatization features. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/05 00:02:30 UTC, 7 replies.
- [PR] Move order of write_batch_size [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/05 00:30:37 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.45.1 to 1.45.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 04:18:15 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.67.1 to 1.68.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 04:22:42 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.203.0 to 0.210.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 04:26:03 UTC, 3 replies.
- Re: [I] [Bug]: Python JDBC IO Try To Connect RDB Before Deploying [beam] - posted by "RhysGrimshaw (via GitHub)" <gi...@apache.org> on 2024/12/05 10:24:44 UTC, 3 replies.
- Re: [PR] Bump org.sonarqube from 3.0 to 6.0.1.5171 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 12:14:26 UTC, 3 replies.
- Re: [PR] Adding Google Storage Requester pays feature to Golang SDK. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 12:14:26 UTC, 9 replies.
- Re: [PR] Support creating BigLake managed tables [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 12:14:28 UTC, 3 replies.
- [I] [Feature Request]: Add support for Iceberg table identifiers with special characters [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/05 12:56:40 UTC, 0 replies.
- [PR] Add support for Iceberg table identifiers with special characters [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/05 13:06:20 UTC, 7 replies.
- [PR] Bump Iceberg to v1.6.1 [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/05 13:44:25 UTC, 10 replies.
- Re: [I] [Task]: Document Jinja templatization for yaml [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/05 16:26:52 UTC, 2 replies.
- Re: [PR] [Managed Iceberg] Support partitioning time types (year, month, day, hour) [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/12/05 16:47:26 UTC, 9 replies.
- Re: [I] [Feature Request]: Expand --extra_package option to allow passing a directory containing the package and deprecate the --setup_file option [beam] - posted by "lgeiger (via GitHub)" <gi...@apache.org> on 2024/12/05 18:11:07 UTC, 2 replies.
- [PR] Small string fix for error message [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/05 18:16:51 UTC, 3 replies.
- Re: [I] [Bug]: BigQueryIO Storage API Schema Update does not work with dynamic destinations [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/05 18:27:11 UTC, 1 replies.
- [PR] [yaml] various inline provider doc fixes [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/05 18:37:30 UTC, 6 replies.
- [PR] Add Dataflow Cost Benchmark framework to Beam Python [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/05 19:41:36 UTC, 6 replies.
- [PR] [#32211] Fail job on SDK worker disconnect, instead of hanging forever. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/05 19:45:08 UTC, 3 replies.
- [I] [prism] Support OrderedListState [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/05 20:34:22 UTC, 3 replies.
- [I] [Feature Request]: requester-pays flag for GCS storage [beam] - posted by "kellen (via GitHub)" <gi...@apache.org> on 2024/12/05 20:41:43 UTC, 0 replies.
- Re: [PR] Synchronize JdbcSchemaIO provider and Python transform configuration field order [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/05 21:00:57 UTC, 0 replies.
- Re: [I] [Failing Test]: Python PostCommit failing from apache_beam.io.external.xlang_jdbcio_it_test.CrossLanguageJdbcIOTest [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/05 21:00:58 UTC, 0 replies.
- Re: [I] [Bug]: Better error message for specifying inputs on chain pipeline in Beam YAML [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/05 21:24:24 UTC, 2 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/12/05 22:16:29 UTC, 3 replies.
- Re: [I] [Bug]: [TextIO] Prevent threads from hanging indefinitely [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/12/06 00:02:24 UTC, 1 replies.
- Re: [PR] Kafka metrics [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/06 00:33:30 UTC, 1 replies.
- Re: [I] The PerformanceTests WordCountIT PythonVersions job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/06 00:34:31 UTC, 0 replies.
- [PR] Remove mandatory beam-sdks-io-kafka dependency for dataflow worker jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/06 00:45:03 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.38 to 1.17.43 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 04:24:00 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.45 to 1.17.47 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 04:24:41 UTC, 2 replies.
- [PR] Bump golang.org/x/text from 0.20.0 to 0.21.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 04:24:44 UTC, 2 replies.
- [I] [Feature Request][RRIO]: Enable BackOffSupplier configuration [beam] - posted by "krys-allegro (via GitHub)" <gi...@apache.org> on 2024/12/06 09:49:59 UTC, 0 replies.
- Re: [PR] Tour of Beam: update GroupByKey example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 12:14:26 UTC, 5 replies.
- Re: [PR] poc: python translation phase that replaces GBK+CombineValue pairs with CombinePerKey [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 12:46:18 UTC, 1 replies.
- Re: [PR] WIP Tests demonstrating TextIO issues with large delimiters and small splits and skipped headers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 12:46:21 UTC, 2 replies.
- [PR] Flatmaptuplebug [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/12/06 12:59:59 UTC, 0 replies.
- [I] [Bug]: python trivial inferencing code fails when dealing with unpacking+generators [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/12/06 13:26:17 UTC, 0 replies.
- [I] [Task]: Automatic spotlessApply [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/12/06 14:01:46 UTC, 1 replies.
- [PR] [infra] #33309 automatically apply spotless [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2024/12/06 14:05:43 UTC, 8 replies.
- Re: [PR] Fix FlatMapTuple typehint bug [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/12/06 14:38:22 UTC, 4 replies.
- Re: [I] [Bug]: apache-beam is unusable in recent python due to pinning an old dill library from 2019 [beam] - posted by "chebbyChefNEQ (via GitHub)" <gi...@apache.org> on 2024/12/06 15:25:45 UTC, 2 replies.
- [PR] Add throttling metrics and retries to vertex embeddings [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/06 16:03:37 UTC, 3 replies.
- Re: [I] [Bug]: ReadFromKafka does not work without max_num_records parameter [beam] - posted by "dulangah2 (via GitHub)" <gi...@apache.org> on 2024/12/06 17:28:17 UTC, 3 replies.
- Re: [PR] Enable managed service in Python tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/06 19:05:22 UTC, 2 replies.
- Re: [PR] Eliminate nullness errors from a bit of the FlinkRunner [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 19:14:46 UTC, 0 replies.
- [PR] Reapply "bump hadoop version (#33011)" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/06 20:16:16 UTC, 4 replies.
- [PR] [PROTOTYPE- DO NOT SUBMIT] Rag e2e [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/12/06 20:39:58 UTC, 4 replies.
- Re: [PR] learning+website: add `FlattenWith` and `Tee` to Playground and Transform Catalog [WIP] [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/06 20:52:39 UTC, 2 replies.
- Re: [I] [Bug]: FlatMapTuple with certain callables can result in wrong type hints [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/06 22:03:35 UTC, 0 replies.
- [I] [Bug]: [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/06 22:05:52 UTC, 0 replies.
- [PR] Add Iceberg support for name-based mapping schema [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/06 22:08:22 UTC, 8 replies.
- [PR] Polish FlatMapTuple and MapTuple docstrings [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2024/12/06 22:17:01 UTC, 3 replies.
- [PR] Disable keepalive pings. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/12/06 22:19:25 UTC, 8 replies.
- [PR] [WIP] Dataflow Streaming GroupByKey state multiplexing for small keys [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/12/06 22:40:07 UTC, 6 replies.
- Re: [PR] [Do not Merge] [WIP] Combine.perKeyWithBucketing: Combiner for reducing key cardinality [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2024/12/06 22:41:29 UTC, 1 replies.
- [PR] Allow annotations to be attached to transforms via a context. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/06 23:07:40 UTC, 1 replies.
- Re: [I] Difficulty reprocessing failed records [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/06 23:20:51 UTC, 1 replies.
- Re: [PR] Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/07 12:14:12 UTC, 6 replies.
- Re: [PR] Auth testing changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/07 12:45:45 UTC, 2 replies.
- Re: [PR] Add a mutex guard around using the prism servers artifacts cache map. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/07 12:45:46 UTC, 2 replies.
- [I] [Bug]: Python error just in importing apache-beam line within docker image [beam] - posted by "maneesh299 (via GitHub)" <gi...@apache.org> on 2024/12/08 09:28:02 UTC, 4 replies.
- [PR] Batch optimized SparkRunner groupByKey [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/12/08 12:28:28 UTC, 12 replies.
- Re: [PR] Add Application Default Authentication Support for KafkaIO when Using GMK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 12:45:57 UTC, 2 replies.
- Re: [PR] Support portable pipeline dot graph rendering [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 12:45:59 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 22:13:49 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 22:14:13 UTC, 1 replies.
- Re: [PR] Add option to adjust ReadChangeStream API timeout to allow longer timeout for longer checkpoint durations [beam] - posted by "tonytanger (via GitHub)" <gi...@apache.org> on 2024/12/09 02:00:00 UTC, 4 replies.
- [PR] Update numpy requirement from <2.2.0,>=1.14.3 to >=1.14.3,<2.3.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 04:18:52 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.31.0 to 0.32.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 04:48:06 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.47.0 to 1.48.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 04:48:16 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.27.0 to 0.28.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 04:48:20 UTC, 3 replies.
- [I] [Bug]: GroupByKey() emits only key but not values for streaming job on a FixedWindows() with early trigger [beam] - posted by "elitongadotti (via GitHub)" <gi...@apache.org> on 2024/12/09 10:42:06 UTC, 2 replies.
- Re: [PR] #28096 go get updated to go install issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 12:46:29 UTC, 2 replies.
- Re: [PR] fix: workaround BigtableIO.read() recreating the client for every split [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 12:46:31 UTC, 2 replies.
- Re: [I] The PostCommit Python Dependency job is flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/09 14:47:27 UTC, 1 replies.
- Re: [I] [Task]: Upgrade Parquet to 0.13.1 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/12/09 15:23:27 UTC, 0 replies.
- Re: [I] [Task]: Deprecate Java8 [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/12/09 15:30:33 UTC, 2 replies.
- Re: [PR] [yaml] Add use cases for Enrichment transform in YAML [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/09 17:11:56 UTC, 7 replies.
- Re: [I] [Bug]: Newly created Storage API write streams do not recognize the previously updated table schema [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/09 17:25:15 UTC, 0 replies.
- [I] [Bug]: FileIO.matchAll() injects a Reshuffle step which in some case is not useful and might break desirable fusion with more CPU intensive steps [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2024/12/09 17:52:07 UTC, 0 replies.
- [I] [Feature Request]: Add support for partition identity transforms [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/09 18:09:27 UTC, 1 replies.
- [PR] Support Iceberg partition identity transform [beam] - posted by "regadas (via GitHub)" <gi...@apache.org> on 2024/12/09 18:09:58 UTC, 14 replies.
- [I] [Bug]: Release Nightly Snapshot fails HTTP requests to https://repository.apache.org. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/09 18:37:57 UTC, 1 replies.
- [PR] Force portable TestStream to use the Nested Coder context throughout. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/09 19:00:46 UTC, 2 replies.
- [I] [Bug]: Beam example repo warning log while launching on Dataflow [beam] - posted by "svetakvsundhar (via GitHub)" <gi...@apache.org> on 2024/12/09 20:13:33 UTC, 0 replies.
- [PR] Replace None metric values with 0.0 in Dataflow Cost Benchmark [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/09 21:18:10 UTC, 3 replies.
- Re: [I] [Bug]: Release and PostRelease Nightly Snapshot fails HTTP requests to https://repository.apache.org. [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/09 22:09:18 UTC, 3 replies.
- Re: [PR] Add kafka sdf poll metrics [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/09 22:40:26 UTC, 0 replies.
- [PR] [#32211] Support OnWindowExpiration in Prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/09 23:21:59 UTC, 20 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 00:42:34 UTC, 8 replies.
- [PR] Fix beam post commit java io performance tests [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 00:45:30 UTC, 0 replies.
- Re: [PR] Remove the use of google-github-actions/auth@v1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/10 01:34:51 UTC, 4 replies.
- [PR] [WIP] Use output type hints in Reshuffle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/10 04:18:36 UTC, 0 replies.
- [I] [Feature Request]: Hudi Table support / IO Connector for HoodieIO [beam] - posted by "saathwik-tk (via GitHub)" <gi...@apache.org> on 2024/12/10 10:20:01 UTC, 0 replies.
- Re: [PR] adding example of writting to kafka [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/10 12:46:27 UTC, 2 replies.
- Re: [PR] [feat 32473] Added soft deadline logic to Spanner Change Stream IO connector. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/12/10 14:12:44 UTC, 12 replies.
- Re: [I] [Bug]: BigQueryAvroUtils don't handle Avro FLOAT type correcty. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/10 17:36:47 UTC, 0 replies.
- [PR] Update .GitHub/workflows README.md [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 19:05:03 UTC, 7 replies.
- [PR] Add hadoop-auth [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/10 19:10:37 UTC, 3 replies.
- [I] [Task]: Remove static GCP credentials from Java Tests [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 19:11:03 UTC, 0 replies.
- [I] [Task]: [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 19:11:55 UTC, 0 replies.
- [I] [Task]: Remove static GCP credentials from Python Tests [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 19:13:17 UTC, 0 replies.
- [I] [Bug]: TypeScript xlang ValueError: numpy.dtype size changed [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/10 19:22:50 UTC, 0 replies.
- Re: [I] [Bug]: Test runner(Python SDK) fails when generic type is specified as a type for pardo element [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/10 20:11:41 UTC, 2 replies.
- [PR] reconstruct vendoe hive-exec jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/10 20:13:04 UTC, 0 replies.
- Re: [PR] Bump avro, fix CVE-2024-47561 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/10 21:01:26 UTC, 0 replies.
- [PR] Add Python multi-language guide [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/10 22:54:55 UTC, 3 replies.
- [PR] Switch to use unshaded hive-exec for io expansion service [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/10 23:47:14 UTC, 8 replies.
- [PR] [#32929] Add OrderedListState support to Prism. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/11 01:17:49 UTC, 6 replies.
- [PR] Bump cloud.google.com/go/profiler from 0.4.1 to 0.4.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 04:48:05 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.22 to 2.10.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 04:48:21 UTC, 2 replies.
- Re: [PR] [Managed Iceberg] Use table file size property if exists [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 12:46:24 UTC, 2 replies.
- Re: [PR] [WIP] Add background thread and caching of consumers to Kafka SDF [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 12:46:28 UTC, 2 replies.
- [PR] Fixes flaky tests failing with "Error processing result file: CData section too big found" [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/12/11 15:41:29 UTC, 2 replies.
- Re: [PR] bump confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/12/11 15:49:34 UTC, 2 replies.
- Re: [I] [Bug]: Error: Error processing result file: CData section too big found, ... FROM EnricoMi/publish-unit-test-result-action [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/11 16:51:24 UTC, 0 replies.
- Re: [I] [Feature Request]: Support streaming inserts for bounded PCollections [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/12/11 18:11:34 UTC, 0 replies.
- [PR] Java rm static gcp creds [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/11 18:35:14 UTC, 3 replies.
- Re: [I] [Bug]: KafkaIO pulls dependency vulnerable to CVE-2024-26308 and CVE-2024-25710 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/12/11 19:19:17 UTC, 1 replies.
- Re: [PR] Update confluent version to fix CVE-2024-26308 CVE-2024-25710 [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/12/11 19:35:45 UTC, 0 replies.
- [PR] Enable caching in Python tests workflow [beam] - posted by "eduramirezh (via GitHub)" <gi...@apache.org> on 2024/12/11 20:46:48 UTC, 4 replies.
- [I] [Bug]: Reshuffle failed to use custom coders in non-global window scenario [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/11 21:39:35 UTC, 1 replies.
- Re: [I] Timers exception on "Job Drain" while using stateful beam processing in global window [beam] - posted by "genyhamud (via GitHub)" <gi...@apache.org> on 2024/12/11 22:10:26 UTC, 2 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 22:16:28 UTC, 1 replies.
- Re: [PR] Fix custom coder not being used in ReshufflePerKey in a global window setting [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 22:39:11 UTC, 2 replies.
- [I] [Task]: Add new Python SchemaTransform multi-language documentation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/11 23:17:32 UTC, 5 replies.
- [PR] Python ExternalTransformProvider improvements [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/11 23:17:55 UTC, 3 replies.
- [PR] Add new Python multi-lang quickstart using the SchemaTransform framework [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/11 23:18:13 UTC, 0 replies.
- [PR] Improve existing Python multi-lang SchemaTransform examples [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/11 23:18:30 UTC, 2 replies.
- [PR] Add new Python SchemaTransform multi-lang guide [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/11 23:18:55 UTC, 0 replies.
- [PR] Reshuffle output hint non global window [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/12 04:16:11 UTC, 0 replies.
- [PR] Rag chunking embedding [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/12/12 04:43:18 UTC, 11 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.64.0 to 1.65.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/12 04:51:59 UTC, 2 replies.
- Re: [I] [Bug]: BigtableIO.Read can't retrive large row that exceeds 256MB [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2024/12/12 11:14:04 UTC, 0 replies.
- Re: [I] [Bug]: Pipeline may stuck after error thrown in transform due to racing condition in CancellableQueue [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2024/12/12 12:59:26 UTC, 2 replies.
- [PR] Bump golang.org/x/crypto from 0.30.0 to 0.31.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/12 15:29:36 UTC, 2 replies.
- Re: [PR] Fix custom coder not being used in Reshuffle (global window) [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/12 15:30:41 UTC, 0 replies.
- [PR] Deprecate AWS v1 module [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/12 19:00:05 UTC, 2 replies.
- Re: [PR] [docs] Add new Python SchemaTransform multi-lang guide [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/12 19:34:51 UTC, 10 replies.
- Re: [PR] [docs] Add new Python multi-lang quickstart using the SchemaTransform framework [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/12 19:34:58 UTC, 2 replies.
- [PR] Parameterize GoogleCloudStorage provider in GcsUtil to unblock gcs-co… [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2024/12/12 19:55:37 UTC, 9 replies.
- Re: [I] [prism] Support OnWindowExpiry [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/12 21:04:29 UTC, 0 replies.
- [PR] Fix Apache snapshot repo usage [beam] - posted by "adoroszlai (via GitHub)" <gi...@apache.org> on 2024/12/12 22:34:39 UTC, 5 replies.
- Re: [I] [Task]: Clean up Python Tests workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/12 22:48:15 UTC, 1 replies.
- Re: [I] [Task]: Clean up Typescript Tests workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/12 22:48:59 UTC, 1 replies.
- [PR] Remove flaky Go DataMGR tests that terminate before read. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/12 23:01:43 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.67.2 to 1.69.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 04:17:44 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 27.4.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 04:17:52 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.210.0 to 0.211.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 04:18:03 UTC, 2 replies.
- [PR] Bump com.gradle.develocity from 3.17.6 to 3.19 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 05:03:57 UTC, 2 replies.
- Re: [PR] Bump com.gradle.develocity from 3.17.6 to 3.18.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 05:04:00 UTC, 1 replies.
- Re: [PR] SolaceIO: separate auth and session settings [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2024/12/13 10:44:42 UTC, 8 replies.
- Re: [I] [Task]: Add tests to Kafka SDF and fix known and discovered issues [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2024/12/13 16:08:48 UTC, 1 replies.
- [PR] Bump nanoid from 3.3.6 to 3.3.8 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 18:07:51 UTC, 1 replies.
- Re: [PR] Clean up Java Tests GitHub workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/13 18:41:09 UTC, 0 replies.
- Re: [I] [Task]: Clean up Java Tests workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/13 18:41:10 UTC, 0 replies.
- [PR] fix BoundedTrieData get_result return type hint [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/13 19:42:12 UTC, 4 replies.
- [PR] End to end BoundedTrie metrics through worker and runner APIs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/13 21:47:00 UTC, 5 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/13 22:15:32 UTC, 1 replies.
- [PR] Adds references to KeyCommitTooLargeException docs [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2024/12/13 22:42:27 UTC, 3 replies.
- [PR] Migrate lineage counters to bounded tries. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/14 00:14:01 UTC, 8 replies.
- Re: [PR] Fix custom coders not being used in Reshuffle (non global window) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/14 01:05:31 UTC, 6 replies.
- Re: [I] [Bug]: GBK with global window must fit all values for a key into a memory [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2024/12/14 01:47:31 UTC, 0 replies.
- [PR] Faster default coder for unknown windows. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2024/12/14 02:18:55 UTC, 7 replies.
- [PR] Fix TextIO not fully reading a GCS file when decompressive transcoding happens [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/15 05:07:24 UTC, 3 replies.
- Re: [PR] Fix Maybereshuffle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/15 12:45:55 UTC, 2 replies.
- Re: [PR] Fix flaky test suite beam_PostCommit_XVR_Direct [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/15 12:46:07 UTC, 0 replies.
- Re: [PR] [yaml] Add UDF docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/15 12:46:10 UTC, 1 replies.
- Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/15 12:46:11 UTC, 2 replies.
- [PR] Introduce a BoundedTrie metric which is used to efficiently store and… [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/12/16 10:26:20 UTC, 9 replies.
- [PR] In contributor docs, don't try to download releases from snapshot repo [beam] - posted by "raboof (via GitHub)" <gi...@apache.org> on 2024/12/16 10:30:53 UTC, 2 replies.
- Re: [PR] DO NOT MERGE: test cloudpickle default [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/16 12:46:36 UTC, 2 replies.
- [PR] Fix duplicate yml entry causing test result dashboard sync to fail [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/16 15:07:17 UTC, 1 replies.
- [I] [Feature Request]: Infrastructure documentation [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/16 15:14:00 UTC, 0 replies.
- [PR] [java] BQ: Add avro schema to BQ TableSchema conversion [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/12/16 15:23:16 UTC, 5 replies.
- [PR] Fix yaml error in Flink Java8 ValidatesRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/16 15:35:47 UTC, 2 replies.
- [PR] Add TF MNIST classification cost benchmark [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/16 16:36:05 UTC, 9 replies.
- [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/16 18:02:04 UTC, 15 replies.
- [I] The PerformanceTests HadoopFormat job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/16 18:40:21 UTC, 0 replies.
- [I] The Build python source distribution and wheels job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/16 18:40:22 UTC, 1 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/16 18:40:29 UTC, 1 replies.
- [PR] chore: Upgrade google cloud bigdataoss version [beam] - posted by "ldetmer (via GitHub)" <gi...@apache.org> on 2024/12/16 20:39:11 UTC, 3 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/16 21:34:34 UTC, 1 replies.
- [PR] Clean up Python Tests workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/17 01:51:37 UTC, 5 replies.
- [PR] Bump google.golang.org/protobuf from 1.35.2 to 1.36.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/17 04:12:17 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.211.0 to 0.212.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/17 04:12:31 UTC, 2 replies.
- [PR] Rag ingestion enrichment [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/12/17 14:14:57 UTC, 0 replies.
- [I] [Bug]: Error on start-build-env.sh [beam] - posted by "marblejenka (via GitHub)" <gi...@apache.org> on 2024/12/17 14:44:34 UTC, 3 replies.
- [PR] fix error on start-build-env.sh [beam] - posted by "marblejenka (via GitHub)" <gi...@apache.org> on 2024/12/17 14:51:04 UTC, 2 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/12/17 14:57:05 UTC, 4 replies.
- Re: [PR] [java] Add Optional coder [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/12/17 15:02:20 UTC, 3 replies.
- [PR] KafkaIO: Do no throw exceptions if commitSync fails in KafkaUnboundedReader. [beam] - posted by "an2x (via GitHub)" <gi...@apache.org> on 2024/12/17 19:05:24 UTC, 2 replies.
- [PR] Add missing to_type_hint to WindowedValueCoder [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/17 19:37:02 UTC, 5 replies.
- [PR] Fix env variable loading in Cost Benchmark workflow [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/17 20:10:41 UTC, 3 replies.
- Re: [I] [Feature Request]: {BIgQuery IO} - Allow users to Create BigQuery tables for Apache Iceberg if it does not exist [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/17 21:32:02 UTC, 1 replies.
- Re: [I] [Bug]: IcebergIO cannot write data into an hourly partitioned table [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/17 21:33:54 UTC, 0 replies.
- [PR] [yaml] add better error message for python MapToFields expression [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/17 21:37:43 UTC, 2 replies.
- [PR] [yaml] add RunInference support with VertexAI [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/17 21:44:30 UTC, 21 replies.
- [I] [Bug]: tfrecordio does not work with snappy >= 0.7 [beam] - posted by "cnsgsz (via GitHub)" <gi...@apache.org> on 2024/12/17 22:08:25 UTC, 0 replies.
- [PR] Kafka add gauge v1 [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2024/12/17 23:00:26 UTC, 15 replies.
- Re: [PR] [BigQueryIO] fetch updated schema for newly created Storage API stream writers [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/18 00:01:31 UTC, 11 replies.
- [PR] Bump google.golang.org/api from 0.212.0 to 0.213.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/18 04:44:03 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.10.23 to 2.10.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/18 04:44:17 UTC, 1 replies.
- Re: [I] DatastoreV1.write() Should Optionally Return PCollection [beam] - posted by "bitnahian (via GitHub)" <gi...@apache.org> on 2024/12/18 04:48:11 UTC, 3 replies.
- [I] [Feature Request]: Provide error log for troubleshooting newJarGetter function [beam] - posted by "stephanusb (via GitHub)" <gi...@apache.org> on 2024/12/18 09:35:47 UTC, 0 replies.
- [PR] [java] Fix avro bytes conversion for BQ storage [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/12/18 11:55:37 UTC, 3 replies.
- [PR] Add rag enrichment and ingestion. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2024/12/18 14:04:41 UTC, 9 replies.
- Re: [I] [Bug]: BigQuery streaming throwing OutOfRangeException [beam] - posted by "mapoulos (via GitHub)" <gi...@apache.org> on 2024/12/18 14:36:27 UTC, 0 replies.
- [PR] Revert three commits related to supporting custom coder in reshuffle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/18 15:50:59 UTC, 12 replies.
- Re: [I] [Feature Request]: Support Stateful Processing in Spark Runner (Without Timer Functionality) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/18 16:09:05 UTC, 0 replies.
- [PR] [Do not merge] Disable keepalive pings. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2024/12/18 20:01:14 UTC, 0 replies.
- [PR] [WIP] Update xlang kinesis to v2 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/18 20:15:01 UTC, 2 replies.
- [PR] Add an SdkHarnessOption that controls whether logging is redirected t… [beam] - posted by "t2h6 (via GitHub)" <gi...@apache.org> on 2024/12/18 23:55:55 UTC, 1 replies.
- [PR] Adds an SdkHarnessOption that controls whether logging is redirected through the FnApi [beam] - posted by "t2h6 (via GitHub)" <gi...@apache.org> on 2024/12/19 00:09:18 UTC, 1 replies.
- [PR] Eliminate benign race condition in DirectStreamObserver [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/19 01:58:09 UTC, 1 replies.
- Re: [PR] Eliminate benign race condition in DirectStreamObserver and make first and subsequent iterations consistent [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 01:59:56 UTC, 0 replies.
- [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 27.4.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 04:29:12 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.67.2 to 1.69.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 04:29:20 UTC, 2 replies.
- [PR] [java] Fix avro logical-types conversions for BQ storage [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/12/19 09:59:45 UTC, 8 replies.
- Re: [I] Add integration testing for BQ Storage API write modes [beam] - posted by "RustedBones (via GitHub)" <gi...@apache.org> on 2024/12/19 10:46:56 UTC, 0 replies.
- Re: [I] [Distroless] Enable Distroless Java SDK based container images [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/19 13:09:45 UTC, 0 replies.
- [PR] Add 2.63.0 section to CHANGES.md [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/19 13:50:39 UTC, 1 replies.
- Re: [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/19 14:18:57 UTC, 1 replies.
- [I] [Bug]: beam_Publish_Beam_SDK_Snapshots is extremely flaky due to failing to build wheels [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/12/19 16:50:40 UTC, 3 replies.
- [PR] Move Dataflow Python Managed tests to prod [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/19 18:59:52 UTC, 2 replies.
- Re: [I] [Feature Request]: Python-based Unbounded WebSocker IO Connector [beam] - posted by "CWrecker (via GitHub)" <gi...@apache.org> on 2024/12/19 19:23:10 UTC, 0 replies.
- [PR] Update typehinting code to use primitives and collections types as main types over typing variants [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2024/12/19 20:44:10 UTC, 0 replies.
- [PR] disable cache for beam_Publish_Beam_SDK_Snapshots.yml when running Python [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/20 01:17:18 UTC, 3 replies.
- [I] The Clean Up GCP Resources job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/20 03:37:37 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.212.0 to 0.214.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/20 04:20:52 UTC, 2 replies.
- [I] [Task]: Remove Deprecated AWS v1 IOs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/20 15:22:40 UTC, 1 replies.
- [PR] Update golang.org/x/net to 0.33.0 to avoid a CVE. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/20 19:07:16 UTC, 3 replies.
- [PR] Use other fallback coders for protobuf Message base class. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/20 19:36:31 UTC, 0 replies.
- Re: [PR] Use other fallback coders for protobuf Message base class [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/20 19:37:08 UTC, 5 replies.
- Re: [PR] Read worker harness image name from pipeline option for portable runners [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2024/12/20 19:55:36 UTC, 1 replies.
- [PR] [yaml] allow logging bytes in LogForTesting [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/20 20:21:37 UTC, 4 replies.
- Re: [I] [Bug]: Metrics not showing up in the FlinkRunner [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/20 22:29:18 UTC, 0 replies.
- [PR] Migrate Beam Go to use the new Opaque Protocol Buffers [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/20 22:36:34 UTC, 6 replies.
- [I] [Bug]: beam_CleanupGCPResources is failing due to "The operation was canceled" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/12/20 23:40:05 UTC, 1 replies.
- Re: [I] [Bug]: beam_CleanupGCPResources is failing with log "The operation was canceled" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/12/20 23:50:49 UTC, 5 replies.
- Re: [PR] Use other fallback coders for protobuf message base class [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/21 01:23:49 UTC, 0 replies.
- [PR] Implement "stage_file_with_retry" for robust file staging [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2024/12/21 05:14:49 UTC, 5 replies.
- Re: [I] [Bug]: Add check for self-referencing input in YAML transform [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/21 20:45:06 UTC, 1 replies.
- Re: [PR] Add support for Flink 1.20 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 12:43:44 UTC, 2 replies.
- [I] [Bug]: symbols are not exported from `apache_beam`, causing type errors from Pylance [beam] - posted by "sebastian-correa (via GitHub)" <gi...@apache.org> on 2024/12/22 16:24:36 UTC, 2 replies.
- [PR] [Prism] Use the worker-id gRPC metadata [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/23 02:57:19 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.6 to 1.32.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/23 04:32:06 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.28.6 to 1.28.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/23 04:33:01 UTC, 2 replies.
- Re: [PR] [yaml] add mysql, oracle, postgres and sql server providers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/23 14:49:18 UTC, 3 replies.
- [I] [Task]: Use DataFrame.map instead of DataFrame.applymap [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2024/12/23 15:51:47 UTC, 2 replies.
- [I] [Bug]: JDBC javasdk_date:v1 decode error [beam] - posted by "ffernandez92 (via GitHub)" <gi...@apache.org> on 2024/12/23 16:35:04 UTC, 0 replies.
- Re: [I] [Bug]: Support error handling in PyTransform [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/23 19:08:12 UTC, 1 replies.
- [PR] [yaml] propogate error_handling to windowing composite config [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/23 20:38:07 UTC, 5 replies.
- [PR] [Managed Iceberg] refactor integration tests; make it easy to add a new catalog to test suite [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/23 22:07:00 UTC, 4 replies.
- [PR] Bump jinja2 from 3.1.4 to 3.1.5 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/24 00:48:29 UTC, 3 replies.
- [PR] Bump net.researchgate.release from 2.8.1 to 3.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/24 04:52:37 UTC, 1 replies.
- [PR] Suppress DataFrame.applymap deprecation warning [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/24 04:58:40 UTC, 6 replies.
- Re: [PR] Fix tableExists() method [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/24 12:45:28 UTC, 0 replies.
- [I] [Bug]: Gauge metrics are not extracted in metrics result. [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/12/25 04:31:06 UTC, 0 replies.
- Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] - posted by "Raaaaaaaay86 (via GitHub)" <gi...@apache.org> on 2024/12/25 12:49:13 UTC, 1 replies.
- Re: [PR] Update Enrichment Handlers to PEP 585 typing [beam] - posted by "lianliangzhang (via GitHub)" <gi...@apache.org> on 2024/12/26 08:36:56 UTC, 2 replies.
- Re: [I] [yaml] Normalize KinesisIO [beam] - posted by "mravi (via GitHub)" <gi...@apache.org> on 2024/12/26 16:36:06 UTC, 0 replies.
- Re: [PR] Upgrade default kafka from 2.4.1 to 3.1.2 [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2024/12/26 17:58:14 UTC, 0 replies.
- [I] [Bug]: starts.ApproximateQuantiles() sometimes returns one split potint when the number of requested quantiles is 1. [beam] - posted by "Labutin (via GitHub)" <gi...@apache.org> on 2024/12/26 19:17:55 UTC, 0 replies.
- [I] [Bug]: Python SDK inconsistently instantiates WorkerIdInterceptor [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/26 20:36:42 UTC, 1 replies.
- Re: [PR] test: update protobuf version [beam] - posted by "ldetmer (via GitHub)" <gi...@apache.org> on 2024/12/26 21:36:42 UTC, 0 replies.
- [PR] chore: update to use versions for LTS 8 [beam] - posted by "ldetmer (via GitHub)" <gi...@apache.org> on 2024/12/26 21:51:33 UTC, 1 replies.
- [PR] DO NOT MERGE - testing candidate fixes to Python SDK [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/26 23:41:29 UTC, 2 replies.
- [PR] Fix missing worker_id from interceptor [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/27 01:05:20 UTC, 7 replies.
- [PR] [Cherrypick] Managed BigQuery use file loads with Avro format for better performance [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/27 14:12:03 UTC, 2 replies.
- Re: [PR] Update xlang kinesis to v2 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/27 16:27:01 UTC, 5 replies.
- [PR] Remove aws v1 from infrastructure [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/27 16:48:21 UTC, 9 replies.
- [PR] [WIP] Remove amazon-web-services and kinesis folders + settings.gradle cleanup [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/27 17:34:52 UTC, 2 replies.
- [PR] Btrie disable flag [beam] - posted by "rohitsinha54 (via GitHub)" <gi...@apache.org> on 2024/12/27 20:58:21 UTC, 3 replies.
- [PR] Clean up Typescript Tests workflow [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/27 23:06:51 UTC, 2 replies.
- Re: [PR] Modify JVM options if enableHeapDumps is specified to dump heap in directory that MemoryMonitor will look in. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/28 12:43:55 UTC, 0 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/29 00:36:41 UTC, 4 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/29 12:43:54 UTC, 0 replies.
- [I] [Bug]: local-env-setup.sh fails to install goavro [beam] - posted by "marblejenka (via GitHub)" <gi...@apache.org> on 2024/12/30 12:03:41 UTC, 0 replies.
- [PR] fix error on local-env-setup.sh [beam] - posted by "marblejenka (via GitHub)" <gi...@apache.org> on 2024/12/30 12:08:20 UTC, 4 replies.
- [PR] Fix iceberg ITs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/30 12:20:32 UTC, 3 replies.
- Re: [I] [Failing Test]: PreCommit Yaml Xlang Direct is broken [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2024/12/30 12:48:20 UTC, 1 replies.
- [PR] Fix typo of output type in the docs. [beam] - posted by "damjad (via GitHub)" <gi...@apache.org> on 2024/12/30 15:42:23 UTC, 1 replies.
- [PR] Update Java expansion service to use distroless [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 16:21:09 UTC, 5 replies.
- Re: [PR] Remove amazon-web-services and kinesis folders + settings.gradle cleanup [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 17:50:44 UTC, 3 replies.
- [PR] Don't block bot on neutral responses [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 18:49:20 UTC, 3 replies.
- [PR] Remove aws v1 dependencies [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 18:53:56 UTC, 3 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/30 19:06:16 UTC, 0 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/30 19:06:22 UTC, 0 replies.
- [PR] Update release finalization to push postrelease branch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 20:13:56 UTC, 2 replies.
- [PR] Rename release branch to release-2.XX instead of release-2.XX.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2024/12/30 20:45:43 UTC, 1 replies.
- Re: [PR] [#32167][Prism] Use the worker-id gRPC metadata [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2024/12/30 23:04:40 UTC, 1 replies.
- [PR] Create beam_Publish_Java_SDK_Distroless_Snapshots.yml [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/30 23:20:00 UTC, 0 replies.
- Re: [I] [Distroless] Support BuildKit and multi-stage container image builds [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/30 23:20:52 UTC, 0 replies.
- [PR] Stage beam_Publish_Python_SDK_Distroless_Snapshots.yml [beam] - posted by "damondouglas (via GitHub)" <gi...@apache.org> on 2024/12/30 23:48:24 UTC, 1 replies.
- [I] [Bug]: org.xbill.DNS.spi.DnsjavaInetAddressResolverProvider when running multi-lang Python jobs on Dataflow with Java 21 [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2024/12/31 00:04:42 UTC, 4 replies.
- Re: [PR] Stage beam_Publish_Java_SDK_Distroless_Snapshots.yml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/31 00:24:59 UTC, 0 replies.
- [PR] Make Beam expansion service shadowJar multi-release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2024/12/31 00:45:03 UTC, 0 replies.
- Re: [PR] Replace StorageV1 client with GCS client - Draft [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/31 12:45:12 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/12/31 22:15:21 UTC, 0 replies.