[
https://issues.apache.org/jira/browse/APEXMALHAR-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981482#comment-15981482
]
Thomas Weise commented on APEXMALHAR-2483:
------------------------------------------
{code}
Running org.apache.apex.malhar.stream.sample.complete.TopWikipediaSessionsTest
2017-04-24 16:36:23,772 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,783 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,790 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,796 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,800 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,803 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,807 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,817 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,826 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:23,830 [main] WARN stram.Journal write - Journal output
stream is null. Skipping write to the WAL.
2017-04-24 16:36:25,502 [4/ComputeSessions:KeyedWindowedOperatorImpl] ERROR
engine.StreamingContainer run - Operator set
[OperatorDeployInfo[id=4,name=ComputeSessions,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=com.datatorrent.api.DefaultOutputPort@7693551e,sourceNodeId=3,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=com.datatorrent.api.DefaultOutputPort@1ca34126,bufferServer=testing-docker-7bb272bc-041c-4b0b-97b5-4ab27259d3e1]]]]
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:76)
at
org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.assignWindows(AbstractWindowedOperator.java:367)
at
org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.getWindowedValueWithTimestamp(AbstractWindowedOperator.java:331)
at
org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator.processTuple(AbstractWindowedOperator.java:149)
at
org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator$1.process(AbstractWindowedOperator.java:114)
at
org.apache.apex.malhar.lib.window.impl.AbstractWindowedOperator$1.process(AbstractWindowedOperator.java:110)
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:1407)
{code}
> Error in High Level API test
> ----------------------------
>
> Key: APEXMALHAR-2483
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2483
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Thomas Weise
>
> There is an exception in the log but no error reported in the test suite.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
