(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 e205aec39ea Updating config from bot
e205aec39ea is described below
commit e205aec39eab76bf1a25032ca5f9fcbc9b63e1f9
Author: github-actions
AuthorDate: Tue Mar 19 05:34:29 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 115a6f3c159..c4b545f49f3 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": 1709741161841,
+"lostluck": 171082643,
"jrmccluskey": 1710375529238,
"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 bb0e22617c2 Updating config from bot
bb0e22617c2 is described below
commit bb0e22617c2d8a27adbce1b781a30007f738547f
Author: github-actions
AuthorDate: Tue Mar 19 05:34:25 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30670.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30670.json
b/scripts/ci/pr-bot/state/pr-state/pr-30670.json
new file mode 100644
index 000..242a48d7d3b
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30670.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
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 ce3f7327442 Updating config from bot
ce3f7327442 is described below
commit ce3f7327442d8a4a0b26e22c92df91aa005e5984
Author: github-actions
AuthorDate: Tue Mar 19 05:34:28 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30669.json | 10 ++
1 file changed, 10 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30669.json
b/scripts/ci/pr-bot/state/pr-state/pr-30669.json
new file mode 100644
index 000..8ea94810368
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30669.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 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 64dff168e5f Updating config from bot
64dff168e5f is described below
commit 64dff168e5f5f81c4e22324b83fbd6d7b486da91
Author: github-actions
AuthorDate: Tue Mar 19 05:34:22 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30671.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30671.json
b/scripts/ci/pr-bot/state/pr-state/pr-30671.json
new file mode 100644
index 000..242a48d7d3b
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30671.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/aws/aws-sdk-go-v2/feature/s3/manager-1.16.11 deleted (was 6c4ba3f7b21)
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/aws/aws-sdk-go-v2/feature/s3/manager-1.16.11 in repository https://gitbox.apache.org/repos/asf/beam.git was 6c4ba3f7b21 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager 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 dependabot/go_modules/sdks/github.com/aws/aws-sdk-go-v2/feature/s3/manager-1.16.12 created (now 0a1e158043b)
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/aws/aws-sdk-go-v2/feature/s3/manager-1.16.12 in repository https://gitbox.apache.org/repos/asf/beam.git at 0a1e158043b Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks No new revisions were added by this update.
(beam) branch dependabot/go_modules/sdks/github.com/aws/aws-sdk-go-v2/service/s3-1.52.1 deleted (was aa12ad1d742)
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/aws/aws-sdk-go-v2/service/s3-1.52.1 in repository https://gitbox.apache.org/repos/asf/beam.git was aa12ad1d742 Bump github.com/aws/aws-sdk-go-v2/service/s3 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 dependabot/go_modules/sdks/github.com/aws/aws-sdk-go-v2/service/s3-1.53.0 created (now ee4d6239533)
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/aws/aws-sdk-go-v2/service/s3-1.53.0 in repository https://gitbox.apache.org/repos/asf/beam.git at ee4d6239533 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks No new revisions were added by this update.
(beam) branch dependabot/go_modules/sdks/github.com/aws/aws-sdk-go-v2/credentials-1.17.8 created (now 6566d41a855)
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/aws/aws-sdk-go-v2/credentials-1.17.8 in repository https://gitbox.apache.org/repos/asf/beam.git at 6566d41a855 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks No new revisions were added by this update.
(beam) branch nightly-refs/heads/master updated (3aa78d21f70 -> c3b3fa62c3a)
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 3aa78d21f70 Better error message for large elements. (#30639) add 50c59912bc0 Revert "Implementing lull reporting at bundle level processing (#29882)" (#30648) add 63aff7e580b Bump google.golang.org/protobuf from 1.32.0 to 1.33.0 in /sdks (#30629) add c3b3fa62c3a Include byte size of stateKey in estimated weight of WindmillBag, WindmillValue, and WindmillWatermarkHold (#30654) No new revisions were added by this update. Summary of changes: .../core/metrics/ExecutionStateTracker.java| 25 .../dataflow/worker/DataflowExecutionContext.java | 117 + .../dataflow/worker/DataflowOperationContext.java | 80 +++- .../runners/dataflow/worker/StackTraceUtil.java| 66 -- .../worker/windmill/state/WindmillBag.java | 2 +- .../worker/windmill/state/WindmillValue.java | 2 +- .../windmill/state/WindmillWatermarkHold.java | 3 +- .../worker/DataflowExecutionStateTrackerTest.java | 140 + .../worker/DataflowOperationContextTest.java | 80 ++-- .../windmill/state/WindmillStateInternalsTest.java | 18 +-- sdks/go.mod| 2 +- sdks/go.sum| 4 +- 12 files changed, 171 insertions(+), 368 deletions(-) delete mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StackTraceUtil.java
(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 14b804a2194 Updating config from bot
14b804a2194 is described below
commit 14b804a2194b5625e0f1f961d276f83f39a16d3b
Author: github-actions
AuthorDate: Tue Mar 19 03:34:50 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 dd7a475147b..d5eeca57d2f 100644
--- a/scripts/ci/pr-bot/state/reviewers-for-label-build.json
+++ b/scripts/ci/pr-bot/state/reviewers-for-label-build.json
@@ -1,7 +1,7 @@
{
"label": "build",
"dateOfLastReviewAssignment": {
-"damccorm": 1710439579182,
+"damccorm": 1710819285271,
"Abacn": 1710630350352
}
}
\ 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 79c04c64b3b Updating config from bot 79c04c64b3b is described below commit 79c04c64b3b78f61375232bbd41887c04240de85 Author: github-actions AuthorDate: Tue Mar 19 03:34:48 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 a5e4a8d6725..cb711f1f431 100644 --- a/scripts/ci/pr-bot/state/reviewers-for-label-python.json +++ b/scripts/ci/pr-bot/state/reviewers-for-label-python.json @@ -11,7 +11,7 @@ "damccorm": 1709863822385, "jrmccluskey": 1710776076591, "riteshghorse": 1709764491759, -"liferoad": 1709786079956, +"liferoad": 1710819285271, "shunping": 1710265960889 } } \ 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 726ead6b28b Updating config from bot
726ead6b28b is described below
commit 726ead6b28b7629986578f909817353b39352e0f
Author: github-actions
AuthorDate: Tue Mar 19 03:34:46 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30668.json | 11 +++
1 file changed, 11 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30668.json
b/scripts/ci/pr-bot/state/pr-state/pr-30668.json
new file mode 100644
index 000..5216b6274e8
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30668.json
@@ -0,0 +1,11 @@
+{
+ "commentedAboutFailingChecks": false,
+ "reviewersAssignedForLabels": {
+"python": "liferoad",
+"build": "damccorm"
+ },
+ "nextAction": "Reviewers",
+ "stopReviewerNotifications": false,
+ "remindAfterTestsPass": [],
+ "committerAssigned": false
+}
\ No newline at end of file
(beam-site) branch updates_release_2.55.0 created (now b8d0843799)
This is an automated email from the ASF dual-hosted git repository. yhu pushed a change to branch updates_release_2.55.0 in repository https://gitbox.apache.org/repos/asf/beam-site.git at b8d0843799 Update beam-site for release 2.55.0. No new revisions were added by this update.
svn commit: r67999 - /dev/beam/2.55.0/python/
Author: yhu Date: Tue Mar 19 00:45:38 2024 New Revision: 67999 Log: Staging Python artifacts for Apache Beam 2.55.0 RC Modified: dev/beam/2.55.0/python/apache-beam-2.55.0.tar.gz dev/beam/2.55.0/python/apache-beam-2.55.0.tar.gz.asc dev/beam/2.55.0/python/apache-beam-2.55.0.tar.gz.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-macosx_10_9_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-macosx_10_9_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-macosx_10_9_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_i686.manylinux2014_i686.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_i686.manylinux2014_i686.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_i686.manylinux2014_i686.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win32.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win32.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win32.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win_amd64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win_amd64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp310-cp310-win_amd64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-macosx_10_9_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-macosx_10_9_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-macosx_10_9_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_i686.manylinux2014_i686.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_i686.manylinux2014_i686.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_i686.manylinux2014_i686.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win32.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win32.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win32.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win_amd64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win_amd64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp311-cp311-win_amd64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-macosx_10_9_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-macosx_10_9_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-macosx_10_9_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_i686.manylinux2014_i686.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_i686.manylinux2014_i686.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_i686.manylinux2014_i686.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.asc dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.sha512 dev/beam/2.55.0/python/apache_beam-2.55.0-cp38-cp38-win32.whl
(beam-site) branch updates_release_2.55.0 deleted (was 3019ebee75)
This is an automated email from the ASF dual-hosted git repository. yhu pushed a change to branch updates_release_2.55.0 in repository https://gitbox.apache.org/repos/asf/beam-site.git was 3019ebee75 Update beam-site for release 2.55.0. 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 asf-site updated: Publishing website 2024/03/18 23:39:27 at commit c3b3fa6
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 932d4dae31e Publishing website 2024/03/18 23:39:27 at commit c3b3fa6 932d4dae31e is described below commit 932d4dae31ee03752cdc51f7c87567b778edba58 Author: runner AuthorDate: Mon Mar 18 23:39:28 2024 + Publishing website 2024/03/18 23:39:27 at commit c3b3fa6 --- 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 20d26863caf..f73110725b5 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-18T12:43:27-04:00/categories/blog/2024-03-18T12:43:27-04:00/blog/2024-03-18T12:43:27-04:00/categories/2024-03-18T12:43:27-04: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-18T11:43:27-07:00/categories/blog/2024-03-18T11:43:27-07:00/blog/2024-03-18T11:43:27-07:00/categories/2024-03-18T11:43:27-07:00/catego [...] \ No newline at end of file
(beam-site) branch updates_release_2.55.0 updated (2ab0a42caf -> 3019ebee75)
This is an automated email from the ASF dual-hosted git repository. yhu pushed a change to branch updates_release_2.55.0 in repository https://gitbox.apache.org/repos/asf/beam-site.git omit 2ab0a42caf Update beam-site for release 2.55.0. add 3019ebee75 Update beam-site for release 2.55.0. This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (2ab0a42caf) \ N -- N -- N refs/heads/updates_release_2.55.0 (3019ebee75) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: javadoc/2.55.0/deprecated-list.html| 38 +-- .../sdk/extensions/sql/impl/rel/package-tree.html | 2 +- .../org/apache/beam/sdk/io/cdap/package-tree.html | 2 +- .../org/apache/beam/sdk/io/fs/package-tree.html| 4 +- .../beam/sdk/io/gcp/bigquery/package-tree.html | 14 +- .../beam/sdk/io/gcp/healthcare/package-tree.html | 4 +- .../spanner/changestreams/model/package-tree.html | 2 +- .../org/apache/beam/sdk/io/package-tree.html | 6 +- .../beam/sdk/io/snowflake/enums/package-tree.html | 2 +- .../org/apache/beam/sdk/options/package-tree.html | 16 +- .../2.55.0/org/apache/beam/sdk/package-tree.html | 2 +- .../beam/sdk/schemas/annotations/package-tree.html | 8 +- .../org/apache/beam/sdk/schemas/package-tree.html | 6 +- .../apache/beam/sdk/transforms/package-tree.html | 48 ++-- .../sdk/transforms/windowing/package-tree.html | 4 +- .../org/apache/beam/sdk/values/package-tree.html | 2 +- javadoc/2.55.0/overview-tree.html | 110 pydoc/2.55.0/apache_beam.dataframe.frames.html | 294 ++--- pydoc/2.55.0/apache_beam.dataframe.io.html | 10 +- pydoc/2.55.0/apache_beam.dataframe.transforms.html | 12 +- pydoc/2.55.0/apache_beam.io.fileio.html| 2 +- ...he_beam.ml.inference.huggingface_inference.html | 16 +- .../apache_beam.ml.inference.onnx_inference.html | 6 +- ...apache_beam.ml.inference.pytorch_inference.html | 16 +- ...che_beam.ml.inference.tensorflow_inference.html | 14 +- ...pache_beam.ml.inference.tensorrt_inference.html | 6 +- ...apache_beam.ml.inference.xgboost_inference.html | 22 +- .../2.55.0/apache_beam.ml.transforms.handlers.html | 8 +- pydoc/2.55.0/apache_beam.ml.transforms.tft.html| 18 +- .../apache_beam.transforms.periodicsequence.html | 2 +- pydoc/2.55.0/apache_beam.typehints.schemas.html| 4 +- pydoc/2.55.0/doctest/output.txt| 8 +- .../2.55.0/doctrees/apache_beam.io.fileio.doctree | Bin 83008 -> 83008 bytes ...beam.ml.inference.huggingface_inference.doctree | Bin 116743 -> 116743 bytes ...apache_beam.ml.inference.onnx_inference.doctree | Bin 28774 -> 28774 bytes ...che_beam.ml.inference.pytorch_inference.doctree | Bin 86539 -> 86539 bytes ..._beam.ml.inference.tensorflow_inference.doctree | Bin 71158 -> 71158 bytes ...he_beam.ml.inference.tensorrt_inference.doctree | Bin 40614 -> 40614 bytes ...che_beam.ml.inference.xgboost_inference.doctree | Bin 118378 -> 118378 bytes .../apache_beam.ml.transforms.handlers.doctree | Bin 29035 -> 29035 bytes .../doctrees/apache_beam.ml.transforms.tft.doctree | Bin 94617 -> 94617 bytes ...apache_beam.transforms.periodicsequence.doctree | Bin 37699 -> 37699 bytes .../doctrees/apache_beam.typehints.schemas.doctree | Bin 222136 -> 222136 bytes pydoc/2.55.0/doctrees/environment.pickle | Bin 12927496 -> 12927048 bytes pydoc/2.55.0/searchindex.js| 2 +- .../classes/coders_js_coders.BsonObjectCoder.html | 10 +- .../coders_js_coders.GeneralObjectCoder.html | 16 +- .../classes/coders_required_coders.BytesCoder.html | 14 +- ...ers_required_coders.FullWindowedValueCoder.html | 18 +- .../coders_required_coders.GlobalWindowCoder.html | 12 +- .../coders_required_coders.InstantCoder.html | 12 +- .../coders_required_coders.IterableCoder.html | 18 +- .../classes/coders_required_coders.KVCoder.html| 18 +- ...coders_required_coders.LengthPrefixedCoder.html | 14 +- .../coders_required_coders.PaneInfoCoder.html | 18 +- .../2.55.0/classes/coders_row_coder.RowCoder.html | 44 +-- .../classes/coders_standard_coders.BoolCoder.html | 12 +- .../coders_standard_coders.DoubleCoder.html| 10 +- ...coders_standard_coders.IntervalWindowCoder.html | 12 +- .../coders_standard_coders.NullableCoder.html | 16
svn commit: r67998 - in /dev/beam/2.55.0: apache-beam-2.55.0-source-release.zip apache-beam-2.55.0-source-release.zip.asc apache-beam-2.55.0-source-release.zip.sha512
Author: yhu Date: Mon Mar 18 22:32:42 2024 New Revision: 67998 Log: Staging Java artifacts for Apache Beam 2.55.0 RC3 Added: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip (with props) Modified: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.asc dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.sha512 Added: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip == Binary file - no diff available. Propchange: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip -- svn:mime-type = application/octet-stream Modified: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.asc == --- dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.asc (original) +++ dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.asc Mon Mar 18 22:32:42 2024 @@ -1,17 +1,17 @@ -BEGIN PGP SIGNATURE- -iQJMBAABCgA2FiEEkTwzkqdwx4HtxN2r0gMW9xIhNCIFAmXzQYYYHHByaXZhdGVA -YmVhbS5hcGFjaGUub3JnAAoJENIDFvcSITQiLnQP/iuILXNvLK3EG6TzCCfPBC1t -Z24/Vbc9irAAfNd7EhStwV5X1AjaUTBPfzYDibU0rjPXKXw4RKDNBuEuCRJySO5b -7hH9A4zwFUL6RbWtXBpkGg/r/Qf542B/ubq0HIHdh+tIdn4abmCtVoPz+1S5X4hU -dklbO1kVV58x9UnFHhwvrS5ds9farEBfwPjsefKnfeuwUJvaxZcVZfClqQ5XLmdb -94MRHi31YW7LH3ZCl3S7M8Pf6DOHR+o5oOwljbCg5PQx1xK6h0C77/V7q1wASXym -zTL2wBEHV2yRX0De80sgfcsc7PqyHXcR+peCcAMQp7nIE5Lj7q0S2PhaDdV3YtUX -E1B4Rbm43qHk/U3SYlCq5ecPovVORXcOfUqggHHNnSyxOOkQJa+uBerMd+Fw2Cks -BPUiKdtCUnQUnchAQI7jSW2BX2ud8omr598MlIp+fVt6xmeINrsH9oRQhgcZrGhf -vIP5xWkpCHFMm59XQyNXVM82ULLHD6oJhsbpBQMXEgNHt4y0J82M2/R1XfAk7yO9 -aFNSozHIcPmJiTtpq3mctu0gu2QNR/IshqEO+Ka4HMQACzYhGFm4R6TCY/K4LNSv -UbnA9kKOGal5nmx41qR4bhR4u8g42AHk2PBnkR62kEe5vwux6br/ajUuSQX1SQM4 -gXJfbWFkuZQTI2PQnyxK -=oqhV +iQJMBAABCgA2FiEEkTwzkqdwx4HtxN2r0gMW9xIhNCIFAmX4wQYYHHByaXZhdGVA +YmVhbS5hcGFjaGUub3JnAAoJENIDFvcSITQiKSIP/RhfEkrNlivZF2xTn/s9C7qO +BaIp16LfExDZiPArUfPXI29QEee5G4yUdKj6cZSjJ2ElmHJ1jrIj8jVxocoWXMTI +AMbFNfmqPo8ML4B24tw9k31gF6P3hqrwX6vlFCTqzfaJgQa+k405lWZA+MKjXnRo +OKt3bqODW/GjGBiV6uslVqw0EY3YhB5k0IxMKeXVl5VLK2XUG7ePnJeI8i2RT3XL +vVsdE87ctjEnDCPJS3Lct9XqsBBUZGTho+swtyEUBYRzuVvtE6uULdM+ihOLXwTh +RBMVf5xE2xd+sGyZKNNs1y9b3L3PFi3TWkBXzeCi39qzZOyeXSyiL7objiOZd0QE +J4GqOcFwLi9wp5xMVjsQ9/bJwFn0rsCRN5hCA638/sRXR/Ig53/gJmjayDMZoDoL +i/3Z+k9ivK/54fR/UvnRAD2PjDa2hBDP/jDO86sPBTzeYK7VoArctj0MCs2Op7E5 +lF9ZYJcPYVWziP7d7xtjM3ygWMxiwqM4RX2BzWBLoGjVbOCZqqwBKxUd2eBr5h2W +Q2HfTfsZA3R/mbjZkJ574dZcake/bURZElNVtAX3aeWo6VVdCS3J7rqUvDVwLH+f +h9g8G1hc0LC58+H/BhVapdXcu6Wxjsp3DyHKO00wBw3iKBHji/HCqotCy3R6mXRm +x6qmuuSXrjrHgJWPTUil +=MPuF -END PGP SIGNATURE- Modified: dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.sha512 == --- dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.sha512 (original) +++ dev/beam/2.55.0/apache-beam-2.55.0-source-release.zip.sha512 Mon Mar 18 22:32:42 2024 @@ -1 +1 @@ -ef69cfd73a2d8c330e38a50bcf3615adde6feb4caff71f1192dda6c0b050e06cf76a91b5e445acb2fda23c92cbd859d1354869941c1d493f2ba559d712ee0f39 apache-beam-2.55.0-source-release.zip +1b042b99e084ac15dfdc7c32c775bc4c389b9d58d313309c7fad191743a77495ff8f1e03562805f5275c534a654c98cec41d02ba0e2b3d334a34ff687309484c apache-beam-2.55.0-source-release.zip
(beam) annotated tag sdks/v2.55.0-RC3 updated (dda0549e5e8 -> 3dc2157e7e0)
This is an automated email from the ASF dual-hosted git repository. yhu pushed a change to annotated tag sdks/v2.55.0-RC3 in repository https://gitbox.apache.org/repos/asf/beam.git *** WARNING: tag sdks/v2.55.0-RC3 was modified! *** from dda0549e5e8 (commit) to 3dc2157e7e0 (tag) tagging dda0549e5e848cbc2a47a86c9ee9494040130c1f (commit) replaces jupyterlab-sidepanel-v3.0.0 by Yi Hu on Mon Mar 18 21:35:56 2024 + - Log - Go SDK v2.55.0-RC3 --- No new revisions were added by this update. Summary of changes:
(beam) annotated tag v2.55.0-RC3 updated (dda0549e5e8 -> 986a611dd83)
This is an automated email from the ASF dual-hosted git repository. yhu pushed a change to annotated tag v2.55.0-RC3 in repository https://gitbox.apache.org/repos/asf/beam.git *** WARNING: tag v2.55.0-RC3 was modified! *** from dda0549e5e8 (commit) to 986a611dd83 (tag) tagging dda0549e5e848cbc2a47a86c9ee9494040130c1f (commit) replaces jupyterlab-sidepanel-v3.0.0 by Yi Hu on Mon Mar 18 21:35:56 2024 + - Log - v2.55.0-RC3 --- No new revisions were added by this update. Summary of changes:
(beam) branch release-2.55.0 updated: Revert "Implementing lull reporting at bundle level processing (#29882)" (#30648) (#30664)
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch release-2.55.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.55.0 by this push:
new 0dc330e6d53 Revert "Implementing lull reporting at bundle level
processing (#29882)" (#30648) (#30664)
0dc330e6d53 is described below
commit 0dc330e6d53cce51b13bcb652e80859c1b3a5975
Author: Yi Hu
AuthorDate: Mon Mar 18 17:29:24 2024 -0400
Revert "Implementing lull reporting at bundle level processing (#29882)"
(#30648) (#30664)
This reverts commit ffe2dba532028cdbbb5bca9c374f0a2d756ee8bf.
Co-authored-by: Arvind Ram
---
.../core/metrics/ExecutionStateTracker.java| 25
.../dataflow/worker/DataflowExecutionContext.java | 117 +
.../dataflow/worker/DataflowOperationContext.java | 80 +++-
.../runners/dataflow/worker/StackTraceUtil.java| 66 --
.../worker/DataflowExecutionStateTrackerTest.java | 140 +
.../worker/DataflowOperationContextTest.java | 80 ++--
6 files changed, 155 insertions(+), 353 deletions(-)
diff --git
a/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
b/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
index b0b8f0107f3..dc6fd2f8248 100644
---
a/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
+++
b/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
@@ -46,7 +46,6 @@ public class ExecutionStateTracker implements
Comparable
new ConcurrentHashMap<>();
private static final long LULL_REPORT_MS = TimeUnit.MINUTES.toMillis(5);
- private static final long BUNDLE_LULL_REPORT_MS =
TimeUnit.MINUTES.toMillis(10);
private static final AtomicIntegerFieldUpdater
SAMPLING_UPDATER =
AtomicIntegerFieldUpdater.newUpdater(ExecutionStateTracker.class,
"sampling");
@@ -140,17 +139,8 @@ public class ExecutionStateTracker implements
Comparable
*/
private volatile long millisSinceLastTransition = 0;
- /**
- * The number of milliseconds since the {@link ExecutionStateTracker}
initial state.
- *
- * This variable is updated by the Sampling thread, and read by the
Progress Reporting thread,
- * thus it being marked volatile.
- */
- private volatile long millisSinceBundleStart = 0;
-
private long transitionsAtLastSample = 0;
private long nextLullReportMs = LULL_REPORT_MS;
- private long nextBundleLullReportMs = BUNDLE_LULL_REPORT_MS;
public ExecutionStateTracker(ExecutionStateSampler sampler) {
this.sampler = sampler;
@@ -165,10 +155,8 @@ public class ExecutionStateTracker implements
Comparable
currentState = null;
numTransitions = 0;
millisSinceLastTransition = 0;
-millisSinceBundleStart = 0;
transitionsAtLastSample = 0;
nextLullReportMs = LULL_REPORT_MS;
-nextBundleLullReportMs = BUNDLE_LULL_REPORT_MS;
}
@VisibleForTesting
@@ -347,19 +335,6 @@ public class ExecutionStateTracker implements
Comparable
transitionsAtLastSample = transitionsAtThisSample;
}
updateMillisSinceLastTransition(millisSinceLastSample, state);
-updateMillisSinceBundleStart(millisSinceLastSample);
- }
-
- // Override this to implement bundle level lull reporting.
- protected void reportBundleLull(long millisSinceBundleStart) {}
-
- @SuppressWarnings("NonAtomicVolatileUpdate")
- private void updateMillisSinceBundleStart(long millisSinceLastSample) {
-millisSinceBundleStart += millisSinceLastSample;
-if (millisSinceBundleStart > nextBundleLullReportMs) {
- reportBundleLull(millisSinceBundleStart);
- nextBundleLullReportMs += BUNDLE_LULL_REPORT_MS;
-}
}
@SuppressWarnings("NonAtomicVolatileUpdate")
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
index 16ff2975b02..080fa7c9dac 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
@@ -19,7 +19,6 @@ package org.apache.beam.runners.dataflow.worker;
import static
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions.checkNotNull;
-import com.google.api.client.util.Clock;
import com.google.api.services.dataflow.model.SideInputInfo;
import java.io.Closeable;
import java.io.IOException;
@@ -30,8 +29,6 @@ import java.util.IntSummaryStatistics;
import java.util.LinkedHashMap;
import java.util.Map;
import
(beam) branch release-2.55.0 updated: Include byte size of stateKey in estimated weight of WindmillBag, WindmillValue, and WindmillWatermarkHold (#30654) (#30665)
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch release-2.55.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.55.0 by this push:
new d9897b0fc33 Include byte size of stateKey in estimated weight of
WindmillBag, WindmillValue, and WindmillWatermarkHold (#30654) (#30665)
d9897b0fc33 is described below
commit d9897b0fc334f5804af54aeedad6c78935a4237b
Author: Yi Hu
AuthorDate: Mon Mar 18 17:28:11 2024 -0400
Include byte size of stateKey in estimated weight of WindmillBag,
WindmillValue, and WindmillWatermarkHold (#30654) (#30665)
* Update WindmillBag.java
Include byte size of the stateKey on the BagState weight used to estimate
and limit the total state cache size
* Update WindmillValue.java
Include stateKey size in the byte size of a WidnmillValue
* Update WindmillWatermarkHold.java
Include keyState size in the WatermarkHold estimated byte size
* Fix formatting issue
* Fix expected cache item weights in WindmillStateInternalsTest
Co-authored-by: dmitryor <34167644+dmitr...@users.noreply.github.com>
---
.../dataflow/worker/windmill/state/WindmillBag.java| 2 +-
.../dataflow/worker/windmill/state/WindmillValue.java | 2 +-
.../worker/windmill/state/WindmillWatermarkHold.java | 3 ++-
.../windmill/state/WindmillStateInternalsTest.java | 18 +-
4 files changed, 13 insertions(+), 12 deletions(-)
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
index b3719cc666d..702be70f411 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
@@ -193,7 +193,7 @@ public class WindmillBag extends SimpleWindmillState
implements BagState {
}
// We now know the complete bag contents, and any read on it will yield a
// cached value, so cache it for future reads.
- cache.put(namespace, address, this, encodedSize);
+ cache.put(namespace, address, this, encodedSize + stateKey.size());
}
// Don't reuse the localAdditions object; we don't want future changes to
it to
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
index 923d166c823..bc3e0906f99 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
@@ -124,7 +124,7 @@ public class WindmillValue extends SimpleWindmillState
implements ValueState<
coder.encode(value, stream, Coder.Context.OUTER);
}
encoded = stream.toByteString();
- cachedSize = encoded.size();
+ cachedSize = (long) encoded.size() + stateKey.size();
}
// Place in cache to avoid a future read.
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
index 9d939c759d2..e8b2290c3c7 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
@@ -175,13 +175,14 @@ public class WindmillWatermarkHold extends WindmillState
implements WatermarkHol
throw new IllegalStateException("Unreachable condition");
}
+final int estimatedByteSize = ENCODED_SIZE + stateKey.size();
return Futures.lazyTransform(
result,
result1 -> {
cleared = false;
localAdditions = null;
if (cachedValue != null) {
-cache.put(namespace, address, WindmillWatermarkHold.this,
ENCODED_SIZE);
+cache.put(namespace, address, WindmillWatermarkHold.this,
estimatedByteSize);
}
return result1;
});
diff --git
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateInternalsTest.java
(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 b25de9ab56e Updating config from bot
b25de9ab56e is described below
commit b25de9ab56ee3704a0bd332b177f5c96c36c738e
Author: github-actions
AuthorDate: Mon Mar 18 19:08:21 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30666.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30666.json
b/scripts/ci/pr-bot/state/pr-state/pr-30666.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30666.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 b3b61550717 Updating config from bot
b3b61550717 is described below
commit b3b61550717fc5ed6c40516a04fa68fd8193a459
Author: github-actions
AuthorDate: Mon Mar 18 18:49:22 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30665.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30665.json
b/scripts/ci/pr-bot/state/pr-state/pr-30665.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30665.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: Include byte size of stateKey in estimated weight of WindmillBag, WindmillValue, and WindmillWatermarkHold (#30654)
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 c3b3fa62c3a Include byte size of stateKey in estimated weight of
WindmillBag, WindmillValue, and WindmillWatermarkHold (#30654)
c3b3fa62c3a is described below
commit c3b3fa62c3a323e8da15a18aeba4a43b628efd24
Author: dmitryor <34167644+dmitr...@users.noreply.github.com>
AuthorDate: Mon Mar 18 11:43:27 2024 -0700
Include byte size of stateKey in estimated weight of WindmillBag,
WindmillValue, and WindmillWatermarkHold (#30654)
* Update WindmillBag.java
Include byte size of the stateKey on the BagState weight used to estimate
and limit the total state cache size
* Update WindmillValue.java
Include stateKey size in the byte size of a WidnmillValue
* Update WindmillWatermarkHold.java
Include keyState size in the WatermarkHold estimated byte size
* Fix formatting issue
* Fix expected cache item weights in WindmillStateInternalsTest
---
.../dataflow/worker/windmill/state/WindmillBag.java| 2 +-
.../dataflow/worker/windmill/state/WindmillValue.java | 2 +-
.../worker/windmill/state/WindmillWatermarkHold.java | 3 ++-
.../windmill/state/WindmillStateInternalsTest.java | 18 +-
4 files changed, 13 insertions(+), 12 deletions(-)
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
index b3719cc666d..702be70f411 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
@@ -193,7 +193,7 @@ public class WindmillBag extends SimpleWindmillState
implements BagState {
}
// We now know the complete bag contents, and any read on it will yield a
// cached value, so cache it for future reads.
- cache.put(namespace, address, this, encodedSize);
+ cache.put(namespace, address, this, encodedSize + stateKey.size());
}
// Don't reuse the localAdditions object; we don't want future changes to
it to
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
index 923d166c823..bc3e0906f99 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
@@ -124,7 +124,7 @@ public class WindmillValue extends SimpleWindmillState
implements ValueState<
coder.encode(value, stream, Coder.Context.OUTER);
}
encoded = stream.toByteString();
- cachedSize = encoded.size();
+ cachedSize = (long) encoded.size() + stateKey.size();
}
// Place in cache to avoid a future read.
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
index 9d939c759d2..e8b2290c3c7 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
@@ -175,13 +175,14 @@ public class WindmillWatermarkHold extends WindmillState
implements WatermarkHol
throw new IllegalStateException("Unreachable condition");
}
+final int estimatedByteSize = ENCODED_SIZE + stateKey.size();
return Futures.lazyTransform(
result,
result1 -> {
cleared = false;
localAdditions = null;
if (cachedValue != null) {
-cache.put(namespace, address, WindmillWatermarkHold.this,
ENCODED_SIZE);
+cache.put(namespace, address, WindmillWatermarkHold.this,
estimatedByteSize);
}
return result1;
});
diff --git
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateInternalsTest.java
(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 a456fc598fb Updating config from bot
a456fc598fb is described below
commit a456fc598fb14ace4675e35b0c2e352fe7f53f9b
Author: github-actions
AuthorDate: Mon Mar 18 18:12:12 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30664.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30664.json
b/scripts/ci/pr-bot/state/pr-state/pr-30664.json
new file mode 100644
index 000..9c2aa5aa212
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30664.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/03/18 17:38:23 at commit 63aff7e
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 6ff0d29aeaa Publishing website 2024/03/18 17:38:23 at commit 63aff7e 6ff0d29aeaa is described below commit 6ff0d29aeaa14db61b3941bd4d5a56d5823ec892 Author: runner AuthorDate: Mon Mar 18 17:38:23 2024 + Publishing website 2024/03/18 17:38:23 at commit 63aff7e --- 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 47b38384502..20d26863caf 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-18T03:31:49-07:00/categories/blog/2024-03-18T03:31:49-07:00/blog/2024-03-18T03:31:49-07:00/categories/2024-03-18T03:31:49-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-18T12:43:27-04:00/categories/blog/2024-03-18T12:43:27-04:00/blog/2024-03-18T12:43:27-04:00/categories/2024-03-18T12:43:27-04: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 5fd7401f318 Updating config from bot
5fd7401f318 is described below
commit 5fd7401f318bb7d7f717b30be4925d581716ee37
Author: github-actions
AuthorDate: Mon Mar 18 17:35:10 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30653.json | 8 +---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30653.json
b/scripts/ci/pr-bot/state/pr-state/pr-30653.json
index 242a48d7d3b..cd352f44205 100644
--- a/scripts/ci/pr-bot/state/pr-state/pr-30653.json
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30653.json
@@ -1,7 +1,9 @@
{
- "commentedAboutFailingChecks": true,
- "reviewersAssignedForLabels": {},
- "nextAction": "Author",
+ "commentedAboutFailingChecks": false,
+ "reviewersAssignedForLabels": {
+"no-matching-label": "jrmccluskey"
+ },
+ "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 98eacebf21f Updating config from bot 98eacebf21f is described below commit 98eacebf21fbbedad86866ef563e6cc9dc4d0419 Author: github-actions AuthorDate: Mon Mar 18 17:35:12 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 e8613a6bfd2..b103b6decd6 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 @@ -6,7 +6,7 @@ "chamikaramj": 1710277574566, "damccorm": 1710372879389, "johnjcasey": 171055495, -"jrmccluskey": 1709647558176, +"jrmccluskey": 1710783309312, "kennknowles": 1710638927810, "lostluck": 1709770542862, "riteshghorse": 1709649338569,
(beam) branch dependabot/go_modules/sdks/google.golang.org/protobuf-1.33.0 deleted (was d78ea8becf3)
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.33.0 in repository https://gitbox.apache.org/repos/asf/beam.git was d78ea8becf3 Bump google.golang.org/protobuf from 1.32.0 to 1.33.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.32.0 to 1.33.0 in /sdks (#30629)
This is an automated email from the ASF dual-hosted git repository. jrmccluskey 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 63aff7e580b Bump google.golang.org/protobuf from 1.32.0 to 1.33.0 in /sdks (#30629) 63aff7e580b is described below commit 63aff7e580b860190e5efa5501ab329b34aa6781 Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> AuthorDate: Mon Mar 18 12:43:27 2024 -0400 Bump google.golang.org/protobuf from 1.32.0 to 1.33.0 in /sdks (#30629) Bumps google.golang.org/protobuf from 1.32.0 to 1.33.0. --- updated-dependencies: - dependency-name: google.golang.org/protobuf dependency-type: direct:production ... 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 e4b02336821..4042a9a848d 100644 --- a/sdks/go.mod +++ b/sdks/go.mod @@ -62,7 +62,7 @@ require ( google.golang.org/api v0.166.0 google.golang.org/genproto v0.0.0-20240213162025-012b6fc9bca9 google.golang.org/grpc v1.62.0 - google.golang.org/protobuf v1.32.0 + google.golang.org/protobuf v1.33.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 b3be36490cf..dc0ac9189bd 100644 --- a/sdks/go.sum +++ b/sdks/go.sum @@ -734,8 +734,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.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I= -google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= +google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI= +google.golang.org/protobuf v1.33.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 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 ef994a7cf51 Updating config from bot ef994a7cf51 is described below commit ef994a7cf51fa1cd36bf29508ddd9a1569db38f1 Author: github-actions AuthorDate: Mon Mar 18 16:07:22 2024 + Updating config from bot --- scripts/ci/pr-bot/state/pr-state/pr-30662.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30662.json b/scripts/ci/pr-bot/state/pr-state/pr-30662.json index 75c264d0c37..04cb39b64b2 100644 --- a/scripts/ci/pr-bot/state/pr-state/pr-30662.json +++ b/scripts/ci/pr-bot/state/pr-state/pr-30662.json @@ -7,5 +7,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 bf44a5058a1 Updating config from bot bf44a5058a1 is described below commit bf44a5058a1d859174861d3986bf44bdfe21a337 Author: github-actions AuthorDate: Mon Mar 18 15:34:40 2024 + Updating config from bot --- scripts/ci/pr-bot/state/reviewers-for-label-io.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/scripts/ci/pr-bot/state/reviewers-for-label-io.json b/scripts/ci/pr-bot/state/reviewers-for-label-io.json index 013b723c4dd..b5a57a0e6e5 100644 --- a/scripts/ci/pr-bot/state/reviewers-for-label-io.json +++ b/scripts/ci/pr-bot/state/reviewers-for-label-io.json @@ -4,7 +4,7 @@ "chamikaramj": 1710418434680, "johnjcasey": 1709813615178, "pabloem": 1691787951165, -"Abacn": 1709554543036, +"Abacn": 1710776076591, "ahmedabu98": 1709760886425, "bvolpato": 1710432374340, "manavgarg": 1690826779210,
(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 e1f141d1954 Updating config from bot e1f141d1954 is described below commit e1f141d1954add799038275aceab23ade88e2f7d Author: github-actions AuthorDate: Mon Mar 18 15:34:38 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 ed651ca379d..a5e4a8d6725 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": 1709863822385, -"jrmccluskey": 1709598146839, +"jrmccluskey": 1710776076591, "riteshghorse": 1709764491759, "liferoad": 1709786079956, "shunping": 1710265960889
(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 9e3d8f62d09 Updating config from bot
9e3d8f62d09 is described below
commit 9e3d8f62d09fce06e24e0244ab3cddffb309bb9d
Author: github-actions
AuthorDate: Mon Mar 18 15:34:37 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30662.json | 11 +++
1 file changed, 11 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30662.json
b/scripts/ci/pr-bot/state/pr-state/pr-30662.json
new file mode 100644
index 000..75c264d0c37
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30662.json
@@ -0,0 +1,11 @@
+{
+ "commentedAboutFailingChecks": false,
+ "reviewersAssignedForLabels": {
+"python": "jrmccluskey",
+"io": "Abacn"
+ },
+ "nextAction": "Reviewers",
+ "stopReviewerNotifications": false,
+ "remindAfterTestsPass": [],
+ "committerAssigned": false
+}
\ No newline at end of file
(beam) branch master updated: Revert "Implementing lull reporting at bundle level processing (#29882)" (#30648)
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 50c59912bc0 Revert "Implementing lull reporting at bundle level
processing (#29882)" (#30648)
50c59912bc0 is described below
commit 50c59912bc002947c335170b42827b278b78aae1
Author: Arvind Ram
AuthorDate: Mon Mar 18 03:31:49 2024 -0700
Revert "Implementing lull reporting at bundle level processing (#29882)"
(#30648)
This reverts commit ffe2dba532028cdbbb5bca9c374f0a2d756ee8bf.
---
.../core/metrics/ExecutionStateTracker.java| 25
.../dataflow/worker/DataflowExecutionContext.java | 117 +
.../dataflow/worker/DataflowOperationContext.java | 80 +++-
.../runners/dataflow/worker/StackTraceUtil.java| 66 --
.../worker/DataflowExecutionStateTrackerTest.java | 140 +
.../worker/DataflowOperationContextTest.java | 80 ++--
6 files changed, 155 insertions(+), 353 deletions(-)
diff --git
a/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
b/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
index b0b8f0107f3..dc6fd2f8248 100644
---
a/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
+++
b/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java
@@ -46,7 +46,6 @@ public class ExecutionStateTracker implements
Comparable
new ConcurrentHashMap<>();
private static final long LULL_REPORT_MS = TimeUnit.MINUTES.toMillis(5);
- private static final long BUNDLE_LULL_REPORT_MS =
TimeUnit.MINUTES.toMillis(10);
private static final AtomicIntegerFieldUpdater
SAMPLING_UPDATER =
AtomicIntegerFieldUpdater.newUpdater(ExecutionStateTracker.class,
"sampling");
@@ -140,17 +139,8 @@ public class ExecutionStateTracker implements
Comparable
*/
private volatile long millisSinceLastTransition = 0;
- /**
- * The number of milliseconds since the {@link ExecutionStateTracker}
initial state.
- *
- * This variable is updated by the Sampling thread, and read by the
Progress Reporting thread,
- * thus it being marked volatile.
- */
- private volatile long millisSinceBundleStart = 0;
-
private long transitionsAtLastSample = 0;
private long nextLullReportMs = LULL_REPORT_MS;
- private long nextBundleLullReportMs = BUNDLE_LULL_REPORT_MS;
public ExecutionStateTracker(ExecutionStateSampler sampler) {
this.sampler = sampler;
@@ -165,10 +155,8 @@ public class ExecutionStateTracker implements
Comparable
currentState = null;
numTransitions = 0;
millisSinceLastTransition = 0;
-millisSinceBundleStart = 0;
transitionsAtLastSample = 0;
nextLullReportMs = LULL_REPORT_MS;
-nextBundleLullReportMs = BUNDLE_LULL_REPORT_MS;
}
@VisibleForTesting
@@ -347,19 +335,6 @@ public class ExecutionStateTracker implements
Comparable
transitionsAtLastSample = transitionsAtThisSample;
}
updateMillisSinceLastTransition(millisSinceLastSample, state);
-updateMillisSinceBundleStart(millisSinceLastSample);
- }
-
- // Override this to implement bundle level lull reporting.
- protected void reportBundleLull(long millisSinceBundleStart) {}
-
- @SuppressWarnings("NonAtomicVolatileUpdate")
- private void updateMillisSinceBundleStart(long millisSinceLastSample) {
-millisSinceBundleStart += millisSinceLastSample;
-if (millisSinceBundleStart > nextBundleLullReportMs) {
- reportBundleLull(millisSinceBundleStart);
- nextBundleLullReportMs += BUNDLE_LULL_REPORT_MS;
-}
}
@SuppressWarnings("NonAtomicVolatileUpdate")
diff --git
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
index 16ff2975b02..080fa7c9dac 100644
---
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
+++
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java
@@ -19,7 +19,6 @@ package org.apache.beam.runners.dataflow.worker;
import static
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions.checkNotNull;
-import com.google.api.client.util.Clock;
import com.google.api.services.dataflow.model.SideInputInfo;
import java.io.Closeable;
import java.io.IOException;
@@ -30,8 +29,6 @@ import java.util.IntSummaryStatistics;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Optional;
-import java.util.logging.Level;
-import
(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 68f8c51a9a1 Updating config from bot
68f8c51a9a1 is described below
commit 68f8c51a9a1036f0e46174fd240c69799a8cc0c2
Author: github-actions
AuthorDate: Mon Mar 18 06:06:49 2024 +
Updating config from bot
---
scripts/ci/pr-bot/state/pr-state/pr-30660.json | 8
1 file changed, 8 insertions(+)
diff --git a/scripts/ci/pr-bot/state/pr-state/pr-30660.json
b/scripts/ci/pr-bot/state/pr-state/pr-30660.json
new file mode 100644
index 000..242a48d7d3b
--- /dev/null
+++ b/scripts/ci/pr-bot/state/pr-state/pr-30660.json
@@ -0,0 +1,8 @@
+{
+ "commentedAboutFailingChecks": true,
+ "reviewersAssignedForLabels": {},
+ "nextAction": "Author",
+ "stopReviewerNotifications": false,
+ "remindAfterTestsPass": [],
+ "committerAssigned": false
+}
\ No newline at end of file
