apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Thomas Weise (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (APEXMALHAR-1729) HDHT Exception In end window.
Date Sun, 03 Jan 2016 16:23:39 GMT

     [ 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)

Mime
View raw message