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 42de462 [BEAM-13218] Re-enable PubSubIntegrationTest.test_streaming_with_attributes (#16497) add e3e30a7 Merge pull request #16857 from [BEAM-13662] [Playground] Support mutlifile examples add 2a45a5b Merge pull request #16826 from [BEAM-13870] [Playground] Increase test coverage for the cache package add b0899a4 Fix BoundedQueueExecutor and StreamingDataflowWorker to actually limit memory from windmill (#16901) add 0fe57b1 [BEAM-1857] Add Neo4jIO (#15916) add 5a62228 [BEAM-13767] Migrate serveral portable runner tasks to use configuration avoidance API. (#16837) add 9145b5b Revert PR#16253 due errors with plugin flaky-test-handler add 86f2677 Merge pull request #16930 from benWize/revert_PR_16253 add cc16171 [BEAM-13996] Removing 'No cluster_manager is associated with the provided pipeline!' logger error add 90dd44e [BEAM-13906] Improve coverage of errors package (#16934) add b4ee2b9 [BEAM-13886] unit tests for trigger package (#16935) add f94a00f [BEAM-4767] Remove beam- prefix from release script tags (#16899) add bf020ac [BEAM-13866] Add small unit tests to errorx, make boolean assignment more clear (#16943) add 8fcb103 [BEAM-13925] Add most of the supporting files for the pr management automation (#16898) No new revisions were added by this update. Summary of changes: .github/REVIEWERS.yml | 21 + .test-infra/jenkins/job_PreCommit_Java.groovy | 7 +- .test-infra/jenkins/job_PreCommit_Python.groovy | 9 +- build.gradle.kts | 1 + buildSrc/build.gradle.kts | 1 - .../org/apache/beam/gradle/BeamModulePlugin.groovy | 38 +- .../internal/cache/local/local_cache_test.go | 115 +- .../internal/cache/redis/redis_cache_test.go | 68 +- playground/frontend/assets/multifile.svg | 22 + playground/frontend/lib/config.g.dart | 12 +- playground/frontend/lib/constants/assets.dart | 1 + playground/frontend/lib/constants/links.dart | 1 + playground/frontend/lib/constants/sizes.dart | 1 + playground/frontend/lib/l10n/app_en.arb | 18 +- .../lib/modules/editor/components/run_button.dart | 11 +- .../description_popover/description_popover.dart | 39 +- .../description_popover_button.dart | 14 +- .../example_list/example_item_actions.dart | 66 + .../example_list/expansion_panel_item.dart | 9 +- .../multifile_popover.dart} | 26 +- .../multifile_popover_button.dart} | 36 +- .../examples/components/outside_click_handler.dart | 44 +- .../lib/modules/examples/example_selector.dart | 120 +- .../lib/modules/examples/models/example_model.dart | 4 + .../examples/models/popover_state.dart} | 22 +- .../example_client/grpc_example_client.dart | 2 + .../components/editor_textarea_wrapper.dart | 13 +- release/src/main/scripts/cut_release_branch.sh | 2 +- release/src/main/scripts/set_version.sh | 3 - runners/flink/flink_runner.gradle | 2 +- runners/flink/job-server/flink_job_server.gradle | 5 +- .../options/DataflowPipelineDebugOptions.java | 24 + .../dataflow/worker/StreamingDataflowWorker.java | 64 +- .../dataflow/worker/util/BoundedQueueExecutor.java | 148 +- .../worker/StreamingDataflowWorkerTest.java | 16 +- runners/samza/build.gradle | 2 +- runners/samza/job-server/build.gradle | 2 +- runners/spark/job-server/spark_job_server.gradle | 2 +- runners/spark/spark_runner.gradle | 16 +- runners/twister2/build.gradle | 4 +- scripts/ci/pr-bot/README.md | 45 + scripts/ci/pr-bot/package-lock.json | 2062 ++++++++++++++++++++ scripts/ci/pr-bot/package.json | 27 + scripts/ci/pr-bot/shared/checks.ts | 109 ++ scripts/ci/pr-bot/shared/commentStrings.ts | 72 + .../ci/pr-bot/shared/constants.ts | 20 +- scripts/ci/pr-bot/shared/githubUtils.ts | 96 + scripts/ci/pr-bot/shared/persistentState.ts | 121 ++ scripts/ci/pr-bot/shared/pr.ts | 89 + scripts/ci/pr-bot/shared/reviewerConfig.ts | 97 + scripts/ci/pr-bot/shared/reviewersForLabel.ts | 102 + scripts/ci/pr-bot/shared/userCommand.ts | 231 +++ scripts/ci/pr-bot/test/prTest.ts | 45 + scripts/ci/pr-bot/test/reviewerConfigTest.ts | 238 +++ scripts/ci/pr-bot/test/reviewersForLabelTest.ts | 135 ++ scripts/ci/pr-bot/tsconfig.json | 12 + .../pkg/beam/core/graph/window/trigger/trigger.go | 3 + .../beam/core/graph/window/trigger/trigger_test.go | 73 + sdks/go/pkg/beam/internal/errors/errors_test.go | 68 + sdks/go/pkg/beam/util/errorx/guarded.go | 2 +- .../util/errorx/{guarded.go => guarded_test.go} | 48 +- sdks/java/io/neo4j/OWNERS | 5 + sdks/java/io/neo4j/build.gradle | 39 + .../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 1221 ++++++++++++ .../org/apache/beam/sdk/io/neo4j/package-info.java | 14 +- .../org/apache/beam/sdk/io/neo4j/Neo4jIOIT.java | 275 +++ .../org/apache/beam/sdk/io/neo4j/Neo4jIOTest.java | 117 ++ .../apache/beam/sdk/io/neo4j/Neo4jTestUtil.java | 70 + .../runners/interactive/interactive_beam.py | 4 - .../runners/interactive/interactive_beam_test.py | 13 - sdks/python/test-suites/portable/common.gradle | 2 +- settings.gradle.kts | 1 + 72 files changed, 6116 insertions(+), 351 deletions(-) create mode 100644 .github/REVIEWERS.yml create mode 100644 playground/frontend/assets/multifile.svg create mode 100644 playground/frontend/lib/modules/examples/components/example_list/example_item_actions.dart copy playground/frontend/lib/modules/examples/components/{description_popover/description_popover.dart => multifile_popover/multifile_popover.dart} (64%) copy playground/frontend/lib/modules/examples/components/{description_popover/description_popover_button.dart => multifile_popover/multifile_popover_button.dart} (73%) copy .test-infra/jenkins/job_PreCommit_Python.groovy => playground/frontend/lib/modules/examples/components/outside_click_handler.dart (53%) copy playground/frontend/lib/{constants/links.dart => modules/examples/models/popover_state.dart} (61%) create mode 100644 scripts/ci/pr-bot/README.md create mode 100644 scripts/ci/pr-bot/package-lock.json create mode 100644 scripts/ci/pr-bot/package.json create mode 100644 scripts/ci/pr-bot/shared/checks.ts create mode 100644 scripts/ci/pr-bot/shared/commentStrings.ts copy playground/frontend/lib/constants/links.dart => scripts/ci/pr-bot/shared/constants.ts (61%) create mode 100644 scripts/ci/pr-bot/shared/githubUtils.ts create mode 100644 scripts/ci/pr-bot/shared/persistentState.ts create mode 100644 scripts/ci/pr-bot/shared/pr.ts create mode 100644 scripts/ci/pr-bot/shared/reviewerConfig.ts create mode 100644 scripts/ci/pr-bot/shared/reviewersForLabel.ts create mode 100644 scripts/ci/pr-bot/shared/userCommand.ts create mode 100644 scripts/ci/pr-bot/test/prTest.ts create mode 100644 scripts/ci/pr-bot/test/reviewerConfigTest.ts create mode 100644 scripts/ci/pr-bot/test/reviewersForLabelTest.ts create mode 100644 scripts/ci/pr-bot/tsconfig.json create mode 100644 sdks/go/pkg/beam/core/graph/window/trigger/trigger_test.go copy sdks/go/pkg/beam/util/errorx/{guarded.go => guarded_test.go} (53%) create mode 100644 sdks/java/io/neo4j/OWNERS create mode 100644 sdks/java/io/neo4j/build.gradle create mode 100644 sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java copy playground/frontend/lib/constants/links.dart => sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/package-info.java (61%) create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jIOIT.java create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jIOTest.java create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jTestUtil.java