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:15 UTC
[beam] 01/01: Fix some lingering flink tests
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}",