This Error is in Hadoop logs
for cluster com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems,
kafka partition 48
2017-05-18 10:43:49,670 INFO [main] kafka.AbstractKafkaInputOperator
(AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]:
Create operator partition for cluster
com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka
partition 49
2017-05-18 10:43:49,711 INFO [main] util.AsyncFSStorageAgent
(AsyncFSStorageAgent.java:save(91)) - using
/var/data/yarn/local/usercache/apex/appcache/application_1495028624385_0004/container_1495028624385_0004_01_000001/tmp/chkp7782336962410843784
as the basepath for checkpointing.
2017-05-18 10:43:51,290 ERROR [main] stram.StreamingAppMaster
(StreamingAppMaster.java:main(106)) - Exiting Application Master
java.lang.NoSuchFieldError: INSTANCE
at
org.apache.http.impl.conn.HttpClientConnectionOperator.<init>(HttpClientConnectionOperator.java:74)
at
org.apache.http.impl.conn.PoolingHttpClientConnectionManager.<init>(PoolingHttpClientConnectionManager.java:151)
at
org.apache.http.impl.conn.PoolingHttpClientConnectionManager.<init>(PoolingHttpClientConnectionManager.java:138)
at
org.apache.http.impl.conn.PoolingHttpClientConnectionManager.<init>(PoolingHttpClientConnectionManager.java:114)
at
org.apache.http.impl.conn.PoolingHttpClientConnectionManager.<init>(PoolingHttpClientConnectionManager.java:105)
at
com.datatorrent.stram.util.WebServicesClient.<clinit>(WebServicesClient.java:95)
at
com.datatorrent.stram.StreamingContainerManager.getAppMasterContainerInfo(StreamingContainerManager.java:488)
at
com.datatorrent.stram.StreamingContainerManager.init(StreamingContainerManager.java:455)
at
com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:427)
at
com.datatorrent.stram.StreamingContainerManager.getInstance(StreamingContainerManager.java:3135)
at
com.datatorrent.stram.StreamingAppMasterService.serviceInit(StreamingAppMasterService.java:557)
at
org.apache.hadoop.service.AbstractService.init(AbstractService.java:163)
at
com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:102)
--
View this message in context:
http://apache-apex-users-list.78494.x6.nabble.com/Fwd-Hdfs-apex-core-tp1608p1631.html
Sent from the Apache Apex Users list mailing list archive at Nabble.com.
