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/08/31 13:40:15 UTC
[beam] branch master updated: Filter out unsupported state tests (#22963)
This is an automated email from the ASF dual-hosted git repository.
damccorm 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 d615b624e9f Filter out unsupported state tests (#22963)
d615b624e9f is described below
commit d615b624e9ff211e857d026d541c4d56fd18e2d3
Author: Danny McCormick <da...@google.com>
AuthorDate: Wed Aug 31 09:40:07 2022 -0400
Filter out unsupported state tests (#22963)
---
sdks/go/test/integration/integration.go | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/sdks/go/test/integration/integration.go b/sdks/go/test/integration/integration.go
index 48fe610f099..ce72271d9e4 100644
--- a/sdks/go/test/integration/integration.go
+++ b/sdks/go/test/integration/integration.go
@@ -145,6 +145,11 @@ var flinkFilters = []string{
"TestFhirIO.*",
// OOMs currently only lead to heap dumps on Dataflow runner
"TestOomParDo",
+ // Flink does not support map based state types.
+ "TestMapState",
+ "TestMapStateClear",
+ "TestSetStateClear",
+ "TestSetState",
}
var samzaFilters = []string{
@@ -201,6 +206,11 @@ var sparkFilters = []string{
"TestFhirIO.*",
// OOMs currently only lead to heap dumps on Dataflow runner
"TestOomParDo",
+ // Spark does not support map based state types.
+ "TestMapState",
+ "TestMapStateClear",
+ "TestSetStateClear",
+ "TestSetState",
}
var dataflowFilters = []string{