[ https://issues.apache.org/jira/browse/TIKA-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334861#comment-17334861 ]
Hudson commented on TIKA-3370: ------------------------------ FAILURE: Integrated in Jenkins build Tika ยป tika-main-jdk8 #210 (See [https://ci-builds.apache.org/job/Tika/job/tika-main-jdk8/210/]) TIKA-3370 -- refactor AsyncProcessor (tallison: [https://github.com/apache/tika/commit/05709eef16d1b290467aa0c2b96ed4f9cd8d2489]) * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncConfig.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/OfferLargerThanQueueSize.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncEmitter.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncTask.java * (edit) tika-core/src/main/java/org/apache/tika/pipes/emitter/EmitData.java * (delete) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncEmitter.java * (edit) tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/TikaServerAsyncIntegrationTest.java * (delete) tika-pipes/tika-pipes-async/src/test/java/org/apache/tika/pipes/async/SerializationTest.java * (delete) tika-pipes/tika-pipes-async/src/test/java/org/apache/tika/pipes/async/MockFetcher.java * (delete) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncParser.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncWorkerProcess.java * (edit) tika-core/src/main/java/org/apache/tika/pipes/fetcher/FetchKey.java * (edit) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerCli.java * (edit) tika-core/pom.xml * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncServer.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncClientConfig.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncRuntimeException.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncEmitter.java * (delete) tika-pipes/tika-pipes-async/src/test/java/org/apache/tika/pipes/async/AsyncProcessorTest.java * (edit) tika-server/tika-server-core/pom.xml * (edit) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncResource.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncClient.java * (delete) tika-pipes/tika-pipes-async/src/test/java/org/apache/tika/pipes/async/MockEmitter.java * (edit) tika-core/src/main/java/org/apache/tika/pipes/emitter/EmitKey.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncCli.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncWorker.java * (edit) tika-core/src/main/java/org/apache/tika/pipes/HandlerConfig.java * (delete) tika-pipes/tika-pipes-async/pom.xml * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncRuntimeException.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncData.java * (edit) tika-core/src/main/java/org/apache/tika/pipes/FetchEmitTuple.java * (add) tika-core/src/test/java/org/apache/tika/pipes/async/MockEmitter.java * (edit) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerConfig.java * (add) tika-core/src/test/java/org/apache/tika/pipes/async/MockFetcher.java * (edit) tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/TikaServerConfigTest.java * (add) tika-core/src/main/java/org/apache/tika/pipes/async/AsyncEmitterConfig.java * (delete) tika-pipes/tika-pipes-async/src/main/resources/log4j.properties * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncEmitHook.java * (edit) tika-pipes/pom.xml * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncPipesEmitHook.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncEmitterProcess.java * (add) tika-core/src/test/java/org/apache/tika/pipes/async/AsyncProcessorTest.java * (delete) tika-pipes/tika-pipes-async/src/main/java/org/apache/tika/pipes/async/AsyncConfig.java * (edit) tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerProcess.java > Refactor the AsyncProcessor in 2.x > ---------------------------------- > > Key: TIKA-3370 > URL: https://issues.apache.org/jira/browse/TIKA-3370 > Project: Tika > Issue Type: Task > Reporter: Tim Allison > Assignee: Tim Allison > Priority: Major > > Yesterday, I finally got back to trying to wire the AsyncProcessor in > tika-pipes into the AsyncHandler in tika-server. I've now convinced myself > that the notorious antipattern of using a db as a queue is in fact a really, > really bad idea -- there's every chance that I wasn't doing it right or that > H2 isn't a great choice...my $ is on the former. > Nevertheless, I think removing H2 from that process and going with a > modification of our ForkParser or a lightweight purpose-built knock-off to > handle fetchers and emitters will be as robust, a bunch cleaner, have fewer > dependencies and hopefully be more performant than what I had in the > AsyncProcessor. > Immediate term, I'd like to get this running and wired into tika-server. > Longer term, we can use this instead of tika-batch in tika-app...more use, > fewer bugs. > This is the last item I'd like to finish before 2.0.0-BETA. -- This message was sent by Atlassian Jira (v8.3.4#803005)