TIKA-4252: fix metadata issue

apache · May 9, 2024 · 4428df0 · 4428df0
1 parent 63b7e91
commit 4428df0
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) {