[
https://issues.apache.org/jira/browse/UNOMI-298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrés Páez updated UNOMI-298:
------------------------------
Summary: UNOMI doesn't connect to Elasticsearch Cluster (was: UNOMI
doesn't connect to Elasticsearch)
> UNOMI doesn't connect to Elasticsearch Cluster
> ----------------------------------------------
>
> Key: UNOMI-298
> URL: https://issues.apache.org/jira/browse/UNOMI-298
> Project: Apache Unomi
> Issue Type: Bug
> Reporter: Andrés Páez
> Priority: Major
>
> 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)
