apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Yan (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2550) NycTaxiDataReader throws exception when encountering lines with unrecognized format in the NYC taxi example
Date Wed, 29 Nov 2017 04:31:01 GMT
David Yan created APEXMALHAR-2550:
-------------------------------------

             Summary: NycTaxiDataReader throws exception when encountering lines with unrecognized
format in the NYC taxi example
                 Key: APEXMALHAR-2550
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2550
             Project: Apache Apex Malhar
          Issue Type: Bug
            Reporter: David Yan
            Assignee: David Yan



17/11/28 16:21:42 ERROR engine.StreamingContainer: Operator set [OperatorDeployInfo[id=1,name=NycTaxiDataReader,type=INPUT,checkpoint={ffffffffffffffff,
0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=input_to_parser,bufferServer=localhost]]]]
stopped running due to an exception.
java.lang.ArrayIndexOutOfBoundsException: 1
	at org.apache.apex.examples.nyctaxi.NycTaxiDataReader.readEntity(NycTaxiDataReader.java:58)
	at org.apache.apex.examples.nyctaxi.NycTaxiDataReader.readEntity(NycTaxiDataReader.java:34)
	at com.datatorrent.lib.io.fs.AbstractFileInputOperator.emitTuples(AbstractFileInputOperator.java:684)
	at com.datatorrent.stram.engine.InputNode.run(InputNode.java:124)

and

ask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=parser_to_extractor,bufferServer=localhost]]]]
stopped running due to an exception.

java.lang.ArrayIndexOutOfBoundsException: 18

at org.apache.apex.examples.nyctaxi.NycTaxiCsvParser$1.process(NycTaxiCsvParser.java:49)

at org.apache.apex.examples.nyctaxi.NycTaxiCsvParser$1.process(NycTaxiCsvParser.java:39)

at com.datatorrent.api.DefaultInputPort.put(DefaultInputPort.java:79)

at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:288)

at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:269)

at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1428)





--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message