You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/02/25 03:48:57 UTC
[beam] branch nightly-refs/heads/master updated (42de462 -> 8fcb103)
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