TIKA-4252: fix metadata issue (#1752)

Co-authored-by: Nicholas DiPiazza <ndipiazza@apache.org>
apache · May 9, 2024 · 2f8dbdf · 2f8dbdf
1 parent 84d05ad
commit 2f8dbdf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tika-core/src/main/java/org/apache/tika/pipes/PipesServer.java b/tika-core/src/main/java/org/apache/tika/pipes/PipesServer.java
@@ -462,7 +462,7 @@ protected MetadataListAndEmbeddedBytes parseFromTuple(FetchEmitTuple t, Fetcher
                 throw new IllegalArgumentException(
                         "fetch key has a range, but the fetcher is not a range fetcher");
             }
-            Metadata metadata = new Metadata();
+            Metadata metadata = t.getMetadata() == null ? new Metadata() : t.getMetadata();
             try (InputStream stream = ((RangeFetcher) fetcher).fetch(fetchKey.getFetchKey(),
                     fetchKey.getRangeStart(), fetchKey.getRangeEnd(), metadata)) {
                 return parseWithStream(t, stream, metadata);
@@ -474,7 +474,7 @@ protected MetadataListAndEmbeddedBytes parseFromTuple(FetchEmitTuple t, Fetcher
                 write(STATUS.FETCH_EXCEPTION, ExceptionUtils.getStackTrace(e));
             }
         } else {
-            Metadata metadata = new Metadata();
+            Metadata metadata = t.getMetadata() == null ? new Metadata() : t.getMetadata();
             try (InputStream stream = fetcher.fetch(t.getFetchKey().getFetchKey(), metadata)) {
                 return parseWithStream(t, stream, metadata);
             } catch (SecurityException e) {