apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sanjay M Pujare (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2328) ClassCastException while running TopWikipediaSessions
Date Mon, 07 Nov 2016 22:26:58 GMT
Sanjay M Pujare created APEXMALHAR-2328:
-------------------------------------------

             Summary: 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)

Mime
View raw message