You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by austin solomon <au...@gmail.com> on 2017/03/16 14:04:50 UTC
Apache NiFi PutIgnite Cache Error: Failed to send job request
Hi I am trying to get the streaming data from one Kafka topic and put it into
Ignite's cache using Apache Nifi.
The flow is like this GetKafka --> PutIgniteCache (I have a doubt what is
the value for *Ignite Cache Entry Identifier*)
My Ignite version is 2.0.0-SNAPSHOT and in NiFi also I have given the same
version.
When I check the ignitevisorcmd.sh to check the cache's data I got the
following error
[ERROR][main][GridTaskWorker] Failed to send job request:
GridJobExecuteRequest [subjId=16fe496a-1561-4305-ad32-2a5e37ccd68a,
sesId=9e42f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a,
jobId=ae42f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a,
startTaskTime=1489672078485, timeout=9223372036854775807,
taskName=o.a.i.i.v.cache.VisorCacheMetricsCollectorTask, userVer=0,
taskClsName=o.a.i.i.v.cache.VisorCacheMetricsCollectorTask,
ldrParticipants=null, cpSpi=null, createTime=1489672078485,
clsLdrId=1742f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a, depMode=ISOLATED,
dynamicSiblings=false, forceLocDep=true, sesFullSup=false, internal=true,
part=-1, topVer=null]
class org.apache.ignite.IgniteCheckedException: Failed to send message (node
may have left the grid or TCP connection cannot be established due to
firewall issues) [node=TcpDiscoveryNode
[id=2a918041-97d5-47c7-a97f-c2009865feb6, addrs=[10.10.10.34, 127.0.0.1,
192.168.10.159, 192.168.122.1], sockAddrs=[/10.10.10.34:0, /192.168.122.1:0,
/127.0.0.1:0, /192.168.10.159:0], discPort=0, order=3, intOrder=3,
lastExchangeTime=1489672067057, loc=false, ver=2.0.0#19700101-sha1:00000000,
isClient=true], topic=TOPIC_JOB, msg=GridJobExecuteRequest
[subjId=16fe496a-1561-4305-ad32-2a5e37ccd68a,
sesId=9e42f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a,
jobId=ae42f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a,
startTaskTime=1489672078485, timeout=9223372036854775807,
taskName=org.apache.ignite.internal.visor.cache.VisorCacheMetricsCollectorTask,
userVer=0,
taskClsName=org.apache.ignite.internal.visor.cache.VisorCacheMetricsCollectorTask,
ldrParticipants=null, cpSpi=null, createTime=1489672078485,
clsLdrId=1742f57da51-16fe496a-1561-4305-ad32-2a5e37ccd68a, depMode=ISOLATED,
dynamicSiblings=false, forceLocDep=true, sesFullSup=false, internal=true,
part=-1, topVer=null], policy=3]
at
org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1299)
at
org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1351)
at
org.apache.ignite.internal.processors.task.GridTaskWorker.sendRequest(GridTaskWorker.java:1385)
at
org.apache.ignite.internal.processors.task.GridTaskWorker.processMappedJobs(GridTaskWorker.java:644)
at
org.apache.ignite.internal.processors.task.GridTaskWorker.body(GridTaskWorker.java:536)
at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
at
org.apache.ignite.internal.processors.task.GridTaskProcessor.startTask(GridTaskProcessor.java:679)
at
org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(GridTaskProcessor.java:370)
at
org.apache.ignite.internal.IgniteComputeImpl.execute(IgniteComputeImpl.java:287)
at org.apache.ignite.visor.visor$.execute(visor.scala:1750)
at org.apache.ignite.visor.visor$.executeMulti(visor.scala:1824)
at
org.apache.ignite.visor.commands.cache.VisorCacheCommand.cacheData(VisorCacheCommand.scala:543)
at
org.apache.ignite.visor.commands.cache.VisorCacheCommand.cache(VisorCacheCommand.scala:274)
at
org.apache.ignite.visor.commands.cache.VisorCacheCommand.cache(VisorCacheCommand.scala:522)
at
org.apache.ignite.visor.commands.cache.VisorCacheCommand$$anonfun$1.apply$mcV$sp(VisorCacheCommand.scala:836)
at
org.apache.ignite.visor.commands.VisorConsole.mainLoop(VisorConsole.scala:213)
at
org.apache.ignite.visor.commands.VisorConsole$.delayedEndpoint$org$apache$ignite$visor$commands$VisorConsole$1(VisorConsole.scala:330)
at
org.apache.ignite.visor.commands.VisorConsole$delayedInit$body.apply(VisorConsole.scala:319)
at scala.Function0$class.apply$mcV$sp(Function0.scala:34)
at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.collection.immutable.List.foreach(List.scala:381)
at
scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
at scala.App$class.main(App.scala:76)
at
org.apache.ignite.visor.commands.VisorConsole$.main(VisorConsole.scala:319)
at org.apache.ignite.visor.commands.VisorConsole.main(VisorConsole.scala)
Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to send
message to remote node: TcpDiscoveryNode
[id=2a918041-97d5-47c7-a97f-c2009865feb6, addrs=[10.10.10.34, 127.0.0.1,
192.168.10.159, 192.168.122.1], sockAddrs=[/10.10.10.34:0, /192.168.122.1:0,
/127.0.0.1:0, /192.168.10.159:0], discPort=0, order=3, intOrder=3,
lastExchangeTime=1489672067057, loc=false, ver=2.0.0#19700101-sha1:00000000,
isClient=true]
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage0(TcpCommunicationSpi.java:2377)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage(TcpCommunicationSpi.java:2313)
at
org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1294)
... 26 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to connect
to node (is node still alive?). Make sure that each ComputeTask and cache
Transaction has a timeout set in order to prevent parties from waiting
forever in case of network issues
[nodeId=2a918041-97d5-47c7-a97f-c2009865feb6, addrs=[/127.0.0.1:47102,
tg34/10.10.10.34:47102, /192.168.10.159:47102, /192.168.122.1:47102]]
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2972)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createNioClient(TcpCommunicationSpi.java:2596)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.reserveClient(TcpCommunicationSpi.java:2488)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage0(TcpCommunicationSpi.java:2349)
... 28 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
connect to address: /127.0.0.1:47102
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2974)
... 31 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to read
remote node recovery handshake (connection closed).
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.safeHandshake(TcpCommunicationSpi.java:3223)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2845)
... 31 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
connect to address: tg34/10.10.10.34:47102
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2974)
... 31 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to read
remote node recovery handshake (connection closed).
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.safeHandshake(TcpCommunicationSpi.java:3223)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2845)
... 31 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
connect to address: /192.168.10.159:47102
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2974)
... 31 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to read
remote node recovery handshake (connection closed).
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.safeHandshake(TcpCommunicationSpi.java:3223)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2845)
... 31 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
connect to address: /192.168.122.1:47102
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2974)
... 31 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to read
remote node recovery handshake (connection closed).
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.safeHandshake(TcpCommunicationSpi.java:3223)
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:2845)
... 31 more
Can you Please help me with this?
Thanks in advance.
--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Apache-NiFi-PutIgnite-Cache-Error-Failed-to-send-job-request-tp11237.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Re: Apache NiFi PutIgnite Cache Error: Failed to send job request
Posted by austin solomon <au...@gmail.com>.
The Cache is getting created however their is no data in it.
+===================================================================================================================+
| Name(@) | Mode | Nodes | Entries (Heap / Off-heap) | Hits
| Misses | Reads | Writes |
+===================================================================================================================+
| NifiIgnite(@c0) | PARTITIONED | 1 | min: 0 (0 / 0) | min: 0
| min: 0 | min: 0 | min: 0 |
| | | | avg: 0.00 (0.00 / 0.00) | avg:
0.00 | avg: 0.00 | avg: 0.00 | avg: 0.00 |
| | | | max: 0 (0 / 0) | max: 0
| max: 0 | max: 0 | max: 0 |
+-------------------------------------------------------------------------------------------------------------------+
and their is no error in Apache Nifi's log (I have attached a screen shot
of that)
<http://apache-ignite-users.70518.x6.nabble.com/file/n11238/Screenshot_from_2017-03-16_19-38-45.png>
--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Apache-NiFi-PutIgnite-Cache-Error-Failed-to-send-job-request-tp11237p11238.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.