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] [Commented] (APEXMALHAR-2483) Error in High Level API test
Date Mon, 24 Apr 2017 16:44:04 GMT

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

Mime
View raw message