You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by Manish Mishra <ma...@knoldus.com> on 2016/09/29 10:15:16 UTC
Getting Error [grid-timeout-worker] when running join query on Single
Ignite Node
Hi,
I am populating three caches running on a single ignite node (version
1.5.27 ) with 4 GB heap (Configure as: JVM_OPTS="-server -Xms4g -Xmx4g)
with less than 100k records in each. I'am performing a join query on them
but the query takes a hell lot of time and I get this log (Or I don't know
It is just ERROR or INFO) as following logs.
[09:47:18,720][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Added new node to topology: TcpDiscoveryNode
[id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=8, intOrder=5,
lastExchangeTime=1475142438712, loc=false,
ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
[09:47:18,721][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Topology snapshot [ver=8, servers=1, clients=1, CPUs=16, heap=5.8GB]
[09:47:18,729][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=8, minorTopVer=0], evt=NODE_JOINED,
node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
[09:47:19,279][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=8, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
[09:47:19,345][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=8, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
[09:47:19,376][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=8, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
[09:47:25,611][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Node left topology: TcpDiscoveryNode
[id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=8, intOrder=5,
lastExchangeTime=1475142438712, loc=false,
ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
[09:47:25,612][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Topology snapshot [ver=9, servers=1, clients=0, CPUs=16, heap=4.0GB]
[09:47:25,621][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=9, minorTopVer=0], evt=NODE_LEFT,
node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
[09:47:47,234][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Added new node to topology: TcpDiscoveryNode
[id=448da668-5262-46bb-951a-c6122543882a, addrs=[0:0:0:0:0:0:0:1%lo,
10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=10,
intOrder=6, lastExchangeTime=1475142467220, loc=false,
ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
[09:47:47,235][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
Topology snapshot [ver=10, servers=1, clients=1, CPUs=16, heap=5.8GB]
[09:47:47,243][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=10, minorTopVer=0], evt=NODE_JOINED,
node=448da668-5262-46bb-951a-c6122543882a]
[09:47:47,861][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=10, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
node=448da668-5262-46bb-951a-c6122543882a]
[09:47:47,922][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=10, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
node=448da668-5262-46bb-951a-c6122543882a]
[09:47:47,955][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
[topVer=10, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
node=448da668-5262-46bb-951a-c6122543882a]
[09:48:04,885][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
Metrics for local node (to disable set 'metricsLogFrequency' to 0)
^-- Node [id=6caab193, name=null]
^-- H/N/C [hosts=1, nodes=2, CPUs=16]
^-- CPU [cur=0.03%, avg=3.31%, GC=0%]
^-- Heap [used=1219MB, free=70.23%, comm=4095MB]
^-- Public thread pool [active=0, idle=32, qSize=0]
^-- System thread pool [active=0, idle=32, qSize=0]
^-- Outbound messages queue [size=0]
[09:49:04,879][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
Metrics for local node (to disable set 'metricsLogFrequency' to 0)
^-- Node [id=6caab193, name=null]
^-- H/N/C [hosts=1, nodes=2, CPUs=16]
^-- CPU [cur=0%, avg=3.23%, GC=0%]
^-- Heap [used=1222MB, free=70.14%, comm=4095MB]
^-- Public thread pool [active=0, idle=32, qSize=0]
^-- System thread pool [active=0, idle=32, qSize=0]
^-- Outbound messages queue [size=0]
[09:50:04,883][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
Metrics for local node (to disable set 'metricsLogFrequency' to 0)
^-- Node [id=6caab193, name=null]
^-- H/N/C [hosts=1, nodes=2, CPUs=16]
^-- CPU [cur=0.03%, avg=3.17%, GC=0%]
^-- Heap [used=1227MB, free=70.04%, comm=4095MB]
^-- Public thread pool [active=0, idle=32, qSize=0]
^-- System thread pool [active=0, idle=32, qSize=0]
^-- Outbound messages queue [size=0]
[09:51:04,882][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
Metrics for local node (to disable set 'metricsLogFrequency' to 0)
^-- Node [id=6caab193, name=null]
^-- H/N/C [hosts=1, nodes=2, CPUs=16]
Here is what my join query (Generated by some custom engine which work
perfectly normal with postgres with same tables and joins)looks like:
SELECT DISTINCT m1 AS m1,m1_TYP AS m1_TYP FROM (SELECT entry AS a5,QS5.a1
AS a1,QS5.a4 AS a4,QS5.m1 AS m1,m1_TYP AS m1_TYP
FROM "TABLE1".TABLE1 AS T,(SELECT entity AS m1,typ AS m1_typ,elem AS
a5,QS4.a1 AS a1,QS4.a4 AS a4
FROM "TABLE2".TABLE2 AS T,(SELECT entry AS a2,QS3.a1 AS a1,QS3.a4 AS
a4,QS3.m1 AS m1,m1_TYP AS m1_TYP
FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a4,QS2.a1 AS a1,QS2.a2 AS
a2,QS2.m1 AS m1,m1_TYP AS m1_TYP
FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a3,QS1.a1 AS a1,QS1.a2 AS
a2,QS1.a4 AS a4,QS1.m1 AS m1,m1_TYP AS m1_TYP
FROM "TABLE1".TABLE1 AS T,(SELECT a1 AS a1,m1 AS m1,m1_TYP AS
m1_TYP,COALESCE(S3.elem,val3) AS a3,COALESCE(S4.elem,val4) AS
a4,COALESCE(S2.elem,val2) AS a2
FROM (SELECT entry AS a1,T.val2 AS m1,T.typ2 AS m1_TYP,T.val6 AS
VAL3,T.val6 AS VAL4,T.val8 AS VAL2
FROM "TABLE1".TABLE1 AS T,(SELECT elem AS a1
FROM "TABLE2".TABLE2 AS T
WHERE entity = '3' AND typ = 5001
AND (prop = '1oh~#some_prop1')) AS QS0 WHERE entry = QS0.a1
AND (T.prop0 = '4xm~#type' AND T.prop8 = '1oh~#some_prop2' AND T.prop6
= '1oh~#some_prop3' AND T.prop6 = '1oh~#some_prop3' AND T.prop2 =
'1oh~#is_atom_of')
AND T.val0 = '7a~') AS Q1 LEFT OUTER JOIN "TABLE3".TABLE3 AS S3 ON
Q1.VAL3 = S3.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S4 ON Q1.VAL4 =
S4.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S2 ON Q1.VAL2 = S2.list_id
WHERE ( (a1 <> COALESCE(S4.elem,val4)
) )) AS QS1 WHERE entry = QS1.a3
AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1' AND T.prop8
= '1oh~#some_prop4')
AND T.val0 = '562~' AND T.val5 = '1' AND T.val8 = '6o7~') AS QS2 WHERE
entry = QS2.a4
AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
AND T.val0 = '7a~' AND T.val5 = '1') AS QS3 WHERE entry = QS3.a2
AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
AND T.val0 = '562~' AND T.val5 = '1') AS QS4 WHERE entity = QS4.m1 AND
typ = QS4.m1_TYP
AND (prop = '1oh~#isome_prop5')) AS QS5 WHERE entry = QS5.a5
AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
AND T.val0 = '1eg~' AND T.val5 = '0') AS QS6 LIMIT 100
PS: I've been able to run the similar query with join and that doesn't give
the above error logs. Please help me with that.
--
Thanks & Regard
Manish Mishra
Software Consultant,
Knoldus Software, LLP
Re: Getting Error [grid-timeout-worker] when running join query on
Single Ignite Node
Posted by Alexander Paschenko <al...@gmail.com>.
Mainish,
Your EXPLAIN query has EXPLAIN word twice (in the very beginning) and
thus is not synctactically correct.
2016-09-30 15:26 GMT+03:00 Manish Mishra <ma...@knoldus.com>:
> Thanks for reply.
> @Taras I have set QuerySqlField(index=true) on the indexing fields. @Alex,
> I've used the EXPLAIN with query I make to Gridgain Cache but I don't know
> how to verify if the indexes are invoked on not. Here is the output when I
> used explain with the Query:
>
> SELECT DISTINCT
> M1 __C0,
> M1_TYP __C1
> FROM (SELECT
> ENTRY AS A5,
> QS5.A1 AS A1,
> QS5.A4 AS A4,
> QS5.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTITY AS M1,
> TYP AS M1_TYP,
> ELEM AS A5,
> QS4.A1 AS A1,
> QS4.A4 AS A4
> FROM RS.RS T
> INNER JOIN (SELECT
> ENTRY AS A2,
> QS3.A1 AS A1,
> QS3.A4 AS A4,
> QS3.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTRY AS A4,
> QS2.A1 AS A1,
> QS2.A2 AS A2,
> QS2.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTRY AS A3,
> QS1.A1 AS A1,
> QS1.A2 AS A2,
> QS1.A4 AS A4,
> QS1.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> A1 AS A1,
> M1 AS M1,
> M1_TYP AS M1_TYP,
> COALESCE(S2.ELEM, VAL2) AS A2,
> COALESCE(S3.ELEM, VAL3) AS A3,
> COALESCE(S4.ELEM, VAL4) AS A4
> FROM (SELECT
> ENTRY AS A1,
> T.VAL2 AS M1,
> T.TYP2 AS M1_TYP,
> T.VAL8 AS VAL2,
> T.VAL6 AS VAL3,
> T.VAL6 AS VAL4
> FROM (SELECT
> ELEM AS A1
> FROM RS.RS T
> WHERE (PROP = '1oh~#has_neighbours') AND ((ENTITY = '3') AND (TYP = 5001)))
> QS0
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL0 = '7a~') AND ((ENTRY = QS0.A1) AND ((T.PROP2 =
> '1oh~#is_atom_of') AND ((T.PROP6 = '1oh~#has_single_bond') AND ((T.PROP6 =
> '1oh~#has_single_bond') AND ((T.PROP0 = '4xm~#type') AND (T.PROP8 =
> '1oh~#has_double_bond'))))))) Q1
> LEFT OUTER JOIN DS.DS S2
> ON Q1.VAL2 = S2.LIST_ID
> LEFT OUTER JOIN DS.DS S3
> ON Q1.VAL3 = S3.LIST_ID
> LEFT OUTER JOIN DS.DS S4
> ON Q1.VAL4 = S4.LIST_ID
> WHERE A1 <> COALESCE(S4.ELEM, VAL4)) QS1
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL8 = '6o7~') AND ((T.VAL5 = '1') AND ((T.VAL0 = '562~') AND
> ((ENTRY = QS1.A3) AND ((T.PROP8 = '1oh~#has_charge') AND ((T.PROP0 =
> '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))))) QS2
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '1') AND ((T.VAL0 = '7a~') AND ((ENTRY = QS2.A4) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS3
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '1') AND ((T.VAL0 = '562~') AND ((ENTRY = QS3.A2) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS4
> ON TRUE
> WHERE (PROP = '1oh~#is_atom_of') AND ((ENTITY = QS4.M1) AND (TYP =
> QS4.M1_TYP))) QS5
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '0') AND ((T.VAL0 = '1eg~') AND ((ENTRY = QS5.A5) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS6 LIMIT
> 100"; expected "ANALYZE, PLAN, SELECT, FROM, (, DELETE, UPDATE, INSERT,
> MERGE, WITH"; SQL statement:
> EXPLAIN EXPLAIN SELECT DISTINCT
> M1 __C0,
> M1_TYP __C1
> FROM (SELECT
> ENTRY AS A5,
> QS5.A1 AS A1,
> QS5.A4 AS A4,
> QS5.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTITY AS M1,
> TYP AS M1_TYP,
> ELEM AS A5,
> QS4.A1 AS A1,
> QS4.A4 AS A4
> FROM RS.RS T
> INNER JOIN (SELECT
> ENTRY AS A2,
> QS3.A1 AS A1,
> QS3.A4 AS A4,
> QS3.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTRY AS A4,
> QS2.A1 AS A1,
> QS2.A2 AS A2,
> QS2.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> ENTRY AS A3,
> QS1.A1 AS A1,
> QS1.A2 AS A2,
> QS1.A4 AS A4,
> QS1.M1 AS M1,
> M1_TYP AS M1_TYP
> FROM (SELECT
> A1 AS A1,
> M1 AS M1,
> M1_TYP AS M1_TYP,
> COALESCE(S2.ELEM, VAL2) AS A2,
> COALESCE(S3.ELEM, VAL3) AS A3,
> COALESCE(S4.ELEM, VAL4) AS A4
> FROM (SELECT
> ENTRY AS A1,
> T.VAL2 AS M1,
> T.TYP2 AS M1_TYP,
> T.VAL8 AS VAL2,
> T.VAL6 AS VAL3,
> T.VAL6 AS VAL4
> FROM (SELECT
> ELEM AS A1
> FROM RS.RS T
> WHERE (PROP = '1oh~#has_neighbours') AND ((ENTITY = '3') AND (TYP = 5001)))
> QS0
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL0 = '7a~') AND ((ENTRY = QS0.A1) AND ((T.PROP2 =
> '1oh~#is_atom_of') AND ((T.PROP6 = '1oh~#has_single_bond') AND ((T.PROP6 =
> '1oh~#has_single_bond') AND ((T.PROP0 = '4xm~#type') AND (T.PROP8 =
> '1oh~#has_double_bond'))))))) Q1
> LEFT OUTER JOIN DS.DS S2
> ON Q1.VAL2 = S2.LIST_ID
> LEFT OUTER JOIN DS.DS S3
> ON Q1.VAL3 = S3.LIST_ID
> LEFT OUTER JOIN DS.DS S4
> ON Q1.VAL4 = S4.LIST_ID
> WHERE A1 <> COALESCE(S4.ELEM, VAL4)) QS1
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL8 = '6o7~') AND ((T.VAL5 = '1') AND ((T.VAL0 = '562~') AND
> ((ENTRY = QS1.A3) AND ((T.PROP8 = '1oh~#has_charge') AND ((T.PROP0 =
> '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))))) QS2
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '1') AND ((T.VAL0 = '7a~') AND ((ENTRY = QS2.A4) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS3
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '1') AND ((T.VAL0 = '562~') AND ((ENTRY = QS3.A2) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS4
> ON TRUE
> WHERE (PROP = '1oh~#is_atom_of') AND ((ENTITY = QS4.M1) AND (TYP =
> QS4.M1_TYP))) QS5
> INNER JOIN DPH.DPH T
> ON TRUE
> WHERE (T.VAL5 = '0') AND ((T.VAL0 = '1eg~') AND ((ENTRY = QS5.A5) AND
> ((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS6 LIMIT
> 100
>
>
>
>
>
>
>
>
> On Thu, Sep 29, 2016 at 11:05 PM, Alexey Kuznetsov <ak...@gridgain.com>
> wrote:
>>
>> Alex,
>>
>> it is better to give a link to docs when you are sugesting EXPLAIN
>> SELECT :)
>>
>> https://apacheignite.readme.io/docs/sql-queries#using-explain
>>
>> Hope this help :)
>>
>> --
>> Alexey Kuznetsov
>
>
>
>
> --
> Thanks & Regard
>
> Manish Mishra
> Software Consultant,
> Knoldus Software, LLP
>
Re: Getting Error [grid-timeout-worker] when running join query on
Single Ignite Node
Posted by Manish Mishra <ma...@knoldus.com>.
Thanks for reply.
@Taras I have set QuerySqlField(index=true) on the indexing fields. @Alex,
I've used the EXPLAIN with query I make to Gridgain Cache but I don't know
how to verify if the indexes are invoked on not. Here is the output when I
used explain with the Query:
SELECT DISTINCT
M1 __C0,
M1_TYP __C1
FROM (SELECT
ENTRY AS A5,
QS5.A1 AS A1,
QS5.A4 AS A4,
QS5.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTITY AS M1,
TYP AS M1_TYP,
ELEM AS A5,
QS4.A1 AS A1,
QS4.A4 AS A4
FROM RS.RS T
INNER JOIN (SELECT
ENTRY AS A2,
QS3.A1 AS A1,
QS3.A4 AS A4,
QS3.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTRY AS A4,
QS2.A1 AS A1,
QS2.A2 AS A2,
QS2.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTRY AS A3,
QS1.A1 AS A1,
QS1.A2 AS A2,
QS1.A4 AS A4,
QS1.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
A1 AS A1,
M1 AS M1,
M1_TYP AS M1_TYP,
COALESCE(S2.ELEM, VAL2) AS A2,
COALESCE(S3.ELEM, VAL3) AS A3,
COALESCE(S4.ELEM, VAL4) AS A4
FROM (SELECT
ENTRY AS A1,
T.VAL2 AS M1,
T.TYP2 AS M1_TYP,
T.VAL8 AS VAL2,
T.VAL6 AS VAL3,
T.VAL6 AS VAL4
FROM (SELECT
ELEM AS A1
FROM RS.RS T
WHERE (PROP = '1oh~#has_neighbours') AND ((ENTITY = '3') AND (TYP = 5001)))
QS0
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL0 = '7a~') AND ((ENTRY = QS0.A1) AND ((T.PROP2 =
'1oh~#is_atom_of') AND ((T.PROP6 = '1oh~#has_single_bond') AND ((T.PROP6 =
'1oh~#has_single_bond') AND ((T.PROP0 = '4xm~#type') AND (T.PROP8 =
'1oh~#has_double_bond'))))))) Q1
LEFT OUTER JOIN DS.DS S2
ON Q1.VAL2 = S2.LIST_ID
LEFT OUTER JOIN DS.DS S3
ON Q1.VAL3 = S3.LIST_ID
LEFT OUTER JOIN DS.DS S4
ON Q1.VAL4 = S4.LIST_ID
WHERE A1 <> COALESCE(S4.ELEM, VAL4)) QS1
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL8 = '6o7~') AND ((T.VAL5 = '1') AND ((T.VAL0 = '562~') AND
((ENTRY = QS1.A3) AND ((T.PROP8 = '1oh~#has_charge') AND ((T.PROP0 =
'4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))))) QS2
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '1') AND ((T.VAL0 = '7a~') AND ((ENTRY = QS2.A4) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS3
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '1') AND ((T.VAL0 = '562~') AND ((ENTRY = QS3.A2) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS4
ON TRUE
WHERE (PROP = '1oh~#is_atom_of') AND ((ENTITY = QS4.M1) AND (TYP =
QS4.M1_TYP))) QS5
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '0') AND ((T.VAL0 = '1eg~') AND ((ENTRY = QS5.A5) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS6
LIMIT 100"; expected "ANALYZE, PLAN, SELECT, FROM, (, DELETE, UPDATE,
INSERT, MERGE, WITH"; SQL statement:
EXPLAIN EXPLAIN SELECT DISTINCT
M1 __C0,
M1_TYP __C1
FROM (SELECT
ENTRY AS A5,
QS5.A1 AS A1,
QS5.A4 AS A4,
QS5.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTITY AS M1,
TYP AS M1_TYP,
ELEM AS A5,
QS4.A1 AS A1,
QS4.A4 AS A4
FROM RS.RS T
INNER JOIN (SELECT
ENTRY AS A2,
QS3.A1 AS A1,
QS3.A4 AS A4,
QS3.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTRY AS A4,
QS2.A1 AS A1,
QS2.A2 AS A2,
QS2.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
ENTRY AS A3,
QS1.A1 AS A1,
QS1.A2 AS A2,
QS1.A4 AS A4,
QS1.M1 AS M1,
M1_TYP AS M1_TYP
FROM (SELECT
A1 AS A1,
M1 AS M1,
M1_TYP AS M1_TYP,
COALESCE(S2.ELEM, VAL2) AS A2,
COALESCE(S3.ELEM, VAL3) AS A3,
COALESCE(S4.ELEM, VAL4) AS A4
FROM (SELECT
ENTRY AS A1,
T.VAL2 AS M1,
T.TYP2 AS M1_TYP,
T.VAL8 AS VAL2,
T.VAL6 AS VAL3,
T.VAL6 AS VAL4
FROM (SELECT
ELEM AS A1
FROM RS.RS T
WHERE (PROP = '1oh~#has_neighbours') AND ((ENTITY = '3') AND (TYP = 5001)))
QS0
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL0 = '7a~') AND ((ENTRY = QS0.A1) AND ((T.PROP2 =
'1oh~#is_atom_of') AND ((T.PROP6 = '1oh~#has_single_bond') AND ((T.PROP6 =
'1oh~#has_single_bond') AND ((T.PROP0 = '4xm~#type') AND (T.PROP8 =
'1oh~#has_double_bond'))))))) Q1
LEFT OUTER JOIN DS.DS S2
ON Q1.VAL2 = S2.LIST_ID
LEFT OUTER JOIN DS.DS S3
ON Q1.VAL3 = S3.LIST_ID
LEFT OUTER JOIN DS.DS S4
ON Q1.VAL4 = S4.LIST_ID
WHERE A1 <> COALESCE(S4.ELEM, VAL4)) QS1
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL8 = '6o7~') AND ((T.VAL5 = '1') AND ((T.VAL0 = '562~') AND
((ENTRY = QS1.A3) AND ((T.PROP8 = '1oh~#has_charge') AND ((T.PROP0 =
'4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))))) QS2
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '1') AND ((T.VAL0 = '7a~') AND ((ENTRY = QS2.A4) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS3
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '1') AND ((T.VAL0 = '562~') AND ((ENTRY = QS3.A2) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS4
ON TRUE
WHERE (PROP = '1oh~#is_atom_of') AND ((ENTITY = QS4.M1) AND (TYP =
QS4.M1_TYP))) QS5
INNER JOIN DPH.DPH T
ON TRUE
WHERE (T.VAL5 = '0') AND ((T.VAL0 = '1eg~') AND ((ENTRY = QS5.A5) AND
((T.PROP0 = '4xm~#type') AND (T.PROP5 = '1oh~#has_neighbours'))))) QS6
LIMIT 100
On Thu, Sep 29, 2016 at 11:05 PM, Alexey Kuznetsov <ak...@gridgain.com>
wrote:
> Alex,
>
> it is better to give a link to docs when you are sugesting EXPLAIN
> SELECT :)
>
> https://apacheignite.readme.io/docs/sql-queries#using-explain
>
> Hope this help :)
>
> --
> Alexey Kuznetsov
>
--
Thanks & Regard
Manish Mishra
Software Consultant,
Knoldus Software, LLP
Re: Getting Error [grid-timeout-worker] when running join query on
Single Ignite Node
Posted by Alexey Kuznetsov <ak...@gridgain.com>.
Alex,
it is better to give a link to docs when you are sugesting EXPLAIN SELECT
:)
https://apacheignite.readme.io/docs/sql-queries#using-explain
Hope this help :)
--
Alexey Kuznetsov
Re: Getting Error [grid-timeout-worker] when running join query on
Single Ignite Node
Posted by Alexander Paschenko <al...@gmail.com>.
Hello Manish,
Also, Ignite supports SQL command EXPLAIN SELECT - please use it to
make sure indexes are invoked during your query execution, i.e.
there's no full scan.
2016-09-29 17:04 GMT+03:00 Taras Ledkov <tl...@gridgain.com>:
> Hi, Manish
>
> - Do you use the 'index=true' parameter of the @QuerySqlField annotation
> (default false)?
>
> - Please use the
>
> SqlFieldsQuery.setLocal(true);
>
> if the the query is executed on the single node topology or all data are
> available locally. In this case map/reduce is skipped.
>
>
> On 29.09.2016 13:15, Manish Mishra wrote:
>
> Hi,
>
> I am populating three caches running on a single ignite node (version 1.5.27
> ) with 4 GB heap (Configure as: JVM_OPTS="-server -Xms4g -Xmx4g) with less
> than 100k records in each. I'am performing a join query on them but the
> query takes a hell lot of time and I get this log (Or I don't know It is
> just ERROR or INFO) as following logs.
>
> [09:47:18,720][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Added new node to topology: TcpDiscoveryNode
> [id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
> elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=8, intOrder=5,
> lastExchangeTime=1475142438712, loc=false,
> ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:18,721][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=8, servers=1, clients=1, CPUs=16, heap=5.8GB]
> [09:47:18,729][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=0], evt=NODE_JOINED,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,279][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,345][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,376][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:25,611][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Node left topology: TcpDiscoveryNode
> [id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
> elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=8, intOrder=5,
> lastExchangeTime=1475142438712, loc=false,
> ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:25,612][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=9, servers=1, clients=0, CPUs=16, heap=4.0GB]
> [09:47:25,621][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=9, minorTopVer=0], evt=NODE_LEFT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:47,234][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Added new node to topology: TcpDiscoveryNode
> [id=448da668-5262-46bb-951a-c6122543882a, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0,
> elssie-gridgain2.internal/10.178.148.8:0], discPort=0, order=10, intOrder=6,
> lastExchangeTime=1475142467220, loc=false,
> ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:47,235][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=10, servers=1, clients=1, CPUs=16, heap=5.8GB]
> [09:47:47,243][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=0], evt=NODE_JOINED,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,861][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,922][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,955][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:48:04,885][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0.03%, avg=3.31%, GC=0%]
> ^-- Heap [used=1219MB, free=70.23%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:49:04,879][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0%, avg=3.23%, GC=0%]
> ^-- Heap [used=1222MB, free=70.14%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:50:04,883][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0.03%, avg=3.17%, GC=0%]
> ^-- Heap [used=1227MB, free=70.04%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:51:04,882][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
>
>
> Here is what my join query (Generated by some custom engine which work
> perfectly normal with postgres with same tables and joins)looks like:
>
> SELECT DISTINCT m1 AS m1,m1_TYP AS m1_TYP FROM (SELECT entry AS a5,QS5.a1
> AS a1,QS5.a4 AS a4,QS5.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entity AS m1,typ AS m1_typ,elem AS
> a5,QS4.a1 AS a1,QS4.a4 AS a4
> FROM "TABLE2".TABLE2 AS T,(SELECT entry AS a2,QS3.a1 AS a1,QS3.a4 AS
> a4,QS3.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a4,QS2.a1 AS a1,QS2.a2 AS
> a2,QS2.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a3,QS1.a1 AS a1,QS1.a2 AS
> a2,QS1.a4 AS a4,QS1.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT a1 AS a1,m1 AS m1,m1_TYP AS
> m1_TYP,COALESCE(S3.elem,val3) AS a3,COALESCE(S4.elem,val4) AS
> a4,COALESCE(S2.elem,val2) AS a2
> FROM (SELECT entry AS a1,T.val2 AS m1,T.typ2 AS m1_TYP,T.val6 AS
> VAL3,T.val6 AS VAL4,T.val8 AS VAL2
> FROM "TABLE1".TABLE1 AS T,(SELECT elem AS a1
> FROM "TABLE2".TABLE2 AS T
> WHERE entity = '3' AND typ = 5001
> AND (prop = '1oh~#some_prop1')) AS QS0 WHERE entry = QS0.a1
> AND (T.prop0 = '4xm~#type' AND T.prop8 = '1oh~#some_prop2' AND T.prop6 =
> '1oh~#some_prop3' AND T.prop6 = '1oh~#some_prop3' AND T.prop2 =
> '1oh~#is_atom_of')
> AND T.val0 = '7a~') AS Q1 LEFT OUTER JOIN "TABLE3".TABLE3 AS S3 ON
> Q1.VAL3 = S3.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S4 ON Q1.VAL4 =
> S4.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S2 ON Q1.VAL2 = S2.list_id
> WHERE ( (a1 <> COALESCE(S4.elem,val4)
> ) )) AS QS1 WHERE entry = QS1.a3
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1' AND T.prop8
> = '1oh~#some_prop4')
> AND T.val0 = '562~' AND T.val5 = '1' AND T.val8 = '6o7~') AS QS2 WHERE
> entry = QS2.a4
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '7a~' AND T.val5 = '1') AS QS3 WHERE entry = QS3.a2
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '562~' AND T.val5 = '1') AS QS4 WHERE entity = QS4.m1 AND
> typ = QS4.m1_TYP
> AND (prop = '1oh~#isome_prop5')) AS QS5 WHERE entry = QS5.a5
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '1eg~' AND T.val5 = '0') AS QS6 LIMIT 100
>
>
> PS: I've been able to run the similar query with join and that doesn't give
> the above error logs. Please help me with that.
>
>
>
>
>
>
> --
> Thanks & Regard
>
> Manish Mishra
> Software Consultant,
> Knoldus Software, LLP
>
>
> --
> Taras Ledkov
> Mail-To: tledkov@gridgain.com
Re: Getting Error [grid-timeout-worker] when running join query on
Single Ignite Node
Posted by Taras Ledkov <tl...@gridgain.com>.
Hi, Manish
- Do you use the 'index=true' parameter of the @QuerySqlField annotation
(default false)?
- Please use the
SqlFieldsQuery.setLocal(true);
if the the query is executed on the single node topology or all data are
available locally. In this case map/reduce is skipped.
On 29.09.2016 13:15, Manish Mishra wrote:
> Hi,
>
> I am populating three caches running on a single ignite node (version
> 1.5.27 ) with 4 GB heap (Configure as: JVM_OPTS="-server -Xms4g
> -Xmx4g) with less than 100k records in each. I'am performing a join
> query on them but the query takes a hell lot of time and I get this
> log (Or I don't know It is just ERROR or INFO) as following logs.
>
> [09:47:18,720][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Added new node to topology: TcpDiscoveryNode
> [id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0,
> /127.0.0.1:0 <http://127.0.0.1:0>,
> elssie-gridgain2.internal/10.178.148.8:0 <http://10.178.148.8:0>],
> discPort=0, order=8, intOrder=5, lastExchangeTime=1475142438712,
> loc=false, ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:18,721][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=8, servers=1, clients=1, CPUs=16, heap=5.8GB]
> [09:47:18,729][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=0], evt=NODE_JOINED,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,279][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,345][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:19,376][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=8, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:25,611][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Node left topology: TcpDiscoveryNode
> [id=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0,
> /127.0.0.1:0 <http://127.0.0.1:0>,
> elssie-gridgain2.internal/10.178.148.8:0 <http://10.178.148.8:0>],
> discPort=0, order=8, intOrder=5, lastExchangeTime=1475142438712,
> loc=false, ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:25,612][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=9, servers=1, clients=0, CPUs=16, heap=4.0GB]
> [09:47:25,621][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=9, minorTopVer=0], evt=NODE_LEFT,
> node=ea2b3ca3-f5d0-45bd-adb3-58d46bc85b7d]
> [09:47:47,234][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Added new node to topology: TcpDiscoveryNode
> [id=448da668-5262-46bb-951a-c6122543882a, addrs=[0:0:0:0:0:0:0:1%lo,
> 10.178.148.8, 127.0.0.1], sockAddrs=[/0:0:0:0:0:0:0:1%lo:0,
> /127.0.0.1:0 <http://127.0.0.1:0>,
> elssie-gridgain2.internal/10.178.148.8:0 <http://10.178.148.8:0>],
> discPort=0, order=10, intOrder=6, lastExchangeTime=1475142467220,
> loc=false, ver=1.5.27#20160624-sha1:0fe713ae, isClient=true]
> [09:47:47,235][INFO][disco-event-worker-#96%null%][GridDiscoveryManager]
> Topology snapshot [ver=10, servers=1, clients=1, CPUs=16, heap=5.8GB]
> [09:47:47,243][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=0], evt=NODE_JOINED,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,861][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,922][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:47:47,955][INFO][exchange-worker-#99%null%][GridCachePartitionExchangeManager]
> Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion
> [topVer=10, minorTopVer=3], evt=DISCOVERY_CUSTOM_EVT,
> node=448da668-5262-46bb-951a-c6122543882a]
> [09:48:04,885][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0.03%, avg=3.31%, GC=0%]
> ^-- Heap [used=1219MB, free=70.23%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:49:04,879][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0%, avg=3.23%, GC=0%]
> ^-- Heap [used=1222MB, free=70.14%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:50:04,883][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
> ^-- CPU [cur=0.03%, avg=3.17%, GC=0%]
> ^-- Heap [used=1227MB, free=70.04%, comm=4095MB]
> ^-- Public thread pool [active=0, idle=32, qSize=0]
> ^-- System thread pool [active=0, idle=32, qSize=0]
> ^-- Outbound messages queue [size=0]
> [09:51:04,882][INFO][grid-timeout-worker-#81%null%][IgniteKernal]
> Metrics for local node (to disable set 'metricsLogFrequency' to 0)
> ^-- Node [id=6caab193, name=null]
> ^-- H/N/C [hosts=1, nodes=2, CPUs=16]
>
>
> Here is what my join query (Generated by some custom engine which work
> perfectly normal with postgres with same tables and joins)looks like:
>
> SELECT DISTINCT m1 AS m1,m1_TYP AS m1_TYP FROM (SELECT entry AS
> a5,QS5.a1 AS a1,QS5.a4 AS a4,QS5.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entity AS m1,typ AS m1_typ,elem AS
> a5,QS4.a1 AS a1,QS4.a4 AS a4
> FROM "TABLE2".TABLE2 AS T,(SELECT entry AS a2,QS3.a1 AS a1,QS3.a4 AS
> a4,QS3.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a4,QS2.a1 AS a1,QS2.a2 AS
> a2,QS2.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT entry AS a3,QS1.a1 AS a1,QS1.a2 AS
> a2,QS1.a4 AS a4,QS1.m1 AS m1,m1_TYP AS m1_TYP
> FROM "TABLE1".TABLE1 AS T,(SELECT a1 AS a1,m1 AS m1,m1_TYP AS
> m1_TYP,COALESCE(S3.elem,val3) AS a3,COALESCE(S4.elem,val4) AS
> a4,COALESCE(S2.elem,val2) AS a2
> FROM (SELECT entry AS a1,T.val2 AS m1,T.typ2 AS m1_TYP,T.val6 AS
> VAL3,T.val6 AS VAL4,T.val8 AS VAL2
> FROM "TABLE1".TABLE1 AS T,(SELECT elem AS a1
> FROM "TABLE2".TABLE2 AS T
> WHERE entity = '3' AND typ = 5001
> AND (prop = '1oh~#some_prop1')) AS QS0 WHERE entry = QS0.a1
> AND (T.prop0 = '4xm~#type' AND T.prop8 = '1oh~#some_prop2' AND
> T.prop6 = '1oh~#some_prop3' AND T.prop6 = '1oh~#some_prop3' AND
> T.prop2 = '1oh~#is_atom_of')
> AND T.val0 = '7a~') AS Q1 LEFT OUTER JOIN "TABLE3".TABLE3 AS S3 ON
> Q1.VAL3 = S3.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S4 ON
> Q1.VAL4 = S4.list_id LEFT OUTER JOIN "TABLE3".TABLE3 AS S2 ON
> Q1.VAL2 = S2.list_id
> WHERE ( (a1 <> COALESCE(S4.elem,val4)
> ) )) AS QS1 WHERE entry = QS1.a3
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1' AND
> T.prop8 = '1oh~#some_prop4')
> AND T.val0 = '562~' AND T.val5 = '1' AND T.val8 = '6o7~') AS QS2
> WHERE entry = QS2.a4
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '7a~' AND T.val5 = '1') AS QS3 WHERE entry = QS3.a2
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '562~' AND T.val5 = '1') AS QS4 WHERE entity = QS4.m1
> AND typ = QS4.m1_TYP
> AND (prop = '1oh~#isome_prop5')) AS QS5 WHERE entry = QS5.a5
> AND (T.prop0 = '4xm~#type' AND T.prop5 = '1oh~#some_prop1')
> AND T.val0 = '1eg~' AND T.val5 = '0') AS QS6 LIMIT 100
>
>
> PS: I've been able to run the similar query with join and that doesn't
> give the above error logs. Please help me with that.
>
>
>
>
>
>
> --
> Thanks & Regard
>
> Manish Mishra
> Software Consultant,
> Knoldus Software, LLP
>
--
Taras Ledkov
Mail-To: tledkov@gridgain.com