Replies: 2 comments 1 reply
-
已解决~~~但不知道为什么要这样设置 |
Beta Was this translation helpful? Give feedback.
1 reply
-
这是来自兰州大学-信息学院-马月宾的自动回复邮件。您好,我已经收到您的邮件,我会在最短的时间内回复您,谢谢~
|
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
单节点部署时是没问题的,现在改成集群部署却失败了!!麻烦帮忙解答一下吧,多谢
Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: TableSourceScan(table=[[default_catalog, default_database, post]], fields=[PostId, ProjectId, Name, Describe, Category, WorkNature, SalaryType, RecruitNumber, Status, Share, RegionId, Address, Lat, Lng, Department, Education, WorkTime, MinSalary, MaxSalary, Salary, Money, Tags, Highlights, Welfare, UpdatedTime, CreatedTime]) -> Calc(select=[PostId, ProjectId, Name])
at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.(ExecutionJobVertex.java:217) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at
org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:191) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:140) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:323) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
Beta Was this translation helpful? Give feedback.
All reactions