(beam) branch asf-site updated: Publishing website 2024/02/03 05:38:42 at commit f2056e7

2024-02-02 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 5ae69c95d55 Publishing website 2024/02/03 05:38:42 at commit f2056e7
5ae69c95d55 is described below

commit 5ae69c95d55514be81071c70a0d057a48828fd87
Author: runner 
AuthorDate: Sat Feb 3 05:38:43 2024 +

Publishing website 2024/02/03 05:38:42 at commit f2056e7
---
 website/generated-content/documentation/index.xml| 4 ++--
 website/generated-content/documentation/programming-guide/index.html | 2 +-
 website/generated-content/sitemap.xml| 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/website/generated-content/documentation/index.xml 
b/website/generated-content/documentation/index.xml
index 193e70e7fc4..4fd1a9c260c 100644
--- a/website/generated-content/documentation/index.xml
+++ b/website/generated-content/documentation/index.xml
@@ -15753,7 +15753,7 @@ starts the Transform service when a Python runtime 
isn’t available loc
 
 
 
-
java -jar beam-sdks-java-transform
java -jar beam-sdks-java-transform
 
 
-
java -jar beam-sdks-java-transform
java -jar beam-sdks-java-transform(beam) branch pr-bot-state updated: Updating config from 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 cabbab5da82 Updating config from bot
cabbab5da82 is described below

commit cabbab5da82ce5dfe99147a464dbea8767b6c470
Author: github-actions 
AuthorDate: Sat Feb 3 05:05:23 2024 +

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

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



(beam) branch nightly-refs/heads/master updated (574e7bfbc1d -> 8ec51f181a0)

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 574e7bfbc1d Fix script typos for validating docker licenses. (#30176)
 add 7fb05cbb5e1 Move the code from sdks-java-fn-execution to sdks-java-core
 add e8df60381a3 Merge pull request #30170: Move the code from 
sdks-java-fn-execution to sdks-java-core
 add 124880bc8ce Fix typo affecting 
DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)
 add 1f69271044d [Dataflow Streaming] Add a option to use multiple commit 
threads (#30194)
 add 1183b5d5274 Knowledge lookup prompts: (#29747)
 add 801682930e2 Bump google.golang.org/protobuf from 1.31.0 to 1.32.0 in 
/sdks (#29913)
 add 30a778b9cbe Bump github.com/containerd/containerd from 1.7.7 to 1.7.11 
in /sdks (#29823)
 add f03b115830b Remove extraneous mocking that was causing NPEs in 
DataflowWorkUnitClientTest
 add 00f07864784 Remove sdks/java/fn-execution
 add 8ec51f181a0 Merge pull request #30193: Remove sdks/java/fn-execution

No new revisions were added by this update.

Summary of changes:
 build.gradle.kts   |   1 -
 learning/prompts/README.md |  76 +++
 learning/prompts/code-explanation/01_io_kafka.md   |  65 +
 .../02_io_pubsub.md|   0
 .../prompts/code-explanation/03_io_bigquery.md |  39 
 .../prompts/code-explanation/04_io_bigtable.md |  44 +
 learning/prompts/code-explanation/05_io_spanner.md |  96 +++
 .../prompts/code-explanation/06_io_tfrecord.md |  63 +
 learning/prompts/code-explanation/07_io_json.md|  50 ++
 learning/prompts/code-explanation/08_io_csv.md |  44 +
 learning/prompts/code-explanation/09_io_avro.md|  41 
 learning/prompts/code-explanation/10_io_parquet.md |  39 
 learning/prompts/code-explanation/11_io_jdbc.md| 105 +
 learning/prompts/code-generation/01_io_kafka.md|  46 +
 learning/prompts/code-generation/03_io_bigquery.md |  54 +++
 learning/prompts/code-generation/04_io_bigtable.md |  66 +
 learning/prompts/code-generation/05_io_spanner.md  |  63 +
 learning/prompts/code-generation/06_io_tfrecord.md |  60 
 learning/prompts/code-generation/07_io_json.md |  48 ++
 learning/prompts/code-generation/08_io_csv.md  |  47 +
 learning/prompts/code-generation/09_io_avro.md |  42 +
 learning/prompts/code-generation/10_io_parquet.md  |  39 
 learning/prompts/code-generation/11_io_jdbc.md |  75 +++
 .../prompts/documentation-lookup/18_io_kafka.md|  27 ++
 .../prompts/documentation-lookup/21_io_bigtable.md |  28 ++
 .../prompts/documentation-lookup/22_io_spanner.md  |  31 ++
 learning/prompts/documentation-lookup/23_io_gcs.md |  23 +
 .../prompts/documentation-lookup/24_io_json.md |  32 +++
 learning/prompts/documentation-lookup/25_io_csv.md |  32 +++
 .../prompts/documentation-lookup/26_io_avro.md |  31 ++
 .../prompts/documentation-lookup/27_io_parquet.md  |  31 ++
 .../prompts/documentation-lookup/28_io_jdbc.md |  52 ++
 runners/core-construction-java/build.gradle|   1 -
 runners/core-java/build.gradle |   1 -
 runners/direct-java/build.gradle   |   3 -
 runners/flink/flink_runner.gradle  |   1 -
 .../options/DataflowPipelineDebugOptions.java  |   8 +-
 .../google-cloud-dataflow-java/worker/build.gradle |   5 -
 .../dataflow/worker/StreamingDataflowWorker.java   |  49 +-
 .../worker/DataflowWorkUnitClientTest.java |  99 +++
 .../worker/StreamingDataflowWorkerTest.java|  46 -
 runners/java-fn-execution/build.gradle |   1 -
 runners/java-job-service/build.gradle  |   1 -
 runners/samza/build.gradle |   1 -
 runners/spark/spark_runner.gradle  |   1 -
 sdks/go.mod|   6 +-
 sdks/go.sum|  12 +--
 sdks/java/core/build.gradle|   2 +
 .../org/apache/beam/sdk/fn/CancellableQueue.java   |   0
 .../java/org/apache/beam/sdk/fn/IdGenerator.java   |   0
 .../java/org/apache/beam/sdk/fn/IdGenerators.java  |   0
 .../org/apache/beam/sdk/fn/JvmInitializers.java|   0
 .../sdk/fn/channel/AddHarnessIdInterceptor.java|   0
 .../beam/sdk/fn/channel/ManagedChannelFactory.java |   0
 .../beam/sdk/fn/channel/SocketAddressFactory.java  |   0
 .../apache/beam/sdk/fn/channel/package-info.java   |   0
 .../sdk/fn/data/BeamFnDataGrpcMultiplexer.java |   0
 .../sdk/fn/data/BeamFnDataInboundObserver.java |   0
 .../sd

(beam) branch master updated (9f8dda274dc -> f2056e72dea)

This is an automated email from the ASF dual-hosted git repository.

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


from 9f8dda274dc Split standalone transform service application from 
launcher jar (#30190)
 add f2056e72dea Fix stale dataflow prebuilt image cleaner (#30168)

No new revisions were added by this update.

Summary of changes:
 .../tools/stale_dataflow_prebuilt_image_cleaner.sh | 55 +-
 1 file changed, 32 insertions(+), 23 deletions(-)



(beam) branch fixdeletecontainer deleted (was 4e101439568)

This is an automated email from the ASF dual-hosted git repository.

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


 was 4e101439568 Defer fail script

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: Split standalone transform service application from launcher jar (#30190)

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 9f8dda274dc Split standalone transform service application from 
launcher jar (#30190)
9f8dda274dc is described below

commit 9f8dda274dc7f7f562fb10bc9153d40ebf593ff0
Author: Yi Hu 
AuthorDate: Fri Feb 2 21:51:47 2024 -0500

Split standalone transform service application from launcher jar (#30190)
---
 build.gradle.kts   |  1 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |  6 +--
 sdks/java/extensions/python/build.gradle   |  2 +-
 sdks/java/harness/build.gradle |  2 +-
 .../{launcher => app}/build.gradle | 45 ++
 sdks/java/transform-service/launcher/build.gradle  | 23 +++
 .../utils/transform_service_launcher.py|  2 +-
 settings.gradle.kts|  1 +
 .../content/en/documentation/programming-guide.md  |  4 +-
 9 files changed, 27 insertions(+), 59 deletions(-)

diff --git a/build.gradle.kts b/build.gradle.kts
index 82b3b6356a6..7e4c6cdc71a 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -312,6 +312,7 @@ tasks.register("javaPreCommit") {
   dependsOn(":sdks:java:testing:tpcds:build")
   dependsOn(":sdks:java:testing:watermarks:build")
   dependsOn(":sdks:java:transform-service:build")
+  dependsOn(":sdks:java:transform-service:app:build")
   dependsOn(":sdks:java:transform-service:launcher:build")
 }
 
diff --git 
a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy 
b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
index f3d79c528f8..10a7ba7f1c8 100644
--- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
+++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -2860,7 +2860,7 @@ class BeamModulePlugin implements Plugin {
   project.evaluationDependsOn(":sdks:python")
   project.evaluationDependsOn(":runners:core-construction-java")
   project.evaluationDependsOn(":sdks:java:extensions:python")
-  project.evaluationDependsOn(":sdks:java:transform-service:launcher")
+  project.evaluationDependsOn(":sdks:java:transform-service:app")
 
   def usesDataflowRunner = 
config.pythonPipelineOptions.contains("--runner=TestDataflowRunner") || 
config.pythonPipelineOptions.contains("--runner=DataflowRunner")
 
@@ -2868,7 +2868,7 @@ class BeamModulePlugin implements Plugin {
   def envDir = project.project(":sdks:python").envdir
   def pythonDir = project.project(":sdks:python").projectDir
   def externalPort = getRandomPort()
-  def launcherJar = 
project.project(':sdks:java:transform-service:launcher').shadowJar.archivePath
+  def launcherJar = 
project.project(':sdks:java:transform-service:app').shadowJar.archivePath
   def groupId = project.name + randomUUID().toString()
   def transformServiceOpts = [
 "transform_service_launcher_jar": launcherJar,
@@ -2895,7 +2895,7 @@ class BeamModulePlugin implements Plugin {
 dependsOn ':sdks:python:expansion-service-container:docker'
 dependsOn ':sdks:java:expansion-service:container:docker'
 dependsOn ":sdks:python:installGcpTest"
-dependsOn 
project.project(':sdks:java:transform-service:launcher').shadowJar.getPath()
+dependsOn 
project.project(':sdks:java:transform-service:app').shadowJar.getPath()
 
 if (usesDataflowRunner) {
   dependsOn 
":sdks:python:test-suites:dataflow:py${project.ext.pythonVersion.replace('.', 
'')}:initializeForDataflowJob"
diff --git a/sdks/java/extensions/python/build.gradle 
b/sdks/java/extensions/python/build.gradle
index 40729d5f9ca..a83afac6881 100644
--- a/sdks/java/extensions/python/build.gradle
+++ b/sdks/java/extensions/python/build.gradle
@@ -30,7 +30,7 @@ dependencies {
 implementation project(path: ":model:pipeline", configuration: "shadow")
 implementation project(path: ":runners:core-construction-java")
 implementation project(path: ":sdks:java:core", configuration: "shadow")
-implementation project(path: ":sdks:java:transform-service:launcher", 
configuration: "shadow")
+implementation project(path: ":sdks:java:transform-service:launcher")
 testImplementation library.java.junit
 testImplementation library.java.hamcrest
 testImplementation 
project(":runners:core-construction-java").sourceSets.test.output
diff --git a/sdks/java/harness/build.gradle b/sdks/java/harness/build.gradle
index d3b4267424c..3c50f3c8edf 100644
--- a/sdks/java/harness/build.gradle
+++ b/sdks/java/harness/build.gradle
@@ -29,7 +29,7 @@ dependencies {
   // :sdks:java:core and transitive dependencies
   provided project(path: ":model:pipeline", configuration: "shadow")
   provided project(path: ":sdks:java:core", configurat

(beam) branch pr-bot-state updated: Updating config from 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 46dbf1c00e5 Updating config from bot
46dbf1c00e5 is described below

commit 46dbf1c00e5cfd0aaa49f14d0cfdb51ef94e25e7
Author: github-actions 
AuthorDate: Sat Feb 3 00:05:43 2024 +

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

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



(beam) branch asf-site updated: Publishing website 2024/02/02 23:39:32 at commit 8ec51f1

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 9ca237e6b13 Publishing website 2024/02/02 23:39:32 at commit 8ec51f1
9ca237e6b13 is described below

commit 9ca237e6b130494f9e149484ee4d047f823ea341
Author: runner 
AuthorDate: Fri Feb 2 23:39:32 2024 +

Publishing website 2024/02/02 23:39:32 at commit 8ec51f1
---
 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 5e57a7d3d2a..80838f3157f 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.53.0/2024-02-02T18:10:48+01:00/categories/blog/2024-02-02T18:10:48+01:00/blog/2024-02-02T18:10:48+01:00/categories/2024-02-02T18:10:48+01: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.53.0/2024-02-02T15:32:22-05:00/categories/blog/2024-02-02T15:32:22-05:00/blog/2024-02-02T15:32:22-05:00/categories/2024-02-02T15:32:22-05:00/catego
 [...]
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from 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 54b43590757 Updating config from bot
54b43590757 is described below

commit 54b435907574c4395ead655f65fb66b3f70f0dfa
Author: github-actions 
AuthorDate: Fri Feb 2 23:05:47 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 303a3c2ab9e..2a998fcb45f 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-python.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-python.json
@@ -9,7 +9,7 @@
 "pabloem": 1681281324703,
 "y1chi": 1667002607045,
 "damccorm": 1706876018447,
-"jrmccluskey": 1706648779876,
+"jrmccluskey": 1706915144832,
 "riteshghorse": 1706729651902,
 "liferoad": 1706812494692
   }



(beam) branch pr-bot-state updated: Updating config from 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 16a58010a52 Updating config from bot
16a58010a52 is described below

commit 16a58010a5289d944e4a2a620bd96d3506b1cbc4
Author: github-actions 
AuthorDate: Fri Feb 2 23:05:46 2024 +

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

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



(beam) branch pr-bot-state updated: Updating config from 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 dca9fd6e5b2 Updating config from bot
dca9fd6e5b2 is described below

commit dca9fd6e5b24ac8695327bb02f5a2cfb237f479b
Author: github-actions 
AuthorDate: Fri Feb 2 21:35:29 2024 +

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

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



(beam) branch fix-path updated (0a0d329e3ce -> e51bc4ebc13)

This is an automated email from the ASF dual-hosted git repository.

anandinguva pushed a change to branch fix-path
in repository https://gitbox.apache.org/repos/asf/beam.git


from 0a0d329e3ce Update artifacts fetcher to download artifacts
 add e51bc4ebc13 Use context for tempdir creation

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/ml/transforms/utils.py | 36 +-
 1 file changed, 18 insertions(+), 18 deletions(-)



(beam) 01/01: Update artifacts fetcher to download artifacts

This is an automated email from the ASF dual-hosted git repository.

anandinguva pushed a commit to branch fix-path
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 0a0d329e3ce4adafdcb9dac50597fc6fe0aa1348
Author: Anand Inguva 
AuthorDate: Fri Feb 2 16:20:25 2024 -0500

Update artifacts fetcher to download artifacts
---
 sdks/python/apache_beam/ml/transforms/utils.py | 19 +--
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/sdks/python/apache_beam/ml/transforms/utils.py 
b/sdks/python/apache_beam/ml/transforms/utils.py
index fadf611b0e6..96f0f7f2f57 100644
--- a/sdks/python/apache_beam/ml/transforms/utils.py
+++ b/sdks/python/apache_beam/ml/transforms/utils.py
@@ -18,18 +18,28 @@
 __all__ = ['ArtifactsFetcher']
 
 import os
+import tempfile
 import typing
 
 import tensorflow_transform as tft
+from apache_beam.io.filesystems import FileSystems
 from apache_beam.ml.transforms import base
 
 
-class ArtifactsFetcher():
+class ArtifactsFetcher:
   """
   Utility class used to fetch artifacts from the artifact_location passed
   to the TFTProcessHandlers in MLTransform.
+
+  This is intended to be used for testing purposes only.
   """
   def __init__(self, artifact_location):
+tempdir = tempfile.mkdtemp()
+self._artifact_location = tempdir
+# TODO: Can we use FileSystems.match() here with a * glob pattern?
+# using match, does it output files and directories path?
+FileSystems.copy(artifact_location, tempdir)
+assert os.listdir(tempdir), f"No files found in {artifact_location}"
 files = os.listdir(artifact_location)
 files.remove(base._ATTRIBUTE_FILE_NAME)
 # TODO: https://github.com/apache/beam/issues/29356
@@ -43,9 +53,7 @@ class ArtifactsFetcher():
 self._artifact_location = os.path.join(artifact_location, files[0])
 self.transform_output = tft.TFTransformOutput(self._artifact_location)
 
-  def get_vocab_list(
-  self,
-  vocab_filename: str = 'compute_and_apply_vocab') -> typing.List[bytes]:
+  def get_vocab_list(self, vocab_filename: str) -> typing.List[bytes]:
 """
 Returns list of vocabulary terms created during MLTransform.
 """
@@ -57,8 +65,7 @@ class ArtifactsFetcher():
   vocab_filename)) from e
 return [x.decode('utf-8') for x in vocab_list]
 
-  def get_vocab_filepath(
-  self, vocab_filename: str = 'compute_and_apply_vocab') -> str:
+  def get_vocab_filepath(self, vocab_filename: str) -> str:
 """
 Return the path to the vocabulary file created during MLTransform.
 """



(beam) branch fix-path created (now 0a0d329e3ce)

This is an automated email from the ASF dual-hosted git repository.

anandinguva pushed a change to branch fix-path
in repository https://gitbox.apache.org/repos/asf/beam.git


  at 0a0d329e3ce Update artifacts fetcher to download artifacts

This branch includes the following new commits:

 new 0a0d329e3ce Update artifacts fetcher to download artifacts

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) branch pr-bot-state updated: Updating config from 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 564f833ec8f Updating config from bot
564f833ec8f is described below

commit 564f833ec8fc05cd2ca42c199a9c6ad88551cf67
Author: github-actions 
AuthorDate: Fri Feb 2 21:04:54 2024 +

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

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



(beam) branch pr-bot-state updated: Updating config from 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 05b5a60e5e3 Updating config from bot
05b5a60e5e3 is described below

commit 05b5a60e5e31a602bfbaec27586a22d240840ef8
Author: github-actions 
AuthorDate: Fri Feb 2 20:34:52 2024 +

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

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-no-matching-label.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-no-matching-label.json
index 28924af27a9..1dbb81baf3d 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-no-matching-label.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-no-matching-label.json
@@ -7,7 +7,7 @@
 "damccorm": 1706746787532,
 "johnjcasey": 1706756770922,
 "jrmccluskey": 1705430101174,
-"kennknowles": 1705097216618,
+"kennknowles": 1706906090429,
 "lostluck": 1705635383761,
 "riteshghorse": 1705435557774,
 "robertwb": 1705698339778,



(beam) branch pr-bot-state updated: Updating config from 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 9aa9245eff3 Updating config from bot
9aa9245eff3 is described below

commit 9aa9245eff316f350ba4217f0d2ca043e7667ad4
Author: github-actions 
AuthorDate: Fri Feb 2 20:34:51 2024 +

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

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30185.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30185.json
index 242a48d7d3b..8ad90f2eea6 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-30185.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30185.json
@@ -1,7 +1,9 @@
 {
-  "commentedAboutFailingChecks": true,
-  "reviewersAssignedForLabels": {},
-  "nextAction": "Author",
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"no-matching-label": "kennknowles"
+  },
+  "nextAction": "Reviewers",
   "stopReviewerNotifications": false,
   "remindAfterTestsPass": [],
   "committerAssigned": false



(beam) branch master updated (30a778b9cbe -> 8ec51f181a0)

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 30a778b9cbe Bump github.com/containerd/containerd from 1.7.7 to 1.7.11 
in /sdks (#29823)
 add f03b115830b Remove extraneous mocking that was causing NPEs in 
DataflowWorkUnitClientTest
 add 00f07864784 Remove sdks/java/fn-execution
 new 8ec51f181a0 Merge pull request #30193: Remove sdks/java/fn-execution

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:
 build.gradle.kts   |  1 -
 runners/direct-java/build.gradle   |  2 -
 .../worker/DataflowWorkUnitClientTest.java | 99 +-
 sdks/java/expansion-service/build.gradle   |  2 -
 sdks/java/fn-execution/build.gradle| 34 
 sdks/java/harness/build.gradle |  3 +-
 settings.gradle.kts|  1 -
 7 files changed, 62 insertions(+), 80 deletions(-)
 delete mode 100644 sdks/java/fn-execution/build.gradle



(beam) 01/01: Merge pull request #30193: Remove sdks/java/fn-execution

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 8ec51f181a02c8e1163e6fa0239e2361f30d16d8
Merge: 30a778b9cbe 00f07864784
Author: Kenneth Knowles 
AuthorDate: Fri Feb 2 15:32:22 2024 -0500

Merge pull request #30193: Remove sdks/java/fn-execution

 build.gradle.kts   |  1 -
 runners/direct-java/build.gradle   |  2 -
 .../worker/DataflowWorkUnitClientTest.java | 99 +-
 sdks/java/expansion-service/build.gradle   |  2 -
 sdks/java/fn-execution/build.gradle| 34 
 sdks/java/harness/build.gradle |  3 +-
 settings.gradle.kts|  1 -
 7 files changed, 62 insertions(+), 80 deletions(-)



(beam) branch pr-bot-state updated: Updating config from 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 548858a733c Updating config from bot
548858a733c is described below

commit 548858a733cd9f501d62fa697d368610b6c5333a
Author: github-actions 
AuthorDate: Fri Feb 2 19:05:41 2024 +

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

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



(beam) branch dependabot/go_modules/sdks/github.com/containerd/containerd-1.7.11 deleted (was 394f148ef04)

This is an automated email from the ASF dual-hosted git repository.

tvalentyn pushed a change to branch 
dependabot/go_modules/sdks/github.com/containerd/containerd-1.7.11
in repository https://gitbox.apache.org/repos/asf/beam.git


 was 394f148ef04 Bump github.com/containerd/containerd from 1.7.7 to 1.7.11 
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/containerd/containerd from 1.7.7 to 1.7.11 in /sdks (#29823)

This is an automated email from the ASF dual-hosted git repository.

tvalentyn 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 30a778b9cbe Bump github.com/containerd/containerd from 1.7.7 to 1.7.11 
in /sdks (#29823)
30a778b9cbe is described below

commit 30a778b9cbeb7b79615daa371fc3041a0dda2090
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Fri Feb 2 10:07:52 2024 -0800

Bump github.com/containerd/containerd from 1.7.7 to 1.7.11 in /sdks (#29823)

Bumps 
[github.com/containerd/containerd](https://github.com/containerd/containerd) 
from 1.7.7 to 1.7.11.
- [Release notes](https://github.com/containerd/containerd/releases)
- 
[Changelog](https://github.com/containerd/containerd/blob/main/RELEASES.md)
- 
[Commits](https://github.com/containerd/containerd/compare/v1.7.7...v1.7.11)

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

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 d6eed60bda9..ebcea04a37c 100644
--- a/sdks/go.mod
+++ b/sdks/go.mod
@@ -75,7 +75,7 @@ require (
 
 require (
dario.cat/mergo v1.0.0 // indirect
-   github.com/Microsoft/hcsshim v0.11.1 // indirect
+   github.com/Microsoft/hcsshim v0.11.4 // indirect
github.com/containerd/log v0.1.0 // indirect
github.com/frankban/quicktest v1.14.0 // indirect
github.com/go-logr/logr v1.3.0 // indirect
@@ -131,7 +131,7 @@ require (
github.com/cespare/xxhash/v2 v2.2.0 // indirect
github.com/cncf/udpa/go v0.0.0-20220112060539-c52dc94e7fbe // indirect
github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4 // indirect
-   github.com/containerd/containerd v1.7.7 // indirect
+   github.com/containerd/containerd v1.7.11 // indirect
github.com/cpuguy83/dockercfg v0.3.1 // indirect
github.com/docker/distribution v2.8.2+incompatible // indirect
github.com/docker/docker v24.0.7+incompatible // but required to 
resolve issue docker has with go1.20
diff --git a/sdks/go.sum b/sdks/go.sum
index 3a44301e936..7ef59c4f469 100644
--- a/sdks/go.sum
+++ b/sdks/go.sum
@@ -64,8 +64,8 @@ github.com/BurntSushi/xgb 
v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym
 github.com/JohnCGriffin/overflow v0.0.0-20211019200055-46fa312c352c 
h1:RGWPOewvKIROun94nF7v2cua9qP+thov/7M50KEoeSU=
 github.com/Microsoft/go-winio v0.6.1 
h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
 github.com/Microsoft/go-winio v0.6.1/go.mod 
h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
-github.com/Microsoft/hcsshim v0.11.1 
h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
-github.com/Microsoft/hcsshim v0.11.1/go.mod 
h1:nFJmaO4Zr5Y7eADdFOpYswDDlNVbvcIJJNJLECr5JQg=
+github.com/Microsoft/hcsshim v0.11.4 
h1:68vKo2VN8DE9AdN4tnkWnmdhqdbpUFM8OF3Airm7fz8=
+github.com/Microsoft/hcsshim v0.11.4/go.mod 
h1:smjE4dvqPX9Zldna+t5FG3rnoHhaB7QYxPRqGcpAD9w=
 github.com/andybalholm/brotli v1.0.4 
h1:V7DdXeJtZscaqfNuAdSRuRFzuiKlHSC/Zh3zl9qY3JY=
 github.com/andybalholm/brotli v1.0.4/go.mod 
h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig=
 github.com/apache/arrow/go/arrow v0.0.0-20200730104253-651201b0f516 
h1:byKBBF2CKWBjjA4J1ZL2JXttJULvWSl50LegTyRZ728=
@@ -149,8 +149,8 @@ github.com/cncf/xds/go 
v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWH
 github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4 
h1:/inchEIKaYC1Akx+H+gqO04wryn5h75LSazbRlnya1k=
 github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4/go.mod 
h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
 github.com/colinmarc/hdfs/v2 v2.1.1/go.mod 
h1:M3x+k8UKKmxtFu++uAZ0OtDU8jR3jnaZIAc6yK4Ue0c=
-github.com/containerd/containerd v1.7.7 
h1:QOC2K4A42RQpcrZyptP6z9EJZnlHfHJUfZrAAHe15q4=
-github.com/containerd/containerd v1.7.7/go.mod 
h1:3c4XZv6VeT9qgf9GMTxNTMFxGJrGpI2vz1yk4ye+YY8=
+github.com/containerd/containerd v1.7.11 
h1:lfGKw3eU35sjV0aG2eYZTiwFEY1pCzxdzicHP3SZILw=
+github.com/containerd/containerd v1.7.11/go.mod 
h1:5UluHxHTX2rdvYuZ5OJTC5m/KJNs0Zs9wVoJm9zf5ZE=
 github.com/containerd/log v0.1.0 
h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I=
 github.com/containerd/log v0.1.0/go.mod 
h1:VRRf09a7mHDIRezVKTRCrOq78v577GXq3bSa3EhrzVo=
 github.com/cpuguy83/dockercfg v0.3.1 
h1:/FpZ+JaygUR/lZP2NlFI2DVfrOEMAIKP5wWEJdoYe9E=



(beam) branch pr-bot-state updated: Updating config from 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 1a8e5e94b1c Updating config from bot
1a8e5e94b1c is described below

commit 1a8e5e94b1c57d208cb9eb367a5b8aa97cea5c7f
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:11 2024 +

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

diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-website.json 
b/scripts/ci/pr-bot/state/reviewers-for-label-website.json
index a3fab4cecc7..280300d3eb4 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-website.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-website.json
@@ -5,6 +5,6 @@
 "melap": 1706549680321,
 "damccorm": 1706573918703,
 "liferoad": 1706735149793,
-"kennknowles": 1705430107048
+"kennknowles": 1706897164657
   }
 }
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from 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 7f81f0f985b Updating config from bot
7f81f0f985b is described below

commit 7f81f0f985b06f44c450fead4df86c7c6c1a6968
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:07 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 ededb85eebe..303a3c2ab9e 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-python.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-python.json
@@ -5,7 +5,7 @@
 "yeandy": 1665802753763,
 "TheNeuralBit": 1667896849319,
 "ryanthompson591": 1670002443548,
-"tvalentyn": 1706565944759,
+"tvalentyn": 1706897164657,
 "pabloem": 1681281324703,
 "y1chi": 1667002607045,
 "damccorm": 1706876018447,



(beam) branch pr-bot-state updated: Updating config from 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 de906311269 Updating config from bot
de906311269 is described below

commit de90631126937d3cf230e433a2ea8ce424c76bbd
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:39 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 912efba2d47..5959c9ddf5a 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": 1706758526034,
+"lostluck": 1706897196607,
 "jrmccluskey": 1706763937839,
 "youngoli": 1657688896155,
 "damccorm": 1680501930289,



(beam) branch pr-bot-state updated: Updating config from 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 bd3b85c416d Updating config from bot
bd3b85c416d is described below

commit bd3b85c416d918889a8dd5f316a05d84eb205f48
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:37 2024 +

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

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-29823.json 
b/scripts/ci/pr-bot/state/pr-state/pr-29823.json
index 242a48d7d3b..8ea94810368 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-29823.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-29823.json
@@ -1,7 +1,9 @@
 {
-  "commentedAboutFailingChecks": true,
-  "reviewersAssignedForLabels": {},
-  "nextAction": "Author",
+  "commentedAboutFailingChecks": false,
+  "reviewersAssignedForLabels": {
+"go": "lostluck"
+  },
+  "nextAction": "Reviewers",
   "stopReviewerNotifications": false,
   "remindAfterTestsPass": [],
   "committerAssigned": false



(beam) branch pr-bot-state updated: Updating config from 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 89ff6971f20 Updating config from bot
89ff6971f20 is described below

commit 89ff6971f2023673dfbde5ada3a42d61a2295415
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:09 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 987ec05e2f8..863c7199f1c 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": 1706616816978,
-"Abacn": 1706149095380
+"Abacn": 1706897164657
   }
 }
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from 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 71a23b7e778 Updating config from bot
71a23b7e778 is described below

commit 71a23b7e778ab4d31b1089ee83e89fdd71b660be
Author: github-actions 
AuthorDate: Fri Feb 2 18:06:06 2024 +

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

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



(beam) branch dependabot/go_modules/sdks/google.golang.org/protobuf-1.32.0 deleted (was 2c8795eacb8)

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/protobuf-1.32.0
in repository https://gitbox.apache.org/repos/asf/beam.git


 was 2c8795eacb8 Bump google.golang.org/protobuf from 1.31.0 to 1.32.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 google.golang.org/protobuf from 1.31.0 to 1.32.0 in /sdks (#29913)

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 801682930e2 Bump google.golang.org/protobuf from 1.31.0 to 1.32.0 in 
/sdks (#29913)
801682930e2 is described below

commit 801682930e25376f471a6c733365123d670d1b4f
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Fri Feb 2 09:55:53 2024 -0800

Bump google.golang.org/protobuf from 1.31.0 to 1.32.0 in /sdks (#29913)

Bumps google.golang.org/protobuf from 1.31.0 to 1.32.0.

---
updated-dependencies:
- dependency-name: google.golang.org/protobuf
  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 | 2 +-
 sdks/go.sum | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/go.mod b/sdks/go.mod
index 80a017c0917..d6eed60bda9 100644
--- a/sdks/go.mod
+++ b/sdks/go.mod
@@ -62,7 +62,7 @@ require (
google.golang.org/api v0.154.0
google.golang.org/genproto v0.0.0-20231120223509-83a465c0220f
google.golang.org/grpc v1.60.1
-   google.golang.org/protobuf v1.31.0
+   google.golang.org/protobuf v1.32.0
gopkg.in/retry.v1 v1.0.3
gopkg.in/yaml.v2 v2.4.0
gopkg.in/yaml.v3 v3.0.1
diff --git a/sdks/go.sum b/sdks/go.sum
index 06b251d29a8..3a44301e936 100644
--- a/sdks/go.sum
+++ b/sdks/go.sum
@@ -730,8 +730,8 @@ google.golang.org/protobuf 
v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpAD
 google.golang.org/protobuf v1.25.0/go.mod 
h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
 google.golang.org/protobuf v1.26.0-rc.1/go.mod 
h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
 google.golang.org/protobuf v1.26.0/go.mod 
h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
-google.golang.org/protobuf v1.31.0 
h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8=
-google.golang.org/protobuf v1.31.0/go.mod 
h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+google.golang.org/protobuf v1.32.0 
h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I=
+google.golang.org/protobuf v1.32.0/go.mod 
h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod 
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod 
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c 
h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=



(beam) branch asf-site updated: Publishing website 2024/02/02 17:39:10 at commit 1183b5d

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 136d61d85b5 Publishing website 2024/02/02 17:39:10 at commit 1183b5d
136d61d85b5 is described below

commit 136d61d85b56a5777a7708fcfaf284f975434d3b
Author: runner 
AuthorDate: Fri Feb 2 17:39:11 2024 +

Publishing website 2024/02/02 17:39:10 at commit 1183b5d
---
 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 647efe94017..5e57a7d3d2a 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.53.0/2024-02-02T02:38:21-08:00/categories/blog/2024-02-02T02:38:21-08:00/blog/2024-02-02T02:38:21-08:00/categories/2024-02-02T02:38:21-08: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.53.0/2024-02-02T18:10:48+01:00/categories/blog/2024-02-02T18:10:48+01:00/blog/2024-02-02T18:10:48+01:00/categories/2024-02-02T18:10:48+01:00/catego
 [...]
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from 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 030c8f7d6e0 Updating config from bot
030c8f7d6e0 is described below

commit 030c8f7d6e00be3d252e1b52ba1a1313517019ad
Author: github-actions 
AuthorDate: Fri Feb 2 17:34:17 2024 +

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

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



(beam) branch master updated (1f69271044d -> 1183b5d5274)

This is an automated email from the ASF dual-hosted git repository.

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


from 1f69271044d [Dataflow Streaming] Add a option to use multiple commit 
threads (#30194)
 add 1183b5d5274 Knowledge lookup prompts: (#29747)

No new revisions were added by this update.

Summary of changes:
 learning/prompts/README.md |  76 +++
 learning/prompts/code-explanation/01_io_kafka.md   |  65 +
 .../02_io_pubsub.md|   0
 .../prompts/code-explanation/03_io_bigquery.md |  39 
 .../prompts/code-explanation/04_io_bigtable.md |  44 +
 learning/prompts/code-explanation/05_io_spanner.md |  96 +++
 .../prompts/code-explanation/06_io_tfrecord.md |  63 +
 learning/prompts/code-explanation/07_io_json.md|  50 ++
 learning/prompts/code-explanation/08_io_csv.md |  44 +
 learning/prompts/code-explanation/09_io_avro.md|  41 
 learning/prompts/code-explanation/10_io_parquet.md |  39 
 learning/prompts/code-explanation/11_io_jdbc.md| 105 +
 learning/prompts/code-generation/01_io_kafka.md|  46 +
 learning/prompts/code-generation/03_io_bigquery.md |  54 +++
 learning/prompts/code-generation/04_io_bigtable.md |  66 +
 learning/prompts/code-generation/05_io_spanner.md  |  63 +
 learning/prompts/code-generation/06_io_tfrecord.md |  60 
 learning/prompts/code-generation/07_io_json.md |  48 ++
 learning/prompts/code-generation/08_io_csv.md  |  47 +
 learning/prompts/code-generation/09_io_avro.md |  42 +
 learning/prompts/code-generation/10_io_parquet.md  |  39 
 learning/prompts/code-generation/11_io_jdbc.md |  75 +++
 .../prompts/documentation-lookup/18_io_kafka.md|  27 ++
 .../prompts/documentation-lookup/21_io_bigtable.md |  28 ++
 .../prompts/documentation-lookup/22_io_spanner.md  |  31 ++
 learning/prompts/documentation-lookup/23_io_gcs.md |  23 +
 .../prompts/documentation-lookup/24_io_json.md |  32 +++
 learning/prompts/documentation-lookup/25_io_csv.md |  32 +++
 .../prompts/documentation-lookup/26_io_avro.md |  31 ++
 .../prompts/documentation-lookup/27_io_parquet.md  |  31 ++
 .../prompts/documentation-lookup/28_io_jdbc.md |  52 ++
 31 files changed, 1489 insertions(+)
 create mode 100644 learning/prompts/README.md
 create mode 100644 learning/prompts/code-explanation/01_io_kafka.md
 rename learning/prompts/{code-explaination => 
code-explanation}/02_io_pubsub.md (100%)
 create mode 100644 learning/prompts/code-explanation/03_io_bigquery.md
 create mode 100644 learning/prompts/code-explanation/04_io_bigtable.md
 create mode 100644 learning/prompts/code-explanation/05_io_spanner.md
 create mode 100644 learning/prompts/code-explanation/06_io_tfrecord.md
 create mode 100644 learning/prompts/code-explanation/07_io_json.md
 create mode 100644 learning/prompts/code-explanation/08_io_csv.md
 create mode 100644 learning/prompts/code-explanation/09_io_avro.md
 create mode 100644 learning/prompts/code-explanation/10_io_parquet.md
 create mode 100644 learning/prompts/code-explanation/11_io_jdbc.md
 create mode 100644 learning/prompts/code-generation/01_io_kafka.md
 create mode 100644 learning/prompts/code-generation/03_io_bigquery.md
 create mode 100644 learning/prompts/code-generation/04_io_bigtable.md
 create mode 100644 learning/prompts/code-generation/05_io_spanner.md
 create mode 100644 learning/prompts/code-generation/06_io_tfrecord.md
 create mode 100644 learning/prompts/code-generation/07_io_json.md
 create mode 100644 learning/prompts/code-generation/08_io_csv.md
 create mode 100644 learning/prompts/code-generation/09_io_avro.md
 create mode 100644 learning/prompts/code-generation/10_io_parquet.md
 create mode 100644 learning/prompts/code-generation/11_io_jdbc.md
 create mode 100644 learning/prompts/documentation-lookup/18_io_kafka.md
 create mode 100644 learning/prompts/documentation-lookup/21_io_bigtable.md
 create mode 100644 learning/prompts/documentation-lookup/22_io_spanner.md
 create mode 100644 learning/prompts/documentation-lookup/23_io_gcs.md
 create mode 100644 learning/prompts/documentation-lookup/24_io_json.md
 create mode 100644 learning/prompts/documentation-lookup/25_io_csv.md
 create mode 100644 learning/prompts/documentation-lookup/26_io_avro.md
 create mode 100644 learning/prompts/documentation-lookup/27_io_parquet.md
 create mode 100644 learning/prompts/documentation-lookup/28_io_jdbc.md



(beam) branch remove_cogbk updated (48614b330a4 -> 094a8888659)

This is an automated email from the ASF dual-hosted git repository.

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


from 48614b330a4 Use PicklerCoder for encoding and decoding elements
 add 98404ca34fb Remove comments
 add 094a659 update coder

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/ml/transforms/handlers.py | 7 +++
 1 file changed, 3 insertions(+), 4 deletions(-)



(beam) branch pr-bot-state updated: Updating config from 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 a61a36ef55d Updating config from bot
a61a36ef55d is described below

commit a61a36ef55d2adf88166f1e1cacf5e11596ba3eb
Author: github-actions 
AuthorDate: Fri Feb 2 16:06:11 2024 +

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

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30178.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30178.json
index aa3638a74ec..1e9dcd816d5 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-30178.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30178.json
@@ -6,5 +6,5 @@
   "nextAction": "Reviewers",
   "stopReviewerNotifications": false,
   "remindAfterTestsPass": [],
-  "committerAssigned": false
+  "committerAssigned": true
 }
\ No newline at end of file



(beam) branch pr-bot-state updated: Updating config from 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 b2c4f346db6 Updating config from bot
b2c4f346db6 is described below

commit b2c4f346db626adeaaae13ee116d048efce99731
Author: github-actions 
AuthorDate: Fri Feb 2 12:13: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 a23eda4d7b5..ededb85eebe 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-python.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-python.json
@@ -8,7 +8,7 @@
 "tvalentyn": 1706565944759,
 "pabloem": 1681281324703,
 "y1chi": 1667002607045,
-"damccorm": 1706565938559,
+"damccorm": 1706876018447,
 "jrmccluskey": 1706648779876,
 "riteshghorse": 1706729651902,
 "liferoad": 1706812494692



(beam) branch pr-bot-state updated: Updating config from 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 6fd68dd727e Updating config from bot
6fd68dd727e is described below

commit 6fd68dd727e7385cf7a2dd6ea2cd48337c3b6655
Author: github-actions 
AuthorDate: Fri Feb 2 12:13:39 2024 +

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

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30086.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30086.json
index e1b3308f259..88d1920a8bb 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-30086.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30086.json
@@ -1,7 +1,7 @@
 {
   "commentedAboutFailingChecks": false,
   "reviewersAssignedForLabels": {
-"python": "liferoad"
+"python": "damccorm"
   },
   "nextAction": "Reviewers",
   "stopReviewerNotifications": false,



(beam) branch pr-bot-state updated: Updating config from 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 ae674cb014f Updating config from bot
ae674cb014f is described below

commit ae674cb014f51f97a96e5884134e15cfeaf007b0
Author: github-actions 
AuthorDate: Fri Feb 2 11:58:16 2024 +

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

diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30193.json 
b/scripts/ci/pr-bot/state/pr-state/pr-30193.json
index 242a48d7d3b..37f7ab41238 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-30193.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30193.json
@@ -2,7 +2,7 @@
   "commentedAboutFailingChecks": true,
   "reviewersAssignedForLabels": {},
   "nextAction": "Author",
-  "stopReviewerNotifications": false,
+  "stopReviewerNotifications": true,
   "remindAfterTestsPass": [],
   "committerAssigned": false
 }
\ No newline at end of file



(beam) branch master updated (124880bc8ce -> 1f69271044d)

This is an automated email from the ASF dual-hosted git repository.

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


from 124880bc8ce Fix typo affecting 
DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)
 add 1f69271044d [Dataflow Streaming] Add a option to use multiple commit 
threads (#30194)

No new revisions were added by this update.

Summary of changes:
 .../options/DataflowPipelineDebugOptions.java  |  6 +++
 .../dataflow/worker/StreamingDataflowWorker.java   | 49 --
 .../worker/StreamingDataflowWorkerTest.java| 46 +++-
 3 files changed, 77 insertions(+), 24 deletions(-)



(beam) branch pr-bot-state updated: Updating config from 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 a0b1a314be1 Updating config from bot
a0b1a314be1 is described below

commit a0b1a314be1d49541aa828b542487554544f7564
Author: github-actions 
AuthorDate: Fri Feb 2 09:13:53 2024 +

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

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



(beam) branch master updated: Fix typo affecting DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)

This is an automated email from the ASF dual-hosted git repository.

scwhittle 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 124880bc8ce Fix typo affecting 
DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)
124880bc8ce is described below

commit 124880bc8ce22a2ccbbc0efab435f64099ce65df
Author: Arun Pandian 
AuthorDate: Fri Feb 2 00:52:55 2024 -0800

Fix typo affecting 
DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)

Co-authored-by: Arun Pandian 
---
 .../beam/runners/dataflow/options/DataflowPipelineDebugOptions.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java
 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java
index 290418bd1cb..794dd76d243 100644
--- 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java
+++ 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java
@@ -258,7 +258,7 @@ public interface DataflowPipelineDebugOptions
   @Default.Integer(60 * 1000) // 1 minute
   Integer getStreamingSideInputCacheExpirationMillis();
 
-  void setstreamingSideInputCacheExpirationMillis(Integer value);
+  void setStreamingSideInputCacheExpirationMillis(Integer value);
 
   /**
* The amount of time before UnboundedReaders are considered idle and closed 
during streaming