我的目標是在一組3個linux(ubuntu)物理工作站上建立一個docker swarm,並在其上運行dask羣集。 $ docker --version
Docker version 17.06.0-ce, build 02c1d87
我能夠初始化碼頭羣並將所有機器添加到羣中。 cordoba$ docker node ls
ID HOSTNAME STATUS AVAIL
的緩慢增加內存使用情況我運行一個測試: client = Client('127.0.0.1:8786')
def x(i):
return {}
while True:
start = time.time()
a = client.submit(randint(0,1000000))
res = a.result()
del a
我得到這個錯誤與此PARAMS: import pandas as pd
import numpy as np
from sqlalchemy import create_engine
import dask.dataframe as dd
from sqlalchemy.sql import text
query = text("Some SQL statement")
df = d