laixueyong
laixueyong
{ "job": { "setting": { "speed": { "channel": 1, "bytes": -1 } }, "content": [ { "reader": { "name": "streamreader", "parameter": { "column": [ { "random": "1,1000", "type": "long" },...
``` ___ _ _ / _ \ | | | | / /_\ \ __| | __| | __ ___ __ | _ |/ _` |/ _` |/ _` \...
``` / _ \ | | | | / /_\ \ __| | __| | __ ___ __ | _ |/ _` |/ _` |/ _` \ \/ / |...
一个是高版本不能识别数据类型 低版本不支持int64
4.1.6版本 不曾修改 用的是官网下载编译的
然4.0.2版本是可以跑但是不支持int64和UNIXTIME_MICROS类型
老哥想问一下为什么我读取hdfs进行Kerberos认证后报文件不存在 Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:811) at com.dtstack.chunjun.environment.MyLocalStreamEnvironment.execute(MyLocalStreamEnvironment.java:194) at com.dtstack.chunjun.Main.exeSyncJob(Main.java:227) at com.dtstack.chunjun.Main.main(Main.java:118) at com.dtstack.chunjun.client.local.LocalClusterClientHelper.submit(LocalClusterClientHelper.java:35) at com.dtstack.chunjun.client.Launcher.main(Launcher.java:119) Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by...