We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
streamis-server
linux
create table kafka_source_car_speed_info ( carLicense string, areaId string, roadId string, monitorId string, cameraId string, actionTime bigint, speed float, rt AS TO_TIMESTAMP(FROM_UNIXTIME( actionTime / 1000 , 'yyyy-MM-dd HH:mm:ss')), -- 定义事件时间 WATERMARK FOR rt AS rt - INTERVAL '5' SECOND ) with ( 'connector' = 'kafka', 'properties.bootstrap.servers' = 'localhost:19092', 'topic' = 'ttt1', 'format' = 'json' )
SELECT CONCAT(areaId,'',roadId,'',monitorId) ckey, COUNT(1) cars, SUM(speed) sumed, SUM(speed) / COUNT(1) , TUMBLE_START(rt, INTERVAL '30' SECOND ) , TUMBLE_END(rt, INTERVAL '30' SECOND) FROM kafka_source_car_speed_info GROUP BY CONCAT(areaId,'',roadId,'',monitorId) , TUMBLE(rt, INTERVAL '30' SECOND)
SELECT CONCAT(areaId,'',roadId,'',monitorId) ckey, COUNT(1) cars, SUM(speed) sumed, SUM(speed) / COUNT(1) , HOP_START(rt, interval '30' second , interval '1' minute ) , HOP_END(rt, interval '30' second , interval '1' minute) FROM kafka_source_car_speed_info GROUP BY CONCAT(areaId,'',roadId,'',monitorId) , HOP(rt, interval '30' second , interval '1' minute)
No response
The text was updated successfully, but these errors were encountered:
任务日志还是yarn日志无法查看,streamis linkis版本是多少
Sorry, something went wrong.
是任务日志,streamis 版本0.2.0 , linkis 1.3.2
linkis 1.3.2有个bug会导致无法获取到本地ec日志,在1.4.0已经修复了哈
请问 apache/linkis#4686 是这个fix的么?
No branches or pull requests
Search before asking
Streamis Component
streamis-server
What happened + What you expected to happen
Relevent platform
linux
Reproduction script
create table kafka_source_car_speed_info (
carLicense string,
areaId string,
roadId string,
monitorId string,
cameraId string,
actionTime bigint,
speed float,
rt AS TO_TIMESTAMP(FROM_UNIXTIME( actionTime / 1000 , 'yyyy-MM-dd HH:mm:ss')), -- 定义事件时间
WATERMARK FOR rt AS rt - INTERVAL '5' SECOND
) with (
'connector' = 'kafka',
'properties.bootstrap.servers' = 'localhost:19092',
'topic' = 'ttt1',
'format' = 'json'
)
SELECT
CONCAT(areaId,'',roadId,'',monitorId) ckey,
COUNT(1) cars,
SUM(speed) sumed,
SUM(speed) / COUNT(1) ,
TUMBLE_START(rt, INTERVAL '30' SECOND ) ,
TUMBLE_END(rt, INTERVAL '30' SECOND)
FROM kafka_source_car_speed_info
GROUP BY CONCAT(areaId,'',roadId,'',monitorId) , TUMBLE(rt, INTERVAL '30' SECOND)
SELECT
CONCAT(areaId,'',roadId,'',monitorId) ckey,
COUNT(1) cars,
SUM(speed) sumed,
SUM(speed) / COUNT(1) ,
HOP_START(rt, interval '30' second , interval '1' minute ) ,
HOP_END(rt, interval '30' second , interval '1' minute)
FROM kafka_source_car_speed_info
GROUP BY CONCAT(areaId,'',roadId,'',monitorId) , HOP(rt, interval '30' second , interval '1' minute)
Anything else
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: