You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by "daxwang (王文军)" <da...@tencent.com> on 2017/05/24 06:58:10 UTC

bug: kill topology failed by thrift in no-leader nimbus

in storm-1.0.3 cluster,  there have 2 nimubs, i kill topology by thrift api killTopologyWithOpts.  i found it can kill succussfully in leader nimbus, but failed in no leader nimbus.
maybe it's a bug

my python thrift version: thrift==0.9.2

error trace:

"exception": [
"Traceback (most recent call last):\n",
" File \"/data/home/pizza/storm-rt-api/stormrt/views.py\", line 1355, in stop_job\n kill_topology(storm_ip, 'topology-%s' % topology_id)\n",
" File \"/data/home/pizza/storm-rt-api/stormrt/util_helper.py\", line 1473, in kill_topology\n topology_name, KillOptions(wait_secs=30))\n",
" File \"/data/home/pizza/storm-rt-api/stormrt/storm/Nimbus.py\", line 266, in killTopologyWithOpts\n self.recv_killTopologyWithOpts()\n",
" File \"/data/home/pizza/storm-rt-api/stormrt/storm/Nimbus.py\", line 278, in recv_killTopologyWithOpts\n (fname, mtype, rseqid) = self._iprot.readMessageBegin()\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/protocol/TBinaryProtocol.py\", line 126, in readMessageBegin\n sz = self.readI32()\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/protocol/TBinaryProtocol.py\", line 206, in readI32\n buff = self.trans.readAll(4)\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/transport/TTransport.py\", line 58, in readAll\n chunk = self.read(sz - have)\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/transport/TTransport.py\", line 271, in read\n self.readFrame()\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/transport/TTransport.py\", line 275, in readFrame\n buff = self.__trans.readAll(4)\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/transport/TTransport.py\", line 58, in readAll\n chunk = self.read(sz - have)\n",
" File \"/data/home/pizza/storm-rt-api/.pizza/lib/python2.7/site-packages/thrift/transport/TSocket.py\", line 120, in read\n message='TSocket read 0 bytes')\n",
"TTransportException: TSocket read 0 bytes\n"
],

________________________________
[cid:_Foxmail.1@a95f7419-1516-4d21-3026-8979f5b8b130]