[
https://issues.apache.org/jira/browse/IGNITE-4105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ksenia Rybakova closed IGNITE-4105.
-----------------------------------
Checked using CacheQueryExample with one remote node started in
ExampleNodeStartup:
{noformat}
[12:31:04,851][TRACE][tcp-disco-sock-reader-#10%null%][TcpDiscoverySpi] Message
has been received: TcpDiscoveryConnectionCheckMessage
[super=TcpDiscoveryAbstractMessage
[sndNodeId=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, id=null, verifierNodeId=null,
topVer=0, pendingIdx=0, failedNodes=null, isClient=false]]
[12:31:04,855][TRACE][grid-nio-worker-tcp-comm-0-#17%null%][TcpCommunicationSpi]
Bytes received [sockCh=java.nio.channels.SocketChannel[connected
local=/0:0:0:0:0:0:0:1:58976 remote=/0:0:0:0:0:0:0:1:47101], cnt=9]
[12:31:04,857][DEBUG][query-#60%null%][GridMapQueryExecutor] Processed request:
3eaefcfa-8813-4c37-86e1-d9bf399e3ae8->54a51de3-5360-4fa1-b928-b1ad9bf9fe2c
GridQueryCancelRequest [qryReqId=5]
[12:31:04,860][TRACE][grid-nio-worker-tcp-comm-0-#17%null%][TcpCommunicationSpi]
Bytes received [sockCh=java.nio.channels.SocketChannel[connected
local=/0:0:0:0:0:0:0:1:58976 remote=/0:0:0:0:0:0:0:1:47101], cnt=423]
[12:31:04,862][DEBUG][query-#61%null%][IgniteH2Indexing] Set schema:
"CacheQueryExamplePersons"
[12:31:04,863][DEBUG][query-#61%null%][GridCacheProcessor] Getting internal
cache adapter: CacheQueryExampleOrganizations
[12:31:04,868][DEBUG][query-#61%null%][GridH2TreeIndex] Starting stream:
[node=TcpDiscoveryNode [id=54a51de3-5360-4fa1-b928-b1ad9bf9fe2c,
addrs=[0:0:0:0:0:0:0:1, 127.0.0.1, 172.25.4.192, 192.168.56.1],
sockAddrs=[DESKTOP-FVDFB13/192.168.56.1:47500, /0:0:0:0:0:0:0:1:47500,
/172.25.4.192:47500, /127.0.0.1:47500], discPort=47500, order=1, intOrder=1,
lastExchangeTime=1490261464747, loc=true, ver=2.0.0#19700101-sha1:00000000,
isClient=false], req=GridH2IndexRangeRequest
[originNodeId=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, qryId=6, originSegmentId=0,
segmentId=0, batchLookupId=1, boundsSize=1]]
[12:31:04,868][DEBUG][query-#61%null%][GridCacheProcessor] Getting internal
cache adapter: CacheQueryExamplePersons
[12:31:04,869][DEBUG][query-#61%null%][GridH2TreeIndex] Starting stream:
[node=TcpDiscoveryNode [id=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8,
addrs=[0:0:0:0:0:0:0:1, 127.0.0.1, 172.25.4.192, 192.168.56.1],
sockAddrs=[/172.25.4.192:47501, /0:0:0:0:0:0:0:1:47501,
DESKTOP-FVDFB13/192.168.56.1:47501, /127.0.0.1:47501], discPort=47501, order=2,
intOrder=2, lastExchangeTime=1490261457990, loc=false,
ver=2.0.0#19700101-sha1:00000000, isClient=false], req=GridH2IndexRangeRequest
[originNodeId=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, qryId=6, originSegmentId=0,
segmentId=0, batchLookupId=1, boundsSize=1]]
[12:31:04,869][TRACE][query-#61%null%][TcpCommunicationSpi] Sending message
with ack to node [node=TcpDiscoveryNode
[id=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.192, 192.168.56.1], sockAddrs=[/172.25.4.192:47501,
/0:0:0:0:0:0:0:1:47501, DESKTOP-FVDFB13/192.168.56.1:47501, /127.0.0.1:47501],
discPort=47501, order=2, intOrder=2, lastExchangeTime=1490261457990, loc=false,
ver=2.0.0#19700101-sha1:00000000, isClient=false], msg=GridIoMessage [plc=7,
topic=IgniteBiTuple [val1=TOPIC_QUERY,
val2=CacheQueryExamplePersons.PERSON.orgId_idx], topicOrd=-1, ordered=false,
timeout=0, skipOnTimeout=false, msg=GridH2IndexRangeRequest
[originNodeId=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, qryId=6, originSegmentId=0,
segmentId=0, batchLookupId=1, boundsSize=1]]]
[12:31:04,870][TRACE][grid-nio-worker-tcp-comm-0-#17%null%][TcpCommunicationSpi]
Bytes sent [sockCh=java.nio.channels.SocketChannel[connected
local=/0:0:0:0:0:0:0:1:58976 remote=/0:0:0:0:0:0:0:1:47101], cnt=132]
[12:31:04,876][TRACE][grid-nio-worker-tcp-comm-0-#17%null%][TcpCommunicationSpi]
Bytes received [sockCh=java.nio.channels.SocketChannel[connected
local=/0:0:0:0:0:0:0:1:58976 remote=/0:0:0:0:0:0:0:1:47101], cnt=494]
[12:31:04,878][TRACE][query-#61%null%][TcpCommunicationSpi] Sending message
with ack to node [node=TcpDiscoveryNode
[id=3eaefcfa-8813-4c37-86e1-d9bf399e3ae8, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.192, 192.168.56.1], sockAddrs=[/172.25.4.192:47501,
/0:0:0:0:0:0:0:1:47501, DESKTOP-FVDFB13/192.168.56.1:47501, /127.0.0.1:47501],
discPort=47501, order=2, intOrder=2, lastExchangeTime=1490261457990, loc=false,
ver=2.0.0#19700101-sha1:00000000, isClient=false], msg=GridIoMessage [plc=10,
topic=TOPIC_QUERY, topicOrd=19, ordered=false, timeout=0, skipOnTimeout=false,
msg=GridQueryNextPageResponse [qryReqId=6, segmentId=0, qry=0, page=0,
allRows=2, cols=2, retry=null, valsSize=4, rowsSize=0]]]
[12:31:04,878][DEBUG][query-#61%null%][GridMapQueryExecutor] Processed request:
3eaefcfa-8813-4c37-86e1-d9bf399e3ae8->54a51de3-5360-4fa1-b928-b1ad9bf9fe2c
GridH2QueryRequest [reqId=6, caches=[-508728550, 726884348],
topVer=AffinityTopologyVersion [topVer=2, minorTopVer=3], parts=null,
pageSize=1024, qrys=[GridCacheSqlQuery [qry=SELECT
"CacheQueryExamplePersons".__Z0._KEY AS __C0_0,
"CacheQueryExamplePersons".__Z0._VAL AS __C0_1
FROM "CacheQueryExampleOrganizations".ORGANIZATION ORG__Z1
INNER JOIN "CacheQueryExamplePersons".PERSON __Z0
ON TRUE
WHERE (__Z0.ORGID = ORG__Z1.ID) AND (LOWER(ORG__Z1.NAME) = LOWER(?1)),
params=[Other], paramIdxs=null, paramsSize=0, cols=null, alias=null, sort=null,
partitioned=false, node=null]], flags=3,
tbls=[CacheQueryExampleOrganizations.ORGANIZATION,
CacheQueryExamplePersons.PERSON], timeout=0]
[12:31:04,879][TRACE][grid-nio-worker-tcp-comm-0-#17%null%][TcpCommunicationSpi]
Bytes sent [sockCh=java.nio.channels.SocketChannel[connected
local=/0:0:0:0:0:0:0:1:58976 remote=/0:0:0:0:0:0:0:1:47101], cnt=262]
{noformat}
> Create separate thread pool for SQL queries
> -------------------------------------------
>
> Key: IGNITE-4105
> URL: https://issues.apache.org/jira/browse/IGNITE-4105
> Project: Ignite
> Issue Type: Task
> Components: SQL
> Affects Versions: 1.7
> Reporter: Vladimir Ozerov
> Assignee: Sergey Kalashnikov
> Fix For: 2.0
>
>
> If several long-running queries are executed, all concurrent cache operations
> will be blocked because there will be no threads in system pool to server
> cache requests/responses.
> Let's introduce separate thread pool for SQL queries execution.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
