[jira] [Created] (PIO-122) always get Error initializing storage client for source ELASTICSEARCH in 0.11 when pio train

["dongjie.shi (JIRA)" <ji...@apache.org>]

dongjie.shi created PIO-122:
-------------------------------

             Summary: always get Error initializing storage client for source ELASTICSEARCH in 0.11 when pio train
                 Key: PIO-122
                 URL: https://issues.apache.org/jira/browse/PIO-122
             Project: PredictionIO
          Issue Type: Bug
          Components: Core
    Affects Versions: 0.11.0-incubating
            Reporter: dongjie.shi


Always get this error when I try to run PIO train to test a local PIO with HBase and Elasticsearch.

[ERROR] [Storage$] Error initializing storage client for source ELASTICSEARCH
Exception in thread "main" org.apache.predictionio.data.storage.StorageClientException: Data source ELASTICSEARCH was not properly initialized.
    at org.apache.predictionio.data.storage.Storage$$anonfun$10.apply(Storage.scala:285)
    at org.apache.predictionio.data.storage.Storage$$anonfun$10.apply(Storage.scala:285)
    at scala.Option.getOrElse(Option.scala:120)
    at org.apache.predictionio.data.storage.Storage$.getDataObject(Storage.scala:284)
    at org.apache.predictionio.data.storage.Storage$.getDataObjectFromRepo(Storage.scala:269)
    at org.apache.predictionio.data.storage.Storage$.getMetaDataEngineInstances(Storage.scala:371)
    at org.apache.predictionio.workflow.CreateWorkflow$.main(CreateWorkflow.scala:247)
    at org.apache.predictionio.workflow.CreateWorkflow.main(CreateWorkflow.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:497)
    at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:731)
    at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:181)
    at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:206)
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:121)
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
It seems that every component is ok in pio staus:

[INFO] [Management$] Your system is all ready to go.

And about the configurations in pio-env.conf, I have checked them for many times.

PIO_FS_BASEDIR=${HOME}/.pio_store
PIO_FS_ENGINESDIR=${PIO_FS_BASEDIR}/engines
PIO_FS_TMPDIR=${PIO_FS_BASEDIR}/tmp

SPARK_HOME=${SPARK_HOME}
HBASE_CONF_DIR=${HBASE_HOME}/conf

PIO_STORAGE_REPOSITORIES_METADATA_NAME=pio_meta
PIO_STORAGE_REPOSITORIES_METADATA_SOURCE=ELASTICSEARCH
PIO_STORAGE_REPOSITORIES_EVENTDATA_NAME=pio_event
PIO_STORAGE_REPOSITORIES_EVENTDATA_SOURCE=HBASE
PIO_STORAGE_REPOSITORIES_MODELDATA_NAME=pio_model
PIO_STORAGE_REPOSITORIES_MODELDATA_SOURCE=LOCALFS

PIO_STORAGE_SOURCES_ELASTICSEARCH_TYPE=elasticsearch
PIO_STORAGE_SOURCES_ELASTICSEARCH_CLUSTERNAME=predictionio
PIO_STORAGE_SOURCES_ELASTICSEARCH_HOSTS=localhost
PIO_STORAGE_SOURCES_ELASTICSEARCH_PORTS=9300
PIO_STORAGE_SOURCES_ELASTICSEARCH_HOME=${ELASTICSEARCH_HOME}

PIO_STORAGE_SOURCES_LOCALFS_TYPE=localfs
PIO_STORAGE_SOURCES_LOCALFS_PATH=${PIO_FS_BASEDIR}/models
PIO_STORAGE_SOURCES_HBASE_TYPE=hbase
PIO_STORAGE_SOURCES_HBASE_HOME=${HBASE_HOME}



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