我正在使用 apache 梁將 json 寫入 gcs。但是遇到如下錯(cuò)誤NotImplementedError: offset: 0, whence: 0, position: 50547, last: 50547 [while running 'Writing new data to gcs/write data gcs/Write/WriteImpl/WriteBundles/WriteBundles']不知道為什么會(huì)出現(xiàn)這個(gè)錯(cuò)誤。相同的代碼如下：class WriteDataGCS(beam.PTransform):        """        To write data to GCS        """        def __init__(self, bucket):            """            Initiate the bucket as a class field            :type bucket:string            :param bucket: query to be run for data            """            self.bucket = bucket        def expand(self, pcoll):            """            PTransform Method run when called on Class Name            :type pcoll: PCollection            :param pcoll: A pcollection            """            (pcoll | "print intermediate" >> beam.Map(print_row))            return (pcoll | "write data gcs" >> beam.io.WriteToText(self.bucket, coder=JsonCoder(), file_name_suffix=".json"))class JsonCoder:    """    This class represents dump and load operations performed on json    """    def encode(self,data):        """        Encodes the json data.        :type data: string        :param data: Data to be encoded        """        # logger.info("JSON DATA for encoding - {}".format(data))        return json.dumps(data,default=str)    def decode(self,data):        """        Decodes the json data.        :type data: string        :param data: Data to be decoded        """        # logger.info("JSON DATA for decoding - {}".format(data))        return json.loads(data)