Skip to content

Commit e542d1f

Browse files
kw2542kw2542
authored
[BEAM-12556] Enable Go Build Tests in Samza Runner (apache#15167)
1 parent f93a930 commit e542d1f

File tree

17 files changed

+135
-7
lines changed

17 files changed

+135
-7
lines changed

‎.github/PULL_REQUEST_TEMPLATE.md

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,11 @@ See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on
3939
<img alt="Build Status" src="https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/badge/icon">
4040
</a>
4141
</td>
42-
<td>---</td>
42+
<td>
43+
<a href="https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/lastCompletedBuild/">
44+
<img alt="Build Status" src="https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/lastCompletedBuild/badge/icon">
45+
</a>
46+
</td>
4347
<td>
4448
<a href="https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/">
4549
<img alt="Build Status" src="https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/badge/icon">

‎.test-infra/jenkins/README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@ Beam Jenkins overview page: [link](https://ci-beam.apache.org/)
5656
| beam_PostCommit_CrossLanguageValidatesRunner | [cron](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct_PR/) | `Run XVR_Direct PostCommit` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct) |
5757
| beam_PostCommit_Go | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Go/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Go_PR/) | `Run Go PostCommit` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go) |
5858
| beam_PostCommit_Go_VR_Flink | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink_PR/) | `Run Go Flink ValidatesRunner` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/) |
59+
| beam_PostCommit_Go_VR_Samza | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza_PR/) | `Run Go Samza ValidatesRunner` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/) |
5960
| beam_PostCommit_Go_VR_Spark | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark_PR/) | `Run Go Spark ValidatesRunner` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/) |
6061
| beam_PostCommit_Java | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Java/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Java_PR/) | `Run Java PostCommit` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java) |
6162
| beam_PostCommit_Java_Nexmark_Dataflow | [cron](https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow/), [phrase](https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_PR/) | `Dataflow Runner Nexmark Tests` | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow) |

‎.test-infra/jenkins/job_PostCommit_Go_ValidatesRunner_Samza.groovy

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing, software
13+
* distributed under the License is distributed on an "AS IS" BASIS,
14+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15+
* See the License for the specific language governing permissions and
16+
* limitations under the License.
17+
*/
18+
19+
import CommonJobProperties as commonJobProperties
20+
import PostcommitJobBuilder
21+
22+
// This job runs the suite of Go integration tests against the Samza runner.
23+
PostcommitJobBuilder.postCommitJob('beam_PostCommit_Go_VR_Samza',
24+
'Run Go Samza ValidatesRunner', 'Go Samza ValidatesRunner Tests', this) {
25+
description('Runs Go integration tests on the Samza runner.')
26+
27+
// Set common parameters.
28+
commonJobProperties.setTopLevelMainJobProperties(delegate)
29+
30+
// Gradle goals for this job.
31+
steps {
32+
gradle {
33+
rootBuildScriptDir(commonJobProperties.checkoutDir)
34+
tasks(':sdks:go:test:samzaValidatesRunner')
35+
commonJobProperties.setGradleSwitches(delegate)
36+
}
37+
}
38+
}

‎README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636

3737
Lang | SDK | Dataflow | Flink | Samza | Spark | Twister2
3838
--- | --- | --- | --- | --- | --- | ---
39-
Go | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) | ---
39+
Go | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) | ---
4040
Java | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_VR_Dataflow_V2/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_VR_Dataflow_V2/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Samza/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Samza/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Twister2/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Twister2/lastCompletedBuild/)
4141
Python | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Python36/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Python36/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Python37/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Python37/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Python38/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Python38/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/lastCompletedBuild/)<br>[![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/) | --- | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Spark/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Spark/lastCompletedBuild/) | ---
4242
XLang | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Flink/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Flink/lastCompletedBuild/) | --- | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/lastCompletedBuild/) | [![Build Status](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark3/lastCompletedBuild/badge/icon)](https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark3/lastCompletedBuild/) | ---

‎runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
import org.apache.beam.runners.jobsubmission.JobServerDriver;
2121
import org.apache.beam.sdk.fn.server.ServerFactory;
2222
import org.apache.beam.sdk.io.FileSystems;
23+
import org.apache.beam.sdk.options.PipelineOptions;
2324
import org.apache.beam.sdk.options.PipelineOptionsFactory;
24-
import org.apache.beam.sdk.options.PortablePipelineOptions;
2525
import org.kohsuke.args4j.CmdLineException;
2626
import org.kohsuke.args4j.CmdLineParser;
2727
import org.slf4j.Logger;
@@ -37,8 +37,7 @@ public static class SamzaServerConfiguration extends ServerConfiguration {}
3737

3838
public static void main(String[] args) {
3939
// TODO: Expose the fileSystem related options.
40-
PortablePipelineOptions options =
41-
PipelineOptionsFactory.fromArgs(args).as(PortablePipelineOptions.class);
40+
PipelineOptions options = PipelineOptionsFactory.create();
4241
// Register standard file systems.
4342
FileSystems.setDefaultPipelineOptions(options);
4443
fromParams(args).run();

‎sdks/go/pkg/beam/runners/samza/samza.go

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
// Licensed to the Apache Software Foundation (ASF) under one or more
2+
// contributor license agreements. See the NOTICE file distributed with
3+
// this work for additional information regarding copyright ownership.
4+
// The ASF licenses this file to You under the Apache License, Version 2.0
5+
// (the "License"); you may not use this file except in compliance with
6+
// the License. You may obtain a copy of the License at
7+
//
8+
// http://www.apache.org/licenses/LICENSE-2.0
9+
//
10+
// Unless required by applicable law or agreed to in writing, software
11+
// distributed under the License is distributed on an "AS IS" BASIS,
12+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
// See the License for the specific language governing permissions and
14+
// limitations under the License.
15+
16+
// Package samza contains the Samza runner.
17+
package samza
18+
19+
import (
20+
"context"
21+
22+
"github.com/apache/beam/sdks/go/pkg/beam"
23+
"github.com/apache/beam/sdks/go/pkg/beam/runners/universal"
24+
)
25+
26+
func init() {
27+
beam.RegisterRunner("samza", Execute)
28+
beam.RegisterRunner("SamzaRunner", Execute)
29+
}
30+
31+
// Execute runs the given pipeline on Samza. Convenience wrapper over the
32+
// universal runner.
33+
func Execute(ctx context.Context, p *beam.Pipeline) (beam.PipelineResult, error) {
34+
return universal.Execute(ctx, p)
35+
}

‎sdks/go/pkg/beam/x/beamx/run.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import (
3030
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/direct"
3131
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dot"
3232
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
33+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
3334
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
3435
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/universal"
3536
)

‎sdks/go/test/build.gradle

Lines changed: 24 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,29 @@ task flinkValidatesRunner {
9696
}
9797
}
9898

99+
// ValidatesRunner tests for Samza. Runs tests in the integration directory
100+
// with Samza to validate that the runner behaves as expected.
101+
task samzaValidatesRunner {
102+
dependsOn ":sdks:go:test:goBuild"
103+
dependsOn ":sdks:go:container:docker"
104+
dependsOn ":runners:samza:job-server:shadowJar"
105+
dependsOn ":sdks:java:testing:expansion-service:buildTestExpansionServiceJar"
106+
doLast {
107+
def options = [
108+
"--runner samza",
109+
"--samza_job_server_jar ${project(":runners:samza:job-server").shadowJar.archivePath}",
110+
"--test_expansion_jar ${project(":sdks:java:testing:expansion-service").buildTestExpansionServiceJar.archivePath}",
111+
]
112+
if (project.jenkins.isCIBuild) { // Needed when running this task on Jenkins.
113+
options.add("--jenkins")
114+
}
115+
exec {
116+
executable "sh"
117+
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
118+
}
119+
}
120+
}
121+
99122
// ValidatesRunner tests for Spark. Runs tests in the integration directory
100123
// with Spark to validate that the runner behaves as expected.
101124
task sparkValidatesRunner {
@@ -150,4 +173,4 @@ task ulrValidatesRunner {
150173
args "-c", ". ${envdir}/bin/activate && ./run_validatesrunner_tests.sh ${options.join(' ')}"
151174
}
152175
}
153-
}
176+
}

‎sdks/go/test/integration/integration.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,12 @@ var flinkFilters = []string{
6969
"TestXLang_Combine.*",
7070
}
7171

72+
var samzaFilters = []string{
73+
// TODO(BEAM-12608): Samza tests invalid encoding.
74+
"TestReshuffle",
75+
"TestReshuffleKV",
76+
}
77+
7278
var sparkFilters = []string{
7379
// TODO(BEAM-11498): XLang tests broken with Spark runner.
7480
"TestXLang.*",
@@ -115,6 +121,8 @@ func CheckFilters(t *testing.T) {
115121
filters = portableFilters
116122
case "flink", "FlinkRunner":
117123
filters = flinkFilters
124+
case "samza", "SamzaRunner":
125+
filters = samzaFilters
118126
case "spark", "SparkRunner":
119127
filters = sparkFilters
120128
case "dataflow", "DataflowRunner":

‎sdks/go/test/integration/io/xlang/kafka/kafka_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import (
2222

2323
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2424
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
25+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2526
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2627
"github.com/apache/beam/sdks/go/pkg/beam/testing/ptest"
2728
"github.com/apache/beam/sdks/go/test/integration"

‎sdks/go/test/integration/primitives/primitives_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020

2121
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2222
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
23+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2324
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2425
"github.com/apache/beam/sdks/go/pkg/beam/testing/ptest"
2526
)

‎sdks/go/test/integration/synthetic/synthetic_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import (
2222
"github.com/apache/beam/sdks/go/pkg/beam/io/synthetic"
2323
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2424
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
25+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2526
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2627
"github.com/apache/beam/sdks/go/pkg/beam/testing/passert"
2728
"github.com/apache/beam/sdks/go/pkg/beam/testing/ptest"

‎sdks/go/test/integration/wordcount/wordcount_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import (
2222
"github.com/apache/beam/sdks/go/pkg/beam/io/filesystem/memfs"
2323
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2424
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
25+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2526
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2627
"github.com/apache/beam/sdks/go/pkg/beam/testing/ptest"
2728
"github.com/apache/beam/sdks/go/test/integration"

‎sdks/go/test/integration/xlang/xlang_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525
"github.com/apache/beam/sdks/go/pkg/beam"
2626
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2727
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
28+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2829
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2930
"github.com/apache/beam/sdks/go/pkg/beam/testing/passert"
3031
"github.com/apache/beam/sdks/go/pkg/beam/testing/ptest"

‎sdks/go/test/regression/lperror_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525

2626
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2727
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
28+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2829
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2930
)
3031

‎sdks/go/test/regression/pardo_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import (
2323

2424
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
2525
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/flink"
26+
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/samza"
2627
_ "github.com/apache/beam/sdks/go/pkg/beam/runners/spark"
2728
)
2829

0 commit comments

Comments
 (0)