[ https://issues.apache.org/jira/browse/THRIFT-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Giorgi Grigalashvili updated THRIFT-4890: ----------------------------------------- Description: As part of my university research I'm using Thrift v0.12.0 to communicate between Python server and Scala client. The data my service is providing to client is lists of thrift objects/structs, those lists contain ~1M items. The issue bellow is produced if I'm sending full lists(more than ~60k items) of data, however if I decrease list items to ~60k everything works fine. {code:java} Traceback (most recent call last): File "Server.py", line 40, in <module> server.serve() File "thrift/server/TNonblockingServer.py", line 370, in serve self.handle() File "thrift/server/TNonblockingServer.py", line 350, in handle self.clients[writeable].write() File "thrift/server/TNonblockingServer.py", line 88, in read return func(self, *args, **kwargs) File "thrift/server/TNonblockingServer.py", line 177, in write self._wbuf = self.message[sent:] AttributeError: 'Connection' object has no attribute 'message' {code} This is my server configuration: {code:java} ip = '127.0.0.1' port = '9000' handler = MyHandler() processor = MyService.Processor(handler) transport = TSocket.TServerSocket(host=ip, port=port) tfactory = TBinaryProtocol.TBinaryProtocolFactory() pfactory = TBinaryProtocol.TBinaryProtocolFactory() server = TNonblockingServer.TNonblockingServer(processor, transport, tfactory, pfactory) server.serve() {code} Now my question is as follows, am I doing something wrong or could it be that it's an issue from Thrift? Any ideas how can I resolve this problem or what I could be doing wrong? Thanks in advance. was: As part of my university research I'm using Thrift v0.12.0 to communicate between Python server and Scala client. The data my service is providing to client is lists of thrift objects/structs, those lists contain ~1M items. The issue bellow is produced if I'm sending full lists(more than ~60k items) of data, however if I decrease list items to ~60k everything works fine. {code:java} Traceback (most recent call last): File "Server.py", line 40, in <module> server.serve() File "thrift/server/TNonblockingServer.py", line 370, in serve self.handle() File "thrift/server/TNonblockingServer.py", line 350, in handle self.clients[writeable].write() File "thrift/server/TNonblockingServer.py", line 88, in read return func(self, *args, **kwargs) File "thrift/server/TNonblockingServer.py", line 177, in write self._wbuf = self.message[sent:] AttributeError: 'Connection' object has no attribute 'message' {code} This is my server configuration: {code:java} ip = '127.0.0.1' port = '9000' handler = MyHandler() processor = MyService.Processor(handler) transport = TSocket.TServerSocket(host=ip, port=port) tfactory = TBinaryProtocol.TBinaryProtocolFactory() pfactory = TBinaryProtocol.TBinaryProtocolFactory() server = TNonblockingServer.TNonblockingServer(processor, transport, tfactory, pfactory) server.serve() {code} Now my question is as follows, am I doing something wrong or could it be that it's an issue from Thrift? Any ideas how can I resolve this problem or what I could be doing wrong? Thanks in advance. > AttributeError: 'Connection' object has no attribute 'message' > -------------------------------------------------------------- > > Key: THRIFT-4890 > URL: https://issues.apache.org/jira/browse/THRIFT-4890 > Project: Thrift > Issue Type: Bug > Components: Python - Compiler > Affects Versions: 0.12.0 > Environment: Ubuntu Linux 18.10 64-bit > Reporter: Giorgi Grigalashvili > Priority: Major > Labels: Connection, Newbie, Python3, Question > > As part of my university research I'm using Thrift v0.12.0 to communicate > between Python server and Scala client. > The data my service is providing to client is lists of thrift > objects/structs, those lists contain ~1M items. The issue bellow is produced > if I'm sending full lists(more than ~60k items) of data, however if I > decrease list items to ~60k everything works fine. > {code:java} > Traceback (most recent call last): > File "Server.py", line 40, in <module> > server.serve() > File "thrift/server/TNonblockingServer.py", line 370, in serve > self.handle() > File "thrift/server/TNonblockingServer.py", line 350, in handle > self.clients[writeable].write() > File "thrift/server/TNonblockingServer.py", line 88, in read > return func(self, *args, **kwargs) > File "thrift/server/TNonblockingServer.py", line 177, in write > self._wbuf = self.message[sent:] > AttributeError: 'Connection' object has no attribute 'message' > {code} > This is my server configuration: > {code:java} > ip = '127.0.0.1' > port = '9000' > handler = MyHandler() > processor = MyService.Processor(handler) > transport = TSocket.TServerSocket(host=ip, port=port) > tfactory = TBinaryProtocol.TBinaryProtocolFactory() > pfactory = TBinaryProtocol.TBinaryProtocolFactory() > server = TNonblockingServer.TNonblockingServer(processor, transport, > tfactory, pfactory) > server.serve() > {code} > Now my question is as follows, am I doing something wrong or could it be that > it's an issue from Thrift? Any ideas how can I resolve this problem or what I > could be doing wrong? > Thanks in advance. -- This message was sent by Atlassian JIRA (v7.6.3#76005)