[beam] branch master updated (8fcb103 -> 47ab260)
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8fcb103 [BEAM-13925] Add most of the supporting files for the pr management automation (#16898) add 47ab260 Merge pull request #16846 from [BEAM-12164]: Add sad path tests for Cloud Spanner's ReadChangeStream No new revisions were added by this update. Summary of changes: .../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 + sdks/java/io/google-cloud-platform/build.gradle| 2 + .../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 62 ++- .../beam/sdk/io/gcp/spanner/SpannerConfig.java | 39 ++ .../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 53 ++- .../SpannerChangeStreamErrorTest.java | 497 + 6 files changed, 633 insertions(+), 26 deletions(-) create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java
[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 ++
[beam] branch master updated: [BEAM-13925] Add most of the supporting files for the pr management automation (#16898)
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 8fcb103 [BEAM-13925] Add most of the supporting files for the pr
management automation (#16898)
8fcb103 is described below
commit 8fcb103a7fc246f24e1e4574e59ce4d5dd184d1d
Author: Danny McCormick
AuthorDate: Thu Feb 24 20:31:14 2022 -0500
[BEAM-13925] Add most of the supporting files for the pr management
automation (#16898)
---
.github/REVIEWERS.yml | 21 +
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 +
scripts/ci/pr-bot/shared/constants.ts | 30 +
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 +
17 files changed, 3532 insertions(+)
diff --git a/.github/REVIEWERS.yml b/.github/REVIEWERS.yml
new file mode 100644
index 000..0094897
--- /dev/null
+++ b/.github/REVIEWERS.yml
@@ -0,0 +1,21 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+labels:
+- name: "Go"
+ reviewers: ["damccorm", "lostluck", "jrmccluskey", "youngoli",
"riteshghorse"]
+ exclusionList: [] # These users will never be suggested as reviewers
+# I don't know the other areas well enough to assess who the normal
committers/contributors who might want to be reviewers are
+fallbackReviewers: [] # List of committers to use when no label matches
diff --git a/scripts/ci/pr-bot/README.md b/scripts/ci/pr-bot/README.md
new file mode 100644
index 000..d6a55d4
--- /dev/null
+++ b/scripts/ci/pr-bot/README.md
@@ -0,0 +1,45 @@
+
+
+# PR Bot
+
+This directory holds all the code (except for Actions Workflows) for our PR
bot designed to improve the PR experience.
+For a list of commands to use when interacting with the bot, see
[Commands.md](./Commands.md).
+For a design doc explaining the design and implementation, see [Automate
Reviewer
Assignment](https://docs.google.com/document/d/1FhRPRD6VXkYlLAPhNfZB7y2Yese2FCWBzjx67d3TjBo/edit#)
+
+## Build/Test
+
+To build, run:
+
+```
+npm install
+npm run build
+```
+
+To run the tests:
+
+```
+npm test
+```
+
+Before checking in code, run prettier on it:
+
+```
+npm run format
+```
\ No newline at end of file
diff --git a/scripts/ci/pr-bot/package-lock.json
b/scripts/ci/pr-bot/package-lock.json
new file mode 100644
index 000..cf88168
--- /dev/null
+++ b/scripts/ci/pr-bot/package-lock.json
@@ -0,0 +1,2062 @@
+{
+ "name": "pr-bot",
+ "version": "1.0.0",
+ "lockfileVersion": 2,
+ "requires": true,
+ "packages": {
+"": {
+ "name": "pr-bot",
+ "version": "1.0.0",
+ "dependencies": {
+"@actions/exec": "^1.1.0",
+"@actions/github": "^5.0.0",
+"@octokit/rest": "^18.12.0",
+"js-yaml": "^4.1.0",
+"prettier": "^2.5.1"
+ },
+ "devDependencies": {
+"@types/mocha": "^9.1.0",
+"@types/node": "^16.11.7",
+"mocha": "^9.1.3",
+"typescript": "4.2.4"
+ }
+},
+"node_modules/@actions/exec": {
+ "version": "1.1.0",
+ "resolved": "https://registry.npmjs.org/@actions/exec/-/exec-1.1.0.tgz;,
+ "integrity":
"sha512-LImpN9AY0J1R1mEYJjVJfSZWU4zYOlEcwSTgPve1rFQqK5AwrEs6uWW5Rv70gbDIQIAUwI86z6B+9mPK4w9Sbg==",
+ "dependencies": {
+"@actions/io": "^1.0.1"
+ }
+},
+"node_modules/@actions/github": {
+ "version": "5.0.0",
+ "resolved":
[beam] branch master updated: [BEAM-13866] Add small unit tests to errorx, make boolean assignment more clear (#16943)
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 bf020ac [BEAM-13866] Add small unit tests to errorx, make boolean
assignment more clear (#16943)
bf020ac is described below
commit bf020ac1c620c0367244acc6161f228772559f70
Author: Jack McCluskey <34928439+jrmcclus...@users.noreply.github.com>
AuthorDate: Thu Feb 24 17:01:00 2022 -0500
[BEAM-13866] Add small unit tests to errorx, make boolean assignment more
clear (#16943)
---
sdks/go/pkg/beam/util/errorx/guarded.go| 2 +-
.../util/errorx/{guarded.go => guarded_test.go}| 48 +++---
2 files changed, 24 insertions(+), 26 deletions(-)
diff --git a/sdks/go/pkg/beam/util/errorx/guarded.go
b/sdks/go/pkg/beam/util/errorx/guarded.go
index cc0b07b..186885b 100644
--- a/sdks/go/pkg/beam/util/errorx/guarded.go
+++ b/sdks/go/pkg/beam/util/errorx/guarded.go
@@ -39,7 +39,7 @@ func (g *GuardedError) TrySetError(err error) bool {
g.mu.Lock()
defer g.mu.Unlock()
- upd := g.err == nil
+ upd := (g.err == nil)
if upd {
g.err = err
}
diff --git a/sdks/go/pkg/beam/util/errorx/guarded.go
b/sdks/go/pkg/beam/util/errorx/guarded_test.go
similarity index 53%
copy from sdks/go/pkg/beam/util/errorx/guarded.go
copy to sdks/go/pkg/beam/util/errorx/guarded_test.go
index cc0b07b..1e9c9b2 100644
--- a/sdks/go/pkg/beam/util/errorx/guarded.go
+++ b/sdks/go/pkg/beam/util/errorx/guarded_test.go
@@ -13,35 +13,33 @@
// See the License for the specific language governing permissions and
// limitations under the License.
-// Package errorx contains utilities for handling errors.
package errorx
-import "sync"
+import (
+ "errors"
+ "testing"
+)
-// GuardedError is a concurrency-safe error wrapper. It is sticky
-// in that the first error won't be overwritten.
-type GuardedError struct {
- err error
- mu sync.Mutex
-}
-
-// Error returns the guarded error.
-func (g *GuardedError) Error() error {
- g.mu.Lock()
- defer g.mu.Unlock()
-
- return g.err
+func TestTrySetError(t *testing.T) {
+ var gu GuardedError
+ setErr := errors.New("attempted error")
+ success := gu.TrySetError(setErr)
+ if !success {
+ t.Fatal("got false when trying to set error, want true")
+ }
+ if got, want := gu.Error(), setErr; got != want {
+ t.Errorf("got error %v when checking message, want %v", got,
want)
+ }
}
-// TrySetError sets the error, if not already set. Returns true iff the
-// error was set.
-func (g *GuardedError) TrySetError(err error) bool {
- g.mu.Lock()
- defer g.mu.Unlock()
-
- upd := g.err == nil
- if upd {
- g.err = err
+func TestTrySetError_bad(t *testing.T) {
+ setErr := errors.New("old error")
+ gu := {err: setErr}
+ success := gu.TrySetError(setErr)
+ if success {
+ t.Fatal("got true when trying to set error, want false")
+ }
+ if got, want := gu.Error(), setErr; got != want {
+ t.Errorf("got error %v when checking message, want %v", got,
want)
}
- return upd
}
[beam] branch master updated (b4ee2b9 -> f94a00f)
This is an automated email from the ASF dual-hosted git repository. emilyye pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from b4ee2b9 [BEAM-13886] unit tests for trigger package (#16935) add f94a00f [BEAM-4767] Remove beam- prefix from release script tags (#16899) No new revisions were added by this update. Summary of changes: release/src/main/scripts/cut_release_branch.sh | 2 +- release/src/main/scripts/set_version.sh| 3 --- 2 files changed, 1 insertion(+), 4 deletions(-)
[beam] branch master updated (90dd44e -> b4ee2b9)
This is an automated email from the ASF dual-hosted git repository. lostluck pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 90dd44e [BEAM-13906] Improve coverage of errors package (#16934) add b4ee2b9 [BEAM-13886] unit tests for trigger package (#16935) No new revisions were added by this update. Summary of changes: .../pkg/beam/core/graph/window/trigger/trigger.go | 3 + .../beam/core/graph/window/trigger/trigger_test.go | 73 ++ 2 files changed, 76 insertions(+) create mode 100644 sdks/go/pkg/beam/core/graph/window/trigger/trigger_test.go
[beam] branch master updated (cc16171 -> 90dd44e)
This is an automated email from the ASF dual-hosted git repository. lostluck pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 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) No new revisions were added by this update. Summary of changes: sdks/go/pkg/beam/internal/errors/errors_test.go | 68 + 1 file changed, 68 insertions(+)
[beam] branch master updated (86f2677 -> cc16171)
This is an automated email from the ASF dual-hosted git repository. ningk pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 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 No new revisions were added by this update. Summary of changes: .../apache_beam/runners/interactive/interactive_beam.py | 4 .../runners/interactive/interactive_beam_test.py| 13 - 2 files changed, 17 deletions(-)
[beam] branch master updated: Revert PR#16253 due errors with plugin flaky-test-handler
This is an automated email from the ASF dual-hosted git repository.
kileysok 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 9145b5b Revert PR#16253 due errors with plugin flaky-test-handler
new 86f2677 Merge pull request #16930 from benWize/revert_PR_16253
9145b5b is described below
commit 9145b5b191cdae5fd7e52480a9732c0cdc470343
Author: Benjamin Gonzalez
AuthorDate: Wed Feb 23 13:14:58 2022 -0600
Revert PR#16253 due errors with plugin flaky-test-handler
---
.test-infra/jenkins/job_PreCommit_Java.groovy | 7 +--
.test-infra/jenkins/job_PreCommit_Python.groovy | 9 +
buildSrc/build.gradle.kts | 1 -
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 17 -
4 files changed, 2 insertions(+), 32 deletions(-)
diff --git a/.test-infra/jenkins/job_PreCommit_Java.groovy
b/.test-infra/jenkins/job_PreCommit_Java.groovy
index aced96a..444d240 100644
--- a/.test-infra/jenkins/job_PreCommit_Java.groovy
+++ b/.test-infra/jenkins/job_PreCommit_Java.groovy
@@ -23,7 +23,6 @@ PrecommitJobBuilder builder = new PrecommitJobBuilder(
nameBase: 'Java',
gradleTask: ':javaPreCommit',
gradleSwitches: [
- '-PretryFlakyTest=true',
'-PdisableSpotlessCheck=true'
], // spotless checked in separate pre-commit
triggerPathPatterns: [
@@ -40,11 +39,7 @@ PrecommitJobBuilder builder = new PrecommitJobBuilder(
)
builder.build {
publishers {
-archiveJunit('**/build/test-results/**/*.xml') {
- testDataPublishers {
-publishFlakyTestsReport()
- }
-}
+archiveJunit('**/build/test-results/**/*.xml')
recordIssues {
tools {
errorProne()
diff --git a/.test-infra/jenkins/job_PreCommit_Python.groovy
b/.test-infra/jenkins/job_PreCommit_Python.groovy
index 9a22495..0b5270f 100644
--- a/.test-infra/jenkins/job_PreCommit_Python.groovy
+++ b/.test-infra/jenkins/job_PreCommit_Python.groovy
@@ -21,9 +21,6 @@ import PrecommitJobBuilder
PrecommitJobBuilder builder = new PrecommitJobBuilder(
scope: this,
nameBase: 'Python',
-gradleSwitches: [
- '-PretryFlakyTest=true',
-],
gradleTask: ':pythonPreCommit',
timeoutMins: 180,
triggerPathPatterns: [
@@ -35,10 +32,6 @@ PrecommitJobBuilder builder = new PrecommitJobBuilder(
builder.build {
// Publish all test results to Jenkins.
publishers {
-archiveJunit('**/pytest*.xml'){
- testDataPublishers {
-publishFlakyTestsReport()
- }
-}
+archiveJunit('**/pytest*.xml')
}
}
diff --git a/buildSrc/build.gradle.kts b/buildSrc/build.gradle.kts
index 212074e..f7992ed 100644
--- a/buildSrc/build.gradle.kts
+++ b/buildSrc/build.gradle.kts
@@ -54,7 +54,6 @@ dependencies {
runtimeOnly("ca.cutterslade.gradle:gradle-dependency-analyze:1.8.3")
// Enable dep analysis
runtimeOnly("gradle.plugin.net.ossindex:ossindex-gradle-plugin:0.4.11")
// Enable dep vulnerability analysis
runtimeOnly("org.checkerframework:checkerframework-gradle-plugin:0.5.16")
// Enable enhanced static checking plugin
- runtimeOnly("org.gradle:test-retry-gradle-plugin:1.3.1")
// Enable flaky tests mitigation
}
// Because buildSrc is built and tested automatically _before_ gradle
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 6c6b140..f461305 100644
--- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
+++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -409,23 +409,6 @@ class BeamModulePlugin implements Plugin {
project.tasks.withType(Test) { jacoco.enabled = enabled }
}
-// Add Retry Gradle Plugin to mitigate flaky tests
-if (project.hasProperty("retryFlakyTest")) {
- project.apply plugin: "org.gradle.test-retry"
- project.tasks.withType(Test) {
-reports{
- junitXml{
-mergeReruns = true
- }
-}
-retry {
- failOnPassedAfterRetry = false
- maxFailures = 10
- maxRetries = 3
-}
- }
-}
-
// Apply a plugin which provides tasks for dependency / property / task
reports.
// See
https://docs.gradle.org/current/userguide/project_reports_plugin.html
// for further details. This is typically very useful to look at the
"htmlDependencyReport"
[beam] branch master updated (0fe57b1 -> 5a62228)
This is an automated email from the ASF dual-hosted git repository. yichi pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 0fe57b1 [BEAM-1857] Add Neo4jIO (#15916) add 5a62228 [BEAM-13767] Migrate serveral portable runner tasks to use configuration avoidance API. (#16837) No new revisions were added by this update. Summary of changes: .../org/apache/beam/gradle/BeamModulePlugin.groovy | 21 - runners/flink/flink_runner.gradle | 2 +- runners/flink/job-server/flink_job_server.gradle| 5 +++-- 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 ++-- sdks/python/test-suites/portable/common.gradle | 2 +- 9 files changed, 31 insertions(+), 25 deletions(-)
[beam] branch master updated (b0899a4 -> 0fe57b1)
This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b0899a4 Fix BoundedQueueExecutor and StreamingDataflowWorker to
actually limit memory from windmill (#16901)
add 0fe57b1 [BEAM-1857] Add Neo4jIO (#15916)
No new revisions were added by this update.
Summary of changes:
build.gradle.kts |1 +
{.test-infra => sdks/java/io/neo4j}/OWNERS |3 +-
.../io/{contextualtextio => neo4j}/build.gradle| 22 +-
.../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 1221
.../apache/beam/sdk/io/neo4j}/package-info.java|4 +-
.../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 ++
settings.gradle.kts|1 +
9 files changed, 1699 insertions(+), 15 deletions(-)
copy {.test-infra => sdks/java/io/neo4j}/OWNERS (83%)
copy sdks/java/io/{contextualtextio => neo4j}/build.gradle (63%)
create mode 100644
sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java
copy
sdks/java/io/{amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis
=> neo4j/src/main/java/org/apache/beam/sdk/io/neo4j}/package-info.java (90%)
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
[beam] branch master updated (2a45a5b -> b0899a4)
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 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) No new revisions were added by this update. Summary of changes: .../options/DataflowPipelineDebugOptions.java | 24 .../dataflow/worker/StreamingDataflowWorker.java | 64 - .../dataflow/worker/util/BoundedQueueExecutor.java | 148 - .../worker/StreamingDataflowWorkerTest.java| 16 +-- 4 files changed, 171 insertions(+), 81 deletions(-)
