: 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'

Traceback (most recent call last):


 "/Users/mac/Documents/web/myapp/venv/lib/python3.7/site-packages/aiohttp/web_protocol.py", line 378, in start

resp = await self._request_handler(request)


 "/Users/mac/Documents/web/myapp/venv/lib/python3.7/site-packages/aiohttp/web_app.py", line 341, in _handle

resp = await handler(request)


 "/Users/mac/Documents/web/myapp/view.py", line 12, in index

print(await User.query.gino.all())


 "/Users/mac/Documents/web/myapp/venv/lib/python3.7/site-packages/gino/api.py", line 183, in __aexit__

await self._args[0].pop_bind().close()
AttributeError: 'NoneType' object has no attribute 'close'
