This is an automated email from the ASF dual-hosted git repository. tallison pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/tika.git
The following commit(s) were added to refs/heads/main by this push: new 062efe696 fix another bug in CompositePipesReporter, need to override everything 062efe696 is described below commit 062efe696c59368a23392d9e5e457d9617638039 Author: tballison <talli...@apache.org> AuthorDate: Thu Nov 17 17:16:28 2022 -0500 fix another bug in CompositePipesReporter, need to override everything --- .../org/apache/tika/pipes/CompositePipesReporter.java | 18 ++++++++++++++++++ .../org/apache/tika/pipes/async/AsyncProcessor.java | 2 ++ 2 files changed, 20 insertions(+) diff --git a/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java b/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java index dfce28bb7..997e7ca18 100644 --- a/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java +++ b/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java @@ -25,6 +25,7 @@ import org.apache.tika.config.Initializable; import org.apache.tika.config.InitializableProblemHandler; import org.apache.tika.config.Param; import org.apache.tika.exception.TikaConfigException; +import org.apache.tika.pipes.pipesiterator.TotalCountResult; public class CompositePipesReporter extends PipesReporter implements Initializable { @@ -38,6 +39,23 @@ public class CompositePipesReporter extends PipesReporter implements Initializab } + @Override + public void report(TotalCountResult totalCountResult) { + for (PipesReporter reporter : pipesReporters) { + reporter.report(totalCountResult); + } + } + + @Override + public boolean supportsTotalCount() { + for (PipesReporter reporter : pipesReporters) { + if (reporter.supportsTotalCount()) { + return true; + } + } + return false; + } + @Override public void error(Throwable t) { for (PipesReporter reporter : pipesReporters) { diff --git a/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java b/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java index 7a71f08c9..17292c047 100644 --- a/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java +++ b/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java @@ -116,6 +116,7 @@ public class AsyncProcessor implements Closeable { new AsyncEmitter(asyncConfig, emitData, emitterManager)); } } catch (Exception e) { + LOG.error("problem initializing AsyncProcessor", e); executorService.shutdownNow(); asyncConfig.getPipesReporter().error(e); throw e; @@ -131,6 +132,7 @@ public class AsyncProcessor implements Closeable { try { Thread.sleep(500); TotalCountResult result = totalCounter.getTotalCount(); + LOG.trace("counter total {} {} ", result.getStatus(), result.getTotalCount()); pipesReporter.report(result); status = result.getStatus(); } catch (InterruptedException e) {