From 3c1cc5faf0564540276adeeb96a91efcfe631933 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Fri, 11 Oct 2024 12:03:57 -0400 Subject: [PATCH] Disable cache for io-expansion-service shadowJar temporarily --- .../apache/beam/sdk/expansion/service/ExpansionService.java | 2 +- sdks/java/io/expansion-service/build.gradle | 1 + sdks/python/apache_beam/io/filesystems.py | 4 ++-- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java b/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java index 770da14fa1cf..150fe9729573 100644 --- a/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java +++ b/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java @@ -143,7 +143,7 @@ public static class ExternalTransformRegistrarLoader public Map knownTransforms() { Map 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 registeredBuilders = loadTransformBuilders(); for (Map.Entry registeredBuilder : diff --git a/sdks/java/io/expansion-service/build.gradle b/sdks/java/io/expansion-service/build.gradle index 26a001b6ea24..b09a92ca315c 100644 --- 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 index a32b85332b60..87f45f3308ee 100644 --- 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)