You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "David Yan (JIRA)" <ji...@apache.org> on 2016/11/07 23:01:00 UTC
[jira] [Commented] (APEXMALHAR-2328) ClassCastException while
running TopWikipediaSessions
[ https://issues.apache.org/jira/browse/APEXMALHAR-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15645753#comment-15645753 ]
David Yan commented on APEXMALHAR-2328:
---------------------------------------
[~hsy541] can you take a look at this? I am suspecting it's because ApexWindowedStreamImpl uses the non-session storage as the default, probably around line 259 of ApexWindowedStreamImpl.java.
> ClassCastException while running TopWikipediaSessions
> -----------------------------------------------------
>
> Key: APEXMALHAR-2328
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2328
> Project: Apache Apex Malhar
> Issue Type: Bug
> Components: demonstrations, streams
> Reporter: Sanjay M Pujare
>
> in the TopWikipediaSessions demo I saw this stack trace.
> Stram event details
> Stopped running due to an exception. java.lang.ClassCastException: org.apache.apex.malhar.lib.window.impl.InMemoryWindowedKeyedStorage cannot be cast to org.apache.apex.malhar.lib.window.SessionWindowedStorage
> at org.apache.apex.malhar.lib.window.impl.KeyedWindowedOperatorImpl.assignSessionWindows(KeyedWindowedOperatorImpl.java:62)
> at org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.assignWindows(AbstractWindowedOperator.java:353)
> at org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.getWindowedValueWithTimestamp(AbstractWindowedOperator.java:317)
> at org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.processTuple(AbstractWindowedOperator.java:144)
> at org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator$1.process(AbstractWindowedOperator.java:109)
> at org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator$1.process(AbstractWindowedOperator.java:105)
> at com.datatorrent.api.DefaultInputPort.put(DefaultInputPort.java:79)
> at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:280)
> at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:259)
> at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1415)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)