Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
Date: Thu, 16 Mar 2017 07:04:50 -0700 (MST)
From: austin solomon <austin.solomon007@gmail.com>
To: user@ignite.apache.org
Message-ID: <1489673090435-11237.post@n6.nabble.com>
Subject: Apache NiFi PutIgnite Cache Error: Failed to send job request
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
archived-at: Thu, 16 Mar 2017 14:04:56 -0000

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.