(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 8b12c2d3e8e Updating config from bot
8b12c2d3e8e is described below

commit 8b12c2d3e8e00aa4a088ada34599916733ff0197
Author: github-actions 
AuthorDate: Thu Mar 21 05:34:32 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/reviewers-for-label-go.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-go.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-go.json
index 383c9816fc2..1b6e3439deb 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-go.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-go.json
@@ -1,7 +1,7 @@
 {
   "label": "go",
   "dateOfLastReviewAssignment": {
-"lostluck": 171082643,
+"lostluck": 1710999270077,
 "jrmccluskey": 1710911140654,
 "youngoli": 1657688896155,
 "damccorm": 1680501930289,



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 41a93809b0e Updating config from bot
41a93809b0e is described below

commit 41a93809b0e572611eb63b61de5c1a05f75b5e3b
Author: github-actions 
AuthorDate: Thu Mar 21 05:34:34 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30698.json | 10 ++
 1 file changed, 10 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30698.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30698.json
new file mode 100644
index 000..aa3638a74ec
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30698.json
@@ -0,0 +1,10 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"go": "riteshghorse"
+  },
+  "nextAction": "Reviewers",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new cb0ca4db22a Updating config from bot
cb0ca4db22a is described below

commit cb0ca4db22ac9169dbda2deb97b06d6265232746
Author: github-actions 
AuthorDate: Thu Mar 21 05:34:36 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/reviewers-for-label-go.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-go.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-go.json
index 1b6e3439deb..a61e5ccd085 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-go.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-go.json
@@ -5,6 +5,6 @@
 "jrmccluskey": 1710911140654,
 "youngoli": 1657688896155,
 "damccorm": 1680501930289,
-"riteshghorse": 1710911136987
+"riteshghorse": 1710999274126
   }
 }
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new d89d6498145 Updating config from bot
d89d6498145 is described below

commit d89d64981457d13d1b07459de5116c358438bae6
Author: github-actions 
AuthorDate: Thu Mar 21 05:34:31 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30699.json | 10 ++
 1 file changed, 10 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30699.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30699.json
new file mode 100644
index 000..8ea94810368
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30699.json
@@ -0,0 +1,10 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"go": "lostluck"
+  },
+  "nextAction": "Reviewers",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch dependabot/go_modules/sdks/google.golang.org/api-0.170.0 created (now 41ff5ac4a62)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/go_modules/sdks/google.golang.org/api-0.170.0
in repository https://gitbox.apache.org/repos/asf/beam.git


  at 41ff5ac4a62 Bump google.golang.org/api from 0.166.0 to 0.170.0 in /sdks

No new revisions were added by this update.



(beam) branch dependabot/go_modules/sdks/github.com/golang/protobuf-1.5.4 created (now 048c69a48ce)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/go_modules/sdks/github.com/golang/protobuf-1.5.4
in repository https://gitbox.apache.org/repos/asf/beam.git


  at 048c69a48ce Bump github.com/golang/protobuf from 1.5.3 to 1.5.4 in 
/sdks

No new revisions were added by this update.



(beam) branch nightly-refs/heads/master updated (389e1067c9d -> 8955124219c)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


from 389e1067c9d Disable unsupported custom window type test on samza and 
spark. (#30680)
 add 81cb194f8d1 Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks 
(#30685)
 add 8206d8976d5 Bump github.com/docker/docker in /sdks (#30684)
 add a9ce7700ade Send email when BQ early rollout workflow fails (#30694)
 add f4d03d49713 Minimize scope of expensive lock (#30679)
 add 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)"
 add cdaae0a7fb6 Merge pull request #30691: Revert #30425 "add a way for 
channels to be closed manually"
 add 4a3b6c55fd8 Use unique GCS object path (#30690)
 add 8955124219c Add BigTableIO Stress test (#30630)

No new revisions were added by this update.

Summary of changes:
 .../beam_PostCommit_Java_BigQueryEarlyRollout.yml  |  21 +-
 it/google-cloud-platform/build.gradle  |   5 +-
 .../org/apache/beam/it/gcp/IOLoadTestBase.java |  34 ++
 .../org/apache/beam/it/gcp/IOStressTestBase.java   | 123 +++
 .../apache/beam/it/gcp/bigquery/BigQueryIOST.java  | 105 +-
 .../apache/beam/it/gcp/bigtable/BigTableIOST.java  | 389 +
 it/kafka/build.gradle  |   4 +-
 .../java/org/apache/beam/it/kafka/KafkaIOST.java   | 156 ++---
 .../src/main/groovy/MobileGamingCommands.groovy|   5 +-
 .../main/groovy/mobilegaming-java-dataflow.groovy  |   5 +-
 .../main/groovy/mobilegaming-java-direct.groovy|   5 +-
 .../google-cloud-dataflow-java/worker/build.gradle |  12 -
 .../dataflow/worker/StreamingDataflowWorker.java   |  11 +-
 .../worker/windmill/WindmillConnection.java|   5 -
 .../windmill/client/grpc/GrpcDispatcherClient.java |   4 +-
 .../windmill/client/grpc/GrpcWindmillServer.java   |  29 +-
 .../client/grpc/StreamingEngineClient.java |  25 +-
 .../windmill/client/grpc/stubs/ChannelCache.java   | 117 ---
 .../grpc/stubs/ChannelCachingStubFactory.java  |  38 --
 .../client/grpc/stubs/IsolationChannel.java|   2 +-
 ...Factory.java => RemoteWindmillStubFactory.java} |  38 +-
 .../client/grpc/stubs/WindmillChannelFactory.java  |   2 +-
 .../client/grpc/GrpcWindmillServerTest.java|   3 +-
 .../client/grpc/StreamingEngineClientTest.java |  31 +-
 .../client/grpc/WindmillStreamSenderTest.java  |   3 +-
 .../client/grpc/stubs/ChannelCacheTest.java| 150 
 .../windmill/testing/FakeWindmillStubFactory.java  |  27 +-
 .../budget/EvenGetWorkBudgetDistributorTest.java   |   7 +-
 sdks/go.mod|   6 +-
 sdks/go.sum|  12 +-
 .../resources/beam/checkstyle/suppressions.xml |   1 +
 .../apache_beam/runners/worker/sdk_worker.py   |  14 +-
 32 files changed, 706 insertions(+), 683 deletions(-)
 create mode 100644 
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOStressTestBase.java
 create mode 100644 
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigTableIOST.java
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCache.java
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCachingStubFactory.java
 rename 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/{ChannelCachingRemoteStubFactory.java
 => RemoteWindmillStubFactory.java} (67%)
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCacheTest.java



(beam) branch master updated: Add BigTableIO Stress test (#30630)

2024-03-20 Thread yhu
This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new 8955124219c Add BigTableIO Stress test (#30630)
8955124219c is described below

commit 8955124219cf9bd6dcea74f22c70fed7940da2b8
Author: akashorabek <70029317+akashora...@users.noreply.github.com>
AuthorDate: Thu Mar 21 06:07:57 2024 +0600

Add BigTableIO Stress test (#30630)

* Add BigTableIO Stress test

* refactor

* update dependency tree

* refactor

* Add stress test files to grpc/protobuff exception ignore list

* move exportMetrics method to IOLoadTestBase class

* refactor

* refactor
---
 it/google-cloud-platform/build.gradle  |   5 +-
 .../org/apache/beam/it/gcp/IOLoadTestBase.java |  34 ++
 .../org/apache/beam/it/gcp/IOStressTestBase.java   | 123 +++
 .../apache/beam/it/gcp/bigquery/BigQueryIOST.java  | 105 +-
 .../apache/beam/it/gcp/bigtable/BigTableIOST.java  | 389 +
 it/kafka/build.gradle  |   4 +-
 .../java/org/apache/beam/it/kafka/KafkaIOST.java   | 156 ++---
 .../resources/beam/checkstyle/suppressions.xml |   1 +
 8 files changed, 578 insertions(+), 239 deletions(-)

diff --git a/it/google-cloud-platform/build.gradle 
b/it/google-cloud-platform/build.gradle
index 9717b5f8c84..3353a9692cb 100644
--- a/it/google-cloud-platform/build.gradle
+++ b/it/google-cloud-platform/build.gradle
@@ -32,6 +32,7 @@ dependencies {
 implementation project(path: ":runners:google-cloud-dataflow-java")
 implementation project(path: ":it:conditions", configuration: "shadow")
 implementation project(path: ":it:truthmatchers", configuration: "shadow")
+implementation project(path: ":sdks:java:testing:test-utils")
 implementation library.java.slf4j_api
 implementation library.java.vendored_guava_32_1_2_jre
 implementation library.java.jackson_core
@@ -48,6 +49,7 @@ dependencies {
 implementation library.java.protobuf_java
 implementation library.java.threetenbp
 implementation 'org.awaitility:awaitility:4.2.0'
+implementation 'joda-time:joda-time:2.10.10'
 // Google Cloud Dependencies
 implementation library.java.google_api_services_bigquery
 implementation library.java.google_cloud_core
@@ -71,7 +73,6 @@ dependencies {
 implementation 'com.google.cloud:google-cloud-secretmanager'
 provided 'com.google.api.grpc:proto-google-cloud-secretmanager-v1'
 
-testImplementation project(path: ":sdks:java:testing:test-utils")
 testImplementation project(path: ":sdks:java:io:google-cloud-platform")
 testImplementation project(path: ":sdks:java:extensions:protobuf", 
configuration: "testRuntimeMigration")
 testImplementation project(path: ":sdks:java:io:synthetic")
@@ -83,6 +84,8 @@ dependencies {
 
 tasks.register("GCSPerformanceTest", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'FileBasedIOLT', ['configuration':'large','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
 tasks.register("BigTablePerformanceTest", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigTableIOLT', ['configuration':'large','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
+tasks.register("BigTableStressTestMedium", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigTableIOST', ['configuration':'medium','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
+tasks.register("BigTableStressTestLarge", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigTableIOST', ['configuration':'large','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
 tasks.register("BigQueryPerformanceTest", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigQueryIOLT', ['configuration':'medium','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
 tasks.register("BigQueryStressTestMedium", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigQueryIOST', ['configuration':'medium','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
 tasks.register("BigQueryStressTestLarge", 
IoPerformanceTestUtilities.IoPerformanceTest, project, 'google-cloud-platform', 
'BigQueryIOST', ['configuration':'large','project':'apache-beam-testing', 
'artifactBucket':'io-performance-temp'])
diff --git 
a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOLoadTestBase.java
 
b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOLoadTestBase.java
index 6b728a6a60d..e5f20c07c01 100644
--- 
a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOLoadTestBase.java
+++ 

(beam) branch asf-site updated: Publishing website 2024/03/20 23:39:10 at commit cdaae0a

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/asf-site by this push:
 new 85f275c7450 Publishing website 2024/03/20 23:39:10 at commit cdaae0a
85f275c7450 is described below

commit 85f275c7450982c064e2071ba6ca05aa94a29823
Author: runner 
AuthorDate: Wed Mar 20 23:39:10 2024 +

Publishing website 2024/03/20 23:39:10 at commit cdaae0a
---
 website/generated-content/sitemap.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/website/generated-content/sitemap.xml 
b/website/generated-content/sitemap.xml
index 49333a57b1e..f382cc53eb9 100644
--- a/website/generated-content/sitemap.xml
+++ b/website/generated-content/sitemap.xml
@@ -1 +1 @@
-http://www.sitemaps.org/schemas/sitemap/0.9"; 
xmlns:xhtml="http://www.w3.org/1999/xhtml";>/blog/beam-2.54.0/2024-03-20T09:57:22-07:00/categories/blog/2024-03-20T09:57:22-07:00/blog/2024-03-20T09:57:22-07:00/categories/2024-03-20T09:57:22-07:00/catego
 [...]
\ No newline at end of file
+http://www.sitemaps.org/schemas/sitemap/0.9"; 
xmlns:xhtml="http://www.w3.org/1999/xhtml";>/blog/beam-2.54.0/2024-03-20T18:28:21-04:00/categories/blog/2024-03-20T18:28:21-04:00/blog/2024-03-20T18:28:21-04:00/categories/2024-03-20T18:28:21-04:00/catego
 [...]
\ No newline at end of file



(beam) branch master updated: Use unique GCS object path (#30690)

2024-03-20 Thread damondouglas
This is an automated email from the ASF dual-hosted git repository.

damondouglas pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new 4a3b6c55fd8 Use unique GCS object path (#30690)
4a3b6c55fd8 is described below

commit 4a3b6c55fd8a02911b99d7ef8b5fa6f006c23fb2
Author: Damon 
AuthorDate: Wed Mar 20 16:35:59 2024 -0700

Use unique GCS object path (#30690)
---
 release/src/main/groovy/MobileGamingCommands.groovy   | 5 +++--
 release/src/main/groovy/mobilegaming-java-dataflow.groovy | 5 -
 release/src/main/groovy/mobilegaming-java-direct.groovy   | 5 -
 3 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/release/src/main/groovy/MobileGamingCommands.groovy 
b/release/src/main/groovy/MobileGamingCommands.groovy
index 2b38943067a..39f526d7da8 100644
--- a/release/src/main/groovy/MobileGamingCommands.groovy
+++ b/release/src/main/groovy/MobileGamingCommands.groovy
@@ -21,6 +21,7 @@
 class MobileGamingCommands {
 
   private TestScripts testScripts
+  private String testRunId
 
   private static final INPUT_GAMING_DATA = 
"gs://dataflow-samples/game/5000_gaming_data.csv"
 
@@ -58,11 +59,11 @@ class MobileGamingCommands {
 "BattleshipGrey"))
 
   public String getUserScoreOutputName(String runner){
-return "java-userscore-result-${RUNNERS[runner]}.txt"
+return "java-userscore-result-${RUNNERS[runner]}/${testRunId}/output"
   }
 
   public String getHourlyTeamScoreOutputName(String runner){
-return "java-hourlyteamscore-result-${RUNNERS[runner]}.txt"
+return "java-hourlyteamscore-result-${RUNNERS[runner]}/${testRunId}/output"
   }
 
   public String createPipelineCommand(String exampleName, String runner, 
String jobName='', String className=null){
diff --git a/release/src/main/groovy/mobilegaming-java-dataflow.groovy 
b/release/src/main/groovy/mobilegaming-java-dataflow.groovy
index 462b3d2cea0..bb0b76bd675 100644
--- a/release/src/main/groovy/mobilegaming-java-dataflow.groovy
+++ b/release/src/main/groovy/mobilegaming-java-dataflow.groovy
@@ -18,7 +18,6 @@
  */
 
 t = new TestScripts(args)
-mobileGamingCommands = new MobileGamingCommands(testScripts: t)
 
 /*
  * Run the mobile game examples on Dataflow.
@@ -36,6 +35,8 @@ String command_output_text
  *  Run the UserScore example on DataflowRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: UserScore example on DataflowRunner")
 t.run(mobileGamingCommands.createPipelineCommand("UserScore", runner))
 command_output_text = t.run "gsutil cat 
gs://${t.gcsBucket()}/${mobileGamingCommands.getUserScoreOutputName(runner)}* | 
grep user19_BananaWallaby"
@@ -48,6 +49,8 @@ t.run "gsutil rm 
gs://${t.gcsBucket()}/${mobileGamingCommands.getUserScoreOutput
  * Run the HourlyTeamScore example on DataflowRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: HourlyTeamScore example on DataflowRunner")
 t.run(mobileGamingCommands.createPipelineCommand("HourlyTeamScore", runner))
 command_output_text = t.run "gsutil cat 
gs://${t.gcsBucket()}/${mobileGamingCommands.getHourlyTeamScoreOutputName(runner)}*
 | grep AzureBilby "
diff --git a/release/src/main/groovy/mobilegaming-java-direct.groovy 
b/release/src/main/groovy/mobilegaming-java-direct.groovy
index 9ff24cefaf9..3c6f4ca01a6 100644
--- a/release/src/main/groovy/mobilegaming-java-direct.groovy
+++ b/release/src/main/groovy/mobilegaming-java-direct.groovy
@@ -18,7 +18,6 @@
  */
 
 t = new TestScripts(args)
-mobileGamingCommands = new MobileGamingCommands(testScripts: t)
 
 /*
  * Run the mobile game examples on DirectRunner.
@@ -36,6 +35,8 @@ String command_output_text
  * Run the UserScore example with DirectRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: UserScore example on DirectRunner")
 t.run(mobileGamingCommands.createPipelineCommand("UserScore", runner))
 command_output_text = t.run "grep user19_BananaWallaby 
${mobileGamingCommands.getUserScoreOutputName(runner)}* "
@@ -47,6 +48,8 @@ t.success("UserScore successfully run on DirectRunners.")
  * Run the HourlyTeamScore example with DirectRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: HourlyTeamScore example on DirectRunner")
 t.run(mobileGamingCommands.createPipelineCommand("HourlyTeamScore", runner))
 command_output_text = t.run "grep AzureBilby 
${mobileGamingCommands.getHourlyTeamScoreOutputName(runner)}* "



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 8a080aa5038 Updating config from bot
8a080aa5038 is described below

commit 8a080aa50381cf5ff2bd5981c754419e57138031
Author: github-actions 
AuthorDate: Wed Mar 20 23:34:41 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/reviewers-for-label-python.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-python.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-python.json
index cb711f1f431..bfbec6f766c 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-python.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-python.json
@@ -10,7 +10,7 @@
 "y1chi": 1667002607045,
 "damccorm": 1709863822385,
 "jrmccluskey": 1710776076591,
-"riteshghorse": 1709764491759,
+"riteshghorse": 1710977678377,
 "liferoad": 1710819285271,
 "shunping": 1710265960889
   }



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 100be857096 Updating config from bot
100be857096 is described below

commit 100be857096cf5f96677112a79071d36d134498d
Author: github-actions 
AuthorDate: Wed Mar 20 23:34:39 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30696.json | 10 ++
 1 file changed, 10 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30696.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30696.json
new file mode 100644
index 000..c43704aa814
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30696.json
@@ -0,0 +1,10 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"python": "riteshghorse"
+  },
+  "nextAction": "Reviewers",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new e5176e8e631 Updating config from bot
e5176e8e631 is described below

commit e5176e8e6313cd998f3097815bd3cd121ddd64bd
Author: github-actions 
AuthorDate: Wed Mar 20 23:06:53 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30690.json | 10 ++
 1 file changed, 10 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30690.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30690.json
new file mode 100644
index 000..9c51466b9ee
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30690.json
@@ -0,0 +1,10 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"build": "Abacn"
+  },
+  "nextAction": "Reviewers",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new f27cbbfacea Updating config from bot
f27cbbfacea is described below

commit f27cbbfaceaa504fae40de70288f6f526f0a388c
Author: github-actions 
AuthorDate: Wed Mar 20 23:06:54 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/reviewers-for-label-build.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-build.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-build.json
index d5eeca57d2f..a9d18e2bc9c 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-build.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-build.json
@@ -2,6 +2,6 @@
   "label": "build",
   "dateOfLastReviewAssignment": {
 "damccorm": 1710819285271,
-"Abacn": 1710630350352
+"Abacn": 1710976011952
   }
 }
\ No newline at end of file



(beam) branch revert-30425-mt-shutdown-channels deleted (was 8681ab9901d)

2024-03-20 Thread kenn
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a change to branch revert-30425-mt-shutdown-channels
in repository https://gitbox.apache.org/repos/asf/beam.git


 was 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)"

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam) 01/01: Merge pull request #30691: Revert #30425 "add a way for channels to be closed manually"

2024-03-20 Thread kenn
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit cdaae0a7fb63bd679823488f901603e135d6db67
Merge: f4d03d49713 8681ab9901d
Author: Kenneth Knowles 
AuthorDate: Wed Mar 20 18:28:21 2024 -0400

Merge pull request #30691: Revert #30425 "add a way for channels to be 
closed manually"

 .../google-cloud-dataflow-java/worker/build.gradle |  12 --
 .../dataflow/worker/StreamingDataflowWorker.java   |  11 +-
 .../worker/windmill/WindmillConnection.java|   5 -
 .../windmill/client/grpc/GrpcDispatcherClient.java |   4 +-
 .../windmill/client/grpc/GrpcWindmillServer.java   |  29 +---
 .../client/grpc/StreamingEngineClient.java |  25 ++--
 .../windmill/client/grpc/stubs/ChannelCache.java   | 117 
 .../grpc/stubs/ChannelCachingStubFactory.java  |  38 --
 .../client/grpc/stubs/IsolationChannel.java|   2 +-
 ...Factory.java => RemoteWindmillStubFactory.java} |  38 +++---
 .../client/grpc/stubs/WindmillChannelFactory.java  |   2 +-
 .../client/grpc/GrpcWindmillServerTest.java|   3 +-
 .../client/grpc/StreamingEngineClientTest.java |  31 +++--
 .../client/grpc/WindmillStreamSenderTest.java  |   3 +-
 .../client/grpc/stubs/ChannelCacheTest.java| 150 -
 .../windmill/testing/FakeWindmillStubFactory.java  |  27 ++--
 .../budget/EvenGetWorkBudgetDistributorTest.java   |   7 +-
 17 files changed, 78 insertions(+), 426 deletions(-)



(beam) branch master updated (f4d03d49713 -> cdaae0a7fb6)

2024-03-20 Thread kenn
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


from f4d03d49713 Minimize scope of expensive lock (#30679)
 add 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)"
 new cdaae0a7fb6 Merge pull request #30691: Revert #30425 "add a way for 
channels to be closed manually"

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../google-cloud-dataflow-java/worker/build.gradle |  12 --
 .../dataflow/worker/StreamingDataflowWorker.java   |  11 +-
 .../worker/windmill/WindmillConnection.java|   5 -
 .../windmill/client/grpc/GrpcDispatcherClient.java |   4 +-
 .../windmill/client/grpc/GrpcWindmillServer.java   |  29 +---
 .../client/grpc/StreamingEngineClient.java |  25 ++--
 .../windmill/client/grpc/stubs/ChannelCache.java   | 117 
 .../grpc/stubs/ChannelCachingStubFactory.java  |  38 --
 .../client/grpc/stubs/IsolationChannel.java|   2 +-
 ...Factory.java => RemoteWindmillStubFactory.java} |  38 +++---
 .../client/grpc/stubs/WindmillChannelFactory.java  |   2 +-
 .../client/grpc/GrpcWindmillServerTest.java|   3 +-
 .../client/grpc/StreamingEngineClientTest.java |  31 +++--
 .../client/grpc/WindmillStreamSenderTest.java  |   3 +-
 .../client/grpc/stubs/ChannelCacheTest.java| 150 -
 .../windmill/testing/FakeWindmillStubFactory.java  |  27 ++--
 .../budget/EvenGetWorkBudgetDistributorTest.java   |   7 +-
 17 files changed, 78 insertions(+), 426 deletions(-)
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCache.java
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCachingStubFactory.java
 rename 
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/{ChannelCachingRemoteStubFactory.java
 => RemoteWindmillStubFactory.java} (67%)
 delete mode 100644 
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCacheTest.java



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 5c5a033bc24 Updating config from bot
5c5a033bc24 is described below

commit 5c5a033bc2420f30bcff63ca831681a4950855a4
Author: github-actions 
AuthorDate: Wed Mar 20 22:05:42 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30695.json | 8 
 1 file changed, 8 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30695.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30695.json
new file mode 100644
index 000..242a48d7d3b
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30695.json
@@ -0,0 +1,8 @@
+{
+  "commentedAboutFailingChecks": true,
+  "reviewersAssignedForLabels": {},
+  "nextAction": "Author",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch users/damccorm/critSection deleted (was afe5bc1ebd7)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


 was afe5bc1ebd7 fmt

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam) branch master updated: Minimize scope of expensive lock (#30679)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new f4d03d49713 Minimize scope of expensive lock (#30679)
f4d03d49713 is described below

commit f4d03d49713cf89260c141ee35b4dadb31ad4193
Author: Danny McCormick 
AuthorDate: Wed Mar 20 16:42:38 2024 -0400

Minimize scope of expensive lock (#30679)

* Minimize scope of expensive lock

* Build list in lock

* Update sdks/python/apache_beam/runners/worker/sdk_worker.py

Co-authored-by: tvalentyn 

* Move comment

* Simplify

* fmt

-

Co-authored-by: tvalentyn 
---
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 14 ++
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker.py 
b/sdks/python/apache_beam/runners/worker/sdk_worker.py
index 04b58a6f198..65059ab054f 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker.py
@@ -607,12 +607,18 @@ class BundleProcessorCache(object):
 # type: () -> None
 def shutdown_inactive_bundle_processors():
   # type: () -> None
+  inactive_descriptor_ids = []
+  inactive_time = time.time(
+  ) - DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S
   with self._lock:
 for descriptor_id, last_access_time in self.last_access_times.items():
-  if (time.time() - last_access_time >
-  DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S):
-BundleProcessorCache._shutdown_cached_bundle_processors(
-self.cached_bundle_processors[descriptor_id])
+  if (inactive_time > last_access_time):
+inactive_descriptor_ids.append(descriptor_id)
+
+  # Shutdown can be expensive, keep out of lock
+  for descriptor_id in inactive_descriptor_ids:
+BundleProcessorCache._shutdown_cached_bundle_processors(
+self.cached_bundle_processors[descriptor_id])
 
 self.periodic_shutdown = PeriodicThread(
 DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S,



(beam) branch master updated: Send email when BQ early rollout workflow fails (#30694)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new a9ce7700ade Send email when BQ early rollout workflow fails (#30694)
a9ce7700ade is described below

commit a9ce7700adef058cf93a84906d725d4ecd646aad
Author: Danny McCormick 
AuthorDate: Wed Mar 20 16:14:06 2024 -0400

Send email when BQ early rollout workflow fails (#30694)
---
 .../beam_PostCommit_Java_BigQueryEarlyRollout.yml   | 21 -
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml 
b/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
index f832c5fab56..d0b58dd77c8 100644
--- a/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
+++ b/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
@@ -85,6 +85,25 @@ jobs:
 uses: ./.github/actions/gradle-command-self-hosted-action
 with:
   gradle-command: 
:sdks:java:io:google-cloud-platform:bigQueryEarlyRolloutIntegrationTest
+  - name: Generate Date
+if: failure()
+run: |
+  date=$(date -u +"%Y-%m-%d")
+  echo "date=$date" >> $GITHUB_ENV
+  - name: Send email
+uses: dawidd6/action-send-mail@v3
+if: failure()
+with:
+  server_address: smtp.gmail.com
+  server_port: 465
+  secure: true
+  username: ${{ secrets.ISSUE_REPORT_SENDER_EMAIL_ADDRESS }}
+  password: ${{ secrets.ISSUE_REPORT_SENDER_EMAIL_PASSWORD }}
+  subject: BigQueryEarlyRollout Beam Failure (${{ env.date }}) - 
investigate and escalate quickly
+  to: datapls-plat-t...@google.com # Team at Google responsible for 
escalating BQ failures
+  from: gacti...@beam.apache.org
+  body: |
+PostCommit Java BigQueryEarlyRollout failed on ${{ env.date }}. 
This test monitors BigQuery rollouts impacting Beam and should be escalated 
immediately if a real issue is encountered to pause further rollouts. For 
further details refer to the following links:\n * Failing job: 
https://github.com/apache/beam/actions/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
 \n * Job configuration: 
https://github.com/apache/beam/blob/master/.github/workflows/beam_PostCommit_Java_Bi
 [...]
   - name: Archive JUnit Test Results
 uses: actions/upload-artifact@v4
 if: ${{ !success() }}
@@ -97,4 +116,4 @@ jobs:
 with:
   commit: '${{ env.prsha || env.GITHUB_SHA }}'
   comment_mode: ${{ github.event_name == 'issue_comment'  && 'always' 
|| 'off' }}
-  files: '**/build/test-results/**/*.xml'
\ No newline at end of file
+  files: '**/build/test-results/**/*.xml'



(beam) branch users/damccorm/bq-escalation deleted (was 4c4039b73d3)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/bq-escalation
in repository https://gitbox.apache.org/repos/asf/beam.git


 was 4c4039b73d3 Send email when BQ early rollout workflow fails

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 43c057a3b25 Updating config from bot
43c057a3b25 is described below

commit 43c057a3b255d917c334003c1e3e8d6f7d1f6971
Author: github-actions 
AuthorDate: Wed Mar 20 20:06:30 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30693.json | 8 
 1 file changed, 8 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30693.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30693.json
new file mode 100644
index 000..242a48d7d3b
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30693.json
@@ -0,0 +1,8 @@
+{
+  "commentedAboutFailingChecks": true,
+  "reviewersAssignedForLabels": {},
+  "nextAction": "Author",
+  "stopReviewerNotifications": false,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new a12de0dd2a7 Updating config from bot
a12de0dd2a7 is described below

commit a12de0dd2a76a4bcbae458820937d79c93e475cc
Author: github-actions 
AuthorDate: Wed Mar 20 19:31:35 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30694.json | 8 
 1 file changed, 8 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30694.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30694.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30694.json
@@ -0,0 +1,8 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {},
+  "nextAction": "Author",
+  "stopReviewerNotifications": true,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch users/damccorm/bq-escalation created (now 4c4039b73d3)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/bq-escalation
in repository https://gitbox.apache.org/repos/asf/beam.git


  at 4c4039b73d3 Send email when BQ early rollout workflow fails

This branch includes the following new commits:

 new 4c4039b73d3 Send email when BQ early rollout workflow fails

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.




(beam) 01/01: Send email when BQ early rollout workflow fails

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch users/damccorm/bq-escalation
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 4c4039b73d37a9946a69624e260767d21843f364
Author: Danny McCormick 
AuthorDate: Wed Mar 20 15:28:53 2024 -0400

Send email when BQ early rollout workflow fails
---
 .../beam_PostCommit_Java_BigQueryEarlyRollout.yml   | 21 -
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml 
b/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
index f832c5fab56..d0b58dd77c8 100644
--- a/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
+++ b/.github/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
@@ -85,6 +85,25 @@ jobs:
 uses: ./.github/actions/gradle-command-self-hosted-action
 with:
   gradle-command: 
:sdks:java:io:google-cloud-platform:bigQueryEarlyRolloutIntegrationTest
+  - name: Generate Date
+if: failure()
+run: |
+  date=$(date -u +"%Y-%m-%d")
+  echo "date=$date" >> $GITHUB_ENV
+  - name: Send email
+uses: dawidd6/action-send-mail@v3
+if: failure()
+with:
+  server_address: smtp.gmail.com
+  server_port: 465
+  secure: true
+  username: ${{ secrets.ISSUE_REPORT_SENDER_EMAIL_ADDRESS }}
+  password: ${{ secrets.ISSUE_REPORT_SENDER_EMAIL_PASSWORD }}
+  subject: BigQueryEarlyRollout Beam Failure (${{ env.date }}) - 
investigate and escalate quickly
+  to: datapls-plat-t...@google.com # Team at Google responsible for 
escalating BQ failures
+  from: gacti...@beam.apache.org
+  body: |
+PostCommit Java BigQueryEarlyRollout failed on ${{ env.date }}. 
This test monitors BigQuery rollouts impacting Beam and should be escalated 
immediately if a real issue is encountered to pause further rollouts. For 
further details refer to the following links:\n * Failing job: 
https://github.com/apache/beam/actions/workflows/beam_PostCommit_Java_BigQueryEarlyRollout.yml
 \n * Job configuration: 
https://github.com/apache/beam/blob/master/.github/workflows/beam_PostCommit_Java_Bi
 [...]
   - name: Archive JUnit Test Results
 uses: actions/upload-artifact@v4
 if: ${{ !success() }}
@@ -97,4 +116,4 @@ jobs:
 with:
   commit: '${{ env.prsha || env.GITHUB_SHA }}'
   comment_mode: ${{ github.event_name == 'issue_comment'  && 'always' 
|| 'off' }}
-  files: '**/build/test-results/**/*.xml'
\ No newline at end of file
+  files: '**/build/test-results/**/*.xml'



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new 3452ab757e4 Updating config from bot
3452ab757e4 is described below

commit 3452ab757e4ccf9461ec17c9319c8315c137e427
Author: github-actions 
AuthorDate: Wed Mar 20 18:31:23 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30691.json | 8 
 1 file changed, 8 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30691.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30691.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30691.json
@@ -0,0 +1,8 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {},
+  "nextAction": "Author",
+  "stopReviewerNotifications": true,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch revert-30425-mt-shutdown-channels created (now 8681ab9901d)

2024-03-20 Thread yhu
This is an automated email from the ASF dual-hosted git repository.

yhu pushed a change to branch revert-30425-mt-shutdown-channels
in repository https://gitbox.apache.org/repos/asf/beam.git


  at 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)"

This branch includes the following new commits:

 new 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)"

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.




(beam) 01/01: Revert "Cache and close windmill grpc channels (#30425)"

2024-03-20 Thread yhu
This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch revert-30425-mt-shutdown-channels
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 8681ab9901d38af3c826eb75bbf0816cc55b0627
Author: Yi Hu 
AuthorDate: Wed Mar 20 14:27:29 2024 -0400

Revert "Cache and close windmill grpc channels (#30425)"

This reverts commit c1c255a0a433d7cdf1b5f0bc61986d395c7703ad.
---
 .../google-cloud-dataflow-java/worker/build.gradle |  12 --
 .../dataflow/worker/StreamingDataflowWorker.java   |  11 +-
 .../worker/windmill/WindmillConnection.java|   5 -
 .../windmill/client/grpc/GrpcDispatcherClient.java |   4 +-
 .../windmill/client/grpc/GrpcWindmillServer.java   |  29 +---
 .../client/grpc/StreamingEngineClient.java |  25 ++--
 .../windmill/client/grpc/stubs/ChannelCache.java   | 117 
 .../grpc/stubs/ChannelCachingStubFactory.java  |  38 --
 .../client/grpc/stubs/IsolationChannel.java|   2 +-
 ...Factory.java => RemoteWindmillStubFactory.java} |  38 +++---
 .../client/grpc/stubs/WindmillChannelFactory.java  |   2 +-
 .../client/grpc/GrpcWindmillServerTest.java|   3 +-
 .../client/grpc/StreamingEngineClientTest.java |  31 +++--
 .../client/grpc/WindmillStreamSenderTest.java  |   3 +-
 .../client/grpc/stubs/ChannelCacheTest.java| 150 -
 .../windmill/testing/FakeWindmillStubFactory.java  |  27 ++--
 .../budget/EvenGetWorkBudgetDistributorTest.java   |   7 +-
 17 files changed, 78 insertions(+), 426 deletions(-)

diff --git a/runners/google-cloud-dataflow-java/worker/build.gradle 
b/runners/google-cloud-dataflow-java/worker/build.gradle
index 4ddb3e2755e..124c11026df 100644
--- a/runners/google-cloud-dataflow-java/worker/build.gradle
+++ b/runners/google-cloud-dataflow-java/worker/build.gradle
@@ -71,10 +71,6 @@ def excluded_dependencies = [
 library.java.truth   // Test only
 ]
 
-// For Java8+ and less than Java11, use versions 2.x.x.
-// Java11+ can use versions 3.x.x per https://github.com/ben-manes/caffeine.
-def caffeine_cache_version = "2.9.3"
-
 applyJavaNature(
 automaticModuleName: 'org.apache.beam.runners.dataflow.worker',
 archivesBaseName: 
'beam-runners-google-cloud-dataflow-java-legacy-worker',
@@ -141,13 +137,6 @@ applyJavaNature(
 relocate("org.eclipse.jetty", 
getWorkerRelocatedPath("org.eclipse.jetty"))
 relocate("javax.servlet", getWorkerRelocatedPath("javax.servlet"))
 
-// Use Caffeine cache instead of Guava cache.
-// Context: 
https://guava.dev/releases/snapshot/api/docs/com/google/common/cache/CacheBuilder
-dependencies {
-
include(dependency("com.github.ben-manes.caffeine:caffeine:${caffeine_cache_version}}"))
-}
-relocate("com.github.ben-manes.caffeine", 
getWorkerRelocatedPath("com.github.ben-manes.caffeine"))
-
 // We don't relocate windmill since it is already underneath the 
org.apache.beam.runners.dataflow.worker namespace and never
 // expect a user pipeline to include it. There is also a JNI 
component that windmill server relies on which makes
 // arbitrary relocation more difficult.
@@ -213,7 +202,6 @@ dependencies {
 implementation "javax.servlet:javax.servlet-api:3.1.0"
 implementation "org.eclipse.jetty:jetty-server:9.2.10.v20150310"
 implementation "org.eclipse.jetty:jetty-servlet:9.2.10.v20150310"
-implementation 
"com.github.ben-manes.caffeine:caffeine:${caffeine_cache_version}"
 implementation library.java.avro
 implementation library.java.jackson_annotations
 implementation library.java.jackson_core
diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
index cc5b890bc60..4c3ffd08a0b 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
@@ -457,13 +457,12 @@ public class StreamingDataflowWorker {
   public static StreamingDataflowWorker 
fromOptions(DataflowWorkerHarnessOptions options) {
 ConcurrentMap computationMap = new 
ConcurrentHashMap<>();
 long clientId = clientIdGenerator.nextLong();
-
-Consumer> 
workHeartbeatResponseProcessor =
-new WorkHeartbeatResponseProcessor(
-computationId -> 
Optional.ofNullable(computationMap.get(computationId)));
-
 return new StreamingDataflowWorker(
-createWindmillServerStub(options, clientId, 
workHeartbeatResponseProcessor),
+createWindmillServerStub(
+options,
+clientId,
+   

(beam) branch users/damccorm/critSection updated (d927d984843 -> afe5bc1ebd7)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


from d927d984843 Simplify
 add afe5bc1ebd7 fmt

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)



(beam-starter-go) branch dependabot/go_modules/github.com/docker/docker-24.0.9incompatible deleted (was c4ae0c9)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/go_modules/github.com/docker/docker-24.0.9incompatible
in repository https://gitbox.apache.org/repos/asf/beam-starter-go.git


 was c4ae0c9  Bump github.com/docker/docker

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam-starter-go) branch main updated: Bump github.com/docker/docker (#32)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/beam-starter-go.git


The following commit(s) were added to refs/heads/main by this push:
 new 3d7e55c  Bump github.com/docker/docker (#32)
3d7e55c is described below

commit 3d7e55cee98574095b73eacf098bd55898305036
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Wed Mar 20 13:25:34 2024 -0400

Bump github.com/docker/docker (#32)

Bumps [github.com/docker/docker](https://github.com/docker/docker) from 
24.0.7+incompatible to 24.0.9+incompatible.
- [Release notes](https://github.com/docker/docker/releases)
- [Commits](https://github.com/docker/docker/compare/v24.0.7...v24.0.9)

---
updated-dependencies:
- dependency-name: github.com/docker/docker
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] 
Co-authored-by: dependabot[bot] 
<49699333+dependabot[bot]@users.noreply.github.com>
---
 go.mod | 2 +-
 go.sum | 6 --
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/go.mod b/go.mod
index 7398ea0..68399c2 100644
--- a/go.mod
+++ b/go.mod
@@ -21,7 +21,7 @@ require (
cloud.google.com/go/storage v1.36.0 // indirect
github.com/Microsoft/go-winio v0.6.1 // indirect
github.com/docker/distribution v2.8.2+incompatible // indirect
-   github.com/docker/docker v24.0.7+incompatible // indirect
+   github.com/docker/docker v24.0.9+incompatible // indirect
github.com/docker/go-connections v0.4.0 // indirect
github.com/docker/go-units v0.5.0 // indirect
github.com/dustin/go-humanize v1.0.1 // indirect
diff --git a/go.sum b/go.sum
index 60f5980..21be0f1 100644
--- a/go.sum
+++ b/go.sum
@@ -30,8 +30,8 @@ github.com/davecgh/go-spew v1.1.1 
h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod 
h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/docker/distribution v2.8.2+incompatible 
h1:T3de5rq0dB1j30rp0sA2rER+m322EBzniBPB6ZIzuh8=
 github.com/docker/distribution v2.8.2+incompatible/go.mod 
h1:J2gT2udsDAN96Uj4KfcMRqY0/ypR+oyYUYmja8H+y+w=
-github.com/docker/docker v24.0.7+incompatible 
h1:Wo6l37AuwP3JaMnZa226lzVXGA3F9Ig1seQen0cKYlM=
-github.com/docker/docker v24.0.7+incompatible/go.mod 
h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk=
+github.com/docker/docker v24.0.9+incompatible 
h1:HPGzNmwfLZWdxHqK9/II92pyi1EpYKsAqcl4G0Of9v0=
+github.com/docker/docker v24.0.9+incompatible/go.mod 
h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk=
 github.com/docker/go-connections v0.4.0 
h1:El9xVISelRB7BuFusrZozjnkIM5YnzCViNKohAFqRJQ=
 github.com/docker/go-connections v0.4.0/go.mod 
h1:Gbd7IOopHjR8Iph03tsViu4nIes5XhDvyHbTtUxmeec=
 github.com/docker/go-units v0.5.0 
h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4=
@@ -131,6 +131,8 @@ github.com/pmezard/go-difflib v1.0.0/go.mod 
h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod 
h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
 github.com/rogpeppe/clock v0.0.0-20190514195947-2896927a307a 
h1:3QH7VyOaaiUHNrA9Se4YQIRkDTCw1EJls9xTUCaCeRM=
 github.com/rogpeppe/clock v0.0.0-20190514195947-2896927a307a/go.mod 
h1:4r5QyqhjIWCcK8DO4KMclc5Iknq5qVBAlbYYzAbUScQ=
+github.com/sirupsen/logrus v1.9.3 
h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
+github.com/sirupsen/logrus v1.9.3/go.mod 
h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
 github.com/stretchr/objx v0.1.0/go.mod 
h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod 
h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod 
h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=



(beam-starter-go) branch dependabot/go_modules/github.com/docker/docker-24.0.9incompatible created (now c4ae0c9)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/go_modules/github.com/docker/docker-24.0.9incompatible
in repository https://gitbox.apache.org/repos/asf/beam-starter-go.git


  at c4ae0c9  Bump github.com/docker/docker

No new revisions were added by this update.



(beam) branch dependabot/go_modules/sdks/github.com/docker/docker-25.0.5incompatible deleted (was 38a0341ccf7)

2024-03-20 Thread lostluck
This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a change to branch 
dependabot/go_modules/sdks/github.com/docker/docker-25.0.5incompatible
in repository https://gitbox.apache.org/repos/asf/beam.git


 was 38a0341ccf7 Bump github.com/docker/docker in /sdks

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam) branch master updated: Bump github.com/docker/docker in /sdks (#30684)

2024-03-20 Thread lostluck
This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new 8206d8976d5 Bump github.com/docker/docker in /sdks (#30684)
8206d8976d5 is described below

commit 8206d8976d524853613a9ab350a7061088eda50b
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Wed Mar 20 09:57:22 2024 -0700

Bump github.com/docker/docker in /sdks (#30684)

Bumps [github.com/docker/docker](https://github.com/docker/docker) from 
25.0.3+incompatible to 25.0.5+incompatible.
- [Release notes](https://github.com/docker/docker/releases)
- [Commits](https://github.com/docker/docker/compare/v25.0.3...v25.0.5)

---
updated-dependencies:
- dependency-name: github.com/docker/docker
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] 
Co-authored-by: dependabot[bot] 
<49699333+dependabot[bot]@users.noreply.github.com>
---
 sdks/go.mod | 2 +-
 sdks/go.sum | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/go.mod b/sdks/go.mod
index c5887395a14..26e9bba48cd 100644
--- a/sdks/go.mod
+++ b/sdks/go.mod
@@ -143,7 +143,7 @@ require (
github.com/cncf/xds/go v0.0.0-20231128003011-0fa0005c9caa // indirect
github.com/containerd/containerd v1.7.11 // indirect
github.com/cpuguy83/dockercfg v0.3.1 // indirect
-   github.com/docker/docker v25.0.3+incompatible // but required to 
resolve issue docker has with go1.20
+   github.com/docker/docker v25.0.5+incompatible // but required to 
resolve issue docker has with go1.20
github.com/docker/go-units v0.5.0 // indirect
github.com/envoyproxy/go-control-plane v0.12.0 // indirect
github.com/envoyproxy/protoc-gen-validate v1.0.4 // indirect
diff --git a/sdks/go.sum b/sdks/go.sum
index eaa713f7d06..d59d0ba2173 100644
--- a/sdks/go.sum
+++ b/sdks/go.sum
@@ -160,8 +160,8 @@ github.com/davecgh/go-spew v1.1.1 
h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod 
h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/distribution/reference v0.5.0 
h1:/FUIFXtfc/x2gpa5/VGfiGLuOIdYa1t65IKK2OFGvA0=
 github.com/distribution/reference v0.5.0/go.mod 
h1:BbU0aIcezP1/5jX/8MP0YiH4SdvB5Y4f/wlDRiLyi3E=
-github.com/docker/docker v25.0.3+incompatible 
h1:D5fy/lYmY7bvZa0XTZ5/UJPljor41F+vdyJG5luQLfQ=
-github.com/docker/docker v25.0.3+incompatible/go.mod 
h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk=
+github.com/docker/docker v25.0.5+incompatible 
h1:UmQydMduGkrD5nQde1mecF/YnSbTOaPeFIeP5C4W+DE=
+github.com/docker/docker v25.0.5+incompatible/go.mod 
h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk=
 github.com/docker/go-connections v0.5.0 
h1:USnMq7hx7gwdVZq1L49hLXaFtUdTADjXGp+uj1Br63c=
 github.com/docker/go-connections v0.5.0/go.mod 
h1:ov60Kzw0kKElRwhNs9UlUHAE/F9Fe6GLaXnqyDdmEXc=
 github.com/docker/go-units v0.5.0 
h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4=



(beam) branch users/damccorm/critSection updated (b5a45c1c632 -> d927d984843)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


from b5a45c1c632 Move comment
 add d927d984843 Simplify

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)



(beam) branch users/damccorm/critSection updated (cccaeee8919 -> b5a45c1c632)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


from cccaeee8919 Update sdks/python/apache_beam/runners/worker/sdk_worker.py
 add b5a45c1c632 Move comment

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)



(beam) branch users/damccorm/critSection updated (434a3334c3b -> cccaeee8919)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


from 434a3334c3b Build list in lock
 add cccaeee8919 Update sdks/python/apache_beam/runners/worker/sdk_worker.py

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)



(beam) branch dependabot/go_modules/sdks/golang.org/x/oauth2-0.18.0 deleted (was d9ff2eadf20)

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/go_modules/sdks/golang.org/x/oauth2-0.18.0
in repository https://gitbox.apache.org/repos/asf/beam.git


 was d9ff2eadf20 Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks

The revisions that were on this branch are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(beam) branch master updated: Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks (#30685)

2024-03-20 Thread riteshghorse
This is an automated email from the ASF dual-hosted git repository.

riteshghorse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new 81cb194f8d1 Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks 
(#30685)
81cb194f8d1 is described below

commit 81cb194f8d12e5aa1d39ec9a10c1f1404c4073f7
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Wed Mar 20 10:07:48 2024 -0400

Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks (#30685)

Bumps [golang.org/x/oauth2](https://github.com/golang/oauth2) from 0.17.0 
to 0.18.0.
- [Commits](https://github.com/golang/oauth2/compare/v0.17.0...v0.18.0)

---
updated-dependencies:
- dependency-name: golang.org/x/oauth2
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] 
Co-authored-by: dependabot[bot] 
<49699333+dependabot[bot]@users.noreply.github.com>
---
 sdks/go.mod | 4 ++--
 sdks/go.sum | 8 
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/sdks/go.mod b/sdks/go.mod
index a44a90adba7..c5887395a14 100644
--- a/sdks/go.mod
+++ b/sdks/go.mod
@@ -54,8 +54,8 @@ require (
github.com/xitongsys/parquet-go v1.6.2
github.com/xitongsys/parquet-go-source 
v0.0.0-20220315005136-aec0fe3e777c
go.mongodb.org/mongo-driver v1.13.1
-   golang.org/x/net v0.21.0
-   golang.org/x/oauth2 v0.17.0
+   golang.org/x/net v0.22.0
+   golang.org/x/oauth2 v0.18.0
golang.org/x/sync v0.6.0
golang.org/x/sys v0.18.0
golang.org/x/text v0.14.0
diff --git a/sdks/go.sum b/sdks/go.sum
index 72b1037f254..eaa713f7d06 100644
--- a/sdks/go.sum
+++ b/sdks/go.sum
@@ -554,15 +554,15 @@ golang.org/x/net 
v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwY
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod 
h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-2022202133-69e39bad7dc2/go.mod 
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
 golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod 
h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
-golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4=
-golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
+golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc=
+golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod 
h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod 
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod 
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20191202225959-858c2ad4c8b6/go.mod 
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod 
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
-golang.org/x/oauth2 v0.17.0 h1:6m3ZPmLEFdVxKKWnKq4VqZ60gutO35zm+zrAHVmHyDQ=
-golang.org/x/oauth2 v0.17.0/go.mod 
h1:OzPDGQiuQMguemayvdylqddI7qcD9lnSDb+1FiwQ5HA=
+golang.org/x/oauth2 v0.18.0 h1:09qnuIAgzdx1XplqJvW6CQqMCtGZykZWcXzPMPUusvI=
+golang.org/x/oauth2 v0.18.0/go.mod 
h1:Wf7knwG0MPoWIMMBgFlEaSUDaKskp0dCfrlJRJXbBi8=
 golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod 
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod 
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod 
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=



(beam) branch pr-bot-state updated: Updating config from bot

2024-03-20 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch pr-bot-state
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/pr-bot-state by this push:
 new f635b639712 Updating config from bot
f635b639712 is described below

commit f635b6397126b7bcc2a0178d2e36dce76ecacceb
Author: github-actions 
AuthorDate: Wed Mar 20 14:07:26 2024 +

Updating config from bot
---
 scripts/ci/pr-bot/state/pr-state/pr-30689.json | 8 
 1 file changed, 8 insertions(+)

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30689.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30689.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30689.json
@@ -0,0 +1,8 @@
+{
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {},
+  "nextAction": "Author",
+  "stopReviewerNotifications": true,
+  "remindAfterTestsPass": [],
+  "committerAssigned": false
+}
\ No newline at end of file



(beam) branch users/damccorm/critSection updated (eda0b519d49 -> 434a3334c3b)

2024-03-20 Thread damccorm
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/critSection
in repository https://gitbox.apache.org/repos/asf/beam.git


from eda0b519d49 Minimize scope of expensive lock
 add 434a3334c3b Build list in lock

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 18 ++
 1 file changed, 10 insertions(+), 8 deletions(-)