incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Masoud Moshref Javadi <moshr...@usc.edu>
Subject Fwd: Required field 'name' was not present! Struct: Column(name:null)
Date Sun, 27 Nov 2011 08:59:36 GMT
  I get this error

Required field 'name' was not present! Struct: Column(name:null)

on different column families. My code is going to insert lots of rows in parallel.

I think this debug log from django may help:


  * |/root/twiss/lib/python2.7/site-packages/pycassa/pool.py| in |new_f|
   138.

                         if self.max_retries != -1 and self._retry_count>  self.max_retries:

   139.

                             raise MaximumRetryException('Retried %d times. Last failure was
%s: %s' %

   140.

                                                         (self._retry_count, exc.__class__.__name__,
exc))

   141.

                         # Exponential backoff

   142.

                         time.sleep(_BASE_BACKOFF * (2 ** self._retry_count))

   143.


   144.

                         kwargs['reset'] = True

   145.

                         return new_f(self, *args, **kwargs)

        ...
   146.

   147.

                 new_f.__name__ = f.__name__

   148.

                 return new_f

   149.


   150.

             def _fail_once(self, *args, **kwargs):

   151.

                 if self._should_fail:

    ? Local vars <http://204.57.0.195/LOAD/#>
    Variable 	Value
    exc 	

    EOFError()

    f 	

    <unbound method Connection.batch_mutate>

    self 	

    <pycassa.pool.ConnectionWrapper object at 0x2086050>

    args 	

    ({'user50': {'User': [Mutation(column_or_supercolumn=ColumnOrSuperColumn(column=Column(timestamp=1322382778794088,
name='password', value='password50', ttl=None), counter_super_column=None, super_column=None,
counter_column=None), deletion=None),
                           Mutation(column_or_supercolumn=ColumnOrSuperColumn(column=Column(timestamp=1322382778794088,
name='name', value='User 50', ttl=None), counter_super_column=None, super_column=None, counter_column=None),
deletion=None)]}},
      1)

    new_f 	

    <function batch_mutate at 0x2062cf8>

    kwargs 	

    {'reset': True}

  * |/root/twiss/lib/python2.7/site-packages/pycassa/pool.py| in |new_f|
   121.

                         result = f(self, *args, **kwargs)

   122.

                         self._retry_count = 0 # reset the count after a success

   123.

                         return result

   124.

                     except Thrift.TApplicationException, app_exc:

   125.

                         self.close()

   126.

                         self._pool._decrement_overflow()

   127.

                         self._pool._clear_current()

   128.

                         raise app_exc

        ...
   129.

                     except (TimedOutException, UnavailableException, Thrift.TException,

   130.

                             socket.error, IOError, EOFError), exc:

   131.

                         self._pool._notify_on_failure(exc, server=self.server, connection=self)

   132.


   133.

                         self.close()

   134.

                         self._pool._decrement_overflow()

    ? Local vars <http://204.57.0.195/LOAD/#>
    Variable 	Value
    f 	

    <unbound method Connection.batch_mutate>

    self 	

    <pycassa.pool.ConnectionWrapper object at 0x2086050>

    args 	

    ({'user50': {'User': [Mutation(column_or_supercolumn=ColumnOrSuperColumn(column=Column(timestamp=1322382778794088,
name='password', value='password50', ttl=None), counter_super_column=None, super_column=None,
counter_column=None), deletion=None),
                           Mutation(column_or_supercolumn=ColumnOrSuperColumn(column=Column(timestamp=1322382778794088,
name='name', value='User 50', ttl=None), counter_super_column=None, super_column=None, counter_column=None),
deletion=None)]}},
      1)

    app_exc 	

    TApplicationException(None,)

    new_f 	

    <function batch_mutate at 0x2062cf8>

    kwargs 	

    {}




Mime
View raw message