[ https://issues.apache.org/jira/browse/APEXMALHAR-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chandni Singh reassigned APEXMALHAR-2101: ----------------------------------------- Assignee: Chandni Singh > RuntimeException from Default Bucket which is under managed state. > ------------------------------------------------------------------ > > Key: APEXMALHAR-2101 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2101 > Project: Apache Apex Malhar > Issue Type: Bug > Reporter: Chaitanya > Assignee: Chandni Singh > > Getting the following exception, while using the ManagedTimeStateImpl > operator: > 2016-05-24 15:42:48,813 ERROR > com.datatorrent.stram.engine.StreamingContainer: Operator set > [OperatorDeployInfo[id=4,name=join,type=GENERIC,checkpoint={ffffffffffffffff, > 0, > 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=GenToJoin,sourceNodeId=2,sourcePortName=outputPort,locality=<null>,partitionMask=1,partitionKeys=[1]], > > OperatorDeployInfo.InputDeployInfo[portName=product,streamId=ProductToJoin,sourceNodeId=1,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=JoinToConsole,bufferServer=chaitanya-HP-ENVY-15-Notebook-PC]]]] > stopped running due to an exception. > java.lang.RuntimeException: while loading 0, 12 > at > org.apache.apex.malhar.lib.state.managed.Bucket$DefaultBucket.getValueFromTimeBucketReader(Bucket.java:346) > at > org.apache.apex.malhar.lib.state.managed.Bucket$DefaultBucket.getFromReaders(Bucket.java:291) > at > org.apache.apex.malhar.lib.state.managed.Bucket$DefaultBucket.get(Bucket.java:323) > at > org.apache.apex.malhar.lib.state.managed.AbstractManagedStateImpl.getValueFromBucketSync(AbstractManagedStateImpl.java:288) > at > org.apache.apex.malhar.lib.state.managed.ManagedTimeStateImpl.getSync(ManagedTimeStateImpl.java:56) > at > com.examples.app.ManagedStateIntOperator.get(ManagedStateIntOperator.java:91) > at > com.examples.app.ManagedStateIntOperator.processTuple(ManagedStateIntOperator.java:80) > at > com.examples.app.ManagedStateIntOperator$2.process(ManagedStateIntOperator.java:73) > at > com.examples.app.ManagedStateIntOperator$2.process(ManagedStateIntOperator.java:68) > 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:1393) > Caused by: java.io.EOFException: Cannot seek after EOF > at > org.apache.hadoop.hdfs.DFSInputStream.seek(DFSInputStream.java:1378) > at > org.apache.hadoop.fs.FSDataInputStream.seek(FSDataInputStream.java:62) > at > org.apache.hadoop.io.file.tfile.DTBCFile$Reader.<init>(DTBCFile.java:674) > at > org.apache.hadoop.io.file.tfile.DTFile$Reader.<init>(DTFile.java:827) > at > com.datatorrent.lib.fileaccess.DTFileReader.<init>(DTFileReader.java:55) > at > com.datatorrent.lib.fileaccess.TFileImpl$DTFileImpl.getReader(TFileImpl.java:173) > at > org.apache.apex.malhar.lib.state.managed.BucketsFileSystem.getReader(BucketsFileSystem.java:96) > at > org.apache.apex.malhar.lib.state.managed.Bucket$DefaultBucket.loadFileReader(Bucket.java:371) > at > org.apache.apex.malhar.lib.state.managed.Bucket$DefaultBucket.getValueFromTimeBucketReader(Bucket.java:341) > ... 12 more -- This message was sent by Atlassian JIRA (v6.3.4#6332)