Skip to content

Commit e5e07c5

Browse files
authored
[IcebergIO] create custom java container image for tests (#35307)
* create custom java container image for tests * syntax * eval depends on df
1 parent b995ada commit e5e07c5

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed
Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
{
22
"comment": "Modify this file in a trivial way to cause this test suite to run.",
3-
"modification": 3,
4-
"https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"
3+
"modification": 5
54
}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
{
22
"comment": "Modify this file in a trivial way to cause this test suite to run.",
3-
"modification": 3
3+
"modification": 4
44
}

sdks/java/io/iceberg/build.gradle

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,12 +163,18 @@ task integrationTest(type: Test) {
163163

164164
task dataflowIntegrationTest(type: Test) {
165165
group = "Verification"
166+
evaluationDependsOn(":runners:google-cloud-dataflow-java")
167+
dependsOn ":runners:google-cloud-dataflow-java:buildAndPushDockerJavaContainer"
168+
finalizedBy ":runners:google-cloud-dataflow-java:cleanUpDockerJavaImages"
169+
def dockerJavaImageName = project.project(':runners:google-cloud-dataflow-java').ext.dockerJavaImageName
170+
166171
def args = [
167172
"--runner=DataflowRunner",
168173
"--region=us-central1",
169174
"--project=${gcpProject}",
170175
"--tempLocation=${gcpTempLocation}",
171176
"--tempRoot=${gcpTempLocation}",
177+
"--sdkContainerImage=${dockerJavaImageName}",
172178
"--experiments=use_runner_v2,use_staged_dataflow_worker_jar"
173179
]
174180
if (project.hasProperty('enableManagedTransforms')) {

0 commit comments

Comments
 (0)