disable expansion service cache (apache#32751)

* Disable cache for io-expansion-service shadowJar temporarily * disable cache on sql expansion service
reeba212 · Dec 4, 2024 · 7535ac3 · 7535ac3
1 parent f04945d
commit 7535ac3
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 3 deletions.
diff --git a/sdks/java/expansion-service/build.gradle b/sdks/java/expansion-service/build.gradle
@@ -57,3 +57,7 @@ task runExpansionService (type: JavaExec) {
   classpath = sourceSets.main.runtimeClasspath
   args = [project.findProperty("constructionService.port") ?: "8097"]
 }
+
+compileJava {
+  outputs.upToDateWhen { false }
+}
diff --git a/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java b/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
@@ -143,7 +143,7 @@ public static class ExternalTransformRegistrarLoader
     public Map<String, TransformProvider> knownTransforms() {
       Map<String, TransformProvider> providers = new HashMap<>();
 
-      // First check and register ExternalTransformBuilder in serviceloader style, converting
+      // First check and register ExternalTransformBuilder in ServiceLoader style, converting
       // to TransformProvider after validation.
       Map<String, ExternalTransformBuilder> registeredBuilders = loadTransformBuilders();
       for (Map.Entry<String, ExternalTransformBuilder> registeredBuilder :

diff --git a/sdks/java/extensions/sql/expansion-service/build.gradle b/sdks/java/extensions/sql/expansion-service/build.gradle
@@ -46,3 +46,7 @@ task runExpansionService (type: JavaExec) {
   classpath = sourceSets.main.runtimeClasspath
   args = [project.findProperty("constructionService.port") ?: "8097"]
 }
+
+shadowJar {
+  outputs.upToDateWhen { false }
+}
diff --git a/sdks/java/io/expansion-service/build.gradle b/sdks/java/io/expansion-service/build.gradle
@@ -35,6 +35,7 @@ configurations.runtimeClasspath {
 
 shadowJar {
   mergeServiceFiles()
+  outputs.upToDateWhen { false }
 }
 
 description = "Apache Beam :: SDKs :: Java :: IO :: Expansion Service"

diff --git a/sdks/python/apache_beam/io/filesystems.py b/sdks/python/apache_beam/io/filesystems.py
@@ -393,12 +393,12 @@ def get_chunk_size(path):
   @staticmethod
   def report_source_lineage(path, level=None):
     """
-    Report source :class:`~apache_beam.metrics.metric.Lineage`.
+    Report source :class:`~apache_beam.metrics.metric.LineageLevel`.
 
     Args:
       path: string path to be reported.
       level: the level of file path. default to
-        :class:`~apache_beam.io.filesystem.FileSystem.Lineage`.FILE.
+        :class:`~apache_beam.io.filesystem.FileSystem.LineageLevel`.FILE.
     """
     filesystem = FileSystems.get_filesystem(path)
     filesystem.report_lineage(path, Lineage.sources(), level=level)