byzer-lang
byzer-lang copied to clipboard
执行 load _mlsql_.`log/-1` where filePath="engine_log" as output,获取的engine_log不完整
使用mlsql-api-console同时执行任务
!python env "PYTHON_ENV=source /Users/XXX/pyenv/mlsql/env/bin/activate dev";
!python conf "schema=st(field(petalLength,double),field(petalWidth,double),field(sepalLength,double),field(sepalWidth,double),field(species,string))";
!python conf "dataMode=model";
!ray on command '''
from vega_datasets import data
import time
df = data.iris()
for i in range(10):
time.sleep(2)
print("-----count down-------", i)
context.set_output([[df[name] for name in df]])
''' named mlsql_temp_table2;
select * from mlsql_temp_table2 as output;
任务完成后,分别执行load _mlsql_.
log/-1 where filePath="engine_log" as output
,获取到的engine_log只有结尾的几行
@MichelZhan 你有用2.1.0版本?,api部署可以正常访问?例如:http://192.168.100.3:9003/model/predict?dataType=row&data=[{"feature":[5.1,3.5,1.4,0.2]}]&sql=select rf_predict(vec_dense(feature)) as p。可是都是报org.apache.spark.sql.AnalysisException: Undefined function: 'rf_predict'. This function is neither a registered temporary function nor a permanent function registered in the database 'default'.; l 你有遇到过吗?