Andrés Páez created UNOMI-298:
---------------------------------
Summary: UNOMI doesn't connect to Elasticsearch
Key: UNOMI-298
URL: https://issues.apache.org/jira/browse/UNOMI-298
Project: Apache Unomi
Issue Type: Bug
Reporter: Andrés Páez
Hello,
I'm having problems while trying to start UNOMI, with the following setup:
*UNOMI 1.4:*
Server 1: UNOMI Server.
*Cluster ELASTICSEARCH 7.4.2:*
Server1: Master
Server2: Data
Server3: Data
The configuration changed for UNOMI is the following:
In /etc/custom.system.properties
{code:java}
// code placeholder
org.apache.unomi.elasticsearch.cluster.name=${env:UNOMI_ELASTICSEARCH_CLUSTERNAME:-mdmElasticsearch}#
The elasticSearchAddresses may be a comma seperated list of host names and
ports such as
# hostA:9300,hostB:9300
# Note: the port number must be repeated for each host.
#
org.apache.unomi.elasticsearch.addresses=${env:UNOMI_ELASTICSEARCH_ADDRESSES:-localhost:9300}
org.apache.unomi.elasticsearch.addresses=${env:UNOMI_ELASTICSEARCH_ADDRESSES:-elasticsearch1:9200,elasticsearch2:9200,elasticsearch3:9200}org.apache.unomi.elasticsearch.index.name=${env:UNOMI_ELASTICSEARCH_INDEXNAME:-context}
org.apache.unomi.elasticsearch.monthlyIndex.nbShards=${env:UNOMI_ELASTICSEARCH_MONTHLYINDEX_SHARDS:-5}
org.apache.unomi.elasticsearch.monthlyIndex.nbReplicas=${env:UNOMI_ELASTICSEARCH_MONTHLYINDEX_REPLICAS:-0}
org.apache.unomi.elasticsearch.defaultIndex.nbShards=${env:UNOMI_ELASTICSEARCH_DEFAULTINDEX_SHARDS:-5}
org.apache.unomi.elasticsearch.defaultIndex.nbReplicas=${env:UNOMI_ELASTICSEARCH_DEFAULTINDEX_REPLICAS:-0}
org.apache.unomi.elasticsearch.defaultQueryLimit=${env:UNOMI_ELASTICSEARCH_DEFAULTQUERYLIMIT:-10}
org.apache.unomi.elasticsearch.aggregateQueryBucketSize=${env:UNOMI_ELASTICSEARCH_AGGREGATEBUCKETSIZE:-5000}
org.apache.unomi.elasticsearch.maximumIdsQueryCount=${env:UNOMI_ELASTICSEARCH_MAXIMUMIDSQUERYCOUNT:-5000}
{code}
The elasticsearch cluster is working and in green.
The error that shows when failing to Initialize unomi:
{code:java}
// code placeholder
15:55:36.570 [elasticsearch[_client_][transport_client_boss][T#2]] WARN
org.elasticsearch.transport.netty4.Netty4Transport - exception caught on
transport layer [[id: 0x78a7d0c1, L:/unomi-server:36390 !
R:/elasticsearch1:9200]], closing connection
io.netty.handler.codec.DecoderException: java.io.StreamCorruptedException:
invalid internal transport message format, got (48,54,54,50)
at
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:459)
~[!/:?]
at
io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:392)
~[!/:?]
at
io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:359)
~[!/:?]
at
io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:342)
~[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
[!/:?]
at
io.netty.handler.logging.LoggingHandler.channelInactive(LoggingHandler.java:167)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
[!/:?]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1329)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
[!/:?]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
[!/:?]
at
io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:908)
[!/:?]
at
io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:744)
[!/:?]
at
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
[!/:?]
at
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
[!/:?]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462) [!/:?]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
[!/:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242]
{code}
When executing tail:logs, this is the error that is showing:
{code:java}
// code placeholder
Caused by: org.elasticsearch.client.transport.NoNodeAvailableException: None of
the configured nodes are available:
[{#transport#-1}{UyL1zuYYSpqxqgmi0vXCmQ}{elasticserver1}{elasticserver1:9200},
{#transport#-2}{tIDkmd-aSJOGeCku7sEhvw}{elasticserver2}{elasticserver2:9200},
{#transport#-3}{yiOQmS86QwGHZcCuSmgtlw}{elasticserver3}{elasticserver3:9200}]
at
org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:347)
~[?:?]
at
org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:245)
~[?:?]
at
org.elasticsearch.client.transport.TransportProxyClient.execute(TransportProxyClient.java:59)
~[?:?]
at
org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:363)
~[?:?]
at
org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:408)
~[?:?]
at
org.elasticsearch.client.support.AbstractClient$ClusterAdmin.execute(AbstractClient.java:730)
~[?:?]
at
org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:80)
~[?:?]
at
org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:54)
~[?:?]
at
org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl$1.execute(ElasticSearchPersistenceServiceImpl.java:354)
~[?:?]
at
org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl$InClassLoaderExecute.executeInClassLoader(ElasticSearchPersistenceServiceImpl.java:1887)
~[?:?]
at
org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl.start(ElasticSearchPersistenceServiceImpl.java:430)
~[?:?]
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:498) ~[?:?]
at
org.apache.aries.blueprint.utils.ReflectionUtils.invoke(ReflectionUtils.java:299)
~[?:?]
at
org.apache.aries.blueprint.container.BeanRecipe.invoke(BeanRecipe.java:980)
~[?:?]
at
org.apache.aries.blueprint.container.BeanRecipe.runBeanProcInit(BeanRecipe.java:736)
~[?:?]
at
org.apache.aries.blueprint.container.BeanRecipe.internalCreate2(BeanRecipe.java:848)
~[?:?]
at
org.apache.aries.blueprint.container.BeanRecipe.internalCreate(BeanRecipe.java:811)
~[?:?]
at
org.apache.aries.blueprint.di.AbstractRecipe$1.call(AbstractRecipe.java:79)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:?]
at
org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:88)
~[?:?]
at
org.apache.aries.blueprint.di.RefRecipe.internalCreate(RefRecipe.java:62) ~[?:?]
at
org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:106)
~[?:?]
at
org.apache.aries.blueprint.container.ServiceRecipe.createService(ServiceRecipe.java:285)
~[?:?]
{code}
Do I have to configure something else?
Regards
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
