Github user majdou41 commented on the issue:
    My code is :+1: 
    and i got this error :+1:  UTF8Deserializer(True)
    Traceback (most recent call last):
      File "<stdin>", line 1, in <module>
      File ".../spark/python/pyspark/", line 811, in collect
        return list(_load_from_socket(port, self._jrdd_deserializer))
      File ".../spark/python/pyspark/", line 549, in load_stream
        yield self.loads(stream)
      File ".../spark/python/pyspark/", line 544, in loads
        return s.decode("utf-8") if self.use_unicode else s
 line 16, in decode
        return codecs.utf_8_decode(input, errors, True)
    UnicodeDecodeError: 'utf8' codec can't decode byte 0x80 in position 0: 
invalid start byte
    I had change and serializers (version 2.1.0 to 2.0.2), but i got the 
same error 
    Can you help me please to fixe that .


To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to