Yangxu1990
Yangxu1990
日志样例 {"time":"2020-06-17 23:00:01.211","pushid":"pushback_send-BC110-12392212311","app":"mm"} 由于时间序列是bigint类型，用UNIX_TIMESTAMP进行转换 Flink运行日志报错： ERROR com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong - java.lang.NullPointerException 建表语句： CREATE TABLE MyTable ( time varchar , pushid varchar , app varchar , UNIX_TIMESTAMP(time, 'yyyy-MM-dd HH:mm:ss')*1000 bigint AS xctime ,...
### 嵌套json 解析后输出的数据 uid字段一直为null json日志格式 { "time":"2020-06-15 19:16:29.243", "topic":"room_chat", "appname":"ms", "info":{ "uid":427083 } } kafkasource 建表语句 CREATE TABLE kafka11source ( appname VARCHAR , topic VARCHAR , info.uid bigint as uid,...
> onyarn 提交submit 提示报错，本地环境可以跑，大佬帮忙看下啥问题。 Caused by: java.io.InvalidClassException: org.apache.flink.api.common.operators.ResourceSpec; incompatible types for field cpuCores Exception in thread "main" org.apache.flink.client.program.ProgramInvocationException: Could not submit job (JobID: 8c60482c1b52409d32be4a3b5849f123) at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:250) at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:483) at org.apache.flink.client.program.DetachedEnvironment.finalizeExecute(DetachedEnvironment.java:77)...