You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2022/11/18 16:40:14 UTC
[beam] branch users/damccorm/flink-fixes created (now ae16c455c84)
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/flink-fixes
in repository https://gitbox.apache.org/repos/asf/beam.git
at ae16c455c84 Fix some lingering flink tests
This branch includes the following new commits:
new ae16c455c84 Fix some lingering flink tests
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[beam] 01/01: Fix some lingering flink tests
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch users/damccorm/flink-fixes
in repository https://gitbox.apache.org/repos/asf/beam.git
commit ae16c455c842544682fda945b61a91c4a2904956
Author: Danny McCormick <da...@google.com>
AuthorDate: Fri Nov 18 11:39:58 2022 -0500
Fix some lingering flink tests
---
sdks/go/test/integration/integration.go | 2 --
sdks/python/test-suites/portable/common.gradle | 3 ---
2 files changed, 5 deletions(-)
diff --git a/sdks/go/test/integration/integration.go b/sdks/go/test/integration/integration.go
index 26acc5137e6..2253df597bb 100644
--- a/sdks/go/test/integration/integration.go
+++ b/sdks/go/test/integration/integration.go
@@ -137,8 +137,6 @@ var portableFilters = []string{
var flinkFilters = []string{
// TODO(https://github.com/apache/beam/issues/20723): Flink tests timing out on reads.
"TestXLang_Combine.*",
- // TODO(https://github.com/apache/beam/issues/21094): Test fails on post commits: "Insufficient number of network buffers".
- "TestXLang_Multi",
"TestDebeziumIO_BasicRead",
// TODO(BEAM-13215): GCP IOs currently do not work in non-Dataflow portable runners.
"TestBigQueryIO.*",
diff --git a/sdks/python/test-suites/portable/common.gradle b/sdks/python/test-suites/portable/common.gradle
index 9585d092204..c87696793f0 100644
--- a/sdks/python/test-suites/portable/common.gradle
+++ b/sdks/python/test-suites/portable/common.gradle
@@ -317,9 +317,6 @@ project.tasks.register("postCommitPy${pythonVersionSuffix}IT") {
// suppress metric name collision warning logs
'\\"org.apache.flink.runtime.metrics.groups\\":\\"ERROR\\"}'
]
- if (project.hasProperty('flinkConfDir')) {
- pipelineOpts += ["--flink-conf-dir=${project.property('flinkConfDir')}"]
- }
def cmdArgs = mapToArgString([
"test_opts": testOpts,
"suite": "postCommitIT-flink-py${pythonVersionSuffix}",