[
https://issues.apache.org/jira/browse/APEXMALHAR-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed APEXMALHAR-1729.
------------------------------------
> HDHT Exception In end window.
> -----------------------------
>
> Key: APEXMALHAR-1729
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1729
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Tushar Gosavi
> Assignee: Thomas Weise
>
> After 4 days of running Ads demo with bursts of asynchronous queries
> throughout the day, the follow exception occurred using the DTFile store
> java.lang.RuntimeException: Error processing queries.
> at com.datatorrent.contrib.hdht.HDHTReader.endWindow(HDHTReader.java:191)
> at com.datatorrent.contrib.hdht.HDHTWriter.endWindow(HDHTWriter.java:436)
> at
> com.datatorrent.contrib.dimensions.DimensionsStoreHDHT.endWindow(DimensionsStoreHDHT.java:251)
> at
> com.datatorrent.contrib.dimensions.AppDataSingleSchemaDimensionStoreHDHT.endWindow(AppDataSingleSchemaDimensionStoreHDHT.java:201)
> at
> com.datatorrent.stram.engine.GenericNode.processEndWindow(GenericNode.java:128)
> at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:294)
> at
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1329)
> Caused by: java.lang.NullPointerException
> at
> org.apache.hadoop.io.file.tfile.DTFile$Reader$Scanner.checkKey(DTFile.java:1637)
> at
> org.apache.hadoop.io.file.tfile.DTFile$Reader$Scanner.compareCursorKeyTo(DTFile.java:1671)
> at
> org.apache.hadoop.io.file.tfile.DTFile$Reader$Scanner.inBlockAdvance(DTFile.java:2048)
> at
> org.apache.hadoop.io.file.tfile.DTFile$Reader$Scanner.seekTo(DTFile.java:1409)
> at
> org.apache.hadoop.io.file.tfile.DTFile$Reader$Scanner.seekTo(DTFile.java:1388)
> at com.datatorrent.contrib.hdht.tfile.DTFileReader.seek(DTFileReader.java:91)
> at com.datatorrent.contrib.hdht.HDHTReader.get(HDHTReader.java:269)
> at com.datatorrent.contrib.hdht.HDHTReader$1.run(HDHTReader.java:207)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:744)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
