Traceback (most recent call last):


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\testing\suite\test_types.py", line 278, in test_round_trip

eq_(row, (compare,))


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\testing\assertions.py", line 237, in eq_

assert a == b, msg or "%r != %r" % (a, b)


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\engine\result.py", line 164, in __eq__

return self._op(other, operator.eq)


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\engine\result.py", line 148, in _op

else op(tuple(self), other)


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\engine\result.py", line 78, in __iter__

yield processor(value)


 "c:\users\gord\git\sqlalchemy\lib\sqlalchemy\dialects\mysql\types.py", line 427, in process

microseconds = value.microseconds
AttributeError: 'datetime.time' object has no attribute 'microseconds'

: org.apache.spark.SparkException: Job aborted due to stage failure: Task 44 in stage 1.0 failed 4 times, most recent failure: Lost task 44.3 in stage 1.0 (TID 96, 172.16.10.54): org.apache.spark.api.python.PythonException: Traceback (most recent call last):


 "/opt/mapr/spark/spark-2.0.1/python/lib/pyspark.zip/pyspark/worker.py", line 172, in main

process()


 "/opt/mapr/spark/spark-2.0.1/python/lib/pyspark.zip/pyspark/worker.py", line 167, in process

serializer.dump_stream(func(split_index, iterator), outfile)


 "/opt/mapr/spark/spark-2.0.1/python/pyspark/rdd.py", line 2371, in pipeline_func

return func(split, prev_func(split, iterator))


 "/opt/mapr/spark/spark-2.0.1/python/pyspark/rdd.py", line 2371, in pipeline_func

return func(split, prev_func(split, iterator))


 "/opt/mapr/spark/spark-2.0.1/python/pyspark/rdd.py", line 2371, in pipeline_func

return func(split, prev_func(split, iterator))


 "/opt/mapr/spark/spark-2.0.1/python/pyspark/rdd.py", line 317, in func

return f(iterator)


 "/opt/mapr/spark/spark-2.0.1/python/pyspark/rdd.py", line 762, in func

r = f(it)


 "/usr/lib/python2.7/site-packages/tensorflowonspark/TFSparkNode.py", line 432, in _train

mgr = _get_manager(cluster_info, socket.gethostname(), os.getppid())


 "/usr/lib/python2.7/site-packages/tensorflowonspark/TFSparkNode.py", line 65, in _get_manager

logging.info("Connected to TFSparkNode.mgr on {0}, ppid={1}, state={2}".format(host, ppid, str(TFSparkNode.mgr.get('state'))))
AttributeError: 'NoneType' object has no attribute 'get'
