WSO2 DAS 스파크 스크립트가 실행되지 않습니다.

Question

다음은 실행하려는 스파크 스크립트입니다. 그것은 DAS (3.0.1) 배치 분석 콘솔에서 succesefuly 실행됩니다. 그러나 배치 분석에서 스크립트로 저장하면 실행되지 않습니다.

insert overwrite table CLASS_COUNT select ((timestamp/120000) * 120000) as time , vin , username , classType,   
sum(acceleCount) as acceleCount , sum(decceleCount) as decceleCount 
from ACCELE_COUNTS 
group by ((timestamp/120000) * 120000) ,classType, vin, username; 

오류 : 어떤 문제없이 다음 실행하고있어 이에 대한

ERROR: [1.199] failure: ``limit'' expected but identifier ACCELE_COUNTSgroup found insert overwrite table X1234_CLASS_COUNT select ((timestamp/120000) * 120000) as time , vin , username , classType, sum(acceleCount) as acceleCount , sum(decceleCount) as decceleCountfrom ACCELE_COUNTSgroup by ((timestamp/120000) * 120000) ,classType, vin, username^

이전. 당신이

1) decceleCount 및 from

2) ACCELE_COUNTS 및

group by 사이에 공백이 없기 때문에이 그래서 단어에도 사이에 공백이 있는지 확인 발생

CREATE TEMPORARY TABLE ACCELE_COUNTS 
USING CarbonAnalytics 
OPTIONS (tableName "KAMPANA_RECKLESS_COUNT_STREAM", 
    schema "timestamp LONG , vin STRING, username STRING, classType STRING, acceleCount INT,decceleCount INT"); 

CREATE TEMPORARY TABLE CLASS_COUNT 
USING org.wso2.carbon.analytics.spark.event.EventStreamProvider 
OPTIONS (receiverURL "tcp://localhost:7611", 
    username "admin", 
    password "admin", 
    streamName "DAS_RECKELSS_COUNT_STREAM", 
    version "1.0.0", 
    description "Events are published when product quantity goes beyond a certain level", 
    nickName "product alerts", 
    payload "time LONG,vin STRING,username STRING, classType STRING, acceleCount INT, decceleCount INT" 
); 

Answer 1

두 번째 단어는 새 줄에 있습니다.