Skip to content

Commit 13f4ae0

Browse files
authored
disable expansion service cache (apache#32751)
* Disable cache for io-expansion-service shadowJar temporarily * disable cache on sql expansion service
1 parent 578d6d7 commit 13f4ae0

File tree

5 files changed

+12
-3
lines changed

5 files changed

+12
-3
lines changed

sdks/java/expansion-service/build.gradle

+4
Original file line numberDiff line numberDiff line change
@@ -57,3 +57,7 @@ task runExpansionService (type: JavaExec) {
5757
classpath = sourceSets.main.runtimeClasspath
5858
args = [project.findProperty("constructionService.port") ?: "8097"]
5959
}
60+
61+
compileJava {
62+
outputs.upToDateWhen { false }
63+
}

sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ public static class ExternalTransformRegistrarLoader
143143
public Map<String, TransformProvider> knownTransforms() {
144144
Map<String, TransformProvider> providers = new HashMap<>();
145145

146-
// First check and register ExternalTransformBuilder in serviceloader style, converting
146+
// First check and register ExternalTransformBuilder in ServiceLoader style, converting
147147
// to TransformProvider after validation.
148148
Map<String, ExternalTransformBuilder> registeredBuilders = loadTransformBuilders();
149149
for (Map.Entry<String, ExternalTransformBuilder> registeredBuilder :

sdks/java/extensions/sql/expansion-service/build.gradle

+4
Original file line numberDiff line numberDiff line change
@@ -46,3 +46,7 @@ task runExpansionService (type: JavaExec) {
4646
classpath = sourceSets.main.runtimeClasspath
4747
args = [project.findProperty("constructionService.port") ?: "8097"]
4848
}
49+
50+
shadowJar {
51+
outputs.upToDateWhen { false }
52+
}

sdks/java/io/expansion-service/build.gradle

+1
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ configurations.runtimeClasspath {
3535

3636
shadowJar {
3737
mergeServiceFiles()
38+
outputs.upToDateWhen { false }
3839
}
3940

4041
description = "Apache Beam :: SDKs :: Java :: IO :: Expansion Service"

sdks/python/apache_beam/io/filesystems.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -393,12 +393,12 @@ def get_chunk_size(path):
393393
@staticmethod
394394
def report_source_lineage(path, level=None):
395395
"""
396-
Report source :class:`~apache_beam.metrics.metric.Lineage`.
396+
Report source :class:`~apache_beam.metrics.metric.LineageLevel`.
397397
398398
Args:
399399
path: string path to be reported.
400400
level: the level of file path. default to
401-
:class:`~apache_beam.io.filesystem.FileSystem.Lineage`.FILE.
401+
:class:`~apache_beam.io.filesystem.FileSystem.LineageLevel`.FILE.
402402
"""
403403
filesystem = FileSystems.get_filesystem(path)
404404
filesystem.report_lineage(path, Lineage.sources(), level=level)

0 commit comments

Comments
 (0)