??????
java.lang.RuntimeException: RowTime field should not be null, please convert it
to a non-null long value.
????????????????????????????????server_end_time?? MySQL????Null??????????????????????
String order_sql = "create TABLE sd_service_order (" +
"server_end_time TIMESTAMP(3)," +
"WATERMARK FOR server_end_time AS server_end_time?? With ......"
???? tEnv.executeSql(order_sql); ??????
server_end_time ??????????????????NULL??, ??????
1??executeSql ????????????????????
2?? String out = "insert into out_data_1 " +
" select " +
"
TUMBLE_START(server_end_time, INTERVAL '1' DAY) as window_start," +
"
TUMBLE_END(server_end_time, INTERVAL '1' DAY) as window_end," +
" corp_id, county_id,
area_id, area_name, station_id, station_name, " +
" service_id,
service_name, item_id, item_name, " +
" sum(item_cost) as
item_cost_sum, " +
" count(item_id) as
item_id_count " +
" from sd_service_order
" +
" where server_end_time
is not null" +
" group by
TUMBLE(server_end_time, INTERVAL '1' DAY)," +
" corp_id,
county_id, area_id, area_name, station_id, station_name, " +
"
service_id, service_name, item_id, item_name";
tEnv.executeSql(out);
???? " where server_end_time is not null"
????????????????????????????????????????????
where=[CAST(server_end_time) IS NOT NULL]) (3/4)#24
(4c7c6a76b34efb3f70df2d8e19cf3f08) switched from RUNNING to FAILED with failure
cause: java.lang.RuntimeException: RowTime field should not be null, please
convert it to a non-null long value.
????????????????????????????????
??????
[email protected]
