Re: [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17.1 [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30916: URL: https://github.com/apache/beam/pull/30916#issuecomment-2046570355 Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment `assign set of reviewers` -- This is an automated

Re: [PR] [#30870]: support consumer polling timeout in KafkaIO expansion service [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30915: URL: https://github.com/apache/beam/pull/30915#issuecomment-2046545801 Assigning reviewers. If you would like to opt out of this review, comment `assign to next reviewer`: R: @damccorm for label python. R: @kennknowles for label java.

Re: [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] closed pull request #30836: Bump com.gradle.enterprise from 3.15.1 to 3.17 URL: https://github.com/apache/beam/pull/30836 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] Bump com.gradle.enterprise from 3.15.1 to 3.17 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] commented on PR #30836: URL: https://github.com/apache/beam/pull/30836#issuecomment-2046543816 Superseded by #30916. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[PR] Bump com.gradle.enterprise from 3.15.1 to 3.17.1 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] opened a new pull request, #30916: URL: https://github.com/apache/beam/pull/30916 Bumps com.gradle.enterprise from 3.15.1 to 3.17.1. [![Dependabot compatibility

[PR] [#30870]: support consumer polling timeout in KafkaIO expansion service [beam]

2024-04-09 Thread via GitHub
xianhualiu opened a new pull request, #30915: URL: https://github.com/apache/beam/pull/30915 addresses #30870. Previous PR (https://github.com/apache/beam/pull/30877) made consumer polling timeout configurable for KafkaIO.Read in Java SDK. This PR contains changes to make the same

Re: [PR] [#30870]: support consumer polling timeout in KafkaIO expansion service [beam]

2024-04-09 Thread via GitHub
xianhualiu closed pull request #30914: [#30870]: support consumer polling timeout in KafkaIO expansion service URL: https://github.com/apache/beam/pull/30914 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[PR] [#30870]: support consumer polling timeout in KafkaIO expansion service [beam]

2024-04-09 Thread via GitHub
xianhualiu opened a new pull request, #30914: URL: https://github.com/apache/beam/pull/30914 support consumer polling timeout in KafkaIO expansion service -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

Re: [PR] Skip calling Compute in RemoveSafeDeltaCounterCell if value exists [beam]

2024-04-09 Thread via GitHub
JayajP commented on PR #30913: URL: https://github.com/apache/beam/pull/30913#issuecomment-2046324543 Run Java PreCommit -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on PR #30805: URL: https://github.com/apache/beam/pull/30805#issuecomment-2046280395 Looks like there is something broke in the GHA workflow FYI just so you don't wait for that to go green. I pushed some possible fixes up for that too but I'm not sure if in this case

Re: [PR] Upgrade grpcio-tools. [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30912: URL: https://github.com/apache/beam/pull/30912#issuecomment-2046261283 Assigning reviewers. If you would like to opt out of this review, comment `assign to next reviewer`: R: @riteshghorse for label python. Available commands: -

Re: [I] [Bug]: Install fails with Python3.12 due to old grpcio-tools version [beam]

2024-04-09 Thread via GitHub
tvalentyn commented on issue #30820: URL: https://github.com/apache/beam/issues/30820#issuecomment-2046218664 sent https://github.com/apache/beam/pull/30912 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] Skip calling Compute in RemoveSafeDeltaCounterCell if value exists [beam]

2024-04-09 Thread via GitHub
JayajP opened a new pull request, #30913: URL: https://github.com/apache/beam/pull/30913 This is a minor optimization for incrementing the new `PerWorkerCounters`. The benefits of this PR are detailed below: - Some quick load tests show that this makes incrementing counter

Re: [PR] [yaml] disable javascript mapping for python >=3.12 [beam]

2024-04-09 Thread via GitHub
tvalentyn merged PR #30843: URL: https://github.com/apache/beam/pull/30843 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[PR] Upgrade grpcio-tools. [beam]

2024-04-09 Thread via GitHub
tvalentyn opened a new pull request, #30912: URL: https://github.com/apache/beam/pull/30912 Upgrades the pinned version of grpcio-tools to a newer version, which is compatible with Python 3.12. Thank you for your contribution! Follow this checklist to

Re: [PR] [bug30870]: make consumer polling timeout configurable for KafkaIO.Read [beam]

2024-04-09 Thread via GitHub
damondouglas merged PR #30877: URL: https://github.com/apache/beam/pull/30877 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [yaml] add use-case example [beam]

2024-04-09 Thread via GitHub
liferoad commented on code in PR #30896: URL: https://github.com/apache/beam/pull/30896#discussion_r1558451641 ## sdks/python/apache_beam/yaml/examples/simple_filter.yaml: ## @@ -0,0 +1,41 @@ +# coding=utf-8 Review Comment: we could always create the temp csv file and run

Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam]

2024-04-09 Thread via GitHub
aaltay commented on issue #30911: URL: https://github.com/apache/beam/issues/30911#issuecomment-2046201043 /cc @damccorm @tvalentyn - FYI as this relates to an email discussion. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [yaml] add use-case example [beam]

2024-04-09 Thread via GitHub
liferoad commented on code in PR #30896: URL: https://github.com/apache/beam/pull/30896#discussion_r1558436710 ## sdks/python/apache_beam/yaml/examples/simple_filter_and_combine.yaml: ## @@ -0,0 +1,56 @@ +# coding=utf-8 +# +# Licensed to the Apache Software Foundation (ASF)

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558431502 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/IcebergIO.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558431145 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/IcebergIO.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558429972 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/CombinedScanReader.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558429324 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/CombinedScanReader.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558429734 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/CombinedScanReader.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30805: URL: https://github.com/apache/beam/pull/30805#discussion_r1558428029 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/CombinedScanReader.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Add direct path code path [beam]

2024-04-09 Thread via GitHub
m-trieu commented on code in PR #30764: URL: https://github.com/apache/beam/pull/30764#discussion_r1558353180 ## runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingApplianceConfigLoader.java: ## @@ -0,0

Re: [PR] Iceberg Write SchemaTransform [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30910: URL: https://github.com/apache/beam/pull/30910#issuecomment-2046087851 Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment `assign set of reviewers` -- This is an automated

Re: [PR] Re-add iceberg bounded source; test splitting [beam]

2024-04-09 Thread via GitHub
codecov-commenter commented on PR #30805: URL: https://github.com/apache/beam/pull/30805#issuecomment-2046069455 ## [Codecov](https://app.codecov.io/gh/apache/beam/pull/30805?dropdown=coverage=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report

Re: [I] [Bug]: GRCPIO 1.62.1 deadlocks in Beam SDK worker with Dataflow [beam]

2024-04-09 Thread via GitHub
tvalentyn commented on issue #30867: URL: https://github.com/apache/beam/issues/30867#issuecomment-2046067630 Can you share Dataflow Job IDs where you've seen this error? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[PR] Iceberg Write SchemaTransform [beam]

2024-04-09 Thread via GitHub
ahmedabu98 opened a new pull request, #30910: URL: https://github.com/apache/beam/pull/30910 Creating a SchemaTransform for the recently added Iceberg sink (#30797) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
Abacn merged PR #30907: URL: https://github.com/apache/beam/pull/30907 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [I] [Bug]: GRCPIO 1.62.1 deadlocks in Beam SDK worker with Dataflow [beam]

2024-04-09 Thread via GitHub
DerRidda commented on issue #30867: URL: https://github.com/apache/beam/issues/30867#issuecomment-2046007949 @tvalentyn Some further investigation might point at a combination of the protobuf library version with grpcio: https://github.com/grpc/grpc/issues/36256#issuecomment-2046006931

Re: [PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30907: URL: https://github.com/apache/beam/pull/30907#issuecomment-2045932432 Assigning reviewers. If you would like to opt out of this review, comment `assign to next reviewer`: R: @liferoad for label python. Available commands: - `stop

Re: [PR] [yaml] remove Combine from yaml_experimental_features [beam]

2024-04-09 Thread via GitHub
damccorm merged PR #30897: URL: https://github.com/apache/beam/pull/30897 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[I] [Feature Request]: Beam compat test suites should create compatible environments that installs Beam and Test environment dependencies [beam]

2024-04-09 Thread via GitHub
tvalentyn opened a new issue, #30909: URL: https://github.com/apache/beam/issues/30909 ### What would you like to happen? Current compat test suites first install test environment dependencies

Re: [PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
Abacn commented on PR #30907: URL: https://github.com/apache/beam/pull/30907#issuecomment-2045851422 thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
tvalentyn commented on PR #30907: URL: https://github.com/apache/beam/pull/30907#issuecomment-2045851056 ran `gradlew :sdks:python:test-suites:tox:py38:testPy38TensorflowHubEmbeddings-014 ` manually and checked that tox suite goes beyond the point of failure that happens on master. --

Re: [PR] [yaml] Add Beam YAML Blog [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30898: URL: https://github.com/apache/beam/pull/30898#issuecomment-2045845652 Assigning reviewers. If you would like to opt out of this review, comment `assign to next reviewer`: R: @damccorm for label website. Available commands: -

Re: [PR] Adds a bound on pydantic to exclude incompatible versions in the compat test. [beam]

2024-04-09 Thread via GitHub
tvalentyn commented on PR #30863: URL: https://github.com/apache/beam/pull/30863#issuecomment-2045833138 sent https://github.com/apache/beam/pull/30907 , which might help. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
tvalentyn commented on PR #30907: URL: https://github.com/apache/beam/pull/30907#issuecomment-2045832066 Run Python PostCommit Dependency -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[PR] Update a restriction for another test suite [beam]

2024-04-09 Thread via GitHub
tvalentyn opened a new pull request, #30907: URL: https://github.com/apache/beam/pull/30907 Follow up for: https://github.com/apache/beam/pull/30863 https://github.com/apache/beam/issues/30852 Thank you for your contribution! Follow this checklist

Re: [PR] [yaml] remove Combine from yaml_experimental_features [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30897: URL: https://github.com/apache/beam/pull/30897#issuecomment-2045760952 Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control -- This is an automated message from the Apache Git

Re: [PR] [yaml] remove Combine from yaml_experimental_features [beam]

2024-04-09 Thread via GitHub
Polber commented on PR #30897: URL: https://github.com/apache/beam/pull/30897#issuecomment-2045759032 R: @robertwb -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] Implement LockFreeHistogram and use it for PerWorkerHistograms [beam]

2024-04-09 Thread via GitHub
Abacn merged PR #30769: URL: https://github.com/apache/beam/pull/30769 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [yaml] add use-case example [beam]

2024-04-09 Thread via GitHub
Polber commented on code in PR #30896: URL: https://github.com/apache/beam/pull/30896#discussion_r1558060458 ## sdks/python/apache_beam/yaml/examples/simple_filter_and_combine.yaml: ## @@ -0,0 +1,56 @@ +# coding=utf-8 +# +# Licensed to the Apache Software Foundation (ASF) under

Re: [PR] [yaml] add use-case example [beam]

2024-04-09 Thread via GitHub
Polber commented on code in PR #30896: URL: https://github.com/apache/beam/pull/30896#discussion_r1558059292 ## sdks/python/apache_beam/yaml/examples/resources/products.csv: ## @@ -0,0 +1,6 @@ +transaction_id,product_name,category,price +T0012,Headphones,Electronics,59.99

Re: [PR] [yaml] add use-case example [beam]

2024-04-09 Thread via GitHub
Polber commented on code in PR #30896: URL: https://github.com/apache/beam/pull/30896#discussion_r1558057927 ## sdks/python/apache_beam/yaml/examples/simple_filter.yaml: ## @@ -0,0 +1,41 @@ +# coding=utf-8 Review Comment: I would assume everything under `apache_beam/` is

Re: [PR] [Testing] Try fixing inference benchmark tests [beam]

2024-04-09 Thread via GitHub
riteshghorse closed pull request #30855: [Testing] Try fixing inference benchmark tests URL: https://github.com/apache/beam/pull/30855 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [Flink] Speed up file write in batch mode by using larger bundle size [beam]

2024-04-09 Thread via GitHub
Abacn merged PR #30802: URL: https://github.com/apache/beam/pull/30802 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py311 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] closed pull request #30891: Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py311 URL: https://github.com/apache/beam/pull/30891 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py311 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] commented on PR #30891: URL: https://github.com/apache/beam/pull/30891#issuecomment-2045625607 Looks like pymongo is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py310 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] closed pull request #30889: Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py310 URL: https://github.com/apache/beam/pull/30889 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] Bump pymongo from 4.6.2 to 4.6.3 in /sdks/python/container/py310 [beam]

2024-04-09 Thread via GitHub
dependabot[bot] commented on PR #30889: URL: https://github.com/apache/beam/pull/30889#issuecomment-2045625112 Looks like pymongo is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1711845145 [beam]

2024-04-09 Thread via GitHub
Abacn merged PR #30816: URL: https://github.com/apache/beam/pull/30816 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] Adds a bound on pydantic to exclude incompatible versions in the compat test. [beam]

2024-04-09 Thread via GitHub
Abacn commented on PR #30863: URL: https://github.com/apache/beam/pull/30863#issuecomment-2045619368 Python Coverage PreCommit is fixed however https://github.com/apache/beam/actions/workflows/beam_PostCommit_Python_Dependency.yml?query=event%3Aschedule is still failing. Does the same fix

Re: [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam]

2024-04-09 Thread via GitHub
Abacn commented on issue #30593: URL: https://github.com/apache/beam/issues/30593#issuecomment-2045616843 now it fails to build container image: ``` 1: Task failed with an exception. --- * Where: Build file

Re: [PR] [wip]Add withFormatOnFailureFunction for BQ STORAGE_WRITE_API [beam]

2024-04-09 Thread via GitHub
AnandInguva commented on code in PR #30906: URL: https://github.com/apache/beam/pull/30906#discussion_r1557935162 ## sdks/java/io/google-cloud-platform/build.gradle: ## @@ -32,7 +32,8 @@ ext.summary = "IO library to read and write Google Cloud Platform systems from B

[PR] Add withFormatOnFailureFunction for BQ TableRow input [beam]

2024-04-09 Thread via GitHub
AnandInguva opened a new pull request, #30906: URL: https://github.com/apache/beam/pull/30906 **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us incorporate your contribution

Re: [PR] [java-extension-sql]Beam Sql doesn't honor aliases because of `BeamAggregateProjectMergeRule` optimization [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30902: URL: https://github.com/apache/beam/pull/30902#discussion_r155756 ## sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregateProjectMergeRuleTest.java: ## @@ -106,44 +106,6 @@ public void

Re: [PR] Initial Iceberg Sink [beam]

2024-04-09 Thread via GitHub
kennknowles merged PR #30797: URL: https://github.com/apache/beam/pull/30797 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] Revert #30533: Automatically execute unbounded pipelines in streaming mode. [beam]

2024-04-09 Thread via GitHub
kennknowles commented on PR #30706: URL: https://github.com/apache/beam/pull/30706#issuecomment-2045466784 The tests are entirely internal to Google so there is no externally tracked failure. You would have to write a pipeline with unbounded data and then insist on running it in batch

Re: [PR] Revert #30533: Automatically execute unbounded pipelines in streaming mode. [beam]

2024-04-09 Thread via GitHub
kennknowles commented on PR #30706: URL: https://github.com/apache/beam/pull/30706#issuecomment-2045464303 The description is not accurate - we have an underlying bug in dataflow and some erroneous tests. The original commit was a correct change. This is reverted while we fix our tests and

Re: [PR] #30903: Do not reemit data from impulse [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30905: URL: https://github.com/apache/beam/pull/30905#issuecomment-2045434378 Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control -- This is an automated message from the Apache Git

Re: [PR] #30903: Do not reemit data from impulse [beam]

2024-04-09 Thread via GitHub
je-ik commented on PR #30905: URL: https://github.com/apache/beam/pull/30905#issuecomment-2045431614 R: @JozoVilcek -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] Initial Iceberg Sink [beam]

2024-04-09 Thread via GitHub
kennknowles commented on code in PR #30797: URL: https://github.com/apache/beam/pull/30797#discussion_r1557812336 ## sdks/java/io/iceberg/src/main/java/org/apache/beam/io/iceberg/RecordWriter.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] #30903: Do not reemit data from impulse [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30905: URL: https://github.com/apache/beam/pull/30905#issuecomment-2045414641 Assigning reviewers. If you would like to opt out of this review, comment `assign to next reviewer`: R: @Abacn for label build. Available commands: - `stop

[PR] #30903: Do not reemit data from impulse [beam]

2024-04-09 Thread via GitHub
je-ik opened a new pull request, #30905: URL: https://github.com/apache/beam/pull/30905 Closes #30903 Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the

Re: [PR] Load and Stress Tests: Add workflows, improvements and fixes [beam]

2024-04-09 Thread via GitHub
Amar3tto commented on code in PR #30848: URL: https://github.com/apache/beam/pull/30848#discussion_r1557680032 ## .github/workflows/beam_StressTests_Java_KafkaIO.yml: ## @@ -0,0 +1,111 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor

Re: [PR] Create YAML Join Transform [beam]

2024-04-09 Thread via GitHub
itodotimothy6 commented on code in PR #30734: URL: https://github.com/apache/beam/pull/30734#discussion_r1557157650 ## sdks/python/apache_beam/yaml/yaml_join.py: ## @@ -0,0 +1,273 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license

Re: [PR] Bump github.com/apache/beam/sdks/v2 from 2.55.0 to 2.55.1 [beam-starter-go]

2024-04-09 Thread via GitHub
damccorm merged PR #35: URL: https://github.com/apache/beam-starter-go/pull/35 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] Bump apache-beam from 2.55.0 to 2.55.1 [beam-starter-python]

2024-04-09 Thread via GitHub
damccorm merged PR #31: URL: https://github.com/apache/beam-starter-python/pull/31 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[PR] Bump apache-beam from 2.55.0 to 2.55.1 [beam-starter-python]

2024-04-09 Thread via GitHub
dependabot[bot] opened a new pull request, #31: URL: https://github.com/apache/beam-starter-python/pull/31 Bumps [apache-beam](https://github.com/apache/beam) from 2.55.0 to 2.55.1. Release notes Sourced from https://github.com/apache/beam/releases;>apache-beam's releases.

Re: [PR] [YAML] Add support for callable kwargs for Combine, PyTransform and custom python transform providers [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30117: URL: https://github.com/apache/beam/pull/30117#issuecomment-2045090964 This pull request has been closed due to lack of activity. If you think that is incorrect, or the pull request requires review, you can revive the PR at any time. -- This

Re: [PR] [YAML] Add support for callable kwargs for Combine, PyTransform and custom python transform providers [beam]

2024-04-09 Thread via GitHub
github-actions[bot] closed pull request #30117: [YAML] Add support for callable kwargs for Combine, PyTransform and custom python transform providers URL: https://github.com/apache/beam/pull/30117 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] Add config validation to kafka read schema transform [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30625: URL: https://github.com/apache/beam/pull/30625#issuecomment-2045016191 Reminder, please take a look at this pr: @damondouglas @ahmedabu98 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] Clean up stale code in BigtableService [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30172: URL: https://github.com/apache/beam/pull/30172#issuecomment-2045016335 Assigning new set of reviewers because Pr has gone too long without review. If you would like to opt out of this review, comment `assign to next reviewer`: R: @robertwb

Re: [PR] Update Python Dependencies from BRANCH weekly_update_python_dependencies_1711845145 [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30816: URL: https://github.com/apache/beam/pull/30816#issuecomment-2045016087 Reminder, please take a look at this pr: @robertwb -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] Load and Stress Tests: Add workflows, improvements and fixes [beam]

2024-04-09 Thread via GitHub
volatilemolotov commented on code in PR #30848: URL: https://github.com/apache/beam/pull/30848#discussion_r1557394518 ## .github/workflows/beam_StressTests_Java_KafkaIO.yml: ## @@ -0,0 +1,111 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +#

Re: [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on issue #30593: URL: https://github.com/apache/beam/issues/30593#issuecomment-2044565232 Reopening since the workflow is still flaky -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam]

2024-04-09 Thread via GitHub
github-actions[bot] opened a new issue, #30904: URL: https://github.com/apache/beam/issues/30904 The PostCommit XVR PythonUsingJava Dataflow is failing over 50% of the time Please visit

[PR] Bump github.com/apache/beam/sdks/v2 from 2.55.0 to 2.55.1 [beam-starter-go]

2024-04-09 Thread via GitHub
dependabot[bot] opened a new pull request, #35: URL: https://github.com/apache/beam-starter-go/pull/35 Bumps [github.com/apache/beam/sdks/v2](https://github.com/apache/beam) from 2.55.0 to 2.55.1. Release notes Sourced from

Re: [PR] [java-extension-sql]Beam Sql doesn't honor aliases because of `BeamAggregateProjectMergeRule` optimization [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30902: URL: https://github.com/apache/beam/pull/30902#issuecomment-2044393719 Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment `assign set of reviewers` -- This is an automated

[PR] [java-extension-sql]Beam Sql doesn't honor aliases because of `BeamAggregateProjectMergeRule` optimization [beam]

2024-04-09 Thread via GitHub
brachi-wernick opened a new pull request, #30902: URL: https://github.com/apache/beam/pull/30902 Fixes #30498 See full discussion -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] Bump google.golang.org/grpc from 1.62.1 to 1.63.2 in /sdks [beam]

2024-04-09 Thread via GitHub
github-actions[bot] commented on PR #30900: URL: https://github.com/apache/beam/pull/30900#issuecomment-2044286043 Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment `assign set of reviewers` -- This is an automated

Re: [PR] Elasticsearch enable Point In Time based searches [beam]

2024-04-09 Thread via GitHub
prodriguezdefino commented on PR #30824: URL: https://github.com/apache/beam/pull/30824#issuecomment-2044220747 Run Java_ElasticSearch_IO_Direct PreCommit -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

Re: [PR] Elasticsearch enable Point In Time based searches [beam]

2024-04-09 Thread via GitHub
prodriguezdefino commented on PR #30824: URL: https://github.com/apache/beam/pull/30824#issuecomment-2044211304 Run Java_ElasticSearch_IO_Direct PreCommit -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above