byzer-lang icon indicating copy to clipboard operation
byzer-lang copied to clipboard

执行 load _mlsql_.`log/-1` where filePath="engine_log" as output,获取的engine_log不完整

Open MichelZhan opened this issue 3 years ago • 1 comments

使用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只有结尾的几行 image

MichelZhan avatar Jul 02 '21 06:07 MichelZhan

@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 你有遇到过吗?

hecheng64 avatar Jul 02 '21 09:07 hecheng64