1
以下は実行しようとしているスパークスクリプトです。それは、DAS(3.0.1)バッチ分析コンソールでsuccesefulyを実行します。しかし、バッチアナリティックでスクリプトとして保存すると実行が失敗します。WSO2 DASスパークスクリプトの実行に失敗する
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^
は、私はすべての問題なしに以下を実行しています。
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"
);